MySQL利用binlog恢復(fù)誤操作數(shù)據(jù)

　　在人工手動(dòng)進(jìn)行一些數(shù)據(jù)庫(kù)寫(xiě)操作的時(shí)候（比方說(shuō)數(shù)據(jù)訂正），尤其是一些不可控的批量更新或刪除，通常都建議備份后操作。不過(guò)不怕萬(wàn)一，就怕一萬(wàn)，有備無(wú)患總是好的。在線上或者測(cè)試環(huán)境誤操作導(dǎo)致數(shù)據(jù)被刪除或者更新后，想要恢復(fù)，一般有兩種方法。

　　方法一、利用最近的全量備份+增量binlog備份，恢復(fù)到誤操作之前的狀態(tài)，但是隨著數(shù)據(jù)量的增大，binlog的增多，恢復(fù)起來(lái)很費(fèi)時(shí)。

　　方法二、如果binlog的格式為row，那么就可以將binlog解析出來(lái)生成反向的原始SQL

　　以下是利用方法二寫(xiě)的一個(gè)python腳本binlog_rollback.py，可利用此腳本生成反向的原始SQL。

　　說(shuō)明：

　　0、前提是binlog的格式為row

　　1、要恢復(fù)的表操作前后表結(jié)構(gòu)沒(méi)有發(fā)生變更，否則腳本無(wú)法解析

　　2、只生成DML（insert/update/delete）的rollback語(yǔ)句

　　3、最終生成的SQL是逆序的，所以最新的DML會(huì)生成在輸入文件的最前面，并且?guī)狭藭r(shí)間戳和偏移點(diǎn)，方便查找目標(biāo)

　　4、需要提供一個(gè)連接MySQL的只讀用戶，主要是為了獲取表結(jié)構(gòu)

　　5、如果binlog過(guò)大，建議帶上時(shí)間范圍，也可以指定只恢復(fù)某個(gè)庫(kù)的SQL

　　6、SQL生成后，請(qǐng)務(wù)必在測(cè)試環(huán)境上測(cè)試恢復(fù)后再應(yīng)用到線上

　　腳本代碼

　　#！/bin/env python

　　# -*- coding:utf-8 -*-

　　import os，sys，re，getopt

　　import MySQLdb

　　host = ‘127.0.0.1’

　　user = ‘’

　　password = ‘’

　　port = 3306

　　start_datetime = ‘1971-01-01 00:00:00’

　　stop_datetime = ‘2037-01-01 00:00:00’

　　start_position = ‘4’

　　stop_position = ‘18446744073709551615’

　　database = ‘’

　　mysqlbinlog_bin = ‘mysqlbinlog -v’

　　binlog = ‘’

　　fileContent = ‘’

　　output=‘rollback.sql’

　　only_primary = 0

　　# ----------------------------------------------------------------------------------------

　　# 功能：獲取參數(shù)，生成相應(yīng)的binlog解析文件

　　# ----------------------------------------------------------------------------------------

　　def getopts_parse_binlog（）：

　　global host

　　global user

　　global password

　　global port

　　global fileContent

　　global output

　　global binlog

　　global start_datetime

　　global stop_datetime

　　global start_position

　　global stop_position

　　global database

　　global only_primary

　　try：

　　options， args = getopt.getopt（sys.argv［1：］， “f:o：h:u：p:P：d：”， ［“help”，“binlog=”，“output=”，“host=”，“user=”，“password=”，“port=”，“start-datetime=”， \

　　“stop-datetime=”，“start-position=”，“stop-position=”，“database=”，“only-primary=”］）

　　except getopt.GetoptError：

　　print “參數(shù)輸入有誤！?。。?！”

　　options = ［］

　　if options == ［］ or options［0］［0］ in （“--help”）：

　　usage（）

　　sys.exit（）

　　print “正在獲取參數(shù)。..。.”

　　for name， value in options：

　　if name == “-f” or name == “--binlog”：

　　binlog = value

　　if name == “-o” or name == “--output”：

　　output = value

　　if name == “-h” or name == “--host”：

　　host = value

　　if name == “-u” or name == “--user”：

　　user = value

　　if name == “-p” or name == “--password”：

　　password = value

　　if name == “-P” or name == “--port”：

　　port = value

　　if name == “--start-datetime”：

　　start_datetime = value

　　if name == “--stop-datetime”：

　　stop_datetime = value

　　if name == “--start-position”：

　　start_position = value

　　if name == “--stop-position”：

　　stop_position = value

　　if name == “-d” or name == “--database”：

　　database = value

　　if name == “--only-primary” ：

　　only_primary = value

　　if binlog == ‘’ ：

　　print “錯(cuò)誤：請(qǐng)指定binlog文件名！”

　　usage（）

　　if user == ‘’ ：

　　print “錯(cuò)誤：請(qǐng)指定用戶名！”

　　usage（）

　　if password == ‘’ ：

　　print “錯(cuò)誤：請(qǐng)指定密碼！”

　　usage（）

　　if database 《》 ‘’ ：

　　condition_database = “--database=” + “‘” + database + “’”

　　else：

　　condition_database = ‘’

　　print “正在解析binlog.。..?！?/p>

　　fileContent=os.popen（“%s %s --base64-output=DECODE-ROWS --start-datetime=‘%s’ --stop-datetime=‘%s’ --start-position=‘%s’ --stop-position=‘%s’ %s\

　　|grep ‘###’ -B 2|sed -e ‘s/### //g’ -e ‘s/^INSERT/##INSERT/g’ -e ‘s/^UPDATE/##UPDATE/g’ -e ‘s/^DELETE/##DELETE/g’ ” \

　　%（mysqlbinlog_bin，binlog，start_datetime，stop_datetime，start_position，stop_position，condition_database））.read（）

　　#print fileContent