数据库扩展双11优惠活动

import mysql.connector
from mysql.connector import pooling

# 创建主库连接池
master_config = {
    "host": "master-db-host",
    "user": "admin",
    "password": "secret",
    "database": "mydb"
}
master_pool = pooling.MySQLConnectionPool(pool_name="master_pool", pool_size=5, **master_config)

# 创建从库连接池
slave_config = {
    "host": "slave-db-host",
    "user": "admin",
    "password": "secret",
    "database": "mydb"
}
slave_pool = pooling.MySQLConnectionPool(pool_name="slave_pool", pool_size=5, **slave_config)

def execute_query(query, params=None, is_read_only=False):
    if is_read_only:
        connection = slave_pool.get_connection()
    else:
        connection = master_pool.get_connection()
    
    cursor = connection.cursor()
    cursor.execute(query, params)
    result = cursor.fetchall()
    cursor.close()
    connection.close()
    return result

# 使用示例
users = execute_query("SELECT * FROM users", is_read_only=True)