使用Python 实现数据库表结构同步

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)