python 連接 Mysql


   
   

安裝 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() 關閉游標
 
 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM