pandas在读写mysql数据时，如果是固定的mysql语句是比较容易存取的，不过现网很多需求，需要传入不同的变量的SQL写入或查询。遇到这种情况该如何解决呢？可以使用format函数来实现转化。例如给一个含有时间序列的数据集，给定三个参数，数据集名称tablename，开始时间startDate，结束时间endDate，删除某数据集起始时间的数据，核心代码如下：

1# code from www.361way.com
2tablename='sdata'
3startdate='2019-04-01'
4endDate='2019-04-18'
5sql = "delete from {} where str_to_date(ts,'%Y-%m-%d') between '{}' and '{}' "
6sqlformat = sql.format(tablename, startdate, endDate)
7print(sqlformat)

上面打印的结果是重终会把fromat的大括号内容替换为变量内容。

通过上面的内容，我们实现一个复杂一点的需求，就是有两个表：table1、table2。需要将表1中的某个时间段的数据采集后写入表2，但表2中也有该时间段的数据（没有表1中的全），需要先删除表2中该时段的数据后，才执行写入。具体代码如下：

 1import  pymysql
 2import pandas as pd
 3from sqlalchemy import create_engine
 4#将数据库中的表读成数据框df（给定表名和起止时间）
 5def read_mysql(tablename,startdate,endDate):
 6    db = pymysql.connect("localhost", "root", "123456", "test")
 7    sqlcmd='select * from %s' % tablename+' where date_format(ts,"%Y-%m-%d") between'+"'"+startdate+"'"+' and '+"'"+endDate+"'"
 8    df=pd.read_sql(sqlcmd,db,index_col='index')
 9    return  df
10#将给定时间段的df写到数据库中的给定表
11def write_df_to_table(df,tablename,startdate,endDate):
12    db = pymysql.connect("localhost", "root", "123456", "test")#数据库配置信息
13    cursor = db.cursor()
14#先删除给定时间段的数据，防止重复，{}为变量占位符，下面三句是执行含有变量参数的核心代码
15    sql="delete from {} where date_format(ts,'%Y-%m-%d') between '{}' and '{}' "
16    sql1=sql.format(tablename,startdate,endDate)#sql语句动态变量转化函数
17    cursor.execute(sql1)
18#执行删除操作后一定要提交，否则后面写入时会出现pymysql.err.InternalError1205报错
19    db.commit()
20    yconnect = create_engine('mysql+pymysql://root:123456@localhost:3306/test?charset=utf8')
21    pd.io.sql.to_sql(df, '%s' % tablename, yconnect, schema='test', if_exists='append')
22    db.commit()
23#将表user_test01时间段的数据读成数据框
24df1=read_mysql('user_test01','2019-04-01','2019-04-03')
25#print(df1)
26#将上述数据框df1写到表user_test2（先删除该时间段数据后在写进）
27write_df_to_table(df1,'user_test2,'2019-04-01','2019-04-03')

同样的，连时间参数我们也可以通过变量进行替换。比如我想要取三天前的日期和时间，代码如下：

1import time
2import datetime
3# 先获得时间数组格式的日期
4threeDayAgo = (datetime.datetime.now() - datetime.timedelta(days = 3))
5# 转换为时间戳
6timeStamp = int(time.mktime(threeDayAgo.timetuple()))
7# 转换为其他字符串格式
8otherStyleTime = threeDayAgo.strftime("%Y-%m-%d %H:%M:%S")
9print(otherStyleTime)

执行以上代码输出结果为：2019-04-12 11:06:08