mysql高可用读写分离

import pymysql

class MySQLReadWriteSplit:
    def __init__(self, master_config, slave_configs):
        self.master_conn = pymysql.connect(**master_config)
        self.slave_conns = [pymysql.connect(**config) for config in slave_configs]

    def execute_write(self, sql):
        with self.master_conn.cursor() as cursor:
            cursor.execute(sql)
        self.master_conn.commit()

    def execute_read(self, sql):
        slave_conn = self.slave_conns[hash(sql) % len(self.slave_conns)]
        with slave_conn.cursor() as cursor:
            cursor.execute(sql)
            return cursor.fetchall()

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

slave_configs = [
    {
        'host': 'slave1_host',
        'user': 'user',
        'password': 'password',
        'database': 'database'
    },
    {
        'host': 'slave2_host',
        'user': 'user',
        'password': 'password',
        'database': 'database'
    }
]

# 创建读写分离实例
rw_split = MySQLReadWriteSplit(master_config, slave_configs)

# 执行写操作
rw_split.execute_write("INSERT INTO table (column) VALUES ('value')")

# 执行读操作
result = rw_split.execute_read("SELECT * FROM table")
print(result)