Python 如何实现数据库表结构同步_Python

Python 如何实现数据库表结构同步

2020-09-30 00:09Wu_Candy Python

这篇文章主要介绍了Python 如何实现数据库表结构同步，帮助大家更好的利用python操作数据库，感兴趣的朋友可以了解下

近日，某个QQ 群里的一个朋友提出一个问题，如何将一个DB 的表结构同步给另一个DB。
针对这个问题，我进行了思考与实践，具体的实现代码如下所示：

									# 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)