1. 程式人生 > >mysql update忘加where條件的操作恢復(模擬oracle閃回)

mysql update忘加where條件的操作恢復(模擬oracle閃回)


先準備資料:

CREATE TABLE `student` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(10) NOT NULL DEFAULT '',
  `class` varchar(10) NOT NULL DEFAULT '',
  `score` int(3) NOT NULL DEFAULT 0,
  PRIMARY KEY (`id`),
  KEY `name` (`name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

(product)[email protected]

[test]> select * from student;
+----+------+-------+-------+
| id | name | class | score |
+----+------+-------+-------+
|  1 | a    | 1     |    56 |
|  2 | b    | 1     |    61 |
|  3 | c    | 2     |    78 |
|  4 | d    | 2     |    45 |
|  5 | e    | 3     |    76 |
|  6 | f    | 3     |    89 |
|  7 | g    | 4     |    43 |
|  8 | h    | 4     |    90 |
+----+------+-------+-------+
8 rows in set (0.00 sec)

在執行操作時,忘記帶了where條件了,如下:

(product)[email protected] [test]> update student set score=0;
Query OK, 8 rows affected (0.00 sec)
Rows matched: 8  Changed: 8  Warnings: 0

(product)[email protected] [test]> select * from student;
+----+------+-------+-------+
| id | name | class | score |
+----+------+-------+-------+
|  1 | a    | 1     |     0 |
|  2 | b    | 1     |     0 |
|  3 | c    | 2     |     0 |
|  4 | d    | 2     |     0 |
|  5 | e    | 3     |     0 |
|  6 | f    | 3     |     0 |
|  7 | g    | 4     |     0 |
|  8 | h    | 4     |     0 |
+----+------+-------+-------+
8 rows in set (0.00 sec)

結果,整個表的記錄都更新成0(0表示不記格);

下面開始恢復:
先建一個普通許可權的帳號(不能是super許可權):
grant all privileges on test.* to 'readonly'@'%' identified by '123456';

把read only開啟,設定資料庫只讀,如下:

set global read_only=1;

把readonly帳號給運維前端人員,讓他們將前端應用中的用名改下,並重啟應用,現在對資料庫都是隻讀訪問了。

通過binlog先找到那條語句:
-bash-4.1$ mysqlbinlog --no-defaults -v -v --base64-output=decode-rows mysql-bin.000143|grep -B 15 '@4=0'|more
# update student set score=0
# at 15119746
#160828  6:50:00 server id 65303306  end_log_pos 15119803 CRC32 0x991b4161      Table_map: `test`.`student` mapped to number 111
# at 15119803
#160828  6:50:00 server id 65303306  end_log_pos 15120047 CRC32 0x36d5c3e2      Update_rows: table id 111 flags: STMT_END_F
### UPDATE `test`.`student`
### WHERE
###   @1=1 /* INT meta=0 nullable=0 is_null=0 */
###   @2='a' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=56 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=1 /* INT meta=0 nullable=0 is_null=0 */
###   @2='a' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=2 /* INT meta=0 nullable=0 is_null=0 */
###   @2='b' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=61 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=2 /* INT meta=0 nullable=0 is_null=0 */
###   @2='b' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=3 /* INT meta=0 nullable=0 is_null=0 */
###   @2='c' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='2' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=78 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=3 /* INT meta=0 nullable=0 is_null=0 */
###   @2='c' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='2' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=4 /* INT meta=0 nullable=0 is_null=0 */
###   @2='d' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='2' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=45 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=4 /* INT meta=0 nullable=0 is_null=0 */
###   @2='d' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='2' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=5 /* INT meta=0 nullable=0 is_null=0 */
###   @2='e' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='3' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=76 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=5 /* INT meta=0 nullable=0 is_null=0 */
###   @2='e' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='3' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=6 /* INT meta=0 nullable=0 is_null=0 */
###   @2='f' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='3' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=89 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=6 /* INT meta=0 nullable=0 is_null=0 */
###   @2='f' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='3' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=7 /* INT meta=0 nullable=0 is_null=0 */
###   @2='g' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='4' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=43 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=7 /* INT meta=0 nullable=0 is_null=0 */
###   @2='g' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='4' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=8 /* INT meta=0 nullable=0 is_null=0 */
###   @2='h' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='4' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=90 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=8 /* INT meta=0 nullable=0 is_null=0 */
###   @2='h' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='4' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */

把binlog匯出來:
mysqlbinlog --no-defaults -v -v --base64-output=decode-rows mysql-bin.000143|sed -n '/# at 15119803/,/COMMIT/p' >/data/mysql/mysql3306/logs/1.sql

-bash-4.1$ more /data/mysql/mysql3306/logs/1.sql
# at 15119803
#160828  6:50:00 server id 65303306  end_log_pos 15120047 CRC32 0x36d5c3e2      Update_rows: table id 111 flags: STMT_END_F
### UPDATE `test`.`student`
### WHERE
###   @1=1 /* INT meta=0 nullable=0 is_null=0 */
###   @2='a' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=56 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=1 /* INT meta=0 nullable=0 is_null=0 */
###   @2='a' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=2 /* INT meta=0 nullable=0 is_null=0 */
###   @2='b' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=61 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=2 /* INT meta=0 nullable=0 is_null=0 */
###   @2='b' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=3 /* INT meta=0 nullable=0 is_null=0 */
###   @2='c' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='2' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=78 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=3 /* INT meta=0 nullable=0 is_null=0 */
###   @2='c' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='2' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=4 /* INT meta=0 nullable=0 is_null=0 */
###   @2='d' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='2' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=45 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=4 /* INT meta=0 nullable=0 is_null=0 */
###   @2='d' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='2' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=5 /* INT meta=0 nullable=0 is_null=0 */
###   @2='e' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='3' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=76 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=5 /* INT meta=0 nullable=0 is_null=0 */
###   @2='e' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='3' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=6 /* INT meta=0 nullable=0 is_null=0 */
###   @2='f' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='3' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=89 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=6 /* INT meta=0 nullable=0 is_null=0 */
###   @2='f' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='3' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=7 /* INT meta=0 nullable=0 is_null=0 */
###   @2='g' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='4' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=43 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=7 /* INT meta=0 nullable=0 is_null=0 */
###   @2='g' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='4' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
### UPDATE `test`.`student`
### WHERE
###   @1=8 /* INT meta=0 nullable=0 is_null=0 */
###   @2='h' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='4' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=90 /* INT meta=0 nullable=0 is_null=0 */
### SET
###   @1=8 /* INT meta=0 nullable=0 is_null=0 */
###   @2='h' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='4' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */
# at 15120047
#160828  6:50:00 server id 65303306  end_log_pos 15120078 CRC32 0x2d1407ee      Xid = 26350746
COMMIT/*!*/;
這些是誤操作前的資料:
###   @1=1 /* INT meta=0 nullable=0 is_null=0 */
###   @2='a' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=56 /* INT meta=0 nullable=0 is_null=0 */
這些是誤操作後的資料:
###   @1=1 /* INT meta=0 nullable=0 is_null=0 */
###   @2='a' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @3='1' /* VARSTRING(30) meta=30 nullable=0 is_null=0 */
###   @4=0 /* INT meta=0 nullable=0 is_null=0 */

這裡 @1、@2、@3、@4對應表的欄位分別是id、name、class、score,下面進一步做恢復操作。
cd /data/mysql/mysql3306/logs
sed '/WHERE/{:a;N;/SET/!ba;s/\([^\n]*\)\n\(.*\)\n\(.*\)/\3\n\2\n\1/}' 1.sql | sed -r '/WHERE/{:a;N;/@4/!ba;s/###   @2.*//g}'|sed 's/### //g;s/\/\*.*/,/g'
| sed '/WHERE/{:a;N;/@1/!ba;s/,/;/g};s/#.*//g;s/COMMIT,//g' | sed '/^$/d' > recover.sql
-bash-4.1$ more recover.sql
UPDATE `test`.`student`
SET
  @1=1 ,
  @2='a' ,
  @3='1' ,
  @4=56 ,
WHERE
  @1=1 ;
UPDATE `test`.`student`
SET
  @1=2 ,
  @2='b' ,
  @3='1' ,
  @4=61 ,
WHERE
  @1=2 ;
UPDATE `test`.`student`
SET
  @1=3 ,
  @2='c' ,
  @3='2' ,
  @4=78 ,
WHERE
  @1=3 ;
UPDATE `test`.`student`
SET
  @1=4 ,
  @2='d' ,
  @3='2' ,
  @4=45 ,
.........

sed '/WHERE/{:a;N;/SET/!ba;s/\([^\n]*\)\n\(.*\)\n\(.*\)/\3\n\2\n\1/}' 1.sql | sed -r '/WHERE/{:a;N;/@4/!ba;s/###   @2.*//g}'|sed 's/### //g;s/\/\*.*/,/g'
| sed '/WHERE/{:a;N;/@1/!ba;s/,/;/g};s/#.*//g;s/COMMIT,//g' | sed '/^$/d'命令分段說明一下作用:

sed '/WHERE/{:a;N;/SET/!ba;s/\([^\n]*\)\n\(.*\)\n\(.*\)/\3\n\2\n\1/}' 1.sql ---是將WHERE和SET互相對調
sed -r '/WHERE/{:a;N;/@4/!ba;s/###   @2.*//g}'---去掉where條件後的@2到@4行,只留@1那行
sed '/WHERE/{:a;N;/@1/!ba;s/,/;/g};s/#.*//g;s/COMMIT,//g' ---將欄位後的,號用;號替換,將#號開頭的行用空替換
sed '/^$/d' ---刪除空行

 再把@1、@2、@3、@4對應表的欄位分別用id、name、class、score替換:
sed -i 's/@1/id/g;s/@2/name/g;s/@3/class/g;s/@4/score/g' recover.sql
再將最後一個欄位後的,號去掉:
sed -i -r 's/(score=.*),/\1/g' recover.sql

-bash-4.1$ cat recover.sql
UPDATE `test`.`student`
SET
  id=1 ,
  name='a' ,
  class='1' ,
  score=56
WHERE
  id=1 ;
UPDATE `test`.`student`
SET
  id=2 ,
  name='b' ,
  class='1' ,
  score=61
WHERE
  id=2 ;
UPDATE `test`.`student`
SET
  id=3 ,
  name='c' ,
  class='2' ,
  score=78
WHERE
  id=3 ;
UPDATE `test`.`student`
SET
  id=4 ,
  name='d' ,
  class='2' ,
  score=45
WHERE
  id=4 ;
UPDATE `test`.`student`
SET
  id=5 ,
  name='e' ,
  class='3' ,
  score=76
WHERE
  id=5 ;
UPDATE `test`.`student`
SET
  id=6 ,
  name='f' ,
  class='3' ,
  score=89
WHERE
  id=6 ;
UPDATE `test`.`student`
SET
  id=7 ,
  name='g' ,
  class='4' ,
  score=43
WHERE
  id=7 ;
UPDATE `test`.`student`
SET
  id=8 ,
  name='h' ,
  class='4' ,
  score=90
WHERE
  id=8 ;

下面進行恢復操作:
(product)[email protected] [test]> select * from student;
+----+------+-------+-------+
| id | name | class | score |
+----+------+-------+-------+
|  1 | a    | 1     |     0 |
|  2 | b    | 1     |     0 |
|  3 | c    | 2     |     0 |
|  4 | d    | 2     |     0 |
|  5 | e    | 3     |     0 |
|  6 | f    | 3     |     0 |
|  7 | g    | 4     |     0 |
|  8 | h    | 4     |     0 |
+----+------+-------+-------+
8 rows in set (0.00 sec)
(product)[email protected] [(none)]> use test
Database changed
(product)[email protected] [test]> source recover.sql
Query OK, 1 row affected (0.00 sec)
Rows matched: 1  Changed: 1  Warnings: 0

Query OK, 1 row affected (0.00 sec)
Rows matched: 1  Changed: 1  Warnings: 0

Query OK, 1 row affected (0.00 sec)
Rows matched: 1  Changed: 1  Warnings: 0

Query OK, 1 row affected (0.00 sec)
Rows matched: 1  Changed: 1  Warnings: 0

Query OK, 1 row affected (0.00 sec)
Rows matched: 1  Changed: 1  Warnings: 0

Query OK, 1 row affected (0.01 sec)
Rows matched: 1  Changed: 1  Warnings: 0

Query OK, 1 row affected (0.00 sec)
Rows matched: 1  Changed: 1  Warnings: 0

Query OK, 1 row affected (0.00 sec)
Rows matched: 1  Changed: 1  Warnings: 0

(product)[email protected] [test]> select * from student;
+----+------+-------+-------+
| id | name | class | score |
+----+------+-------+-------+
|  1 | a    | 1     |    56 |
|  2 | b    | 1     |    61 |
|  3 | c    | 2     |    78 |
|  4 | d    | 2     |    45 |
|  5 | e    | 3     |    76 |
|  6 | f    | 3     |    89 |
|  7 | g    | 4     |    43 |
|  8 | h    | 4     |    90 |
+----+------+-------+-------+

被錯誤更新的資料已找回來了。