Python脚本基于MySQL表结构

北京著名痤疮医院 http://pf.39.net/bdfyy/bdfzj/210311/8736666.html
01

概览

封装参数,索取众人函数

缔造HiveTableInfo消息表

输出建表语句

02

组装数据字典,批改盘诘后果构造

defexecuteSql(self,sql):cursor=self.get_cursor()cursor.execute(sql)#猎取sql语句对应的元数据消息col_list=cursor.descriptiondatalist=cursor.fetchall()result_list=[]fordataindatalist:item_data={}forindexinrange(0,len(col_list)):item=data[index]col_item=col_list[index][0]item_data[col_item]=itemresult_list.append(item_data)returnresult_list03

批改SqlUtils类,索取连结

#sql盘诘classSqlUtils:host=""user_name=""password=""db:pymysql.Connectiondef__init__(self,host,user_name,password):self.password=passwordself.user_name=user_nameself.host=hostself.db=pymysql.connect(host=self.host,user=self.user_name,password=self.password)defget_cursor(self):returnself.db.cursor()defexecuteSql(self,sql):cursor=self.get_cursor()cursor.execute(sql)col_list=cursor.descriptiondatalist=cursor.fetchall()result_list=[]fordataindatalist:item_data={}forindexinrange(0,len(col_list)):item=data[index]col_item=col_list[index][0]item_data[col_item]=itemresult_list.append(item_data)returnresult_listdefclose_db(self):self.db.close()defget_table_fields(self,mysql_db,mysql_table_name):db_


转载请注明:http://www.aierlanlan.com/tzrz/994.html

  • 上一篇文章:
  •   
  • 下一篇文章: 没有了