快速,持续,稳定,傻瓜式
支持Mysql,Sqlserver数据同步

[python 数据库表同步]dango+python+mysql数据库同步(把数据库’aa’同步到default数据库中)

请联系QQ:1793040 索取软件

标签:pythondjango数据库

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数据库中)

标签:pythondjango数据库

原文:http://blog.csdn.net/fanyunlei/article/details/21600781

相关推荐

咨询软件
 
QQ在线咨询
售前咨询热线
QQ1793040