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 中文站