mysql echo数据同步

import mysql.connector
from mysql.connector import Error

def sync_data(source_conn, target_conn):
    try:
        # 连接源数据库
        source_cursor = source_conn.cursor()
        source_cursor.execute("SELECT * FROM your_table")
        data = source_cursor.fetchall()

        # 连接目标数据库
        target_cursor = target_conn.cursor()
        for row in data:
            target_cursor.execute("INSERT INTO your_table VALUES (%s, %s, %s)", row)
        target_conn.commit()

    except Error as e:
        print(f"Error: {e}")
    finally:
        source_cursor.close()
        target_cursor.close()

# 连接源数据库
source_conn = mysql.connector.connect(
    host="source_host",
    user="source_user",
    password="source_password",
    database="source_database"
)

# 连接目标数据库
target_conn = mysql.connector.connect(
    host="target_host",
    user="target_user",
    password="target_password",
    database="target_database"
)

# 同步数据
sync_data(source_conn, target_conn)

# 关闭连接
source_conn.close()
target_conn.close()