导航：首页 > 互联网科技 >

怎么用Python将一个DB的表结构同步给另一个DB

发表于：2024-11-28 作者：千家信息网编辑

千家信息网最后更新 2024年11月28日，这篇文章主要介绍"怎么用Python将一个DB的表结构同步给另一个DB"，在日常操作中，相信很多人在怎么用Python将一个DB的表结构同步给另一个DB问题上存在疑惑，小编查阅了各式资料，整理出简单好

千家信息网最后更新 2024年11月28日怎么用Python将一个DB的表结构同步给另一个DB

这篇文章主要介绍"怎么用Python将一个DB的表结构同步给另一个DB"，在日常操作中，相信很多人在怎么用Python将一个DB的表结构同步给另一个DB问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"怎么用Python将一个DB的表结构同步给另一个DB"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

具体的实现代码如下所示：

# coding:utf-8import 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)