Python pymysql——Mysql数据库Python化操作

Posted 2020-11-20 UnikFox

前言

Mysql数据库是目前较为流行使用的数据库之一，众多编程语言都有对其的支持扩展包接口，当然于python而言亦有专门扩展库以便帮助开发者对Mysql数据库进行相应的操作。其中，由于python版本不同，对Mysql支持的库也有区别，目前使用较为普遍的有pymysql和MySQLdb，两者功能上无明显差异，只是前者支持python3.X版本，后者应用于python2.X版本。

在此以python3.X版本为平台基础，对pymysql的相关基础及使用方法作简单介绍。

安装

直接使用pip命令进行安装

pip install pymysql

概念基础

在pymysql中（当然，其他SQL数据库接口也一样），主要有三个基本概念：连接对象、游标对象以及查询SQL select语句的结果。

1）连接对象：代表一个到数据库的连接，它是提交和回滚操作的接口，提供了数据库软件包的细节信息，并能生成游标对象。

2）游标对象：代表了需提交执行的SQL语句，同时它也可以被用来访问和遍历SQL语句的执行结果。

3）查询SQL select语句的结果：SQL select语句的执行结果在python是一个嵌套的序列，它代表了数据库表中的行。

使用方法

1）初始化准备

import pymysql

# 初始化连接配置
ConnectConfig = {
     ‘host‘: ‘localhost‘,
     ‘port‘: 3306,
     ‘user‘: ‘root‘,
     ‘passwd‘: ‘******‘,
     ‘charset‘: ‘utf8‘,
     ‘db‘: ‘tesdbt‘
 }

# 创建连接对象
db = pymysql.connect(
     host=ConnectConfig[‘host‘], 
     port=ConnectConfig[‘port‘],
     user=ConnectConfig[‘user‘],
     passwd=ConnectConfig[‘passwd‘], 
     charset=ConnectConfig[‘charset‘], 
     db=ConnectConfig[‘db‘]
 )

# 创建游标对象
cursor = db.cursor()

2）执行SQL语句

示例1——创建表和添加记录

# 创建数据表
sql="create table people(name char(30),job char(10),pay int(4));"
cursor.execute(sql)

# 添加记录
cursor.execute(‘insert into people values(%s,%s,%s);‘,(‘Bob‘,‘dev‘,50000))# 或者也可以一次性添加多条记录
rows = [(‘Sue‘,‘mus‘,70000),(‘Ann‘,‘adm‘,60000)]
cursor.executemany(‘insert into people values(%s,%s,%s);‘,rows)

# 操作完成后还需要进行事务提交以便数据库保存
db.commit()
# 此外连接对象还有事务回滚操作：db.rollback()

# 最后关闭游标对象和连接对象
cursor.close()
db.close()

示例2——查询、更新和删除记录

# 查询people表中所有记录
cursor.execute(‘select * from people;‘)
result = cursor.fetchall()
for row in result:
    print(row)

""" Output: (‘Bob‘,‘dev‘,50000) (‘Sue‘,‘mus‘,70000) (‘Ann‘,‘adm‘,60000) """

# 更新people表中职务为adm的人员工资增加12000
cursor.execute(‘update people set pay=pay+12000 where job="adm";‘)
cursor.execute(‘select * from people where job="adm";‘)
db.commit();
result = cursor.fetchall()
print(result)

"""Output: [(‘Ann‘,‘adm‘,72000)] """

# 删除people表中姓名为Bob的记录
cursor.execute(‘delete from people where name="Bob";‘)
cursor.execute(‘select * from people;‘)
db.commit();
result = cursor.fetchall()
for row in result:
    print(row)

"""Output: (‘Sue‘,‘mus‘,70000) (‘Ann‘,‘adm‘,72000) """

3)其他使用

①cursor.rowcount属性：返回执行完SQL语句后所影响的行数

# 使用rowcount获取所影响的行数
cursor.execute(‘select * from people;‘)
print(cursor.rowcount)  # Output:3

②cursor.description属性：返回执行完SQL查询语句后所得到的字段名和字段属性

# 使用description获得表字段名和字段属性
cursor.execute(‘select * from people;‘)
print(cursor.description)

""" Output: ((‘name‘,None,None,None,None,None,None),(‘job‘,None,None,None,None,None,None), (‘pay‘,None,None,None,None,None,None))# 具体列属性描述请参阅相关API说明 """

# 格式化表字段名
cursor.execute(‘select * from people;‘)
colnames = [desc[0] for desc in cursor.description]
print(colnames)

""" Output: [‘name‘,‘job‘,‘pay‘] """

③cursor.fetchall()：返回执行完SQL查询语句后得到结果的列表（元素为行的元组形式）

   cursor.fetchone():返回执行完SQL查询语句后得到结果的第一行

   cursor.fetchmany(n)：返回执行完SQL查询语句后得到结果的前n行

这里要注意的是fetch获得的行是根据游标来定位的，就是说每一次调用fetch相关行数，游标就会移动，下一次再调用fetch时从上次游标的位置开始获得记录，当其已经到表末尾时，则返回空序列。

# 连续调用fetch方法
cursor.execute(‘select * from people;‘)
rows1 = cursor.fetchall()
print(rows1)  # Output:[(‘Bob‘,‘dev‘,50000),(‘Sue‘,‘mus‘,70000),(‘Ann‘,‘adm‘,60000)]
rows2 = cursor.fetchall()
print(rows2)  # Output:[]

④cursor.scroll(num,mode)：控制游标对象的移动以便重定fetch方法

# 使用scroll方法调整游标位置
cursor.scroll(1,mode=‘relative‘)  # 相对当前位置顺序移动
cursor.scroll(2,mode=‘absolute‘)  # 相对绝对位置顺序移动

 

---

以上便是对python数据库操作的pymysql库一些简单介绍，希望对大家能有所帮助，如有什么问题欢迎大家留言学习交流。

如想深入了解学习pymysql欢迎查阅相关文档（https://pymysql.readthedocs.io/en/latest/index.html）