① 創(chuàng)建一個(gè)數(shù)據(jù)表

import pymysql

② 插入數(shù)據(jù)

import pymysql

db = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')

cursor = db.cursor

# 插入數(shù)據(jù)

sql = 'insert into students(name,age) values(%s,%s)'

try:

cursor.execute(sql,('孫悟空',100000))

db.commit

except:print("插入失敗")

db.rollback

db.close

注 1：插入數(shù)據(jù)一定要用 try…except…語句，因?yàn)槿f一沒插入成功，其余代碼都無法執(zhí)行。

注 2：import pymysql，此模塊是默認(rèn)開啟mysql的事務(wù)功能的，因此，進(jìn)行“增”、“刪”、“改”的時(shí)候，一定要使用db.commit提交事務(wù)，否則就看不見所插入的數(shù)據(jù)。

③ 更新數(shù)據(jù)

import pymysql

db = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')

cursor = db.cursor

# 更新數(shù)據(jù)

sql = 'update students set age =%s where name=%s'

try:

cursor.execute(sql,(30,"郭衛(wèi)華"))

db.commit

except:

print("插入失敗")

db.rollback

db.close

③ 刪除操作

import pymysql

db = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')

cursor = db.cursor

# 刪除數(shù)據(jù)

sql = 'delete from students where age=100000'

try:

cursor.execute(sql)

db.commit

except:

print("插入失敗")

db.rollback

db.close

④ 查詢操作

fetchone功能：獲取下一個(gè)查詢結(jié)果集，結(jié)果集是一個(gè)對象。

fetchall功能：接收全部返回的行。

import pymysql

db = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')

cursor = db.cursor

# 查詢數(shù)據(jù)

sql = 'select * from students where age>60'

try:

cursor.execute(sql)

reslist = cursor.fetchall

for row in reslist:

print(“%d--%d” %(row[0],row[1],… row[n]))

except:

print("插入失敗")

db.rollback

db.close