如下所示:
#!/usr/bin/env python# -*- coding:utf-8 -*-# __author__ = "blzhu""""python studyDate:2017"""import pymysql# import MySQLdb #python2中的產物try: # 獲取一個數據庫連接,注意如果是UTF-8類型的,需要制定數據庫 conn = pymysql.connect(host='localhost', user='root', passwd='root', db='zbltest1', port=3306, charset='utf8') cur = conn.cursor() # 獲取一個游標 for i in range(1, 10): zbl_id = str(i) zbl_name = 'zbl'+str(i) zbl_gender = 'man' # print("%s,%s,%s" % (zbl_id,zbl_name,zbl_gender)) # sql = "insert student VALUES (id='%s',name='%s',gender='%s')" % (zbl_id,zbl_name,zbl_gender) sql = "insert student VALUES ('%s','%s','%s')" % (zbl_id, zbl_name, zbl_gender) # print(sql) cur.execute(sql) conn.commit()# 將數據寫入數據庫 # try: # cur.execute(sql) # cur.commit() # except: # cur.rollback() #cur.execute("""INSERT INTO 'student' ('id','name','gender') VALUES (%s,%s,%s ,(zbl_id,zbl_name,zbl_gender,))""") #cur.execute("""INSERT INTO 'student' ('id','name','gender') VALUES (zbl_id,zbl_name,zbl_gender)""") # cur.execute("INSERT student VALUES (zbl_id,zbl_name,zbl_gender)") # cur.execute("INSERT student VALUES ('4', 'zbl4', 'man')")# 正確 #cur.execute("INSERT INTO 'student' ('id','name','gender') VALUES ('4', 'zbl4', 'man')")#錯誤 #cur.execute("INSERT student ('id','name','gender') VALUES ('4', 'zbl4', 'man')") cur.execute('select * from student') # data=cur.fetchall() for d in cur: # 注意int類型需要使用str函數轉義 print("ID: " + str(d[0]) + ' 名字: ' + d[1] + " 性別: " + d[2]) print("row_number:", (cur.rownumber)) # print('hello') cur.close() # 關閉游標 conn.close() # 釋放數據庫資源except Exception: print("發生異常")上面代碼是對的,但是是曲折的。
下面整理一下:
#!/usr/bin/env python# -*- coding:utf-8 -*-# __author__ = "blzhu""""python studyDate:2017"""import pymysqltry: # 獲取一個數據庫連接,注意如果是UTF-8類型的,需要制定數據庫 conn = pymysql.connect(host='localhost', user='root', passwd='root', db='zbltest1', port=3306, charset='utf8') cur = conn.cursor() # 獲取一個游標 for i in range(1, 10): zbl_id = str(i) zbl_name = 'zbl'+str(i) zbl_gender = 'man' # print("%s,%s,%s" % (zbl_id,zbl_name,zbl_gender)) # sql = "insert student VALUES (id='%s',name='%s',gender='%s')" % (zbl_id,zbl_name,zbl_gender) sql = "insert student VALUES ('%s','%s','%s')" % (zbl_id, zbl_name, zbl_gender) # print(sql) cur.execute(sql) conn.commit()# 將數據寫入數據庫 cur.execute('select * from student') # data=cur.fetchall() for d in cur: # 注意int類型需要使用str函數轉義 print("ID: " + str(d[0]) + ' 名字: ' + d[1] + " 性別: " + d[2]) print("row_number:", (cur.rownumber)) # print('hello') cur.close() # 關閉游標 conn.close() # 釋放數據庫資源except Exception: print("發生異常")#!/usr/bin/python3import pymysqlimport typesdb=pymysql.connect("localhost","root","123456","python");cursor=db.cursor()#創建user表cursor.execute("drop table if exists user")sql="""CREATE TABLE IF NOT EXISTS `user` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(255) NOT NULL, `age` int(11) NOT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""cursor.execute(sql)#user插入數據sql="""INSERT INTO `user` (`name`, `age`) VALUES('test1', 1),('test2', 2),('test3', 3),('test4', 4),('test5', 5),('test6', 6);"""try: # 執行sql語句 cursor.execute(sql) # 提交到數據庫執行 db.commit()except: # 如果發生錯誤則回滾 db.rollback() #更新id=1sql="update user set age=100 where id='%s'" % (id)try: cursor.execute(sql) db.commit()except: db.rollback() #刪除id=2sql="delete from user where id='%s'" % (id)try: cursor.execute(sql) db.commit()except: db.rollback() #查詢cursor.execute("select * from user")results=cursor.fetchall()for row in results: name=row[0] age=row[1] #print(type(row[1])) #打印變量類型 <class 'str'> print ("name=%s,age=%s" % / (age, name))以上這篇python3.4用循環往mysql5.7中寫數據并輸出的實現方法就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持VEVB武林網。
新聞熱點
疑難解答