import pymysql
# 创建数据库连接
def create_connection():
connection = pymysql.connect(
host='localhost', # 数据库主机地址
user='your_username', # 数据库用户名
password='your_password', # 数据库密码
database='your_database', # 数据库名称
charset='utf8mb4', # 字符编码
cursorclass=pymysql.cursors.DictCursor # 使用字典游标
)
return connection
# 插入数据示例
def insert_data():
connection = create_connection()
try:
with connection.cursor() as cursor:
# SQL 插入语句
sql = "INSERT INTO `users` (`email`, `password`) VALUES (%s, %s)"
cursor.execute(sql, ('webmaster@python.org', 'very-secret'))
# 提交事务
connection.commit()
finally:
connection.close()
# 查询数据示例
def query_data():
connection = create_connection()
try:
with connection.cursor() as cursor:
# SQL 查询语句
sql = "SELECT `id`, `email`, `password` FROM `users` WHERE `email`=%s"
cursor.execute(sql, ('webmaster@python.org',))
result = cursor.fetchone()
print(result)
finally:
connection.close()
# 更新数据示例
def update_data():
connection = create_connection()
try:
with connection.cursor() as cursor:
# SQL 更新语句
sql = "UPDATE `users` SET `password`=%s WHERE `email`=%s"
cursor.execute(sql, ('new-password', 'webmaster@python.org'))
# 提交事务
connection.commit()
finally:
connection.close()
# 删除数据示例
def delete_data():
connection = create_connection()
try:
with connection.cursor() as cursor:
# SQL 删除语句
sql = "DELETE FROM `users` WHERE `email`=%s"
cursor.execute(sql, ('webmaster@python.org',))
# 提交事务
connection.commit()
finally:
connection.close()
# 调用函数示例
if __name__ == "__main__":
insert_data()
query_data()
update_data()
delete_data()
create_connection
函数用于创建与 MySQL 数据库的连接。你需要根据实际情况修改 host
、user
、password
和 database
参数。insert_data
函数演示了如何向 users
表中插入一条记录。query_data
函数展示了如何从 users
表中查询一条记录,并将结果打印出来。update_data
函数展示了如何更新 users
表中的记录。delete_data
函数展示了如何从 users
表中删除一条记录。每个操作都包含在 try...finally
块中,以确保无论是否发生异常,数据库连接都会被关闭。
上一篇:docker 安装 mysql
下一篇:mysql时间格式转换
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站