實現(xiàn)MySQL回滾的Python腳本的編寫教程
更新時間：2015年11月25日 12:17:01 投稿：goldensun
這篇文章主要介紹了實現(xiàn)MySQL回滾的Python腳本的編寫教程,文中的回滾針對的是DELETE語句的數(shù)據(jù)庫誤操作,需要的朋友可以參考下
操作數(shù)據(jù)庫時候難免會因為“大意”而誤操作，需要快速恢復的話通過備份來恢復是不太可能的，因為需要還原和binlog差來恢復，等不了，很費時。這里先說明下因為Delete 操作的恢復方法：主要還是通過binlog來進行恢復，前提是binlog_format必須是Row格式，否則只能通過備份來恢復數(shù)據(jù)了。
方法：
條件：開啟Binlog，F(xiàn)ormat為Row。
步驟：
1.通過MySQL自帶工具mysqlbinlog 指定導出操作的記錄：
mysqlbinlog --no-defaults --start-datetime='2012-12-25 14:56:00' --stop-datetime='2012-12-25 14:57:00' -vv mysql-bin.000001 > /home/zhoujy/restore/binlog.txt
2.數(shù)據(jù)取出來之后，需要把數(shù)據(jù)解析反轉，原始數(shù)據(jù)：
### DELETE FROM test.me_info ### WHERE ### @1=2165974 /* INT meta=0 nullable=0 is_null=0 */ ### @2='1984:03:17' /* DATE meta=0 nullable=1 is_null=0 */ ### @3=NULL /* DATE meta=765 nullable=1 is_null=1 */ ### @4=2012-10-25 00:00:00 /* DATETIME meta=0 nullable=0 is_null=0 */ ### @5='' /* VARSTRING(765) meta=765 nullable=1 is_null=0 */ ### @6=0 /* TINYINT meta=0 nullable=1 is_null=0 */ ### @7='' /* VARSTRING(765) meta=765 nullable=1 is_null=0 */ ### @8=-1 (4294967295) /* INT meta=0 nullable=1 is_null=0 */ ### @9=0 /* MEDIUMINT meta=0 nullable=1 is_null=0 */ ### @10=NULL /* MEDIUMINT meta=0 nullable=1 is_null=1 */ ### @11=2 /* TINYINT meta=0 nullable=1 is_null=0 */ ### @12=0 /* TINYINT meta=0 nullable=1 is_null=0 */ ### @13='' /* VARSTRING(765) meta=765 nullable=1 is_null=0 */ ### @14='' /* VARSTRING(765) meta=765 nullable=1 is_null=0 */ ### @15=0 /* MEDIUMINT meta=0 nullable=1 is_null=0 */ ### @16=320 /* INT meta=0 nullable=1 is_null=0 */ …………………… …………………… ……………………
Row格式的binlog記錄的格式如上面所示，需要做的工作就是吧Delete的操作轉換成Insert操作，發(fā)上面的都是有一定規(guī)律的，并且需要注意的是：
1、字段類型 DATETIME 日期。在日志中保存的格式為 @4=2012-10-25 00:00:00，需要將2012-10-25 00:00:00加上引號。
2、負數(shù)。在日志中保存的格式為 @1=-1 (4294967295)， -2(4294967294)，-3(4294967293)，需要將()里面的數(shù)據(jù)去掉，只保留@1=-1。
3、轉義字符集。如：'s，\，等。
上面3點清楚之后，可以寫一個腳本（水平有限，在提升中，寫的不好看）：
#!/bin/env python
# -*- encoding: utf-8 -*-
#-------------------------------------------------------------------------------
# Name: restore.py
# Purpose: 通過Binlog恢復Delete誤操作數(shù)據(jù)
# Author: zhoujy
# Created: 2012-12-25
# update: 2012-12-25
# Copyright: (c) Mablevi 2012
# Licence: zjy
#-------------------------------------------------------------------------------
def read_binlog(file,column_num):
f=open(file)
num = '@'+str(column_num)
while True:
lines = f.readline()
if lines.strip()[0:3] == '###':
lines=lines.split(' ',3)
if lines[1] == 'DELETE' and lines[2] =='FROM': #該部分替換Delete為Insert
lines[1] = "INSERT"
lines[2] = 'INTO'
lines[-1] = lines[-1].strip()
if lines[1].strip() == 'WHERE':
lines[1] = 'VALUES ('
if ''.join(lines).find('@') <> -1 and lines[3].split('=',1)[0] <> num: #num為列數(shù)，要是小于最大的列數(shù)，后面均加,
lines[3] = lines[3].split('=',1)[-1].strip()
if lines[3].strip('\'').strip().find('\'') <> -1:
lines[3] = lines[3].split('/*')[0].strip('\'').strip().strip('\'').replace('\\','').replace('\'','\\\'') #這里過濾掉轉義的字符串
lines[3] = '\'' + lines[3] + '\','
elif lines[3].find('INT meta') <> -1: #過濾Int類型的字段為負數(shù)后帶的（），正數(shù)不受影響
lines[3] = lines[3].split('/*')[0].strip()
lines[3] = lines[3].split()[0] + ','
elif lines[3].find('NULL') <> -1:
lines[3] = lines[3].split('/*')[0].strip()
lines[3] = lines[3] + ','
else:
lines[3] = lines[3].split('/*')[0].strip('\'').strip().strip('\'').replace('\\','').replace('\'','\\\'') #這里過濾掉轉義的字符串
lines[3] = '\'' + lines[3].strip('\''' ') + '\','
if ''.join(lines).find('@') <> -1 and lines[3].split('=',1)[0] == num: #num為列數(shù)，要是小于最大的列數(shù)，后面均加);
lines[3] = lines[3].split('=',1)[-1].strip()
if lines[3].find('\'') <> -1:
lines[3] = lines[3].split('/*')[0].strip('\'').strip().strip('\'').replace('\\','').replace('\'','\\\'') #同上
lines[3] = '\'' + lines[3] + '\');'
elif lines[3].find('INT meta') <> -1: #同上
lines[3] = lines[3].split('/*')[0].strip()
lines[3] = lines[3].split(' ')[0] + ');'
elif lines[3].find('NULL') <> -1:
lines[3] = lines[3].split('/*')[0].strip()
lines[3] = lines[3] + ');'
else:
lines[3] = lines[3].split('/*')[0].strip('\'').strip().strip('\'').replace('\\','').replace('\'','\\\'') #同上
lines[3] = '\'' + lines[3].strip('\''' ') + '\');'
print ' '.join(lines[1:])
if lines == '':
break
if __name__ == '__main__':
import sys
read_binlog(sys.argv[1],sys.argv[2])
執(zhí)行腳本：
python restore.py binlog.txt 36 > binlog.sql
命令行中的36 表示 需要還原的表的字段有36個，效果：
INSERT INTO test.me_info VALUES ( 2123269, '1990:11:12', NULL, 2, '', 0, '', -1, 0, 340800, 1, 0, '', …… …… 1, NULL );
最后還原：
mysql test < binlog.sql
相關文章
關于mysql create routine 權限的一些說明
下面小編就為大家?guī)硪黄P于mysql create routine 權限的一些說明。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-03-03
線上的MySQL一般都采用源碼編譯，雖然MySQL的源碼編譯挺簡單的，但是試想一下，如果你有幾百臺服務器同時要安裝MySQL，難道你還一臺臺去手動編譯、編寫配置文件嗎？這顯然太低效了，本文討論MySQL的自動化安裝部署。2014-07-07
mysql+Spring數(shù)據(jù)庫隔離級別與性能分析
數(shù)據(jù)庫隔離級別與Spring配置事務的聯(lián)系及性能影響，以下是個人理解，如果有瑕疵請及時指正2014-05-05
MySQL多實例就是，在一臺機器上開啟多個不同的服務端口（如：3306,3307,3308...），運行多個MySQL服務進程，這些服務進程通過不同的socket監(jiān)聽不同的端口提供服務。2018-04-04
mysql啟動報錯Failed?to?start?LSB:start?and?stop?MySQL的問題解決
本文主要介紹了mysql啟動報錯Failed?to?start?LSB:start?and?stop?MySQL的問題解決,具有一定的參考價值,感興趣的可以了解一下2023-10-10
在 MySQL 中，我們經常使用 WHERE 條件用于進行值的相等比較、范圍過濾。然而，我們也會使用關鍵字進行搜索，這個基于搜索值與其他值的相關性來進行過濾。MySQL全文檢索即用于這種場景。本篇將介紹如何使用全文檢索。2021-05-05
這篇文章主要介紹了教你如何使用MySQL8遞歸的方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-12-12
Windows10下MySQL5.7.19安裝教程 MySQL忘記root密碼修改方法
這篇文章主要為大家詳細介紹了Windows10下MySQL5.7.19安裝教程，以及MySQL忘記root密碼的修改方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-10-10
在本篇文章里小編給大家分享的是關于mysql查詢表是否被鎖的方法，有需要的朋友們可以參考下。2020-10-10
解決亂碼的方法是，在執(zhí)行SQL語句之前，將MySQL以下三個系統(tǒng)參數(shù)設置為與服務器字符集character-set-server相同的字符集2012-05-05