mysql数据库拆分实例

import mysql.connector

def write_to_master(data):
    master_conn = mysql.connector.connect(user='master_user', password='master_password', host='master_host', database='master_db')
    cursor = master_conn.cursor()
    query = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)"
    cursor.execute(query, data)
    master_conn.commit()
    cursor.close()
    master_conn.close()

def sync_to_slaves(data):
    slave_conns = [
        mysql.connector.connect(user='slave_user1', password='slave_password1', host='slave_host1', database='slave_db'),
        mysql.connector.connect(user='slave_user2', password='slave_password2', host='slave_host2', database='slave_db')
    ]
    for conn in slave_conns:
        cursor = conn.cursor()
        query = "INSERT INTO table_name (column1, column2) VALUES (%s, %2)"
        cursor.execute(query, data)
        conn.commit()
        cursor.close()
        conn.close()

def main():
    data = ('value1', 'value2')
    write_to_master(data)
    sync_to_slaves(data)

if __name__ == "__main__":
    main()