日常我們寫程序或進行數(shù)據(jù)分析時诚些，都需要跟本地數(shù)據(jù)庫進行大量交互，涉及數(shù)據(jù)的查詢皇型、提取诬烹、創(chuàng)建、修改等等弃鸦。pymysql是python的第三方庫绞吁，作為常用的數(shù)據(jù)庫交互模塊，pymysql能夠簡單易懂得將python和Mysql聯(lián)系起來唬格。
安裝：pip install pymysql
接下來開始介紹pymysql的常規(guī)用法家破。
一、pymysql的運行邏輯
- pymysql通過固定的寫法购岗，創(chuàng)建一個數(shù)據(jù)庫對象汰聋，繼而創(chuàng)建游標(biāo)（cursor)；
- 游標(biāo)類似于此次創(chuàng)建出來的小工具人藕畔，它負責(zé)往返于腳本和數(shù)據(jù)庫進行一系列操作马僻。如提交sql語句、接收語句操作數(shù)據(jù)庫后的返回結(jié)果等注服。
二、連接數(shù)據(jù)庫
obj.connect(host, database, user, password, charset)
| 參數(shù) | 說明 | 舉例 |
|---|---|---|
| host | IP地址 | 127.0.0.1 |
| database | 數(shù)據(jù)庫名 | myKU |
| user | 數(shù)據(jù)庫的用戶名 | admin |
| password | 數(shù)據(jù)庫的密碼 | 123456 |
| charset | 指定讀寫的編碼 | utf-8 |
import pymysql as pm
# 創(chuàng)建數(shù)據(jù)庫對象
db = pm.connect(host='127.0.0.1',
database='mydatabase',
user='zhangsanfeng',
password='taiqiquan123',
charset='utf-8'
)
# 為本次的數(shù)據(jù)庫對象 db 創(chuàng)建游標(biāo)對象 cursor
cursor = db.cursor()
這樣就連接成功了措近。接下來可以無限次使用游標(biāo)cursor對數(shù)據(jù)庫進行操作溶弟。
三、事務(wù)查詢：提交sql查詢瞭郑，接收查詢結(jié)果
| 方法 | 說明 |
|---|---|
| cursor.execute('sql語句') | 提交sql |
| cursor.fetchone() | 一條條返回結(jié)果 |
| cursor.fetchall() | 一次返回所有結(jié)果 |
fetchone()方法：一條條取數(shù)據(jù)
import pymysql as pm
# 創(chuàng)建數(shù)據(jù)庫對象
db = pm.connect(host='127.0.0.1',
database='mydatabase',
user='zhangsanfeng',
password='taiqiquan123',
charset='utf-8'
)
# 為本次的數(shù)據(jù)庫對象 db 創(chuàng)建游標(biāo)對象 cursor
cursor = db.cursor()
# 定義 sql
sql = 'SELECT * FROM namelist WHERE age>18;'
# 提交 sql
cursor.execute(sql)
result = cursor.fetchone() # 從返回的結(jié)果中取出第一條數(shù)據(jù)
num = 1
while result:
print(f'本次查詢的第{num}條結(jié)果：\n{result}')
print('- ' * 20)
num += 1
result = cursor.fetchone() # 取出第二條數(shù)據(jù)
print('本次查詢結(jié)束辜御。')
fetchall()方法：一次取所有數(shù)據(jù)
allResult = cursor.fetchall() # 一次獲取所有的數(shù)據(jù)
print(f'本次共查詢到{len(allResult)}條結(jié)果。')
num = 1
for msg in allResult: # 遍歷每條數(shù)據(jù)
print(f'第{num}條結(jié)果: \n{msg}')
num += 1
四屈张、事務(wù)提交：提交sql事務(wù)
- 事務(wù)查詢：使用sql指令查詢數(shù)據(jù)擒权，整個過程并未對數(shù)據(jù)庫進行任何改動操作袱巨。
- 事務(wù)提交：使用sql指令操作改動數(shù)據(jù)庫（增加、修改碳抄、刪除等操作）愉老。
使用obj.commit()方法進行事務(wù)提交。
注意剖效，由于是對數(shù)據(jù)庫操作改動嫉入，commit()方法不再針對游標(biāo)對象cursor，而是針對前面創(chuàng)建的數(shù)據(jù)庫對象db璧尸。
# 定義 sql
sql = 'DELETE FROM namelist WHERE age<18;'
# 提交 sql
cursor.execute(sql)
# 提交事務(wù)
db.commit()
print(f'刪除成功咒林。')
五、移動游標(biāo)
可能你也發(fā)現(xiàn)了爷光，游標(biāo)就像我們電腦屏幕上閃動的光標(biāo)垫竞，負責(zé)定位本次查詢結(jié)果當(dāng)前位置的數(shù)據(jù)，并通過指令顯示出來蛀序。
針對每次的查詢結(jié)果欢瞪，初始游標(biāo)都在首位。前面的例子中哼拔，我們使用fetchone()一條條取數(shù)據(jù)引有，每取完一次游標(biāo)都會向后移動一位。
我們也可以通過scroll()方法操作游標(biāo)的移動倦逐。這里簡單介紹一下譬正，真正用到的場景并不太多。
| 方法 | 說明 |
|---|---|
| cursor.scroll(2, mode='absolute') | 絕對位置：以初始位置向后移動2位 |
| cursor.scroll(-2, mode='relative') | 相對位置：以當(dāng)前位置向前移動2位 |
六檬姥、關(guān)閉游標(biāo)曾我、關(guān)閉數(shù)據(jù)庫連接
cursor.close()：關(guān)閉游標(biāo)
obj.close()：關(guān)閉數(shù)據(jù)庫
切記最后不要忘了關(guān)閉連接。
import pymysql as pm
# 創(chuàng)建數(shù)據(jù)庫對象
db = pm.connect(host='127.0.0.1',
database='mydatabase',
user='zhangsanfeng',
password='taiqiquan123',
charset='utf-8'
)
# 為本次的數(shù)據(jù)庫對象 db 創(chuàng)建游標(biāo)對象 cursor
cursor = db.cursor()
# 定義 sql
sql = 'DELETE FROM namelist WHERE age<18;'
# 提交 sql
cursor.execute(sql)
# 提交事務(wù)
db.commit()
print(f'刪除成功健民。')
cursor.close()
db.close()
