溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本篇內容介紹了“如何使用pyMySql連接mysql”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！
安裝
| pip3 install pymysql |
常用函數：
execute() 執行語句并返回收影響的行數
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() # 執行SQL，并返回收影響行數 effect_row = cursor.execute("insert into t2 VALUES(1,'ray')") # 執行SQL，并返回受影響行數 # effect_row = cursor.execute("update hosts set host = '1.1.1.2' where nid > %s", (1,)) # 執行SQL，并返回受影響行數 # effect_row = cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)]) # 提交，不然無法保存新建或者修改的數據 conn.commit() # 關閉游標 cursor.close() # 關閉連接 conn.close() |
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() # 執行SQL，并返回收影響行數 truple_str='ray' effect_row = cursor.execute("insert into t2 VALUES(3,%s)",truple_str) print(effect_row) truple_str='suen' effect_row = cursor.execute("insert into t2 VALUES(4,%s)",truple_str) print(effect_row) # 提交，不然無法保存新建或者修改的數據 conn.commit() # 關閉游標 cursor.close() # 關閉連接 conn.close() |
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() # 執行SQL，并返回收影響行數 truple_str=('lalala',1) cursor.execute('update t2 set t_name=%s where t_id=%s',truple_str) # 提交，不然無法保存新建或者修改的數據 conn.commit() # 關閉游標 cursor.close() # 關閉連接 conn.close() |
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() # 執行SQL，并返回收影響行數 # truple_str=('lalala',1) tid=1 cursor.execute('delete from t2 where t_id=%s',tid) # 提交，不然無法保存新建或者修改的數據 conn.commit() # 關閉游標 cursor.close() # 關閉連接 conn.close() |
executemany()執行條語句，以元組的形式傳入
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() # 執行SQL，并返回收影響行數 truple_str=[ (5,'aaa'), (6,'bbb'), (7,'ccc'), (8,'ddd') ] cursor.executemany("insert into t2 VALUES(%s,%s)",truple_str) # 提交，不然無法保存新建或者修改的數據 conn.commit() # 關閉游標 cursor.close() # 關閉連接 conn.close() |
fecheone()
fechemany()
fecheall()
注：在fetch數據時按照順序進行，可以使用cursor.scroll(num,mode)來移動游標位置，如：
cursor.scroll(1,mode='relative') # 相對當前位置移動，正數為向下移動，負數為向上移動
cursor.scroll(2,mode='absolute') # 相對絕對位置移動
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() # 執行SQL，并返回收影響行數 # truple_str=('lalala',1) cursor.execute('select * from t2') #fech 是去內存中獲取 res = cursor.fetchone() print(res) res = cursor.fetchmany(7) #指定獲取的條目數 print(res) res = cursor.fetchall() print(res) # 關閉游標 cursor.close() # 關閉連接 conn.close() |
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() # 執行SQL，并返回收影響行數 # truple_str=('lalala',1) cursor.execute('select * from t2') #fech 是去內存中獲取 res = cursor.fetchone() print(res) res = cursor.fetchone() print(res) cursor.scroll(0,mode='absolute') res = cursor.fetchall() print(res) cursor.scroll(-1,mode='relative') res = cursor.fetchall() print(res) # 關閉游標 cursor.close() # 關閉連接 conn.close() |
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() # 執行SQL，并返回收影響行數 # truple_str=('lalala',1) cursor.execute('select * from t2') #fech 是去內存中獲取 while 1: res = cursor.fetchone() if res == None: break print(res) # 關閉游標 cursor.close() # 關閉連接 conn.close() |
cursor修改，改變獲取后的結果為字典集合
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) # 執行SQL，并返回收影響行數 # truple_str=('lalala',1) cursor.execute('select * from t2') #fech 是去內存中獲取 while 1: res = cursor.fetchone() if res == None: break print(res) # 關閉游標 cursor.close() # 關閉連接 conn.close() |
lastrowid 獲取最后的自增序列號
import pymysql # 創建連接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test',charset="utf8" ) # 創建游標 cursor = conn.cursor() cursor.executemany('insert into t3(t_name) VALUES (%s)',[('aaa07'),('aaa08'),('aaa09')]) conn.commit() tid=cursor.lastrowid print(tid) # 關閉游標 cursor.close() # 關閉連接 conn.close() |
“如何使用pyMySql連接mysql”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
