mysql 主从复制中间件

import mysql.connector

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

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

# 在主库上执行写操作
master_cursor = master_conn.cursor()
master_cursor.execute("INSERT INTO test_table (column1, column2) VALUES (%s, %s)", ("value1", "value2"))
master_conn.commit()

# 在从库上执行读操作
slave_cursor = slave_conn.cursor()
slave_cursor.execute("SELECT * FROM test_table")
result = slave_cursor.fetchall()
print(result)

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