pymysql操作mysql

import pandas as pd
from sqlalchemy import create_engine
import pymysql

con_report = create_engine("mysql+pymysql://XX:XX:3306/XX")
con_discuss = create_engine("mysql+pymysql://XX:XX:3306/XX")
con_target = create_engine("mysql+pymysql://"mysql+pymysql://XX:XX:3306/XX")
# 本机测试库
df = pd.read_sql_table('cts_hot_word_event_report', con_target, columns=['GMT_CREATE'])
time_max = max(df['GMT_CREATE'].tolist())
print(type(time_max))
time_max_str = time_max.strftime("%Y-%m-%d %H:%M:%S")
# print(time_max_str)
# print(type(time_max_str))
# query = "select * from yh_szbgd_eventinfo where occur_time > " + "'" + str(time_max_str) + "'"
# df = pd.read_sql_query(query, con_report)
# print(df)

# sql = "select currentTime from petition_list_checkpoint where type_name = 'hot_word' and origin_name = 'event'"
sql = "select currentTime from petition_list_checkpoint"
df = pd.read_sql_query(sql, con_target)
time = df['currentTime'].tolist()
print(df)
print(time)

con_target =pymysql.connect(host='XX',
                                       port=3306,
                                       user='XX',
                                       password='XX',
                                       db='XX',
                                       charset="utf8")
sql = "UPDATE petition_list_checkpoint SET currentTime = %s WHERE type_name = 'hot_word' AND origin_name = 'room' " % ("'" + str(time_max_str) + "'")
cur = con_target.cursor()
cur.execute(sql)
con_target.commit()

cur.close()
con_target.close()
print("插入成功")