1.引入模塊

• 在py文件中引入pymysql模塊

from pymysql import *

2.Connection 對象

• 用于建立與數(shù)據(jù)庫的連接

• 創(chuàng)建對象：調(diào)用connect()方法

conn=connect(參數(shù)列表)

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

對象的方法

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

3.Cursor對象

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

cs1=conn.cursor()

對象的方法

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

對象的屬性

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

增刪改

• 創(chuàng)建test_insert.py文件，向?qū)W生表中插入一條數(shù)據(jù)

#encoding=utf-8 from pymysql import *if __name__=='__main__':try:#創(chuàng)建Connection連接conn=connect(host='localhost',port=3306,database='test1',user='root',password='mysql',charset='utf8')#獲得Cursor對象cs1=conn.cursor()#執(zhí)行insert語句，并返回受影響的行數(shù)：添加一條學生數(shù)據(jù)# 增加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')#打印受影響的行數(shù)print count#關閉Cursor對象cs1.close()#提交之前的操作，此處為insert操作conn.commit()except Exception,e:print efinally:#關閉Connection對象conn.close()

查詢一行數(shù)據(jù)

• 創(chuàng)建test_one.py文件，查詢一條學生信息

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

查詢多行數(shù)據(jù)

• 創(chuàng)建test_many.py文件，查詢所有學生信息

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

總結

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。