importpymssql
importtime
importdatetime
sql_insert=
insert数据库名.dbo.t_jl_数据库表名values(
%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,
%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,
%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,
%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,
%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,
%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,
%s,%s,%s,%s,%s,%s,%s
)
#定义一个插入数据库的语句，上面中多个%s是数据库表中的列数加2
whileTrue:
try:
cn_server=pymssql.connect(#服务器数据库连接，就是要被插入数据的数据库服务器
host=.16..,
port=,
user=aa,
password=
)
cn_cems=pymssql.connect(#现场数据库连接，就是要提取数据的数据库服务器
host=.16.87.66,
port=,
user=admin,
password=,
database=cems_control
)
cr_server=cn_server.cursor()#服务器数据库游标
cr_cems=cn_cems.cursor()#现场数据库游标
cr_server.execute(selectmax(id)idfrom数据库.dbo.t_jl_数据库中的表)#从服务器读取最后记录的id
begin_datetime=cr_server.fetchone()[0]
cr_cems.execute(select*fromcems_control.dbo.soot1whereid%s,(begin_datetime))#从现场数据库读取数据
data_records=cr_cems.fetchall()
forlindata_records:
cr_server.execute(sql_insert,l)#写入服务器数据库
cn_server.