pymysql数据库

import pymysql

try:
    conn = pymysql.connect(
        host='localhost',
        port=3306,
        user='your_username',
        password='your_password',
        db='your_database'
    )
except pymysql.Error as e:
    print(f"连接数据库失败: {e}")

try:
    with conn.cursor() as cursor:
        sql = "SELECT * FROM your_table"
        cursor.execute(sql)
        result = cursor.fetchall()
        print(result)
except pymysql.Error as e:
    print(f"执行 SQL 语句失败: {e}")

try:
    with conn.cursor() as cursor:
        # 开启事务
        conn.begin()
        sql1 = "UPDATE your_table SET column1 = 'value1' WHERE id = 1"
        sql2 = "UPDATE your_table SET column2 = 'value2' WHERE id = 2"
        cursor.execute(sql1)
        cursor.execute(sql2)
        # 提交事务
        conn.commit()
except pymysql.Error as e:
    # 回滚事务
    conn.rollback()
    print(f"事务处理失败: {e}")