diff --git a/CopyTo.py b/CopyTo.py new file mode 100644 index 0000000..1bcece4 --- /dev/null +++ b/CopyTo.py @@ -0,0 +1,39 @@ +# coding=utf-8 + +import pymysql +from SendEmail import Email + +def start(page): + try: + db = pymysql.connect('localhost', 'root', 'eagle', 'db_east_money', charset='utf8') + cs = db.cursor() + + sql1 = 'select code,name,shijian,type,zhangfu,level_zhuli,level_zhuli_per,level_chaoda,level_chaoda_per,level_da,level_da_per,level_zhong,level_zhong_per,level_xiao,level_xiao_per from t_zijinliu_gegu_1 order by id limit '+str(page)+', 1000;' + + cs.execute(sql1) + list = cs.fetchall() + + for i in list: + sj = i[2][:-3] + sql = "REPLACE INTO `t_zijinliu_gegu` " \ + "(`code`, `name`, `shijian`, `type`, `zhangfu`, `level_zhuli`, `level_zhuli_per`, `level_chaoda`, " \ + "`level_chaoda_per`, `level_da`, `level_da_per`, `level_zhong`, `level_zhong_per`, `level_xiao`, " \ + "`level_xiao_per`) VALUES " \ + "('%s', '%s', '%s', %s, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s');" % \ + (i[0], i[1], sj, i[3], i[4], i[5], i[6], i[7], + i[8], + i[9], i[10], i[11], i[12], i[13], i[14]) + + cs.execute(sql) + db.commit() + + cs.close() + db.close() + + except Exception as e: + Email.sendErr() + + +for i in range(0, 1): + print(i) + start(1000*i)