import pymysql import json import pandas as pd import numpy as np con = pymysql.connect(host='', user='', passwd='', charset='utf8') cursor = con.cursor() sql = ''' select from ''' #pf1=pd.read_sql(con=conn,sql=sql) cursor.execute(sql) results = cursor.fetchmany(2) data1=[] list1=[] for i in range(len(results)): list2=''.join(results[i]) data = json.loads(list2) data1.append(data) print(data1) len1=len(data1[0]) c=[] for p in range(len(data1)): a=data1[0] b=[] for i in range(len(a)): for j in a[i].keys(): b.append(a[i][j]) c.append(b) print(c) empty=pd.DataFrame(c) empty1=pd.DataFrame(empty,dtype=np.int) #empty1.rename(columns{'0':'type1','1':'type1_hit_cnt','2':'type1 seconds','3':'type1_cnt','4':'type2','5':'type2_hit_cnt','6':'type2 seconds','7':'type2_cnt','8':'type3','9':'type3_hit_cnt','10':'type3 seconds','11':'type3_cnt'},inplace=True) empty1.set_axis(['type1','type1_hit_cnt','type1 seconds','type1_cnt','type2','type2_hit_cnt','type2 seconds','type2_cnt','type3','type3_hit_cnt','type3 seconds','type3_cnt'],axis='columns', inplace=True) empty1.drop(['type1','type2','type3'],axis=1,inplace=True) print(empty1)
从sql 到dataframe
猜你喜欢
转载自blog.csdn.net/qq_41951515/article/details/81135530
今日推荐
周排行