import pymysql
try:
# 连接数据库
connection = pymysql.connect(
host='localhost',
user='your_username',
password='your_password',
database='your_database',
charset='utf8mb4'
)
with connection.cursor() as cursor:
# 插入数据的SQL语句
sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
data = [
('Alice', 25),
('Bob', 30)
]
try:
# 开始事务
connection.start_transaction()
for item in data:
cursor.execute(sql, item)
# 提交事务
connection.commit()
except Exception as e:
# 回滚事务
connection.rollback()
print(f"插入数据失败,原因: {e}")
finally:
# 关闭连接
connection.close()