mysql的双写针对日志

import mysql.connector

# 连接主库
master_conn = mysql.connector.connect(
    host="master_host",
    user="master_user",
    password="master_password",
    database="master_db"
)

# 连接从库
slave_conn = mysql.connector.connect(
    host="slave_host",
    user="slave_user",
    password="slave_password",
    database="slave_db"
)

# 创建游标
master_cursor = master_conn.cursor()
slave_cursor = slave_conn.cursor()

# 插入数据
insert_query = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)"
data = ("value1", "value2")

try:
    # 在主库插入数据
    master_cursor.execute(insert_query, data)
    master_conn.commit()

    # 在从库插入数据
    slave_cursor.execute(insert_query, data)
    slave_conn.commit()
except mysql.connector.Error as err:
    print(f"Error: {err}")
finally:
    # 关闭游标和连接
    master_cursor.close()
    slave_cursor.close()
    master_conn.close()
    slave_conn.close()