概览
封装参数，索取众人函数
缔造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_