Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def process(form, path):
- po = pandas.read_json(path)
- #
- sql = "INSERT INTO jd_form_data (" \
- "`create_time`, " \
- "`update_time`, " \
- "`deliver_id`, " \
- "`form`, " \
- "`data_id`, " \
- "`form_data` " \
- ") VALUES "
- for row in po.iterrows():
- data_id = row[1]["_id"]
- form_data = row[1].to_json()
- form_data = json.loads(form_data)
- form_data = {"data": form_data}
- form_data = json.dumps(form_data)
- sql += " (now(),now(),'{}','{}','{}','{}'),".format(form + data_id, form, data_id, form_data)
- #
- sql = sql[0:len(sql) - 1]
- sql += " on duplicate key update " \
- "form_data=values(form_data)"
- cur.execute(sql)
- con.commit()
Add Comment
Please, Sign In to add comment