python-mysql数据同步

简陋同步代码

#-*- coding: utf-8 -*-,  
#coding = utf-8  
from MySQLdb import *
import datetime

def conn():  
    conn_local = Connection('127.0.0.1','root','root@123','orderautocategory')  
    conn_server = Connection('192.168.124.133','sto_dev','Ass1qaz2wsx','orderyiwu')  
    cur_server=conn_server.cursor()  
    cur_local = conn_local.cursor()
    cur_server.execute("select MAX(SysRecevieTime) FROM OrderRecevie")
    cur_server_maxtime = cur_server.fetchone()

    cur_local.execute("select MAX(SysRecevieTime) FROM OrderRecevie")
    cur_local_maxtime = cur_local.fetchone()
    time = (cur_local_maxtime[0])
    if time == None:
        time = 0
    #time_1 = time + datetime.timedelta(minutes=30) 
    #print time
    #while cur_server_maxtime[0] - cur_local_maxtime[0]
    cur_server.execute("select * from OrderRecevie where SysRecevieTime >= '"+str(time)+"' order by SysRecevieTime limit 2000 ")
    row = cur_server.fetchall()

    for i in range(0,len(row)):
        if row == None:
            break
        cur_local.execute("insert into OrderRecevie(WAYBILLNO,Code1,Code2,Code3,SysRecevieTime,OrderTypeEx) \
                            values('"+str(row[i][0])+"','"+str(row[i][1])+"','"+str(row[i][2])+"',\
                                    '"+str(row[i][3])+"','"+str(row[i][5])+"','"+str(row[i][20])+"')")
                          
#
#
    conn_server.commit()  
    conn_local.commit()  
    cur_server.close()  
    cur_local.close()  
    conn_server.close()  
    conn_local.close()  

if __name__=='__main__':
    for i in range(0,1000):
        conn()
        print i
    #conn()