下面我将为您提供关于如何安装和导入 PyMySQL 的详细步骤,并附上一个简单的使用示例。

第一步:安装 PyMySQL
在开始之前,您需要先确保您的 Python 环境中已经安装了 PyMySQL 库,您可以使用 pip(Python 的包管理器)来安装它。
打开您的终端(在 Windows 上是命令提示符或 PowerShell,在 macOS 或 Linux 上是终端),然后运行以下命令:
pip install PyMySQL
如果您使用的是 Python 3,并且您的系统中有多个 Python 版本,建议使用 pip3:
pip3 install PyMySQL
安装成功后,您会看到类似 "Successfully installed PyMySQL-..." 的提示信息。

第二步:导入 PyMySQL
安装完成后,您就可以在您的 Python 代码中导入这个库了,导入的方式非常简单:
import pymysql
这就是您在代码中需要做的所有“导入”工作。import 语句会将 pymysql 库中的所有功能加载到您的程序中,您就可以通过 pymysql 这个前缀来调用它们了。
第三步:连接数据库并执行基本操作(完整示例)
仅仅导入是不够的,PyMySQL 的核心功能是建立与 MySQL 数据库的连接,并进行数据操作,下面是一个完整的示例,展示了如何连接数据库、创建表、插入数据、查询数据,并最后关闭连接。
在运行此代码之前,请确保您已经:

- 安装了 MySQL 数据库服务。
- 创建了一个数据库(名为
testdb)。 - 知道数据库的用户名和密码。
import pymysql
# --- 1. 建立数据库连接 ---
# 请将下面的占位符替换为您自己的数据库信息
db_info = {
'host': 'localhost', # 数据库地址,通常是 'localhost'
'user': 'your_username', # 数据库用户名
'password': 'your_password', # 数据库密码
'db': 'testdb', # 要连接的数据库名
'charset': 'utf8mb4', # 字符编码,推荐使用 utf8mb4
'cursorclass': pymysql.cursors.DictCursor # 使用字典游标,查询结果会以字典形式返回,方便访问
}
try:
# **关键步骤:导入后,使用 pymysql.Connection() 来创建连接**
connection = pymysql.connect(**db_info)
print("成功连接到数据库!")
# --- 2. 创建一个游标对象 ---
# 游标用于执行 SQL 语句
with connection.cursor() as cursor:
# --- 3. 执行 SQL 语句 (创建表) ---
# 使用 execute() 方法来执行 SQL
create_table_sql = """
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255) NOT NULL,
email VARCHAR(255) NOT NULL UNIQUE
)
"""
cursor.execute(create_table_sql)
print("表 'users' 创建成功或已存在。")
# --- 4. 执行 SQL 语句 (插入数据) ---
insert_sql = "INSERT INTO users (name, email) VALUES (%s, %s)"
# 注意:这里使用 %s 作为占位符,可以防止 SQL 注入攻击
# 不要直接将变量拼接到 SQL 字符串中,f"INSERT ... VALUES ({name}, {email})"
cursor.execute(insert_sql, ('张三', 'zhangsan@example.com'))
# 插入另一条数据
cursor.execute(insert_sql, ('李四', 'lisi@example.com'))
# 提交事务,只有提交后,数据才会真正写入数据库
connection.commit()
print(f"成功插入 {cursor.rowcount} 条数据。")
# --- 5. 查询数据 ---
# 注意:查询时需要一个新的游标,或者重新获取一个
with connection.cursor() as cursor:
select_sql = "SELECT id, name, email FROM users"
cursor.execute(select_sql)
# 获取所有查询结果
results = cursor.fetchall()
print("\n--- 查询所有用户 ---")
for row in results:
print(f"ID: {row['id']}, 姓名: {row['name']}, 邮箱: {row['email']}")
except pymysql.MySQLError as e:
# 如果发生错误,回滚事务
if 'connection' in locals() and connection.open:
connection.rollback()
print(f"数据库操作出错: {e}")
finally:
# --- 6. 关闭连接 ---
# 无论是否发生错误,最后都要关闭数据库连接,释放资源
if 'connection' in locals() and connection.open:
connection.close()
print("\n数据库连接已关闭。")
- 安装:在终端运行
pip install PyMySQL。 - 导入:在 Python 脚本中写
import pymysql。 - 使用:
- 使用
pymysql.connect()建立连接。 - 使用
connection.cursor()创建游标。 - 使用
cursor.execute(sql, params)执行 SQL 语句。 - 使用
connection.commit()提交事务(对于写操作)。 - 使用
cursor.fetchall()或cursor.fetchone()获取查询结果。 - 最后使用
connection.close()关闭连接。
- 使用
希望这个详细的指南能帮助您成功地在 Python 中使用 PyMySQL!
