1.引入模塊

• 在py文件中引入pymysql模塊

from pymysql import *

2.Connection 對象

• 用于建立與數據庫的連接

• 創建對象：調用connect()方法

conn=connect(參數列表)

• 參數host：連接的mysql主機，如果本機是'localhost'
• 參數port：連接的mysql主機的端口，默認是3306
• 參數database：數據庫的名稱
• 參數user：連接的用戶名
• 參數password：連接的密碼
• 參數charset：通信采用的編碼方式，推薦使用utf8

對象的方法

• close()關閉連接
• commit()提交
• rollback()回滾
• cursor()返回Cursor對象，用于執行sql語句并獲得結果

3.Cursor對象

• 用于執行sql語句，使用頻度最高的語句為select、insert、update、delete
• 獲取Cursor對象：調用Connection對象的cursor()方法

cs1=conn.cursor()

對象的方法

• close()關閉
• execute(operation [, parameters ])執行語句，返回受影響的行數，主要用于執行insert、update、delete語句，也可以執行create、alter、drop等語句
• fetchone()執行查詢語句時，獲取查詢結果集的第一個行數據，返回一個元組
• fetchall()執行查詢時，獲取結果集的所有行，一行構成一個元組，再將這些元組裝入一個元組返回

對象的屬性

• rowcount只讀屬性，表示最近一次execute()執行后受影響的行數
• connection獲得當前連接對象

增刪改

• 創建test_insert.py文件，向學生表中插入一條數據

#encoding=utf-8 from pymysql import *if __name__=='__main__':try:#創建Connection連接conn=connect(host='localhost',port=3306,database='test1',user='root',password='mysql',charset='utf8')#獲得Cursor對象cs1=conn.cursor()#執行insert語句，并返回受影響的行數：添加一條學生數據# 增加count=cs1.execute('insert into students(name) values("張良")')# 更新count=cs1.execute('update students set name="劉邦" where id=6')# 刪除count=cs1.execute('delete from students where id=6')#打印受影響的行數print count#關閉Cursor對象cs1.close()#提交之前的操作，此處為insert操作conn.commit()except Exception,e:print efinally:#關閉Connection對象conn.close()

查詢一行數據

• 創建test_one.py文件，查詢一條學生信息

#coding=utf-8 from pymysql import *if __name__=='__main__':try:#創建Connection連接conn=connect(host='localhost',port=3306,user='root',password='mysql',database='python1',charset='utf8')#獲得Cursor對象cs1=conn.cursor()#執行select語句，并返回受影響的行數：查詢一條學生數據count=cs1.execute('select id,name from students where id=7')#打印受影響的行數print count#獲取查詢的結果result = cs1.fetchone()#打印查詢的結果print result#關閉Cursor對象cs1.close()except Exception as e:print efinally:#關閉Connection對象conn.close()

查詢多行數據

• 創建test_many.py文件，查詢所有學生信息

#coding=utf-8 from pymysql import *if __name__=='main':try:#創建Connection連接conn=connect(host='localhost',port=3306,user='root',password='mysql',database='python1',charset='utf8')#獲得Cursor對象cs1=conn.cursor()#執行select語句，并返回受影響的行數：查詢所有學生數據count=cs1.execute('select id,name from students')#打印受影響的行數print count#獲取查詢的結果result = cs1.fetchall()#打印查詢的結果print result#關閉Cursor對象cs1.close()except Exception as e:print efinally:#關閉Connection對象conn.close()
創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的Python 中操作 MySQL 步骤的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。