pymysql 是一个纯 python 实现的 mysql 客户端操作库，支持事务、存储过程、批量执行等。pymysql 遵循 python 数据库 api v2.0 规范，并包含了 pure-python mysql 客户端库。
安装
pip install PyMySQL
创建数据库连接
import pymysqlconnection = pymysql.connect(host='localhost', port=3306, user='root', password='root', db='demo', charset='utf8')
参数列表：
host数据库服务器地址，默认 localhostuser用户名，默认为当前程序运行用户password登录密码，默认为空字符串database默认操作的数据库port数据库端口，默认为 3306bind_address当客户端有多个网络接口时，指定连接到主机的接口。参数可以是主机名或IP地址。unix_socketunix 套接字地址，区别于 host 连接read_timeout读取数据超时时间，单位秒，默认无限制write_timeout写入数据超时时间，单位秒，默认无限制charset数据库编码sql_mode指定默认的 SQL_MODEread_default_fileSpecifies my.cnf file to read these parameters from under the [client] section.convConversion dictionary to use instead of the default one. This is used to provide custom marshalling and unmarshaling of types.use_unicodeWhether or not to default to unicode strings. This option defaults to true for Py3k.client_flagCustom flags to send to MySQL. Find potential values in constants.CLIENT.cursorclass设置默认的游标类型init_command当连接建立完成之后执行的初始化 SQL 语句connect_timeout连接超时时间，默认 10，最小 1，最大 31536000sslA dict of arguments similar to mysql_ssl_set()’s parameters. For now the capath and cipher arguments are not supported.read_default_groupGroup to read from in the configuration file.compressNot supportednamed_pipeNot supportedautocommit是否自动提交，默认不自动提交，参数值为 None 表示以服务器为准local_infileBoolean to enable the use of LOAD DATA LOCAL command. (default: False)max_allowed_packet发送给服务器的最大数据量，默认为 16MBdefer_connect是否惰性连接，默认为立即连接auth_plugin_mapA dict of plugin names to a class that processes that plugin. The class will take the Connection object as the argument to the constructor. The class needs an authenticate method taking an authentication packet as an argument. For the dialog plugin, a prompt(echo, prompt) method can be used (if no authenticate method) for returning a string from the user. (experimental)server_public_keySHA256 authenticaiton plugin public key value. (default: None)db参数 database 的别名passwd参数 password 的别名binary_prefixAdd _binary prefix on bytes and bytearray. (default: False)
执行 SQL
cursor.execute(sql, args) 执行单条 SQL
# 获取游标cursor = connection.cursor()# 创建数据表effect_row = cursor.execute('''CREATE TABLE `users` ( `name` varchar(32) NOT NULL, `age` int(10) unsigned NOT NULL DEFAULT '0', PRIMARY KEY (`name`)) ENGINE=InnoDB DEFAULT CHARSET=utf8''')# 插入数据(元组或列表)effect_row = cursor.execute('INSERT INTO `users` (`name`, `age`) VALUES (%s, %s)', ('mary', 18))# 插入数据(字典)info = {'name': 'fake', 'age': 15}effect_row = cursor.execute('INSERT INTO `users` (`name`, `age`) VALUES (%(name)s, %(age)s)', info)connection.commit()
executemany(sql, args) 批量执行 SQL
# 获取游标cursor = connection.cursor()# 批量插入effect_row = cursor.executemany( 'INSERT INTO `users` (`name`, `age`) VALUES (%s, %s) ON DUPLICATE KEY UPDATE age=VALUES(age)', [ ('hello', 13), ('fake', 28), ])connection.commit()
注意：INSERT、UPDATE、DELETE 等修改数据的语句需手动执行connection.commit()完成对数据修改的提交。
立即学习“Python免费学习笔记（深入）”；
获取自增 ID
cursor.lastrowid
查询数据
# 执行查询 SQLcursor.execute('SELECT * FROM `users`')# 获取单条数据cursor.fetchone()# 获取前N条数据cursor.fetchmany(3)# 获取所有数据cursor.fetchall()
游标控制
所有的数据查询操作均基于游标，我们可以通过cursor.scroll(num, mode)控制游标的位置。
cursor.scroll(1, mode='relative') # 相对当前位置移动cursor.scroll(2, mode='absolute') # 相对绝对位置移动
设置游标类型
查询时，默认返回的数据类型为元组，可以自定义设置返回类型。支持5种游标类型：
Cursor: 默认，元组类型
DictCursor: 字典类型
DictCursorMixin: 支持自定义的游标类型，需先自定义才可使用
SSCursor: 无缓冲元组类型
SSDictCursor: 无缓冲字典类型
无缓冲游标类型，适用于数据量很大，一次性返回太慢，或者服务端带宽较小时。源码注释：
Unbuffered Cursor, mainly useful for queries that return a lot of data, or for connections to remote servers over a slow network.Instead of copying every row of data into a buffer, this will fetch rows as needed. The upside of this is the client uses much less memory, and rows are returned much faster when traveling over a slow networkor if the result set is very big.There are limitations, though. The MySQL protocol doesn’t support returning the total number of rows, so the only way to tell how many rows there are is to iterate over every row returned. Also, it currently isn’t possible to scroll backwards, as only the current row is held in memory.
创建连接时，通过 cursorclass 参数指定类型：
connection = pymysql.connect(host='localhost', user='root', password='root', db='demo', charset='utf8', cursorclass=pymysql.cursors.DictCursor)
也可以在创建游标时指定类型：
知我AI·PC客户端
离线运行 AI 大模型，构建你的私有个人知识库，对话式提取文件知识，保证个人文件数据安全
0 查看详情 
cursor = connection.cursor(cursor=pymysql.cursors.DictCursor)
事务处理
开启事务
connection.begin()
提交修改
connection.commit()
回滚事务
connection.rollback()
防 SQL 注入
转义特殊字符connection.escape_string(str)
参数化语句
支持传入参数进行自动转义、格式化 SQL 语句，以避免 SQL 注入等安全问题。
# 插入数据(元组或列表)effect_row = cursor.execute('INSERT INTO `users` (`name`, `age`) VALUES (%s, %s)', ('mary', 18))# 插入数据(字典)info = {'name': 'fake', 'age': 15}effect_row = cursor.execute('INSERT INTO `users` (`name`, `age`) VALUES (%(name)s, %(age)s)', info)# 批量插入effect_row = cursor.executemany( 'INSERT INTO `users` (`name`, `age`) VALUES (%s, %s) ON DUPLICATE KEY UPDATE age=VALUES(age)', [ ('hello', 13), ('fake', 28), ])
参考资料
Python中操作mysql的pymysql模块详解
Python之pymysql的使用
相关推荐：
python实现telnet客户端的方法
MemCached的PHP客户端操作类二
数据库mysql视频教程
以上就是分享一个纯 Python 实现的 MySQL 客户端操作库的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/383139.html
微信扫一扫 
支付宝扫一扫 
