Python 实现数据库表结构同步的完整方案

江屿

发布时间：2026-10-12 | 2人浏览过

原创

本文详细介绍如何利用 Python 和 Pymysql 库实现两个数据库之间的表结构同步。通过连接源数据库查询所有表名，并动态生成对应的创建表 SQL 语句，最终在目标数据库中执行这些语句以完成数据表的快速复制与结构同步，适用于需要批量维护多数据库结构的场景。

近期，有用户在技术交流群中咨询了一个常见问题：如何高效地将一个数据库中的表结构同步到另一个数据库中。经过深入分析与实际测试，我整理出了一套可行的实现方案，具体代码逻辑如下所示：

# coding:utf-8
import pymysql

dbDict = {"test1":"l-beta.test1"}
dbUser = "test"
dbPassword = "123456"

class DBUtils():
  def __init__(self):
    self.conn = pymysql.connect(dbDict['test1'], dbUser, dbPassword)
    self.cursor = self.conn.cursor()

  def dbSelect(self, sql):
    print("------------------------------------")
    print(sql)
    resultList = []
    self.cursor.execute(sql)
    result = self.cursor.fetchall()
    columns = self.cursor.description
    for val in result:
      tempDict = {}
      for cloNum in range(len(columns)):
        tempDict[str(columns[cloNum][0])] = val[cloNum]
      resultList.append(tempDict)
    print("---------------------打印查询结果----------------------")
    print(resultList)
    self.dbClose()
    return resultList

  def dbExcute(self, sql):
    print(sql)
    self.cursor.execute(sql)
    self.dbClose()

  def dbClose(self):
    self.conn.commit()
    self.cursor.close()
    self.conn.close()


if __name__ == "__main__":
  test = DBUtils()
  result = test.dbSelect("select table_name from information_schema.tables where table_schema='testdb1'")
  for dict1 in result:
    test = DBUtils()
    create_table_sql = "create table testdb.%s as select * from testdb1.%s" % (dict1['table_name'],dict1['table_name'])
    print(create_table_sql)
    test.dbExcute(create_table_sql)

该示例代码设计简洁且易于理解，因此未添加大量冗余注释。如果您在运行过程中遇到任何疑问或需要进一步的技术支持，欢迎在文章末尾的评论区留言交流。

以上即为使用 Python 实现数据库表结构同步的完整教程。如需获取更多关于 Python 数据库操作及结构同步的高级技巧，请持续关注本站发布的其他相关文章。