1. 概述
PyMySQL是一个用于Python语言连接和操作MySQL数据库的库。它提供了一种简单而强大的方式来与MySQL数据库进行交互，允许开发者执行各种数据库操作，如建立连接、执行查询、插入数据等。
2. 安装和配置
2.1安装PyMySQL
可以使用pip命令安装PyMySQL库：
pip install PyMySQL
2.2 配置数据库连接
要使用PyMySQL连接MySQL数据库，需要提供数据库的主机名、端口号、用户名、密码以及数据库名称等信息。可以将这些信息存储在一个字典中，如：
config = { 'host': 'localhost', 'port': 3306, 'user': 'username', # 你的用户名 'password': 'password', # 你的密码 'database': 'database_name' # 你的数据库名 }
3. 建立数据库连接
3.1 创建连接对象
在PyMySQL中，游标（Cursor）是一个非常重要的概念，它用于执行查询和获取结果。游标允许逐行处理查询结果，从而可以控制从数据库检索的数据量和顺序。
3.1.1 游标的作用
执行SQL语句：游标对象用来执行SQL语句，如查询、插入、更新和删除。
获取结果：执行查询后，游标可以用来逐行或批量获取结果数据。
参数化查询：游标支持使用参数化查询，这有助于防止SQL注入攻击。
事务控制：通过游标执行的操作可以被提交或回滚，这对于维护数据的一致性非常重要。
3.1.2 创建游标对象
从数据库连接对象中创建游标对象的基本方法如下：
cursor = connection.cursor()
此外，PyMySQL允许指定游标的类型，例如，使用DictCursor，查询结果将以字典形式返回，其中列名是字典的键：
cursor = connection.cursor(pymysql.cursors.DictCursor)
这种方式使得处理结果更加直观和方便，因为可以通过列名访问数据，而不是通过列的索引位置。
3.1.3 示例
创建游标对象后，可以使用它来执行SQL命令。例如，执行一个查询并获取所有结果：
cursor.execute("SELECT * FROM users") results = cursor.fetchall() for row in results: print(row)
在这个例子中，execute方法用于执行SQL查询，fetchall方法用于获取所有行的数据。
3.2 创建游标对象
从连接对象中创建一个游标对象，用于执行SQL查询：
cursor = connection.cursor()
4. 执行SQL查询
上面介绍了，在PyMySQL中，执行SQL查询是通过游标对象（Cursor）完成的。这包括SELECT查询来获取数据，以及INSERT、UPDATE和DELETE查询来修改数据。接下来具体介绍如何使用PyMySQL执行这些操作。
4.1 执行SELECT查询
要执行SELECT查询，首先需要编写SQL查询语句。然后，使用游标对象的execute()方法来执行这个查询。查询结果可以通过游标提供的方法如fetchall()或fetchone()来获取。
步骤：
- 编写查询语句：确定你需要执行的SELECT语句。
- 执行查询：使用游标的execute()方法执行SQL语句。
- 获取结果：使用fetchall()获取所有结果，或使用fetchone()获取单个结果。
query = "SELECT * FROM users" cursor.execute(query) results = cursor.fetchall() for row in results: print(row)
在这个例子中，execute()方法执行了SQL查询，fetchall()方法获取了所有的查询结果，并且结果通过一个循环打印出来。
4.2 执行INSERT、UPDATE和DELETE查询
对于INSERT、UPDATE和DELETE操作，步骤类似于执行SELECT查询，但通常需要在执行这些操作后提交更改，以确保更改被保存到数据库中。步骤：
- 编写SQL语句：根据需要修改数据的类型编写相应的INSERT、UPDATE或DELETE语句。
- 执行查询：使用游标的
execute()方法执行SQL语句。对于INSERT和UPDATE操作，可以传递参数来避免SQL注入。 - 提交更改：使用连接对象的
commit()方法提交更改到数据库。
query = "INSERT INTO users (name, age) VALUES (%s, %s)" values = ('John', 25) cursor.execute(query, values) connection.commit()
在这个例子中，execute()方法不仅执行了INSERT查询，还通过传递参数的方式提供了要插入的数据，这有助于防止SQL注入。执行后，使用commit()方法确保更改被保存。
5. 处理查询结果
5.1 遍历查询结果
可以使用for循环遍历fetchall()返回的查询结果：
for row in results: print(row)
5.2 访问特定字段
可以使用索引或字段名访问查询结果中的特定字段：
name = row[0] # 使用索引 age = row['age'] # 使用字段名
6. 关闭连接
6.1 关闭游标和连接
在完成数据库操作后，需要关闭游标和连接对象以释放资源：
cursor.close() connection.close()
6.2 使用with语句自动关闭
可以使用with语句自动管理连接和游标的关闭：
with pymysql.connect(**config) as connection: with connection.cursor() as cursor: # 执行查询操作 pass
7. 一个连续的示例
现在假设你安装好了MySQL、Python3环境，并安装了PyMySQL库。由于PyMySQL库并不会自动创建连接的数据库，需要先登录你的MySQL中手动创建一个数据库。
假设你的root用户的密码为：123456，登录你的MySQL交互环境：
mysql -h localhost -P 3306 -u root -p
在显示Enter password:输入123456（假设为你的密码），回车。其中h localhost可以依据你的MySQL主机地址修改，若为localhost，可以不指定h参数。
现在我们执行SQL创建一个名为mydatabase的数据库：
CREATE DATABASE mydatabase;
然后执行quit命令退出。
PyMySQL依赖于cryptography包的C扩展。如果在后续运行中提示缺少，可以使用下面的命令进行安装：
pip install cryptography
这里的cryptography是一个用于加密和解密的Python库，提供了多种加密算法和工具，帮助开发者实现安全通信和数据保护。它支持对称加密、非对称加密、哈希函数、数字签名等多种加密技术。
接下来编写我们的脚本：
import pymysql # 数据库配置 config = { 'host': 'localhost', 'port': 3306, 'user': 'root', 'password': '123456', 'database': 'mydatabase' } # 建立数据库连接 connection = pymysql.connect(**config) try: with connection.cursor() as cursor: # 创建表 create_table_query = """ CREATE TABLE IF NOT EXISTS users ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT ) """ cursor.execute(create_table_query) connection.commit() # 插入数据 insert_query = "INSERT INTO users (name, age) VALUES (%s, %s)" users_data = [ ('John', 25), ('Alice', 30), ('Bob', 35) ] cursor.executemany(insert_query, users_data) connection.commit() # 查询数据 select_query = "SELECT * FROM users" cursor.execute(select_query) results = cursor.fetchall() print("查询结果:") for row in results: print(row) # 更新数据 update_query = "UPDATE users SET age = %s WHERE name = %s" cursor.execute(update_query, (28, 'John')) connection.commit() # 删除数据 delete_query = "DELETE FROM users WHERE name = %s" cursor.execute(delete_query, ('Bob',)) connection.commit() # 再次查询数据 cursor.execute(select_query) results = cursor.fetchall() print("更新后的查询结果:") for row in results: print(row) finally: # 关闭连接 connection.close()
这个脚本使用了Python的PyMySQL库来与MySQL数据库进行交互，具体执行了以下操作：
- 建立数据库连接： 使用提供的配置（包括主机名、端口号、用户名、密码和数据库名）建立到MySQL数据库的连接；
- 创建表： 在数据库中创建一个名为users的表，如果这个表已经存在，则不会重复创建。表中包含三个字段：
id（自动增长的整数主键）、name（字符串类型，最大长度255）、age（整数类型）。 - 插入数据： 向
users表中插入三条数据记录，分别是John（25岁）、Alice（30岁）和Bob（35岁）。 - 查询数据：从
users表中查询所有记录，并打印出来。这是在插入数据后立即进行的，所以查询结果将显示所有刚插入的数据。 - 更新数据： 更新名为John的用户的年龄，将其从25岁改为28岁。
- 删除数据： 删除名为Bob的用户记录。
- 再次查询数据： 在更新和删除操作之后，再次从users表中查询所有记录，并打印出来。这次查询的结果将反映出对John年龄的更新和Bob记录的删除。
- 关闭数据库连接： 在所有操作完成后，脚本会关闭数据库连接，释放资源。
整个脚本展示了如何使用PyMySQL进行基本的数据库操作，包括连接数据库、执行SQL命令（创建表、插入、查询、更新、删除数据）以及最后关闭数据库连接。这些操作是数据库管理和数据处理中常见的任务。
运行后的控制套输出为：
查询结果: (1, 'John', 25) (2, 'Alice', 30) (3, 'Bob', 35) 更新后的查询结果: (1, 'John', 28) (2, 'Alice', 30)
