config= {
    'host': '68.79.49.65',
    'port': 30010,
    'user': 'root',
    'passwd': '****',
    'charset':'utf8mb4',
    'database' : '****',
    'cursorclass': pymysql.cursors.DictCursor,
}

###############查询数据###############
conn = pymysql.connect(**config) #**不可不写
# 使用cursor()方法获取操作游标
cursor = conn.cursor()
##执行SQL语句
cursor.execute(sql)
##获取所有记录列表
results = cursor.fetchall()
# results= cursor.fetchmany(10) #读取10条数据
df_re = pd.DataFrame(results)
# 关闭数据库连接
conn.close()

###############修改指定列的数据###############

sql格式： update 表名 set 列名=想改成的值 where 列名=被改的值

sql1 = "update %s set sensor_type=6 where (sensor_type=5) and (station_code=%s) and (create_time < '2022-07-01 00:00:00');"%(save_db_1,station_code)
conn = pymysql.connect(**config) 
cursor = conn.cursor()
cursor.execute(sql1)
conn.commit() # 对存储的数据修改后，需要commit
conn.close()

###############删除指定数据###############

sql格式： delete from 表名 where 删除的数据条件

sql1 = """delete from %s where (station_code=%s) and (create_time < '2022-07-01 00:00:00')"""%(save_db_1,station_code)

conn = pymysql.connect(**config)

cursor = conn.cursor()

cursor.execute(sql1)

conn.commit() # 对存储的数据修改后，需要commit

conn.close()