MySQL遭遇DELETE误操作的回滚

方法:

条件:开启Binlog,Format为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.数据取出来之后,需要把数据解析反转,原始数据:

### 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操作,发上面的都是有一定规律的,并且需要注意的是:

1、字段类型 DATETIME 日期。在日志中保存的格式为 @4=2012-10-25 00:00:00,需要将2012-10-25 00:00:00加上引号。

2、负数。在日志中保存的格式为 @1=-1 (4294967295), -2(4294967294),-3(4294967293),需要将()里面的数据去掉,只保留@1=-1。

3、转义字符集。如:'s,,等。

上面3点清楚之后,可以写一个脚本(水平有限,在提升中,写的不好看):

#!/bin/env python
# -*- encoding: utf-8 -*-
#-------------------------------------------------------------------------------
# Name:        restore.py
# Purpose:     通过Binlog恢复Delete误操作数据
# 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为列数,要是小于最大的列数,后面均加,
                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类型的字段为负数后带的(),正数不受影响
                    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为列数,要是小于最大的列数,后面均加);
                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])

执行脚本:

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

总结:

下次整理Row和STATEMENT的优劣。

时间: 2024-10-29 17:32:54

MySQL遭遇DELETE误操作的回滚的相关文章

【MySQL】恢复误操作的方法

一 .前言 本周接二连三的出现开发人员在测试环境和生产误操作导致数据库误删除/更新,对DBA而言,回滚数据着实是一件头疼的事情,凡涉及到恢复线上数据必然对应用带来一定的影响.大多数情况是开发误操作delete数据,update多数行,根据之前的操作经验,本文介绍常用的恢复方法. 写本文的时候 Monogdb 也被曝出有被利用安全漏洞,数据被删除了,希望各位DBA/安全相关人员及时查看自己负责的业务数据库安全相关问题,保护好自己的数据. 二.常用的恢复方式 2.1 利用备份恢复 使用这种方式的前提

MySQL中truncate误操作后的数据恢复案例_Mysql

实际线上的场景比较复杂,当时涉及了truncate, delete 两个操作,经确认丢数据差不多7万多行,等停下来时,差不多又有共计1万多行数据写入. 这里为了简单说明,只拿弄一个简单的业务场景举例. 测试环境: Percona-Server-5.6.16 日志格式: mixed 没起用gtid 表结构如下: CREATE TABLE `tb_wubx` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(32) DEFAULT NULL

mysql实现事务的提交和回滚实例_Mysql

mysql创建存储过程的官方语法为: 复制代码 代码如下: START TRANSACTION | BEGIN [WORK]COMMIT [WORK] [AND [NO] CHAIN] [[NO] RELEASE]ROLLBACK [WORK] [AND [NO] CHAIN] [[NO] RELEASE]SET AUTOCOMMIT = {0 | 1} 我这里要说明的mysql事务处理多个SQL语句的回滚情况.比如说在一个存储过程中启动一个事务,这个事务同时往三个表中插入数据,每插完一张表需要

利用事务日志来恢复Update、Delete误操作引起的数据丢失

恢复|数据 可能有不少朋友遇到过这样的问题:update或delete语句忘带了where子句,或where子句精度不够,执行之后造成了严重的后果,这种情况的数据恢复只能利用事务日志的备份来进行,所以如果你的SQL没有进行相应的全库备份或不能备份日志(truncate log on checkpoint选项为1),那么就无法进行数据的恢复了,或者只能恢复到最近一次的备份的数据了. 以下简单说明恢复数据方法:1,如果误操作之前存在一个全库备份(或已有多个差异备份或增量备份),首先要做的事就是进进行

利用事务日志来恢复Update、Delete误操作引起的数据丢

恢复|数据 可能有不少朋友遇到过这样的问题:update或delete语句忘带了where子句,或where子句精度不够,执行之后造成了严重的后果,这种情况的数据恢复只能利用事务日志的备份来进行,所以如果你的SQL没有进行相应的全库备份或不能备份日志(truncate log on checkpoint选项为1),那么就无法进行数据的恢复了,或者只能恢复到最近一次的备份的数据了. 以下简单说明恢复数据方法:1,如果误操作之前存在一个全库备份(或已有多个差异备份或增量备份),首先要做的事就是进进行

mysql事务回滚使用与常见问题介绍

方法如下: 1.修改c:appservmysqlmy.ini文件,找到skip-InnoDB,在前面加上#,后保存文件. 2.在运行中输入:services.msc,重启mysql服务. 3.到phpmyadmin中,mysql->show engines;(或执行mysql->show variables like 'have_%'; ),查看InnoDB为YES,即表示数据库支持InnoDB了. 也就说明支持事务transaction了. 4.在创建表时,就可以为Storage Engin

SQL Server中TRUNCATE事务回滚操作方法_mssql2005

我们一般都认为TRUNCATE是一种不可回滚的操作,它会删除表中的所有数据以及重置Identity列. 如果你在事务中进行TRUNCATE操作,就能回滚.反之,它就不会从日志文件文件恢复数据.它不会在日志文件中记录删除的那些数据,它只在日志中记录数据页的单元分配. 下面的例子就能解释上面的所说的.         复制代码 代码如下: USE temp_test_database GO --创建一个临时表 CREATE TABLE TruncateTabel(ID INT) INSERT INT

百神大战续:UC再发声明称百度仍在“误操作”

中介交易 SEO诊断 淘宝客 云主机 技术大厅 新浪科技讯 5月21日下午消息,继本月初UC发布声明指责百度利用垄断打击神马搜索之后,UC今日再度发布声明,称继第一波对神马搜索和UC浏览器展开了一系列封杀和屏蔽后,百度再次对UC旗下产品的"误操作". UC优视表示,近期在手机百度.百度手机助手.百度PC网页搜索以及百度手机网页搜索等产品搜索"UC浏览器",优先推荐的不是下载量最大的主流官方版本,而是UC浏览器(x86版),导致大量用户下载后无法正常安装使用. &qu

MySQL数据库误操作后快速回滚的方法_Mysql

基本上每个跟数据库打交道的程序员(当然也可能是你同事)都会碰一个问题,MySQL误操作后如何快速回滚?比如,delete一张表,忘加限制条件,整张表没了.假如这还是线上环境核心业务数据,那这事就闹大了.误操作后,能快速回滚数据是非常重要的. binlog2sql快速回滚 首先,确认你的MySQL server开启了binlog,设置了以下参数: [mysqld] server-id = 1 log_bin = /var/log/mysql/mysql-bin.log max_binlog_siz