源码导入数据库

import json

# 假设源码中的数据是JSON格式
source_data = '{"name": "Alice", "age": 30}'

# 将JSON数据转换为Python字典
data_dict = json.loads(source_data)

# 将数据插入到数据库中
cursor.execute("INSERT INTO users (name, age) VALUES (%s, %s)", (data_dict['name'], data_dict['age']))

try:
    # 开始事务
    cursor.execute("BEGIN")

    # 执行数据导入操作
    cursor.execute("INSERT INTO users (name, age) VALUES (%s, %s)", (data_dict['name'], data_dict['age']))

    # 提交事务
    cursor.execute("COMMIT")
except Exception as e:
    # 回滚事务
    cursor.execute("ROLLBACK")
    print(f"数据导入失败: {e}")

# 检查数据库中是否已经存在相同的数据
cursor.execute("SELECT * FROM users WHERE name = %s", (data_dict['name'],))
existing_data = cursor.fetchone()

if not existing_data:
    # 如果不存在，则插入数据
    cursor.execute("INSERT INTO users (name, age) VALUES (%s, %s)", (data_dict['name'], data_dict['age']))
else:
    print("数据已存在，不进行插入操作")