Python中pymysql模块详解:安装、连接、执行SQL语句等常见操作
import pymysql
# 连接数据库
connection = pymysql.connect(host='localhost',
user='user',
password='passwd',
database='db',
charset='utf8mb4',
cursorclass=pymysql.cursors.DictCursor)
try:
with connection.cursor() as cursor:
# 创建一个新表
sql = """
CREATE TABLE `users` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,
`password` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
"""
cursor.execute(sql)
# 插入一条记录
sql = "INSERT INTO `users` (`email`, `password`) VALUES (%s, %s)"
cursor.execute(sql, ('webmaster@example.com', 'very-secret'))
# 查询记录
cursor.execute("SELECT * FROM `users`")
results = cursor.fetchall()
for row in results:
print(row)
# 提交事务
connection.commit()
except pymysql.MySQLError as e:
# 处理异常
print(f"Error: {e}")
finally:
# 关闭连接
connection.close()
这段代码展示了如何使用pymysql模块连接MySQL数据库,创建一个新表,插入一条记录,查询记录,以及如何处理可能发生的异常和在最后关闭数据库连接。这是一个典型的数据库交互流程,对于学习如何在Python中操作MySQL数据库有很好的教育价值。
评论已关闭