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