Python中通过pymysql实现数据库主从同步的方法

在Python中使用pymysql库实现数据库主从同步的方法如下：

1. 安装pymysql库：使用pip install pymysql命令安装pymysql库。

2. 创建主从数据库连接：

import pymysql

# 主数据库连接
master_conn = pymysql.connect(host="主数据库ip", port=3306, user="用户名", password="密码", database="数据库名")

# 从数据库连接
slave_conn = pymysql.connect(host="从数据库ip", port=3306, user="用户名", password="密码", database="数据库名")

3. 配置主从关联：

# 在主数据库上创建一个用于复制的账户
cursor = master_conn.cursor()
cursor.execute("CREATE USER 'replication_user'@'%' IDENTIFIED BY '密码'")
cursor.execute("GRANT REPLICATION SLAVE ON *.* TO 'replication_user'@'%'")
cursor.execute("FLUSH PRIVILEGES")
cursor.close()

# 获取主数据库状态
cursor = master_conn.cursor()
cursor.execute("SHOW MASTER STATUS")
master_status = cursor.fetchone()
cursor.close()

# 配置从数据库以复制主数据库
cursor = slave_conn.cursor()
cursor.execute("CHANGE MASTER TO MASTER_HOST='主数据库ip', MASTER_PORT=3306, MASTER_USER='replication_user', MASTER_PASSWORD='密码', MASTER_LOG_FILE=%s, MASTER_LOG_POS=%s", (master_status[0], master_status[1]))
cursor.execute("START SLAVE")
cursor.close()

4. 同步数据：

# 读取主数据库数据
cursor = master_conn.cursor()
cursor.execute("SELECT * FROM 表名")
data = cursor.fetchall()
cursor.close()

# 将数据插入到从数据库
cursor = slave_conn.cursor()
cursor.executemany("INSERT INTO 表名 VALUES (%s, %s)", data)
slave_conn.commit()
cursor.close()

完整的使用例子：

import pymysql

# 主数据库连接
master_conn = pymysql.connect(host="主数据库ip", port=3306, user="用户名", password="密码", database="数据库名")

# 从数据库连接
slave_conn = pymysql.connect(host="从数据库ip", port=3306, user="用户名", password="密码", database="数据库名")

# 在主数据库上创建一个用于复制的账户
cursor = master_conn.cursor()
cursor.execute("CREATE USER 'replication_user'@'%' IDENTIFIED BY '密码'")
cursor.execute("GRANT REPLICATION SLAVE ON *.* TO 'replication_user'@'%'")
cursor.execute("FLUSH PRIVILEGES")
cursor.close()

# 获取主数据库状态
cursor = master_conn.cursor()
cursor.execute("SHOW MASTER STATUS")
master_status = cursor.fetchone()
cursor.close()

# 配置从数据库以复制主数据库
cursor = slave_conn.cursor()
cursor.execute("CHANGE MASTER TO MASTER_HOST='主数据库ip', MASTER_PORT=3306, MASTER_USER='replication_user', MASTER_PASSWORD='密码', MASTER_LOG_FILE=%s, MASTER_LOG_POS=%s", (master_status[0], master_status[1]))
cursor.execute("START SLAVE")
cursor.close()

# 读取主数据库数据
cursor = master_conn.cursor()
cursor.execute("SELECT * FROM 表名")
data = cursor.fetchall()
cursor.close()

# 将数据插入到从数据库
cursor = slave_conn.cursor()
cursor.executemany("INSERT INTO 表名 VALUES (%s, %s)", data)
slave_conn.commit()
cursor.close()

# 关闭数据库连接
master_conn.close()
slave_conn.close()

这样就实现了通过pymysql库在Python中实现数据库主从同步的功能。首先在主数据库上创建一个用于复制的账户，然后获取主数据库的状态，并将状态信息配置到从数据库上，最后将主数据库中的数据读取出来，并插入到从数据库中。