分享一个纯 Python 实现的 MySQL 客户端操作库

pymysql 是一个纯 python 实现的 mysql 客户端操作库，支持事务、存储过程、批量执行等。pymysql 遵循 python 数据库 api v2.0 规范，并包含了 pure-python mysql 客户端库。

安装

pip install PyMySQL

创建数据库连接

import pymysql

connection = pymysql.connect(host='localhost',
                             port=3306,
                             user='root',
                             password='root',
                             db='demo',
                             charset='utf8')

参数列表：

执行 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

查询数据

# 执行查询 SQL
cursor.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)

也可以在创建游标时指定类型：

黄城网络办公系统

具有功能全面实用、安全性稳定性高、易操作、管理维护简单的特点，采用独创的智能型技术，web服务器、数据库和应用程序全部自动傻瓜安装配置，用户可在一分钟内自行安装完毕，无需专业人员即可自行维护，B/S结构，适用于Intranet/Internet应用，客户端只需浏览器便可连接办公系统，无论出差旅行，还是居家办公，工作都能得心应手，实现无地域限制的全球办公，具有邮件管理、业务管理、网络硬盘、智能工作流

下载

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视频教程