4000字，详解 Python 操作 MySQL 数据库！

ゝ一纸荒年。 2022-08-28 02:56 201阅读 0赞

![0dffd885d33f2df512164c2a14e15d1a.gif][]

作者 | 黄伟呢

出品 | 数据分析与统计学之美

本文的重点，就是教会大家，如何用Python来操作MySQL数据库。

## 1. 通用步骤 ##

其实，这里有一个通用步骤，都是写死了的，大家照做就行。

# 1. 导入相关库
    import pymysql
    
    # 2. 链接MySQL服务器
    db = pymysql.connect(host='localhost' , user='root' , password='******' , port=3306 ,db='spiders' , charset='utf8')
    
    # 3. 创建一个cursor游标对象
    cursor = db.cursor()
    
    # 4. 在这一步写你的sql语句
    sql = 'select version()'
    
    # 5. 执行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'，要求与数据库创建时指定的编码一致，否则中文会乱码；

###### Ⅱ cursor游标对象 ######

![021919862008bfc5797dab5a1e9179a3.png][]

## 3. Python增删改查操作 ##

###### ① 创建一个数据表 ######

import pymysql
    
    db = 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')
    
    # 创建表
    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()

注：以后用代码创建表的机会并不多，表一般都是我们提前创建好的。

###### ② 插入数据 ######

import pymysql
    
    db = 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…语句，因为万一没插入成功，其余代码都无法执行。

注 2：import pymysql，此模块是默认开启mysql的事务功能的，因此，进行“增”、“删”、“改”的时候，一定要使用db.commit()提交事务，否则就看不见所插入的数据。

###### ③ 更新数据 ######

import pymysql
    
    db = 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,"郭卫华"))
       db.commit()
    except:
       print("插入失败")
       db.rollback()
    
    db.close()

###### ③ 删除操作 ######

import pymysql
    
    db = 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()功能：接收全部返回的行。

import pymysql
    
    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]))

![819f94a87491cf2d0686b0071815dbd2.gif][]

![d271efcdfaf14b2766ecbb102ea2c660.png][]

往

期

回

顾

资讯

[AI 考古比胡八一更高效][AI]

资讯

[这个机器狗引起网友争议！][Link 1]

资讯

[阿里发布云芯片倚天710][710]

资讯

[英特尔开源编程工具 ControFlag][ControFlag]

![9cd2044eecce84f038a7942b76bdb18d.png][]

**分享**

![0b1d1ab38bfba1eef8e4c4216081f5a7.png][]

**点收藏**

![e8709a3f8fe3466f34385aece3a150cd.png][]

**点点赞**

![65d27d68d2d74c2af745ca48c30c6e3a.png][]

**点在看**

[0dffd885d33f2df512164c2a14e15d1a.gif]: /images/20220828/4372e5445b144e8180f527f53bffba03.png
[021919862008bfc5797dab5a1e9179a3.png]: /images/20220828/d47a53c57295494ba32bce3423164859.png
[819f94a87491cf2d0686b0071815dbd2.gif]: /images/20220828/fb6985afe9664f06999fa0229f7ceff6.png
[d271efcdfaf14b2766ecbb102ea2c660.png]: /images/20220828/521e41a1f1384e30a58761a7d02de2de.png
[AI]: https://blog.csdn.net/dQCFKyQDXYm3F8rB0/article/details/120984102
[Link 1]: http://mp.weixin.qq.com/s?__biz=Mzg4NDQwNTI0OQ==&mid=2247549783&idx=1&sn=0871b975a1fa7e08d746e3e08b32f6ba&chksm=cfbae639f8cd6f2f1d955d22ae861bab757ceb2bc838eb83535db7c4d8e53b88c3f9546fa2af&scene=21#wechat_redirect
[710]: https://blog.csdn.net/QbitAI/article/details/120857567
[ControFlag]: http://mp.weixin.qq.com/s?__biz=Mzg4NDQwNTI0OQ==&mid=2247549726&idx=1&sn=a6cffa905ebe75e93fbbcf54cae8412c&chksm=cfbae670f8cd6f66f2f9189a37824374ea41d7f633303e3794fa8d8257a5ef85fa88237de389&scene=21#wechat_redirect
[9cd2044eecce84f038a7942b76bdb18d.png]: /images/20220828/b7406f6c242545be8778397b0f7d1c7b.png
[0b1d1ab38bfba1eef8e4c4216081f5a7.png]: /images/20220828/98733fabd2174c509d9e1769f6629063.png
[e8709a3f8fe3466f34385aece3a150cd.png]: /images/20220828/edfd54dbed9d494ba48b04489114e542.png
[65d27d68d2d74c2af745ca48c30c6e3a.png]: /images/20220828/7fe89508fe514c83bd965cdbe2e9d285.png