dango+python+mysql数据库同步(把数据库'aa'同步到default数据库中)

def test1(ksId,jsId):


    startId=int(ksId)-1
    endId=int(jsId)
    try:
        r =account_detail.objects.using(‘aa‘).filter(pk__gt=startId).filter(pk__lt=endId)
        #r =account_detail.objects.filter(pk__gt=startId).filter(pk__lt=endId)
        #print r.values()
        if len(r)>0:
                for rvalue in r:


                    #print rvalue.objects.all()
                    rvalue.save()
                    #r.save(using=‘aa‘)
                    pass
                print ("id在[%d--%d]间成功同步数据")%(startId+1,endId)
        else:
                print ("id在[%d--%d]间未查询到数据")%(startId+1,endId)
    except:
        print ("同步数据库id在%d-- %d段出现异常下次执行从%d开始")%(startId+1,endId,startId+1)
        sys.exit()
    print("同步数据库结束下次同步从 %d 开始")%endId
    #print data[0].remark
    #考虑到数据量有可能过大,分批同步,一批同步20行数据
def instance(startId,endId):
    #startId =1
    #endId=100
    numId= (endId-startId)+1
    numi=numId/20
    if numi==0:
        Idstart=startId
        Idend=endId
        test1(Idstart,Idend)
    else:
        addnumId=numId%20
        if addnumId >0:
            numi+=1
        for i in range(numi):
            if i==0:
                Idstart=startId
                Idend =(i+1)*20+startId


            elif i==(numi-1):
                Idstart=startId+(i*20)
                Idend =endId


            else:
                Idstart=startId+(i*20)
                Idend =(i+1)*20+startId




            test1(Idstart,Idend)
#读取txt配置同步数据开始,结束id
def readtxt():
    f =open("syncdb.txt")
    line=f.readline()
    n=[]
    while line:
           k= line[8:]
           n.append(k)
           line = f.readline()
    
    f.close()
    starttime=time.time()
    instance(int(n[0]),int(n[1]))
    endtime=time.time()
    print ("***********************同步数据库结束***************************")
    print("同步数据所需的时间:"+str(endtime-starttime)+"秒")






if __name__==‘__main__‘:
    readtxt()

dango+python+mysql数据库同步(把数据库'aa'同步到default数据库中),布布扣,bubuko.com

dango+python+mysql数据库同步(把数据库'aa'同步到default数据库中)

上一篇:oracle学习笔记002---oracle的体系结构


下一篇:yum安装nginx+mysql+php