Python 如何实现数据库表结构同步
程序员文章站
2022-03-11 10:13:52
近日,某个qq 群里的一个朋友提出一个问题,如何将一个db 的表结构同步给另一个db。针对这个问题,我进行了思考与实践,具体的实现代码如下所示:# coding:utf-8import pymysql...
近日,某个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)
示例代码操作简单,通俗易懂,所以没有过多的注释,如有疑问的小伙伴们,可在文章下方评论。
以上就是python 如何实现数据库表结构同步的详细内容,更多关于python 数据库表结构同步的资料请关注其它相关文章!