1. 程式人生 > >python3連接mysql--增刪改查

python3連接mysql--增刪改查

cut varchar erro .exe bsp back roo 這一 rom

ps:MYSQLdb只適用於python2.x

python3不支持MYSQLdb,取而代之的是pymysql

運行會報:ImportError:No module named ‘MYSQLdb‘

import pymysql as pmq

#connect(ip.user,password,dbname)
con = pmq.connect(localhost,root,123456,python_test)
#操作遊標
cur = con.cursor()

#建表
cur.execute("CREATE TABLE IF NOT EXISTS  Writers(Id INT PRIMARY KEY AUTO_INCREMENT,Name VARCHAR(25))
") #插入數據一 cur.execute("INSERT INTO Writers(Name) VALUES(‘Jack London‘)") cur.execute("INSERT INTO Writers(Name) VALUES(‘Honore de Balzac‘)") cur.execute("INSERT INTO writers VALUES(1,‘Jack London‘)") cur.execute("INSERT INTO writers VALUES(2,‘Honore de Balzac‘)") #提交到數據庫 -------ps:不寫這一行無法插入 con.commit()
#插入數據二 sql="INSERT INTO Writers(Name) VALUES(‘Jack London2‘)" try: #執行sql語句 cur.execute(sql) #提交到數據庫執行 con.commit() except: #如果發生錯誤則回滾 con.rollback()

1 #查詢
2 cur.execute(select * from writers)
3 
4 results = cur.fetchall()
5 
6 for row in results:
7     Id = row[0]
8     Name = row[1]
9     print
("id=%s,name=%s" % (Id,Name))

 1 #更新
 2 Id= 1
 3 sql ="update writers set Name=‘updateJackto‘ where Id = {0}".format(Id)
 4 try:
 5     cur.execute(sql)
 6     con.commit()
 7 except:
 8     con.rollback()
 9     
10 #刪除
11 Id=7
12 sql = "delete from writers where Id = {0}".format(Id)
13 try:
14     cur.execute(sql)
15     con.commit()
16 except:
17     con.rollback()

python3連接mysql--增刪改查