安裝 pymysql
pip install pymysql
連接數據庫的步驟
1. 連上數據庫:帳號、密碼、ip、端口號、數據庫
2. 建立游標
3. 執行sql
4. 獲取結果
5. 關閉游標
6. 連接關閉
1 import pymysql 2 coon = pymysql.connect( 3 host = '127.0.0.1',user = 'root',passwd = '123456', 4 port = 3306,db = 'mydb',charset = 'utf8' 5 #port必須寫int類型 6 #charset必須寫utf8,不能寫utf-8 7 ) 8 cur = coon.cursor() #建立游標 9 cur.execute("select * from stu") #查詢數據 10 res = cur.fetchall() #獲取結果 11 print(res) 12 cur.close() #關閉游標 13 coon.close() #關閉連接 14 --------------------------------------------------------------------------- 15 #如果是插入數據,則要commit一下,把第9行換成以下兩行 16 cur.execute('insert into stu(name,sex) VALUE ("pzp","man");') 17 coon.commit()
把連接數據庫封裝成一個函數
1 def my_db(host,user,passwd,db,sql,port= 3306,charset = 'utf8'): 2 import pymysql 3 coon = pymysql.connect(host=host, 4 port=port, 5 user=user, 6 passwd = passwd, 7 db = db, 8 charset = charset 9 ) 10 cur = coon.cursor() 11 cur.execute(sql) 12 if sql.strip()[:6].upper() == 'SELECT': 13 res = cur.fetchall() 14 else: 15 coon.commit() 16 res = 'ok' 17 cur.close() 18 coon.close() 19 return res
Connection:創建了Python客戶端與數據庫之間的網絡通路。他的參數如下
參數名 | 類型 | 說明 |
host | String | MySQL的服務器地址 |
port | int | MySQL的端口號 |
user | String | 用戶名 |
passwd | String | 密碼 |
db | String | 使用的數據庫 |
charset | String | 連接字符集 |
Connection支持的方法:
方法名 | 說明 |
cursor() | 創建並且返回游標 |
commit() | 提交當前事物 |
rollback() | 回滾當前事物r() |
close() | 關閉Connection |
Cursor:游標對象,用於執行查詢和獲取結果,它支持的方法如下:
方法名 | 說明 |
execute() | 用於執行一個數據庫的查詢命令 |
fetchone() | 獲取結果集中的下一行
返回一條數據,返回字典里面的元素,類型可以是列表或字典(根據游標類型)
|
fetchmany(size) |
獲取結果集中的下(size)行 |
fetchall() | 獲取結果集中的所有行,
把數據庫里面的每一行數據放到一個list里面
|
rowcount | 最近一次execute返回數據/影響的行數 |
close() | 關閉游標 |