mysql如何做读写分离

-- 创建数据库
CREATE DATABASE mydb;

-- 授权用户
GRANT REPLICATION SLAVE ON *.* TO 'replication_user'@'slave_ip' IDENTIFIED BY 'password';
FLUSH PRIVILEGES;

-- 启动二进制日志
log-bin=mysql-bin;
server-id=1;

-- 启动二进制日志
log-bin=mysql-bin;
server-id=2;

-- 配置主服务器信息
CHANGE MASTER TO
MASTER_HOST='master_ip',
MASTER_USER='replication_user',
MASTER_PASSWORD='password',
MASTER_LOG_FILE='mysql-bin.000001',
MASTER_LOG_POS=107;
START SLAVE;

import pymysql

# 连接主服务器
master_conn = pymysql.connect(host='master_ip', user='user', password='password', database='mydb')

# 连接从服务器
slave_conn = pymysql.connect(host='slave_ip', user='user', password='password', database='mydb')

def execute_write_query(query):
    with master_conn.cursor() as cursor:
        cursor.execute(query)
    master_conn.commit()

def execute_read_query(query):
    with slave_conn.cursor() as cursor:
        cursor.execute(query)
        result = cursor.fetchall()
    return result

# 示例写操作
execute_write_query("INSERT INTO users (name, email) VALUES ('Alice', 'alice@example.com')")

# 示例读操作
result = execute_read_query("SELECT * FROM users")
print(result)