python 实现对MySQL 主从复制与读写分离 --2023博客之星候选--城市赛道

在Python中，可以使用pymysql库来实现对MySQL主从复制和读写分离的代码封装。以下是一个简单的示例：

import pymysql

class MySQLReplication:
    def __init__(self, master_config, slave_config):
        self.master_conn = pymysql.connect(**master_config)
        self.slave_conn = pymysql.connect(**slave_config)

    def execute_query(self, query, is_write=False):
        if is_write:
            connection = self.master_conn
        else:
            connection = self.slave_conn

        with connection.cursor() as cursor:
            cursor.execute(query)
            result = cursor.fetchall()

        return result
    
    def close_connections(self):
        self.master_conn.close()
        self.slave_conn.close()


# 示例用法
master_config = {
    'host': 'localhost',
    'user': 'master_user',
    'password': 'master_password',
    'database': 'mydatabase'
}

slave_config = {
    'host': 'localhost',
    'user': 'slave_user',
    'password': 'slave_password',
    'database': 'mydatabase'
}

replication = MySQLReplication(master_config, slave_config)

# 从主数据库中插入数据
query = "INSERT INTO customers (name, address) VALUES ('John', 'Highway 21')"
replication.execute_query(query, is_write=True)

# 从从数据库中查询数据
query = "SELECT * FROM customers"
result = replication.execute_query(query)
for row in result:
    print(row)

replication.close_connections()

在上述示例中，创建了一个名为MySQLReplication的类，该类用于封装主从数据库连接和执行查询的功能。在类的初始化方法中，传入主数据库和从数据库的配置信息，并创建连接。然后，使用execute_query方法执行查询，可以选择是否使用主数据库连接（即写入操作）或从数据库连接（即读取操作）。最后，使用close_connections方法关闭所有数据库连接。

根据实际情况，你需要将master_config和slave_config中的主机名、用户名、密码和数据库名替换为你的实际配置。然后，可以根据需要调用execute_query方法执行查询或写入操作，并使用结果进行后续处理。最后，不要忘记在使用完毕后调用close_connections方法关闭数据库连接。

请注意，这只是一个简单的示例，实际的主从复制和读写分离方案可能需要更复杂的配置和逻辑。你也可以参考MySQL 主从复制与读写分离我觉得他写的不错，但也只是推荐，推荐原因写的很详细。