Linux
基于row模式的binlog，生成DML(insert/update/delete)的rollback语句
通过mysqlbinlog -v 解析binlog生成可读的sql文件
提取需要处理的有效sql
  "### "开头的行.如果输入的start-position位于某个event group中间，则会导致"无法识别event"错误

将INSERT/UPDATE/DELETE 的sql反转,并且1个完整sql只能占1行
  INSERT: INSERT INTO => DELETE FROM, SET => WHERE
  UPDATE: WHERE => SET, SET => WHERE
  DELETE: DELETE FROM => INSERT INTO, WHERE => SET
用列名替换位置@{1,2,3}
  通过desc table获得列顺序及对应的列名
  特殊列类型value做特别处理
逆序

注意:
  表结构与现在的表结构必须相同[谨记]
  由于row模式是幂等的，并且恢复是一次性，所以只提取sql，不提取BEGIN/COMMIT
  只能对INSERT/UPDATE/DELETE进行处理

mysql> select * from yoon;
+----------+------------+-----------+---------------------+
| actor_id | first_name | last_name | last_update         |
+----------+------------+-----------+---------------------+
|        1 | HANK       | YOON      | 2006-02-15 04:34:33 |
|        2 | HANK       | YOON      | 2006-02-15 04:34:33 |
|        3 | HANK       | YOON      | 2006-02-15 04:34:33 |
|        4 | HANK       | YOON      | 2006-02-15 04:34:33 |
|        5 | HANK       | YOON      | 2006-02-15 04:34:33 |
|        6 | HANK       | YOON      | 2006-02-15 04:34:33 |
|        7 | HANK       | YOON      | 2006-02-15 04:34:33 |
|        8 | HANK       | YOON      | 2006-02-15 04:34:33 |
|        9 | HANK       | YOON      | 2006-02-15 04:34:33 |
|       10 | HANK       | YOON      | 2006-02-15 04:34:33 |
|       11 | HANK       | YOON      | 2006-02-15 04:34:33 |
+----------+------------+-----------+---------------------+
11 rows in set (0.00 sec)

mysql> delete from yoon;
Query OK, 11 rows affected (1.03 sec)

mysql> select * from yoon;
Empty set (0.00 sec)

命令之间的空格一定要注意，否则就会无法提取SQL语句：
[root@hank-yoon data]# perl binlog-rollback.pl -f 'mysql-bin.000001' -o '/export/data/mysql/data/yoon.sql' -u 'root' -p 'yoon'
Warning: Using a password on the command line interface can be insecure.
[root@hank-yoon data]# ls
auto.cnf            hank     ibdata2      ib_logfile1  modify.pl  mysql-bin.000001  performance_schema  test  yoon.sql
binlog-rollback.pl  ibdata1  ib_logfile0  ib_logfile2  mysql      mysql-bin.index   sakila              yoon
[root@hank-yoon data]# cat yoon.sql 
INSERT INTO `yoon`.`yoon` SET `actor_id`=11, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=10, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=9, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=8, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=7, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=6, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=5, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=4, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=3, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=2, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
INSERT INTO `yoon`.`yoon` SET `actor_id`=1, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);

mysql> INSERT INTO `yoon`.`yoon` SET `actor_id`=11, `first_name`='HANK', `last_name`='YOON', `last_update`=from_unixtime(1139949273);
Query OK, 1 row affected (0.01 sec)

mysql> select * from yoon;
+----------+------------+-----------+---------------------+
| actor_id | first_name | last_name | last_update         |
+----------+------------+-----------+---------------------+
|       11 | HANK       | YOON      | 2006-02-15 04:34:33 |
+----------+------------+-----------+---------------------+

  • #!/usr/lib/perl -w
  • use strict;
  • use warnings;
  • use Class::Struct;
  • use Getopt::Long qw(:config no_ignore_case);                    # GetOption
  • # register handler system signals
  • use sigtrap 'handler', \&sig_int, 'normal-signals';
  • # catch signal
  • sub sig_int(){
  • my ($signals) = @_;
  • print STDERR "# Caught SIG$signals.\n";
  • exit 1;
  • }
  • my %opt;
  • my $srcfile;
  • my $host = '127.0.0.1';
  • my $port = 3306;
  • my ($user,$pwd);
  • my ($MYSQL, $MYSQLBINLOG, $ROLLBACK_DML);
  • my $outfile = '/dev/null';
  • my (%do_dbs,%do_tbs);
  • # tbname=>tbcol, tbcol: @n=>colname,type
  • my %tbcol_pos;
  • my $SPLITER_COL = ',';
  • my $SQLTYPE_IST = 'INSERT';
  • my $SQLTYPE_UPD = 'UPDATE';
  • my $SQLTYPE_DEL = 'DELETE';
  • my $SQLAREA_WHERE = 'WHERE';
  • my $SQLAREA_SET = 'SET';
  • my $PRE_FUNCT = '========================== ';
  • # =========================================================
  • # 基于row模式的binlog，生成DML(insert/update/delete)的rollback语句
  • # 通过mysqlbinlog -v 解析binlog生成可读的sql文件
  • # 提取需要处理的有效sql
  • #     "### "开头的行.如果输入的start-position位于某个event group中间，则会导致"无法识别event"错误
  • #
  • # 将INSERT/UPDATE/DELETE 的sql反转,并且1个完整sql只能占1行
  • #     INSERT: INSERT INTO => DELETE FROM, SET => WHERE
  • #     UPDATE: WHERE => SET, SET => WHERE
  • #     DELETE: DELETE FROM => INSERT INTO, WHERE => SET
  • # 用列名替换位置@{1,2,3}
  • #     通过desc table获得列顺序及对应的列名
  • #     特殊列类型value做特别处理
  • # 逆序
  • #
  • # 注意:
  • #     表结构与现在的表结构必须相同[谨记]
  • #     由于row模式是幂等的，并且恢复是一次性，所以只提取sql，不提取BEGIN/COMMIT
  • #     只能对INSERT/UPDATE/DELETE进行处理
  • # ========================================================
  • sub main{
  • # get input option
  • &get_options();
  • #
  • &init_tbcol();
  • #
  • &do_binlog_rollback();
  • }
  • &main();
  • # ----------------------------------------------------------------------------------------
  • # Func : get options and set option flag
  • # ----------------------------------------------------------------------------------------
  • sub get_options{
  • #Get options info
  • GetOptions(\%opt,
  • 'help',                    # OUT : print help info
  • 'f|srcfile=s',            # IN : binlog file
  • 'o|outfile=s',            # out : output sql file
  • 'h|host=s',                # IN : host
  • 'u|user=s', # IN : user
  • 'p|password=s', # IN : password
  • 'P|port=i',                # IN : port
  • 'start-datetime=s',        # IN : start datetime
  • 'stop-datetime=s',        # IN : stop datetime
  • 'start-position=i',        # IN : start position
  • 'stop-position=i',        # IN : stop position
  • 'd|database=s',            # IN : database, split comma
  • 'T|table=s',            # IN : table, split comma
  • 'i|ignore',                # IN : ignore binlog check ddl and so on
  • 'debug',                # IN : print debug information
  • ) or print_usage();
  • if (!scalar(%opt)) {
  • &print_usage();
  • }
  • # Handle for options
  • if ($opt{'f'}){
  • $srcfile = $opt{'f'};
  • }else{
  • &merror("please input binlog file");
  • }
  • $opt{'h'} and $host = $opt{'h'};
  • $opt{'u'} and $user = $opt{'u'};
  • $opt{'p'} and $pwd = $opt{'p'};
  • $opt{'P'} and $port = $opt{'P'};
  • if ($opt{'o'}) {
  • $outfile = $opt{'o'};
  • # 清空 outfile
  • `echo '' > $outfile`;
  • }
  • #
  • $MYSQL = qq{mysql -h$host -u$user -p'$pwd' -P$port};
  • &mdebug("get_options::MYSQL\n\t$MYSQL");
  • # 提取binlog,不需要显示列定义信息，用-v，而不用-vv
  • $MYSQLBINLOG = qq{mysqlbinlog -v};
  • $MYSQLBINLOG .= " --start-position=".$opt{'start-position'} if $opt{'start-position'};
  • $MYSQLBINLOG .= " --stop-position=".$opt{'stop-position'} if $opt{'stop-postion'};
  • $MYSQLBINLOG .= " --start-datetime='".$opt{'start-datetime'}."'" if $opt{'start-datetime'};
  • $MYSQLBINLOG .= " --stop-datetime='$opt{'stop-datetime'}'" if $opt{'stop-datetime'};
  • $MYSQLBINLOG .= " $srcfile";
  • &mdebug("get_options::MYSQLBINLOG\n\t$MYSQLBINLOG");
  • # 检查binlog中是否含有 ddl sql: CREATE|ALTER|DROP|RENAME
  • &check_binlog() unless ($opt{'i'});
  • # 不使用mysqlbinlog过滤，USE dbname;方式可能会漏掉某些sql，所以不在mysqlbinlog过滤
  • # 指定数据库
  • if ($opt{'d'}){
  • my @dbs = split(/,/,$opt{'d'});
  • foreach my $db (@dbs){
  • $do_dbs{$db}=1;
  • }
  • }
  • # 指定表
  • if ($opt{'T'}){
  • my @tbs = split(/,/,$opt{'T'});
  • foreach my $tb (@tbs){
  • $do_tbs{$tb}=1;
  • }
  • }
  • # 提取有效DML SQL
  • $ROLLBACK_DML = $MYSQLBINLOG." | grep '^### '";
  • # 去掉注释: '### ' -> ''
  • # 删除首尾空格
  • $ROLLBACK_DML .= " | sed 's/###\\s*//g;s/\\s*\$//g'";
  • &mdebug("rollback dml\n\t$ROLLBACK_DML");
  • # 检查内容是否为空
  • my $cmd = "$ROLLBACK_DML | wc -l";
  • &mdebug("check contain dml sql\n\t$cmd");
  • my $size = `$cmd`;
  • chomp($size);
  • unless ($size >0){
  • &merror("binlog DML is empty:$ROLLBACK_DML");
  • };
  • }
  • # ----------------------------------------------------------------------------------------
  • # Func : check binlog contain DDL
  • # ----------------------------------------------------------------------------------------
  • sub check_binlog{
  • &mdebug("$PRE_FUNCT check_binlog");
  • my $cmd = "$MYSQLBINLOG ";
  • $cmd .= " | grep -E -i '^(CREATE|ALTER|DROP|RENAME)' ";
  • &mdebug("check binlog has DDL cmd\n\t$cmd");
  • my $ddlcnt = `$cmd`;
  • chomp($ddlcnt);
  • my $ddlnum = `$cmd | wc -l`;
  • chomp($ddlnum);
  • my $res = 0;
  • if ($ddlnum>0){
  • # 在ddl sql前面加上前缀<DDL>
  • $ddlcnt = `echo '$ddlcnt' | sed 's/^//g'`;
  • &merror("binlog contain $ddlnum DDL:$MYSQLBINLOG. ddl sql:\n$ddlcnt");
  • }
  • return $res;
  • }
  • # ----------------------------------------------------------------------------------------
  • # Func : init all table column order
  • #        if input --database --table params, only get set table column order
  • # ----------------------------------------------------------------------------------------
  • sub init_tbcol{
  • &mdebug("$PRE_FUNCT init_tbcol");
  • # 提取DML语句
  • my $cmd .= "$ROLLBACK_DML | grep -E '^(INSERT|UPDATE|DELETE)'";
  • # 提取表名，并去重
  • #$cmd .= " | awk '{if (\$1 ~ \"^UPDATE\") {print \$2}else {print \$3}}' | uniq ";
  • $cmd .= " | awk '{if (\$1 ~ \"^UPDATE\") {print \$2}else {print \$3}}' | sort | uniq ";
  • &mdebug("get table name cmd\n\t$cmd");
  • open ALLTABLE, "$cmd | " or die "can't open file:$cmd\n";
  • while (my $tbname = <ALLTABLE>){
  • chomp($tbname);
  • #if (exists $tbcol_pos{$tbname}){
  • #    next;
  • #}
  • &init_one_tbcol($tbname) unless (&ignore_tb($tbname));
  • }
  • close ALLTABLE or die "can't close file:$cmd\n";
  • # init tb col
  • foreach my $tb (keys %tbcol_pos){
  • &mdebug("tbname->$tb");
  • my %colpos = %{$tbcol_pos{$tb}};
  • foreach my $pos (keys %colpos){
  • my $col = $colpos{$pos};
  • my ($cname,$ctype) = split(/$SPLITER_COL/, $col);
  • &mdebug("\tpos->$pos,cname->$cname,ctype->$ctype");
  • }
  • }
  • };
  • # ----------------------------------------------------------------------------------------
  • # Func : init one table column order
  • # ----------------------------------------------------------------------------------------
  • sub init_one_tbcol{
  • my $tbname = shift;
  • &mdebug("$PRE_FUNCT init_one_tbcol");
  • # 获取表结构及列顺序
  • my $cmd = $MYSQL." --skip-column-names --silent -e 'desc $tbname'";
  • # 提取列名，并拼接
  • $cmd .= " | awk -F\'\\t\' \'{print NR\"$SPLITER_COL`\"\$1\"`$SPLITER_COL\"\$2}'";
  • &mdebug("get table column infor cmd\n\t$cmd");
  • open TBCOL,"$cmd | " or die "can't open desc $tbname;";
  • my %colpos;
  • while (my $line = <TBCOL>){
  • chomp($line);
  • my ($pos,$col,$coltype) = split(/$SPLITER_COL/,$line);
  • &mdebug("linesss=$line\n\t\tpos=$pos\n\t\tcol=$col\n\t\ttype=$coltype");
  • $colpos{$pos} = $col.$SPLITER_COL.$coltype;
  • }
  • close TBCOL or die "can't colse desc $tbname";
  • $tbcol_pos{$tbname} = \%colpos;
  • }
  • # ----------------------------------------------------------------------------------------
  • # Func : rollback sql:    INSERT/UPDATE/DELETE
  • # ----------------------------------------------------------------------------------------
  • sub do_binlog_rollback{
  • my $binlogfile = "$ROLLBACK_DML ";
  • &mdebug("$PRE_FUNCT do_binlog_rollback");
  • # INSERT|UPDATE|DELETE
  • my $sqltype;
  • # WHERE|SET
  • my $sqlarea;
  • my ($tbname, $sqlstr) = ('', '');
  • my ($notignore, $isareabegin) = (0,0);
  • # output sql file
  • open SQLFILE, ">> $outfile" or die "Can't open sql file:$outfile";
  • # binlog file
  • open BINLOG, "$binlogfile |" or die "Can't open file: $binlogfile";
  • while (my $line = <BINLOG>){
  • chomp($line);
  • if ($line =~ /^(INSERT|UPDATE|DELETE)/){
  • # export sql
  • if ($sqlstr ne ''){
  • $sqlstr .= ";\n";
  • print SQLFILE $sqlstr;
  • &mdebug("export sql\n\t".$sqlstr);
  • $sqlstr = '';
  • }
  • if ($line =~ /^INSERT/){
  • $sqltype = $SQLTYPE_IST;
  • $tbname = `echo '$line' | awk '{print \$3}'`;
  • chomp($tbname);
  • $sqlstr = qq{DELETE FROM $tbname};
  • }elsif ($line =~ /^UPDATE/){
  • $sqltype = $SQLTYPE_UPD;
  • $tbname = `echo '$line' | awk '{print \$2}'`;
  • chomp($tbname);
  • $sqlstr = qq{UPDATE $tbname};
  • }elsif ($line =~ /^DELETE/){
  • $sqltype = $SQLTYPE_DEL;
  • $tbname = `echo '$line' | awk '{print \$3}'`;
  • chomp($tbname);
  • $sqlstr = qq{INSERT INTO $tbname};
  • }
  • # check ignore table
  • if(&ignore_tb($tbname)){
  • $notignore = 0;
  • &mdebug("#IGNORE#:line:".$line);
  • $sqlstr = '';
  • }else{
  • $notignore = 1;
  • &mdebug("#DO#:line:".$line);
  • }
  • }else {
  • if($notignore){
  • &merror("can't get tbname") unless (defined($tbname));
  • if ($line =~ /^WHERE/){
  • $sqlarea = $SQLAREA_WHERE;
  • $sqlstr .= qq{ SET};
  • $isareabegin = 1;
  • }elsif ($line =~ /^SET/){
  • $sqlarea = $SQLAREA_SET;
  • $sqlstr .= qq{ WHERE};
  • $isareabegin = 1;
  • }elsif ($line =~ /^\@/){
  • $sqlstr .= &deal_col_value($tbname, $sqltype, $sqlarea, $isareabegin, $line);
  • $isareabegin = 0;
  • }else{
  • &mdebug("::unknown sql:".$line);
  • }
  • }
  • }
  • }
  • # export last sql
  • if ($sqlstr ne ''){
  • $sqlstr .= ";\n";
  • print SQLFILE $sqlstr;
  • &mdebug("export sql\n\t".$sqlstr);
  • }
  • close BINLOG or die "Can't close binlog file: $binlogfile";
  • close SQLFILE or die "Can't close out sql file: $outfile";
  • # 逆序
  • # 1!G: 只有第一行不执行G, 将hold space中的内容append回到pattern space
  • # h: 将pattern space 拷贝到hold space
  • # $!d: 除最后一行都删除
  • my $invert = "sed -i '1!G;h;\$!d' $outfile";
  • my $res = `$invert`;
  • &mdebug("inverter order sqlfile :$invert");
  • }
  • # ----------------------------------------------------------------------------------------
  • # Func : transfer column pos to name
  • #    deal column value
  • #
  • # &deal_col_value($tbname, $sqltype, $sqlarea, $isareabegin, $line);
  • # ----------------------------------------------------------------------------------------
  • sub deal_col_value($$$$$){
  • my ($tbname, $sqltype, $sqlarea, $isareabegin, $line) = @_;
  • &mdebug("$PRE_FUNCT deal_col_value");
  • &mdebug("input:tbname->$tbname,type->$sqltype,area->$sqlarea,areabegin->$isareabegin,line->$line");
  • my @vals = split(/=/, $line);
  • my $pos = substr($vals[0],1);
  • my $valstartpos = length($pos)+2;
  • my $val = substr($line,$valstartpos);
  • my %tbcol = %{$tbcol_pos{$tbname}};
  • my ($cname,$ctype) = split(/$SPLITER_COL/,$tbcol{$pos});
  • &merror("can't get $tbname column $cname type") unless (defined($cname) || defined($ctype));
  • &mdebug("column infor:cname->$cname,type->$ctype");
  • # join str
  • my $joinstr;
  • if ($isareabegin){
  • $joinstr = ' ';
  • }else{
  • # WHERE 被替换为 SET, 使用 , 连接
  • if ($sqlarea eq $SQLAREA_WHERE){
  • $joinstr = ', ';
  • # SET 被替换为 WHERE 使用 AND 连接
  • }elsif ($sqlarea eq $SQLAREA_SET){
  • $joinstr = ' AND ';
  • }else{
  • &merror("!!!!!!The scripts error");
  • }
  • }
  • #
  • my $newline = $joinstr;
  • # NULL value
  • if (($val eq 'NULL') && ($sqlarea eq $SQLAREA_SET)){
  • $newline .= qq{ $cname IS NULL};
  • }else{
  • # timestamp: record seconds
  • if ($ctype eq 'timestamp'){
  • $newline .= qq{$cname=from_unixtime($val)};
  • # datetime: @n=yyyy-mm-dd hh::ii::ss
  • }elsif ($ctype eq 'datetime'){
  • $newline .= qq{$cname='$val'};
  • }else{
  • $newline .= qq{$cname=$val};
  • }
  • }
  • &mdebug("\told>$line\n\tnew>$newline");
  • return $newline;
  • }
  • # ----------------------------------------------------------------------------------------
  • # Func : check is ignore table
  • # params: IN table full name # format:`dbname`.`tbname`
  • # RETURN：
  • #        0 not ignore
  • #        1 ignore
  • # ----------------------------------------------------------------------------------------
  • sub ignore_tb($){
  • my $fullname = shift;
  • # 删除`
  • $fullname =~ s/`//g;
  • my ($dbname,$tbname) = split(/\./,$fullname);
  • my $res = 0;
  • # 指定了数据库
  • if ($opt{'d'}){
  • # 与指定库相同
  • if ($do_dbs{$dbname}){
  • # 指定表
  • if ($opt{'T'}){
  • # 与指定表不同
  • unless ($do_tbs{$tbname}){
  • $res = 1;
  • }
  • }
  • # 与指定库不同
  • }else{
  • $res = 1;
  • }
  • }
  • #&mdebug("Table check ignore:$fullname->$res");
  • return $res;
  • }
  • # ----------------------------------------------------------------------------------------
  • # Func : print debug msg
  • # ----------------------------------------------------------------------------------------
  • sub mdebug{
  • my (@msg) = @_;
  • print "@msg\n" if ($opt{'debug'});
  • }
  • # ----------------------------------------------------------------------------------------
  • # Func : print error msg and exit
  • # ----------------------------------------------------------------------------------------
  • sub merror{
  • my (@msg) = @_;
  • print ":@msg\n";
  • &print_usage();
  • exit(1);
  • }
  • # ----------------------------------------------------------------------------------------
  • # Func : print usage
  • # ----------------------------------------------------------------------------------------
  • sub print_usage{
  • print <<EOF;
  • ==========================================================================================
  • Command line options :
  • --help                # OUT : print help info
  • -f, --srcfile            # IN : binlog file. [required]
  • -o, --outfile            # OUT : output sql file. [required]
  • -h, --host            # IN : host. default '127.0.0.1'
  • -u, --user            # IN : user. [required]
  • -p, --password            # IN : password. [required]
  • -P, --port            # IN : port. default '3306'
  • --start-datetime        # IN : start datetime
  • --stop-datetime            # IN : stop datetime
  • --start-position        # IN : start position
  • --stop-position            # IN : stop position
  • -d, --database            # IN : database, split comma
  • -T, --table            # IN : table, split comma. [required] set -d
  • -i, --ignore            # IN : ignore binlog check contain DDL(CREATE|ALTER|DROP|RENAME)
  • --debug                # IN : print debug information
  • Sample :
  • shell> perl binlog-rollback.pl -f 'mysql-bin.000001' -o '/tmp/t.sql' -u 'user' -p 'pwd'
  • shell> perl binlog-rollback.pl -f 'mysql-bin.000001' -o '/tmp/t.sql' -u 'user' -p 'pwd' -i
  • shell> perl binlog-rollback.pl -f 'mysql-bin.000001' -o '/tmp/t.sql' -u 'user' -p 'pwd' --debug
  • shell> perl binlog-rollback.pl -f 'mysql-bin.000001' -o '/tmp/t.sql' -h '192.168.1.2' -u 'user' -p 'pwd' -P 3307
  • shell> perl binlog-rollback.pl -f 'mysql-bin.000001' -o '/tmp/t.sql' -u 'user' -p 'pwd' --start-position=107
  • shell> perl binlog-rollback.pl -f 'mysql-bin.000001' -o '/tmp/t.sql' -u 'user' -p 'pwd' --start-position=107 --stop-position=10000
  • shell> perl binlog-rollback.pl -f 'mysql-bin.000001' -o '/tmp/t.sql' -u 'user' -p 'pwd' -d 'db1,db2'
  • shell> perl binlog-rollback.pl -f 'mysql-bin.0000*' -o '/tmp/t.sql' -u 'user' -p 'pwd' -d 'db1,db2' -T 'tb1,tb2'
  • ==========================================================================================
  • EOF
  • exit;
  • }
  • 1;

关于使用MySQL binlog对数据进行恢复的实战  http://www.linuxidc.com/Linux/2016-01/127808.htm

MySQL 5.6.12切换binlog二进制日志路径  http://www.linuxidc.com/Linux/2016-01/126979.htm

mysqlbinlog解析binlog乱码问题解密  http://www.linuxidc.com/Linux/2016-01/126978.htm

MySQL通过binlog来恢复数据  http://www.linuxidc.com/Linux/2015-12/126897.htm

MySQL binlog 组提交与 XA(两阶段提交)  http://www.linuxidc.com/Linux/2015-11/124942.htm

MySQL使用备份和binlog进行数据恢复 http://www.linuxidc.com/Linux/2014-12/110875.htm

本文永久更新链接地址：http://www.linuxidc.com/Linux/2016-01/128006.htm

转载于:https://www.cnblogs.com/tpshop/p/7209711.html

MySQL在ROW模式下通过binlog提取SQL语句相关推荐

  1. MySQL 【Row】下的 Event_type

    在主库上执行一条 SQL [insert... select... ] 语句,导致从库延迟,以前执行都不会出现延迟的,肯定有蹊跷.所以当时就在从上执行 [show slave status\G;] 查 ...

  2. mysql实现文章上一篇下一篇的sql语句

    转载:http://www.111cn.net/database/mysql/66709.htm 在mysql中查查询上一篇与下一篇只需要对数据进行按id排序之后,然后我们再进行asc或者desc最当 ...

  3. cmd执行服务器sql文件命令行,Dos命令提示符下 - 用sqlcmd执行*.sql语句

    Dos命令提示符下 - 用sqlcmd执行*.sql语句 1)在Dos命令下执行sqlcmd命令(当然事先需要将sqlcmd增加到环境变量中去), 2)下面白色部分替换为服务器名或计算机名即可 sql ...

  4. sql linux 160天,Ubuntu下用脚本执行sql语句（sqlite）

    这里将告诉您Ubuntu下用脚本执行sql语句(sqlite),具体操作过程: 1.环境准备,安装sqlite3软件 sudo apt-get install sqlite3 2.编写sql执行脚本( ...

  5. 在mysql中更新数据sql语句怎么写_在MySQL中，更新数据库表记录的SQL语句，包括______语句...

    在MySQL中,更新数据库表记录的SQL语句,包括______语句 答:insert replace update delete 在域F中,设其特征为2,对于任意a,b∈F,则(a+b)2 等于多少 ...

  6. mysql开启row模式_MySQL Binlog Mixed模式记录成Row格式

    binlog format有三种形式:Statement.Mixed.Row,具体的信息可以自行到网上搜查. 分析(本文碰到的案例): 查看MySQL binlog formatdba@192.168 ...

  7. mysql同步row模式_ROW模式的SQL无法正常同步的问题总结

    ROW模式的SQL无法正常同步的问题总结 最近处理数据库问题时遇到一起mysql从机ROW模式的SQL无法正常同步的问题,今天刚好有时间,将整个过程总结一下,方便后面的同学学习! 一.问题起因 最近有 ...

  8. 数据存取演变史、数据库软件应用史、数据库的本质、分类、 MySQL数据库、系统服务制作、基本的SQL语句

    数据存取演变史 1.文本文件 文本文件有两个主要的缺点:第一个就是不能保证多用户存取的文件路径一致:第二个就是不能保证多用户存取的数据格式一致 2.软件开发目录规范 软件开发目录规范规定了数据文件的大 ...

  9. MySQL的基础架构以及一条查询sql语句的执行流程

    详细介绍了Mysql的基础架构以及一条查询sql的执行流程. 如果不想作为一个只能简单的写写sql工程师,而是想要深入的学习MySQL,那么我们有必要首先从宏观的角度来了解MySQL的整体架构,只有把 ...

最新文章

  1. linux学习中遇到的各种故障与解决方法
  2. 当 RocketMQ 遇上 Serverless，会碰撞出怎样的火花？
  3. 简单的计时器实现（JFrame）
  4. d3.js实现隐藏部分关系
  5. 命令行开启windows下的iis信息服务，开启及配置http端口，开启及配置ftp端口
  6. java网络编程1、2章习题
  7. python switch语句_几个Python里的骚操作
  8. mysql swarm_【Docker】 Swarm简单介绍
  9. linux 系统lv扩展_Filecoin 运维(1) 几个常用的系统配置
  10. php 微信表情字符,微信公众平台开发--表情符号
  11. 2015-5-10分享的PDF
  12. c语言接收rs232串口速率,基于C语言的RS232串行接口通信实现
  13. 相控阵天线方位角俯仰角matlab画图,理解相控阵天线的方向图
  14. 算法基础 计算机数学课件,第4章计算机制图数学基础_中国地质大学：数字测图_ppt_大学课件预览_高等教育资讯网...
  15. 第六周助教工作总结——NWNU李泓毅
  16. 想成为游戏原画师需要哪些系统的学习？
  17. mybatis中使用DATE_SUB()函数实现网站访问量日，月，年统计
  18. php如何ping域名的ip,使用PHP ping域名或IP
  19. windows 10 安装 jdk15 教程
  20. python黑马教程ppt_,python基础教程 PPT

热门文章

  1. Traffic Ccontrol(流量控制)
  2. 手机摇一摇效果-html5
  3. SybaseIQ - 建库、建表、启动
  4. 自由主义者的周一和周五
  5. Objective-C 2.0属性(Property)介绍
  6. 在ThinkPad W500 A98上升级Windows 7以及安装硬件驱动和相关程序(2/2)
  7. flutter集成oc
  8. react native release语法问题解决
  9. android实现多画面播放,可无缝切换小窗/全屏的android播放器实现
  10. iOS10 UI教程视图的几何形状