Commit c0083b92 authored by 张彦钊's avatar 张彦钊

change test

parent abbf1a3f
......@@ -32,6 +32,18 @@ def get_user():
def get_device():
sql = "select device_id,platform,version,model,screen,channel,idfv from statistic_device"
df = pd.DataFrame(list(get_mysql_data(host, port, user, passwd, db, sql)))
df = df.rename(columns={0: "device_id", 1: "platform", 2: "version", 3: "model", 4: "screen",
5: "channel",6:"idfv"})
print(df.shape)
l = 0
r = 10000
length = len(df)
while l < length:
pd.io.sql.to_sql(df[l:r], "device", yconnect, schema='jerry_test', if_exists='append', index=False)
l += 10000
r += 10000
print("insert done")
if __name__ == "__main__":
......@@ -41,7 +53,7 @@ if __name__ == "__main__":
passwd = "BJQaT9VzDcuPBqkd"
db = "zhengxing"
yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@172.16.40.170:4000/jerry_test?charset=utf8')
get_user()
get_device()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment