当前位置: 移动技术网 > IT编程>脚本编程>Python > Python 如何实现数据库表结构同步

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

2020年09月30日  | 移动技术网IT编程  | 我要评论
近日,某个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 数据库表结构同步的资料请关注移动技术网其它相关文章!

如您对本文有疑问或者有任何想说的,请点击进行留言回复,万千网友为您解惑!

相关文章:

验证码:
移动技术网