本文例項講述了Python使用pymysql模組操作mysql增刪改查。分享給大家供大家參考，具體如下：

# -*- coding:utf-8 -*-
import pymysql
user = input('請輸入使用者名稱：')
pwd = input('請輸入密碼：')
# 1.連線
conn = pymysql.connect(host='127.0.0.1',port=3306,user='root',password='123',db='t1',charset='utf8')
print(conn)
# 2.建立遊標
cursor = conn.cursor()
#注意%s需要加引號
sql = "select * from t1.userinfo where username='%s' and pwd='%s'" %(user,pwd)
print(sql)
# 3.執行sql語句
cursor.execute(sql)
result=cursor.execute(sql) #執行sql語句，返回sql查詢成功的記錄數目
print(result)
# 關閉連線，遊標和連線都要關閉
cursor.close()
conn.close()
if result:
 print('登陸成功')
else:
 print('登入失敗')

下面是執行過程

請輸入使用者名稱：lisi
請輸入密碼：123
<pymysql.connections.Connection object at 0x000001BEFABFE240>
select * from t1.userinfo where username='lisi' and pwd='123'

登陸成功

二、execute()之sql注入

方式

#1、sql注入之：使用者存在，繞過密碼
lisi' -- 任意字元
#2、sql注入之：使用者不存在，繞過使用者與密碼
xxx' or 1=1 -- 任意字元

請輸入使用者名稱：sdj;fja;' or 1=1 -- ;j;j;jj;jjkdsjfjsd

請輸入密碼：123
<pymysql.connections.Connection object at 0x000001EF2BE3E240>
select * from t1.userinfo where username='sdj;fja;' or 1=1 -- ;j;j;jj;jjkdsjfjsd' and pwd='123'

登陸成功

解決：

1採用列表的方式

# 原來是我們對sql進行字串拼接
# sql="select * from userinfo where name='%s' and password='%s'" %(username,pwd)
# print(sql)
# result=cursor.execute(sql)
#改寫為（execute幫我們做字串拼接，我們無需且一定不能再為%s加引號了）
sql="select * from userinfo where name=%s and pwd=%s" #！！！注意%s需要去掉引號，因為pymysql會自動為我們加上
result=cursor.execute(sql,[user,pwd]) #pymysql模組自動幫我們解決sql注入的問題，只要我們按照pymysql的規矩來。

2採用字典的方法

# -*- coding:utf-8 -*-
import pymysql
user = input('請輸入使用者名稱').strip()
pwd = input('請輸入密碼').strip()
# 連線服務端
conn = pymysql.connect(
 host='127.0.0.1',password="123",database='t1',charset='utf8'
)
# -- ddadad
# 建立遊標物件
cur = conn.cursor()
sql = "select * from userinfo where username = %(name)s and pwd = %(password)s"
print(sql)
# resultNum = cur.execute(sql,pwd])
resultNum = cur.execute(sql,{"name":user,"password":pwd})
print(resultNum)
cur.close()
conn.close()
if resultNum:
 print('登陸成功')
else:
 print('登陸失敗')

三、增、刪、改：conn.commit()

commit()方法：在資料庫裡增、刪、改的時候，必須要進行提交，否則插入的資料不生效。

基本框架

import pymysql
username = input('請輸入使用者名稱：')
pwd = input('請輸入密碼：')
# 1.連線
conn = pymysql.connect(host='localhost',db='db8',charset='utf8')
# 2.建立遊標
cursor = conn.cursor()
--------增刪改操作----------------
#一定記得commit
conn.commit()
# 4.關閉遊標
cursor.close()
# 5.關閉連線
conn.close()

增--》一組資料

sql='insert into userinfo(username,pwd) values(%s,%s)'
effect_row=cursor.execute(sql,(username,pwd)) # effect_row=1

增---》多組資料

sql='insert into userinfo(username,%s)'
effect_row=cursor.executemany(sql,[('趙八','112'),('劉九','114'),('封十','911')]) #effect_row=3

刪

sql='delete from userinfo where pwd like "%2"'
effect_row=cursor.execute(sql)

改

sql='update userinfo set username = %s where pwd="114"'
effect_row=cursor.execute(sql,'niu') #effect_row=2

**上面的變數 effect_row=cursor.execute(...),返回的是成功改變的條目數字

四、查：fetchone、fetchmany、fetchall

表的內容

mysql> select * from userinfo;
+----+----------+-----+
| id | username | pwd |
+----+----------+-----+
| 1 | mjj  | 123 |
| 3 | 張三  | 110 |
| 4 | 李四  | 119 |
+----+----------+-----+
3 rows in set (0.00 sec)

固定格式

import pymysql
# 1.連線
conn = pymysql.connect(host='localhost',password='',charset='utf8')
# 2.建立遊標
cursor = conn.cursor()
sql = 'select * from userinfo'
cursor.execute(sql)
------------執行的查詢--------------
# 4.關閉遊標
cursor.close()
# 5.關閉連線
conn.close()

fetchone檢視一條符合條件的資料，可以連續使用，查詢的是上一個fetchone的後面一條

# 查詢第一行的資料
row = cursor.fetchone()
print(row) # (1,'mjj','123')
# 查詢第二行資料
row = cursor.fetchone()
print(row) # (3,'張三','110')

fetchall():查詢所有符合條件的資料

# 獲取所有的資料
rows = cursor.fetchall()
print(rows)
#執行結果
((1,'123'),(3,'110'),(4,'李四','119')) 取到的返回值是元組

fetchmany:獲取指定的條數資料

row=cursor.fetchmany(3)
print(row)

cursor.scroll(num,mode='relative|absolute') 當mode=absolute時，num不能小於0

cursor.scroll(1,mode='relative') # 相對當前位置移動
cursor.scroll(2,mode='absolute') # 相對絕對位置移動

# 查詢第一行的資料
row = cursor.fetchone()
print(row) # (1,'123')
# 查詢第二行資料
row = cursor.fetchone() # (3,'110')
print(row)
cursor.scroll(-1,mode='relative') #設定之後，游標相對於當前位置往前移動了一行，所以列印的結果為第二行的資料
row = cursor.fetchone()
print(row)
cursor.scroll(0,mode='absolute') #設定之後，游標相對於首行沒有任何變化，所以列印的結果為第一行資料
row = cursor.fetchone()
print(row)

更多關於Python相關內容感興趣的讀者可檢視本站專題：《Python常見資料庫操作技巧彙總》、《Python數學運算技巧總結》、《Python資料結構與演算法教程》、《Python函式使用技巧總結》、《Python字串操作技巧彙總》、《Python入門與進階經典教程》及《Python檔案與目錄操作技巧彙總》

希望本文所述對大家Python程式設計有所幫助。