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()
        for row in result:
            print(row)
except pymysql.Error as e:
    print(f"执行 SQL 查询失败：{e}")

try:
    with conn.cursor() as cursor:
        # 开启事务
        conn.begin()
        
        # 执行 SQL 操作
        sql1 = "UPDATE your_table SET column1 = value1 WHERE condition1"
        cursor.execute(sql1)
        
        sql2 = "INSERT INTO your_table (column1, column2) VALUES (value1, value2)"
        cursor.execute(sql2)
        
        # 提交事务
        conn.commit()
except pymysql.Error as e:
    # 回滚事务
    conn.rollback()
    print(f"事务处理失败：{e}")