mysql跨国数据库

import pymysql
import time

# 配置主数据库和从数据库连接信息
master_config = {
    'host': 'master_host',
    'user': 'master_user',
    'password': 'master_password',
    'database': 'master_db'
}

slave_config = {
    'host': 'slave_host',
    'user': 'slave_user',
    'password': 'slave_password',
    'database': 'slave_db'
}

def sync_data():
    # 连接主数据库
    master_conn = pymysql.connect(**master_config)
    master_cursor = master_conn.cursor()

    # 连接从数据库
    slave_conn = pymysql.connect(**slave_config)
    slave_cursor = slave_conn.cursor()

    # 查询主数据库中的数据
    master_cursor.execute("SELECT * FROM table_name")
    data = master_cursor.fetchall()

    # 插入数据到从数据库
    for row in data:
        slave_cursor.execute("INSERT INTO table_name VALUES (%s, %s, %s)", row)

    # 提交事务
    slave_conn.commit()

    # 关闭连接
    master_cursor.close()
    master_conn.close()
    slave_cursor.close()
    slave_conn.close()

if __name__ == "__main__":
    while True:
        sync_data()
        time.sleep(60)  # 每分钟同步一次