|
@@ -0,0 +1,33 @@
|
|
|
+import json
|
|
|
+
|
|
|
+from MyUtils.ConfigUtils import ConfigUtils
|
|
|
+import datetime,pymysql
|
|
|
+import requests
|
|
|
+SELECT_SQL="select * from `%s`.saas_employee"
|
|
|
+
|
|
|
+datetimenow = datetime.datetime.now().strftime("%Y-%m-%d %H:%M")
|
|
|
+config = ConfigUtils("config.xml")
|
|
|
+mysql = config.readTopDict("mysql", ["host", "port", "user", "passwd", "database"])
|
|
|
+mysql["port"] = int(mysql["port"])
|
|
|
+database = mysql["database"]
|
|
|
+url = config.readTop("config",["url"])[0]
|
|
|
+#连接mysql
|
|
|
+conn = pymysql.connect(**mysql)
|
|
|
+mysql_cur = conn.cursor()
|
|
|
+mysql_cur.execute(SELECT_SQL % (database))
|
|
|
+#获取列名
|
|
|
+column_list = []
|
|
|
+column = mysql_cur.description
|
|
|
+for i in column:
|
|
|
+ column_list.append(i[0])
|
|
|
+datas = mysql_cur.fetchall()
|
|
|
+lst = []
|
|
|
+for line in datas:
|
|
|
+ lst.append(dict(zip(column_list,list(line))))
|
|
|
+for i in range(0,len(lst),100):
|
|
|
+ dataranges = lst[i:i + 100]
|
|
|
+ data_json = json.dumps(dataranges)
|
|
|
+ r = requests.post(url=url,headers={'Content-Type': 'application/json;charset=UTF-8'},data=data_json)
|
|
|
+ print(r.text)
|
|
|
+mysql_cur.close()
|
|
|
+conn.close()
|