4000字，詳解?Python?操作?MySQL?數據庫！
[導讀]作者|黃偉呢出品|數據分析與統(tǒng)計學之美本文的重點，就是教會大家，如何用Python來操作MySQL數據庫。1.通用步驟其實，這里有一個通用步驟，都是寫死了的，大家照做就行。#?1.?導入相關庫import?pymysql#?2.?鏈接MySQL服務器db?=?pymysql.co...
作者 | 黃偉呢出品 | 數據分析與統(tǒng)計學之美本文的重點，就是教會大家，如何用Python來操作MySQL數據庫。
1. 通用步驟
其實，這里有一個通用步驟，都是寫死了的，大家照做就行。# 1. 導入相關庫import pymysql
# 2. 鏈接MySQL服務器
db = pymysql.connect(host='localhost' , user='root' , password='******' , port=3306 ,db='spiders' , charset='utf8')
# 3. 創(chuàng)建一個cursor游標對象
cursor = db.cursor()
# 4. 在這一步寫你的sql語句
sql = 'select version()'
# 5. 執(zhí)行sql語句
cursor.execute(sql)
# 6. 斷開連接
db.close() 可以看出，整個過程就是第四步那里不同。歸根到底，其實就是寫sql。
2. 需要特別說明的知識點
Ⅰ 各參數說明
db = pymysql.connect(host='localhost' , user='root' , password='******' , port=3306 ,db='spiders' , charset='utf8') 這一行代碼很長，里面涉及到好幾個參數，這里為大家一一介紹如下：- 參數 1 ：mysql 服務器所在的主機 IP
- 參數 2 ：用戶名；
- 參數 3 ：密碼；
- 參數 4 ：連接的 mysql 主機的端口，默認是 3306；
- 參數 5 ：連接的數據庫名；
- 參數 6 ：通信采用的編碼方式，默認是'gb2312'，要求與數據庫創(chuàng)建時指定的編碼一致，否則中文會亂碼；
Ⅱ cursor游標對象
3. Python增刪改查操作
① 創(chuàng)建一個數據表
import pymysqldb = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')
cursor = db.cursor()
# 檢查表是否存在，如果存在刪除
cursor.execute('drop table if exists students')
# 創(chuàng)建表
sql = 'create table students(id int auto_increment primary key not null,name varchar(10) not null,age int not null)'
cursor.execute(sql)
db.close() 注：以后用代碼創(chuàng)建表的機會并不多，表一般都是我們提前創(chuàng)建好的。
② 插入數據
import pymysqldb = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')
cursor = db.cursor()
# 插入數據
sql = 'insert into students(name,age) values(%s,%s)'
try:
cursor.execute(sql,('孫悟空',100000))
db.commit()
except:print("插入失敗")
db.rollback()
db.close() 注 1：插入數據一定要用 try…except…語句，因為萬一沒插入成功，其余代碼都無法執(zhí)行。注 2：import pymysql，此模塊是默認開啟mysql的事務功能的，因此，進行“增”、“刪”、“改”的時候，一定要使用db.commit()提交事務，否則就看不見所插入的數據。
③ 更新數據
import pymysqldb = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')
cursor = db.cursor()
# 更新數據
sql = 'update students set age =%s where name=%s'
try:
cursor.execute(sql,(30,"郭衛(wèi)華"))
db.commit()
except:
print("插入失敗")
db.rollback()
db.close()
③ 刪除操作
import pymysqldb = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')
cursor = db.cursor()
# 刪除數據
sql = 'delete from students where age=100000'
try:
cursor.execute(sql)
db.commit()
except:
print("插入失敗")
db.rollback()
db.close()
④ 查詢操作
- fetchone()功能：獲取下一個查詢結果集，結果集是一個對象。
- fetchall()功能：接收全部返回的行。
db = pymysql.connect(host='192.168.3.47' , user='root',password='******' , port=3306 , db='spiders' , charset='utf8')
cursor = db.cursor()
# 查詢數據
sql = 'select * from students where age>60'
try:
cursor.execute(sql)
reslist = cursor.fetchall()
for row in reslist:
print(“%d--%d” %(row[0],row[1],… row[n]))
except:
print("插入失敗")
db.rollback()
db.close()
4. 封裝一個類
# 注：把下面類寫在 studentsql 文件中import pymysql
class StudentsSql():
def __init__(self,host,user,port,dbname,charset):
self.host = host
self.user = user
self.port = port
self.dbname = dbname
self.charset = charset
def connet(sef):
self.db = pymysql.connect(self.host, self.user, self.port,
self.dbname, self.charset)
def close(self):
self.cursor.close()
self.db.close()
def get_one(self,sql):
res = None
try:
self.connect()
self.cursor.execute(sql)
res = self.cursor.fetchone()
self.close()
except:
print(“查詢失敗”)
return res
def get_all(self,sql):
res = None
try:
self.connect()
self.cursor.execute(sql)
res = self.cursor.fetchall()
self.close()
except:
print(“查詢失敗”)
return res
def inset(self,sql):
return self.__edit(sql)
def update(self,sql):
return self.__edit(sql)
def delete(self,sql):
return self.__edit(sql)
def __edit(self,sql):
count = 0
try:
self.connect()
count = self.cursor.execute(sql)
self.db.commit()
self.close()
except:
print(“事務提交失敗”)
self.db.rollback()
return count 上述類封裝成功，以后只需要調用即可。from studentsql import StudentsSql
s = StudentsSql(“host='192.168.3.47' , user='root', password='******' , port=3306 , db='spiders' , charset='utf8'”)
res = s.get_all('select * from students where age>60')
for row in res:
print(“%d--%d” %(row[0],row[1],… row[n]))
下載文檔
