mysql4.0是老版本了，但是有些早期使用的企業依然在用，在建立主從時特別是線上伺服器建立主從時，保證資料的一致性是個大問題：比如建立完從庫同步時出現重複資料重複執行（雖然資料條數一致，但資料有可能會不一致）等。在mysql5.0以上版本中，此時備份主庫只用在mysqldump時加上-f、master-data=2，single-transaction引數，從庫同步時匯入備份，在取備份檔案開頭的bin-log和pos位置進行同步即可，不會出現資料重複執行等問題，他能確保同步時的一致性。比較悲劇的是，本人所用的資料庫還沒有公升級，是4.0的版本，經過測試，寫了乙個專一用於4.0主從同步時主庫備份的指令碼，原理就是模擬5.0以上的備份過程來做的。也可以用於5.0以上的版本，但是5.0以上的版本沒有必要這麼做。大家可以參考。
#!/usr/bin/env python# -*- coding: utf-8 -*-
#last update:2012-10-25
import os,sys,time,mysqldb
import subprocess,threading
class mysql_dump():
def __init__(self):
self.stat_ip = "192.168.1.110"
self.logfile = "/data/script/db_back/mysql_dump.log"
self.user = "dump"
self.passwd = "123456"
self.distid = "2"
def log_w(self,text):
now = time.strftime("%y-%m-%d %h:%m:%s")
tt = str(now) + "\t" + str(text) + "\n"
f = open(self.logfile,'a+')
f.write(tt)
f.close()
def dump(self,dumpname,now):
cmd = "/usr/local/mysql/bin/mysqldump -a -q -e --add-drop-table --add-locks --extended-insert --quick --no-autocommit --single-transaction -u%s -p%s | bzip2 -2 > %s" % (self.user,self.passwd,dumpname)
print time.strftime("%y-%m-%d %h:%m:%s")
text = "start mysqldump,please wait ..."
print text
self.log_w(text)
a = subprocess.popen(cmd,shell=true)
while
1:
b = subprocess.popen.poll(a)
if b == 0:
text = "mysqldump complete"
print text
self.log_w(text)
break
elif b is
none:
'mysqldump running'
time.sleep(30)
else:
print a.pid,'term'
break
self.rsync(dumpname)
def rsync(self,dumpname):
cmd = "rsync -az %s %s::asktao_db/db_back/" % (dumpname,self.stat_ip)
text = "start rsync to server(%s) ,please wait ..." % self.stat_ip
print text
self.log_w(text)
a = subprocess.popen(cmd,shell=true)
while
1:
b = subprocess.popen.poll(a)
if b == 0:
text = "rsync complete"
print text
self.log_w(text)
break
elif b is
none:
'rsync running'
time.sleep(30)
else:
print a.pid,'term'
break
def bin_log(self):
try:
conn = mysqldb.connect(host = '127.0.0.1',user = 'repl_monitor',passwd = '123456',connect_timeout=5)
cursor = conn.cursor()
cursor.execute("show master status")
alldata = cursor.fetchall()
cursor.close()
conn.close()
file = alldata[0][0]
position = alldata[0][1]
text = "show master status: %s %s" % (file,position)
print text
self.log_w(text)
return file,position
except mysqldb.error,e:
text = e.args
print text
self.log_w(text)
sys.exit()
def lock(self):
try:
conn = mysqldb.connect(host = 'localhost',user = self.user,passwd = self.passwd,connect_timeout=5)
cursor = conn.cursor()
text = "flush tables with read lock"
print text
self.log_w(text)
cursor.execute("flush tables with read lock")
text = "flush logs"
print text
self.log_w(text)
cursor.execute("flush logs")
file,position = self.bin_log()
now = time.strftime("%y%m%d%h%m")
dumpname = "/data/script/db_back/wd_%s_%s_%s_%s.bz2" % (self.distid,now,file,position)
d = threading.thread(target=self.dump, args=(dumpname,now))
d.start()
while
1:
if os.path.isfile(dumpname) and os.path.getsize(dumpname) > 0:
text = "unlock tables"
print text
self.log_w(text)
cursor.execute("unlock tables")
cursor.close()
conn.close()
break
except mysqldb.error,e:
text = e.args
print text
self.log_w(text)
sys.exit()
def work(self):
t = threading.thread(target=self.lock, args=())
t.start()
if __name__ == "__main__":
boss = mysql_dump()
boss.work()
mysql4 0做主從時主庫的備份指令碼
mysql4.0是老版本了，但是有些早期使用的企業依然在用，在建立主從時特別是線上伺服器建立主從時，保證資料的一致性是個大問題 比如建立完從庫同步時出現重複資料重複執行 雖然資料條數一致，但資料有可能會不一致 等。在mysql5.0以上版本中，此時備份主庫只用在mysqldump時加上 f mast...
MySQL 40 表的複製
常見的複製方法有三種 mysqldump 方法，csv 檔案 物理拷貝方法 40.1 mysqldump 使用mysqldump命令將資料匯出成一組insert語句，也就是sql檔案。命令如下 mysqldump h host p port u user add locks 0 no create ...
關於mysql 4 0到5 0的資料遷移
本來想用個資料前端工具,用了好多都是出現亂碼,不得已還得用命令 我們資料庫是utf8編碼格式 關於mysql資料庫之間的資料遷移的說明 一 d匯出資料 首先開啟資料庫服務 dos命令下進入 d mysql bin mysqldump h 10.10.129.155 uroot p quick com...