实现mysql读写分离的方法

master:
  host: 192.168.1.1
  port: 3306
  username: root
  password: root

slave:
  host: 192.168.1.2
  port: 3306
  username: root
  password: root

import mysql.connector

class DBProxy:
    def __init__(self, master_config, slave_config):
        self.master_conn = mysql.connector.connect(**master_config)
        self.slave_conn = mysql.connector.connect(**slave_config)

    def execute(self, query, params=None, read_only=False):
        conn = self.slave_conn if read_only else self.master_conn
        cursor = conn.cursor()
        cursor.execute(query, params)
        result = cursor.fetchall()
        cursor.close()
        return result

    def close(self):
        self.master_conn.close()
        self.slave_conn.close()

# 配置数据库连接
master_config = {
    'host': '192.168.1.1',
    'port': 3306,
    'username': 'root',
    'password': 'root'
}

slave_config = {
    'host': '192.168.1.2',
    'port': 3306,
    'username': 'root',
    'password': 'root'
}

# 创建代理实例
db_proxy = DBProxy(master_config, slave_config)

# 执行读操作
result = db_proxy.execute("SELECT * FROM users WHERE id = %s", (1,), read_only=True)
print(result)

# 执行写操作
db_proxy.execute("UPDATE users SET name = %s WHERE id = %s", ('Alice', 1))

# 关闭连接
db_proxy.close()