我要评论在python开发中，操作mysql数据库最常用的第三方库之一就是pymysql，它能实现与mysql数据库的高效交互，满足建表、数据增删改查等常规需求。
一、前置准备
- 已安装并启动mysql数据库（建议5.7及以上版本），且知晓mysql的连接信息（主机地址、用户名、密码、需操作的数据库名），提前手动创建好目标数据库（例如
test_db，可通过mysql客户端执行create database if not exists test_db default character set utf8mb4 collate utf8mb4_unicode_ci;创建）。 - 已安装python环境（建议3.7及以上版本），确保
pip包管理器可用。 - 安装pymysql库：打开终端（windows用cmd，mac/linux用终端），执行以下命令安装，网络不佳可使用国内镜像源加速。
# 常规安装 pip install pymysql # 国内清华镜像源加速安装（解决下载慢、超时） pip install pymysql -i https://pypi.tuna.tsinghua.edu.cn/simple
二、核心步骤1：连接mysql数据库
首先需要通过pymysql建立与mysql数据库的连接，获取连接对象和游标对象（用于执行sql语句）。注意填写自己的mysql实际连接信息，代码示例如下：
import pymysql
# 1. 建立数据库连接
try:
conn = pymysql.connect(
host='localhost', # 数据库主机地址，本地默认localhost
user='root', # mysql用户名（默认常为root）
password='your_mysql_password', # 你的mysql密码（替换为实际密码）
database='test_db', # 提前创建的目标数据库名
charset='utf8mb4' # 字符集，支持中文及特殊字符，避免乱码
)
print("数据库连接成功！")
# 2. 获取游标对象（用于执行sql语句）
cursor = conn.cursor()
except pymysql.error as e:
print(f"数据库连接失败：{e}")
三、核心步骤2：创建数据表
连接成功后，通过游标对象执行create table语句创建数据表，本文以创建user_info（用户信息表）为例，包含自增主键、用户名、年龄、创建时间等字段。注意添加if not exists避免表已存在时报错，代码示例如下：
# 定义建表sql语句
create_table_sql = """
create table if not exists user_info (
id int primary key auto_increment comment '用户自增id',
username varchar(50) not null unique comment '用户名，唯一不可重复',
age tinyint unsigned not null default 0 comment '用户年龄，非负',
create_time datetime not null default current_timestamp comment '记录创建时间'
) engine=innodb default charset=utf8mb4 comment '用户信息表';
"""
try:
# 执行建表sql
cursor.execute(create_table_sql)
# 提交事务（建表、插入、更新等修改操作需提交事务才生效）
conn.commit()
print("数据表创建成功（或已存在）！")
except pymysql.error as e:
# 若出错则回滚事务
conn.rollback()
print(f"数据表创建失败：{e}")
四、核心步骤3：插入数据
插入数据支持单条数据插入和多条数据批量插入，推荐使用参数化查询（%s作为占位符），避免直接拼接sql字符串导致的sql注入风险，同时提升代码安全性和可维护性。
1. 单条数据插入
# 定义单条插入sql（%s为参数占位符，无需加引号）
insert_single_sql = "insert into user_info (username, age) values (%s, %s);"
# 待插入的数据（与sql占位符顺序对应）
single_data = ("zhangsan", 25)
try:
# 执行单条插入sql
cursor.execute(insert_single_sql, single_data)
# 提交事务
conn.commit()
print(f"单条数据插入成功，插入数据id：{cursor.lastrowid}")
except pymysql.error as e:
conn.rollback()
print(f"单条数据插入失败：{e}")
2. 多条数据批量插入
批量插入使用executemany()方法，效率远高于循环执行单条插入，适合一次性插入大量数据：
# 定义批量插入sql
insert_batch_sql = "insert into user_info (username, age) values (%s, %s);"
# 待插入的多条数据（列表嵌套元组，每个元组对应一条数据）
batch_data = [
("lisi", 28),
("wangwu", 30),
("zhaoliu", 22)
]
try:
# 执行批量插入sql
cursor.executemany(insert_batch_sql, batch_data)
# 提交事务
conn.commit()
print(f"批量数据插入成功，共插入{cursor.rowcount}条数据")
except pymysql.error as e:
conn.rollback()
print(f"批量数据插入失败：{e}")
五、核心步骤4：查询数据
查询数据属于只读操作，无需提交事务，执行查询sql后，可通过fetchone()（获取单条结果）、fetchmany(n)（获取n条结果）、fetchall()（获取所有结果）获取查询数据，代码示例如下：
1. 查询所有数据
# 定义查询所有数据的sql
query_all_sql = "select id, username, age, create_time from user_info;"
try:
# 执行查询sql
cursor.execute(query_all_sql)
# 获取所有查询结果（返回列表嵌套元组，每个元组对应一条记录）
all_results = cursor.fetchall()
print("\n所有用户数据如下：")
print("id\t用户名\t年龄\t创建时间")
for row in all_results:
id, username, age, create_time = row
print(f"{id}\t{username}\t{age}\t{create_time}")
except pymysql.error as e:
print(f"查询数据失败：{e}")
2. 条件查询（示例：查询年龄大于25的用户）
# 定义条件查询sql（参数化查询，避免sql注入）
query_cond_sql = "select id, username, age from user_info where age > %s;"
# 查询条件参数
cond_data = (25,)
try:
cursor.execute(query_cond_sql, cond_data)
# 获取所有符合条件的结果
cond_results = cursor.fetchall()
print("\n年龄大于25的用户如下：")
print("id\t用户名\t年龄")
for row in cond_results:
id, username, age = row
print(f"{id}\t{username}\t{age}")
except pymysql.error as e:
print(f"条件查询失败：{e}")
六、收尾工作：关闭连接
操作完成后，需依次关闭游标对象和数据库连接，释放资源：
# 关闭游标
if cursor:
cursor.close()
# 关闭数据库连接
if conn:
conn.close()
print("\n数据库连接已关闭")
七、常见问题注意事项
- 中文乱码：确保数据库、数据表、pymysql连接的字符集均为
utf8mb4（utf8不支持部分特殊中文）。 - 操作失效：建表、插入、更新等修改操作必须执行
conn.commit()提交事务，否则修改不生效；出错时建议执行conn.rollback()回滚事务。 - sql注入：所有带参数的操作均使用
%s占位符进行参数化查询，切勿直接拼接sql字符串。 - 连接失败：检查mysql是否已启动、主机地址、用户名、密码、数据库名是否正确，以及防火墙是否拦截mysql端口（默认3306）。
到此这篇关于python使用pymysql操作mysql数据库建表、插入/查询数据的文章就介绍到这了,更多相关pymysql建表、插入/查询数据内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论