devbox
羊村懒王
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Python操作mysql数据库_pymysql

作者：羊村懒王 | 2024-04-08 02:06:29

赞

踩

pymysql

一、数据库分类

关系型数据库：采用了关系模型来组织数据的数据库，如MySQL、PostgreSQL、Oracle数据库。

非关系型数据库：以键值对存储，且结构不固定，可以减少一些时间和空间的开销，如MongoDB、Redis。

二、Python操作MySQL环境安装

1、Docker部署MySQL：

1)创建数据库目录(略)

mkdir -p /opt/mysql/data

2)创建并运行MySQL容器

# -d 守护进程后台运行# -v 目录映射——挂载;作用是为了持久化# -e 环境变量# root用户密码设置为hl# -p 映射端口 端口默认3306# root账号的密码为hldocker run -d --name mysql -v /opt/mysql/data:/var/lib/mysql -e MYSQL_ROOT_PASSWORD=hl -p 3306:3306 registry.cn-hangzhou.aliyuncs.com/sqqdcl/waimai-db

如果你想学习接口自动化测试，我这边给你推荐一套视频，这个视频可以说是B站播放全网第一的接口自动化测试教程，同时在线人数到达1000人，并且还有笔记可以领取及各路大神技术交流：798478386    

https://www.bilibili.com/video/BV17p4y1B77x/?spm_id_from=333.337.search-card.all.clickicon-default.png?t=N5K3https://www.bilibili.com/video/BV17p4y1B77x/?spm_id_from=333.337.search-card.all.click

2、安装pymysql库

#python访问MySQL，需要安装pymysql库pip install pymysql

3、Navicat配置连接数据库

三、Python操作MySQL

Python操作数据库的过程：创建连接->获取游标->执行命令->关闭游标->关闭连接

1、创建连接，连接数据库的参数按照实际情况添加

​​

  1. import pymysql
  2.  
  3. #定义一个函数，用来创建连接数据库
  4. def mysql_db():
  5.     con = pymysql.connect(
  6.         host='192.168.223.130',
  7.         port=3306,
  8.         database='mysql',
  9.         charset='utf8',
  10.         user='root',
  11.         password='hl'
  12.     )
  13.  
  14. if __name__ == '__main__':
  15.     mysql_db()

2、获取游标，执行Sql，查询操作

  1.  
  2. import pymysql
  3.  
  4. #定义一个函数，用来操作数据库
  5. def mysql_db():
  6.     con = pymysql.connect(
  7.         host='192.168.223.130',
  8.         port=3306,
  9.         database='mysql',
  10.         charset='utf8',
  11.         user='root',
  12.         password='hl'
  13.     )
  14.     try:
  15.         with con.cursor() as cursor:
  16.             #一、查询
  17.             sql = "select * from tables_priv;"
  18.             #执行SQL语句
  19.             #执行后的结果都保存在cursor中
  20.             cursor.execute(sql)
  21.  
  22.             #1-从cursor中获取全部数据用fetchall
  23.             # datas = cursor.fetchall()
  24.             # print("获取的数据：\n",datas)
  25.  
  26.             #2-从cursor中获取一条数据用fetchall
  27.             # data = cursor.fetchone()
  28.             # print("获取的数据：\n",data)
  29.  
  30.             #3-想要从cursor中获取几条数据用fetchmany
  31.             datas = cursor.fetchmany(3)
  32.             print("获取的数据：\n",datas)
  33.     except Exception as e:
  34.         print("数据库异常：\n",e)
  35.     finally:
  36.         #不管成功还是失败，都要关闭数据库连接
  37.         con.close()
  38.  
  39. if __name__ == '__main__':
  40.     mysql_db()

2.1、fetchall：获取当前SQL语句能查出来的全部数据，元组套元组；

2.2、fetchone：每次获取一条数据。但是获取到这条数据后，指针会往后移一行数据，返回一个元组；

2.3、fetchmany：直接告诉它想要多少条数据。

3、插入数据操作

3.1、插入一条数据

说明：除了查询，其他操作都需要commit；commit对应rollback，回滚到上次提交的地方。​​​​​​​

  1. import pymysql
  2.  
  3. #定义一个函数，用来操作数据库
  4. def mysql_db():
  5.     con = pymysql.connect(
  6.         host='192.168.223.130',
  7.         port=3306,
  8.         database='mysql',
  9.         charset='utf8',
  10.         user='root',
  11.         password='hl'
  12.     )
  13.     try:
  14.         with con.cursor() as cursor:
  15.             # 二、插入
  16.             #1-插入一条数据
  17.             sql = "insert into help_category(help_category_id, name, parent_category_id, url)value(900,'hl-test01',0,'');"
  18.             #执行SQL语句
  19.             cursor.execute(sql)
  20.             #执行玩SQL语句要提交
  21.             con.commit()
  22.             print("提交成功")
  23.  
  24.     except Exception as e:
  25.         # 如果执行失败要回滚
  26.         con.rollback()
  27.         print("数据库异常：\n",e)
  28.     finally:
  29.         #不管成功还是失败，都要关闭数据库连接
  30.         con.close()
  31.  
  32. if __name__ == '__main__':
  33.     mysql_db()

插入结果如下：

3.2、插入多条数据​​​​​​​

  1.  try:
  2.         with con.cursor() as cursor:
  3.             # 二、插入
  4.             #1-插入一条数据
  5.             # sql = "insert into help_category(help_category_id, name, parent_category_id, url)values(900,'hl-test01',0,'');"
  6.  
  7.             # 2-插入多条数据
  8.             value = "(901,'hl-test02',0,''),(902,'hl-test03',0,''),(903,'hl-test04',0,'')"
  9.             # sql = f"insert into help_category(help_category_id, name, parent_category_id, url) values {value};"
  10.             sql = f"insert into help_category values {value};"
  11.             #执行SQL语句
  12.             cursor.execute(sql)
  13.             #执行玩SQL语句要提交
  14.             con.commit()
  15.             print("提交成功")
  16.  
  17.     except Exception as e:
  18.         # 如果执行失败要回滚
  19.         con.rollback()
  20.         print("数据库异常：\n",e)
  21.     finally:
  22.         #不管成功还是失败，都要关闭数据库连接
  23.         con.close()

4、更新数据

  1.  
  2.     try:
  3.         with con.cursor() as cursor:
  4.             #三、更新
  5.             sql = f"update help_category set name='HL-Update' where help_category_id=900;"
  6.            #执行SQL语句
  7.             cursor.execute(sql)
  8.             #执行完SQL语句要提交
  9.             con.commit()
  10.             print("提交成功")
  11.  
  12.     except Exception as e:
  13.         # 如果执行失败要回滚
  14.         con.rollback()
  15.         print("数据库异常：\n",e)
  16.     finally:
  17.         #不管成功还是失败，都要关闭数据库连接
  18.         con.close()

5、删除数据

  1.  
  2. import pymysql
  3.  
  4. #定义一个函数，用来操作数据库
  5. def mysql_db():
  6.     con = pymysql.connect(
  7.         host='192.168.223.130',
  8.         port=3306,
  9.         database='mysql',
  10.         charset='utf8',
  11.         user='root',
  12.         password='hl'
  13.     )
  14.     try:
  15.         with con.cursor() as cursor:
  16.             #一、查询
  17.             # sql = "select * from tables_priv;"
  18.             #执行SQL语句
  19.             #执行后的结果都保存在cursor中
  20.             # cursor.execute(sql)
  21.  
  22.             #1-从cursor中获取全部数据用fetchall
  23.             # datas = cursor.fetchall()
  24.             # print("获取的数据：\n",datas)
  25.  
  26.             #2-从cursor中获取一条数据用fetchall
  27.             # data = cursor.fetchone()
  28.             # print("获取的数据：\n",data)
  29.  
  30.             #3-想要从cursor中获取几条数据用fetchmany
  31.             # datas = cursor.fetchmany(1)
  32.             # print("获取的数据：\n",datas)
  33.  
  34.             # 二、插入
  35.             #1-插入一条数据
  36.             # sql = "insert into help_category(help_category_id, name, parent_category_id, url)values(900,'hl-test01',0,'');"
  37.  
  38.             # 2-插入多条数据
  39.             # value = "(901,'hl-test02',0,''),(902,'hl-test03',0,''),(903,'hl-test04',0,'')"
  40.             # sql = f"insert into help_category values {value};"
  41.  
  42.             #三、更新
  43.             # sql = f"update help_category set name='HL-Update' where help_category_id=900;"
  44.  
  45.             #四、删除
  46.             sql = "delete from help_category where help_category_id like '90%';"
  47.             #执行SQL语句
  48.             cursor.execute(sql)
  49.             #执行完SQL语句要提交
  50.             con.commit()
  51.             print("提交成功")
  52.     except Exception as e:
  53.         # 如果执行失败要回滚
  54.         con.rollback()
  55.         print("数据库异常：\n",e)
  56.     finally:
  57.         #不管成功还是失败，都要关闭数据库连接
  58.         con.close()
  59.  
  60. if __name__ == '__main__':
  61.     mysql_db()

四、Python封装mysql数据库

1、将连接数据的参数写入mysqlConfig.py

  1. class MysqlConfig:
  2.     HOST = '192.168.223.130'
  3.     PORT = 3306
  4.     USER = 'root'
  5.     PASSWORD = 'hl'
  6.     DB = 'mysql'
  7.     CHARSET = 'utf8'

2、封装数据库的增删改查操作

  1.  
  2. import pymysql
  3. from mysqlConfig import MysqlConfig
  4.  
  5. class MysqlConnection:
  6.     def __init__(self,host=MysqlConfig.HOST,
  7.                 port=MysqlConfig.PORT,
  8.                 user=MysqlConfig.USER,
  9.                 pwd=MysqlConfig.PASSWORD,
  10.                 db=MysqlConfig.DB):
  11.         self.db = pymysql.connect(host=host,
  12.                                   port=port,
  13.                                   user=user,
  14.                                   password=pwd,
  15.                                   database=db,
  16.                                   charset=MysqlConfig.CHARSET)#创建连接
  17.         self.cursor = self.db.cursor()#创建游标
  18.  
  19.     #查询方法
  20.     def query(self,sql,many=True):
  21.         try:
  22.             self.cursor.execute(sql)#执行SQL语句
  23.             if many:
  24.                 res = self.cursor.fetchall()
  25.             else:
  26.                 res = self.cursor.fetchone()
  27.             return res
  28.         except Exception as e:
  29.             raise e#打印日志
  30.     #增删改方法
  31.     def __do(self,sql):
  32.         try:
  33.             self.cursor.execute(sql)#执行SQL语句
  34.         except Exception as e:
  35.             self.db.rollback()#如果执行失败要回滚
  36.             #打日志
  37.             raise e
  38.         else:
  39.             self.db.commit()#提交
  40.  
  41.     def update(self,sql):
  42.         self.__do(sql)
  43.  
  44.     def insert(self,sql):
  45.         self.__do(sql)
  46.  
  47.     def delete(self,sql):
  48.         self.__do(sql)
  49.  
  50.     def exit(self):
  51.         self.cursor.close()#关闭游标
  52.         self.db.close()#关闭数据库
  53.  
  54. if __name__ == '__main__':
  55.     db = MysqlConnection()
  56.     res = db.query('select * from tables_priv;')
  57.     print(res)
  58.     db.exit()

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/羊村懒王/article/detail/382205
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号