Python中pymysql 模組的使用詳解
pymysql 模組的使用
一、pymysql的下載和使用
(1)pymysql模組的下載
pip3 install pymysql
(2)pymysql的使用
# 實現:使用Python實現使用者登入,如果使用者存在則登入成功(假設該使用者已在資料庫中) import pymysql user = input('請輸入使用者名稱:') pwd = input('請輸入密碼:') # 1.連線 conn = pymysql.connect(host='127.0.0.1',port=3306,user='root',password='',db='db8',charset='utf8') # 2.建立遊標 cursor = conn.cursor() #注意%s需要加引號 sql = "select * from 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('登入失敗')
二、execute()之sql注入
最後那一個空格,在一條sql語句中如果遇到select * from userinfo where username='mjj' -- asadasdas' and pwd='' 則--之後的條件被註釋掉了(注意--後面還有一個空格)
#1、sql注入之:使用者存在,繞過密碼
mjj' -- 任意字元
#2、sql注入之:使用者不存在,繞過使用者與密碼
xxx' or 1=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 password=%s" #!!!注意%s需要去掉引號,因為pymysql會自動為我們加上 result=cursor.execute(sql,[user,pwd]) #pymysql模組自動幫我們解決sql注入的問題,只要我們按照pymysql的規矩來。
三、增、刪、改:conn.commit()
commit()方法:在資料庫裡增、刪、改的時候,必須要進行提交,否則插入的資料不生效。
import pymysql username = input('請輸入使用者名稱:') pwd = input('請輸入密碼:') # 1.連線 conn = pymysql.connect(host='localhost',charset='utf8') # 2.建立遊標 cursor = conn.cursor() # 操作 # 增 # sql = "insert into userinfo(username,pwd) values (%s,%s)" # effect_row = cursor.execute(sql,(username,pwd)) #同時插入多條資料 #cursor.executemany(sql,[('李四','110'),('王五','119')]) # print(effect_row)# # 改 # sql = "update userinfo set username = %s where id = 2" # effect_row = cursor.execute(sql,username) # print(effect_row) # 刪 sql = "delete from userinfo where id = 2" effect_row = cursor.execute(sql) print(effect_row) #一定記得commit conn.commit() # 4.關閉遊標 cursor.close() # 5.關閉連線 conn.close()
四、查:fetchone、fetchmany、fetchall
fetchone():獲取下一行資料,第一次為首行;
fetchall():獲取所有行資料來源
fetchmany(4):獲取4行資料
檢視一下表內容:
mysql> select * from userinfo; +----+----------+-----+ | id | username | pwd | +----+----------+-----+ | 1 | mjj | 123 | | 3 | 張三 | 110 | | 4 | 李四 | 119 | +----+----------+-----+ 3 rows in set (0.00 sec)
使用fetchone():
import pymysql
# 1.連線 conn = pymysql.connect(host='localhost',charset='utf8') # 2.建立遊標 cursor = conn.cursor() sql = 'select * from userinfo' cursor.execute(sql) # 查詢第一行的資料 row = cursor.fetchone() print(row) # (1,'mjj','123') # 查詢第二行資料 row = cursor.fetchone() print(row) # (3,'張三','110') # 4.關閉遊標 cursor.close() # 5.關閉連線 conn.close()
使用fetchall():
import pymysql # 1.連線 conn = pymysql.connect(host='localhost',charset='utf8') # 2.建立遊標 cursor = conn.cursor() sql = 'select * from userinfo' cursor.execute(sql) # 獲取所有的資料 rows = cursor.fetchall() print(rows) # 4.關閉遊標 cursor.close() # 5.關閉連線 conn.close() #執行結果 ((1,'123'),(3,'110'),(4,'李四','119'))
預設情況下,我們獲取到的返回值是元組,只能看到每行的資料,卻不知道每一列代表的是什麼,這個時候可以使用以下方式來返回字典,每一行的資料都會生成一個字典:
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) #在例項化的時候,將屬性cursor設定為pymysql.cursors.DictCursor
在fetchone示例中,在獲取行資料的時候,可以理解開始的時候,有一個行指標指著第一行的上方,獲取一行,它就向下移動一行,所以當行指標到最後一行的時候,就不能再獲取到行的內容,所以我們可以使用如下方法來移動行指標:
cursor.scroll(1,mode='relative') # 相對當前位置移動
cursor.scroll(2,mode='absolute') # 相對絕對位置移動
第一個值為移動的行數,整數為向下移動,負數為向上移動,mode指定了是相對當前位置移動,還是相對於首行移動
# 1.Python實現使用者登入 # 2.Mysql儲存資料 import pymysql # 1.連線 conn = pymysql.connect(host='localhost',charset='utf8') # 2.建立遊標 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) sql = 'select * from userinfo' cursor.execute(sql) # 查詢第一行的資料 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) # 4.關閉遊標 cursor.close() # 5.關閉連線 conn.close() #結果如下 {'id': 1,'username': 'mjj','pwd': '123'} {'id': 3,'username': '張三','pwd': '110'} {'id': 3,'pwd': '110'} {'id': 1,'pwd': '123'}
fetchmany():
import pymysql # 1.連線 conn = pymysql.connect(host='localhost',charset='utf8') # 2.建立遊標 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) sql = 'select * from userinfo' cursor.execute(sql) # 獲取2條資料 rows = cursor.fetchmany(2) print(rows) # 4.關閉遊標 # rows = cursor.fetchall() # print(rows) cursor.close() # 5.關閉連線 conn.close() #結果如下: [{'id': 1,'pwd': '123'},{'id': 3,'pwd': '110'}]