备案控制台
探索云世界
开发者社区 数据库 文章 正文

MariaDB的闪回flashback尝试

2019-02-28 4597
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL Serverless，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
简介： 测试背景 MariaDB是MySQL的分支，使用也是越来越广泛。闪回是对误操作最大的福音，本文是用来测试MariaDB支持的闪回功能 测试环境 MariaDB 10.2.22 CentOS 7.

测试背景

MariaDB是MySQL的分支，使用也是越来越广泛。闪回是对误操作最大的福音，本文是用来测试MariaDB支持的闪回功能

测试环境

  • MariaDB 10.2.22
  • CentOS 7.4
  • mysqlbinlog工具

测试要求

  • binlog_format=ROW
  • binlog_row_image=FULL
  • DML操作（INSERT, DELETE, UPDATE）

测试步骤

[root@mariadb ~]# mysqlbinlog --help | grep flashback
  -B, --flashback     Flashback feature can rollback you committed data to a special time point.

MariaDB [testdb]> select now();create table test ( id int primary key, name varchar(20) );           
+---------------------+
| now()               |
+---------------------+
| 2019-02-28 10:06:47 |
+---------------------+
1 row in set (0.00 sec)

Query OK, 0 rows affected (0.12 sec)

MariaDB [testdb]> select now();insert into test values(1,'lei'),(2,'liu'),(3,'chen');                                 
+---------------------+
| now()               |
+---------------------+
| 2019-02-28 10:07:00 |
+---------------------+
1 row in set (0.00 sec)

Query OK, 3 rows affected (0.46 sec)
Records: 3  Duplicates: 0  Warnings: 0

MariaDB [testdb]> select now();create table test2 ( id int primary key, name varchar(20) );                  
+---------------------+
| now()               |
+---------------------+
| 2019-02-28 10:07:22 |
+---------------------+
1 row in set (0.00 sec)

Query OK, 0 rows affected (0.13 sec)

MariaDB [testdb]> select now();insert into test2 values(4,'lei'),(5,'liu'),(6,'chen'); 
+---------------------+
| now()               |
+---------------------+
| 2019-02-28 10:07:43 |
+---------------------+
1 row in set (0.00 sec)

Query OK, 3 rows affected (0.11 sec)
Records: 3  Duplicates: 0  Warnings: 0

查看闪回单库（所有表）信息

[root@mariadb ~]# mysqlbinlog -vv --start-datetime='2019-02-28 10:06:40' -B -d testdb  /var/lib/mysql/archive/mysql-bin.000001 > /root/flushback-all.sql    
Warning: mysqlbinlog: unknown variable 'loose_default-character-set=utf8'

[root@mariadb ~]# cat flushback-all.sql 
/*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=1*/;
/*!40019 SET @@session.max_insert_delayed_threads=0*/;
/*!50003 SET @OLD_COMPLETION_TYPE=@@COMPLETION_TYPE,COMPLETION_TYPE=0*/;
DELIMITER /*!*/;
#190228 10:06:33 server id 3306102  end_log_pos 256 CRC32 0xf870631d    Start: binlog v 4, server v 10.2.22-MariaDB-log created 190228 10:06:33 at startup
# Warning: this binlog is either in use or was not closed properly.
ROLLBACK/*!*/;
BINLOG '
KUJ3XA92cjIA/AAAAAABAAABAAQAMTAuMi4yMi1NYXJpYURCLWxvZwAAAAAAAAAAAAAAAAAAAAAA
AAAAAAAAAAAAAAAAAAApQndcEzgNAAgAEgAEBAQEEgAA5AAEGggAAAAICAgCAAAACgoKAAAAAAAA
AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
AAAAAAAAAAAEEwQADQgICAoKCgEdY3D4
'/*!*/;
#190228 10:07:00 server id 3306102  end_log_pos 620 CRC32 0x0270792a    Annotate_rows:
**这里显示的是原SQL**
#Q> insert into test values(1,'lei'),(2,'liu'),(3,'chen')
#190228 10:07:00 server id 3306102  end_log_pos 672 CRC32 0x7ea7d664    Table_map: `testdb`.`test` mapped to number 26
#190228 10:07:43 server id 3306102  end_log_pos 1058 CRC32 0x538d2013   Annotate_rows:
**这里显示的是原SQL**
#Q> insert into test2 values(4,'lei'),(5,'liu'),(6,'chen')
#190228 10:07:43 server id 3306102  end_log_pos 1111 CRC32 0x945d77fc   Table_map: `testdb`.`test2` mapped to number 28
#190228 10:07:43 server id 3306102  end_log_pos 1203 CRC32 0x9ca76eb2   Xid = 139
BEGIN/*!*/;
#190228 10:07:43 server id 3306102  end_log_pos 1172 CRC32 0x310419eb   Delete_rows: table id 28 flags: STMT_END_F

BINLOG '
b0J3XBN2cjIANQAAAFcEAAAAABwAAAAAAAEABnRlc3RkYgAFdGVzdDIAAgMPAjwAAvx3XZQ=
b0J3XBl2cjIAPQAAAJQEAAAAABwAAAAAAAEAAv/8BgAAAARjaGVu/AUAAAADbGl1/AQAAAADbGVp
6xkEMQ==
'/*!*/;
**这里显示的是回滚SQL**
### DELETE FROM `testdb`.`test2`
### WHERE
###   @1=6 /* INT meta=0 nullable=0 is_null=0 */
###   @2='chen' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
### DELETE FROM `testdb`.`test2`
### WHERE
###   @1=5 /* INT meta=0 nullable=0 is_null=0 */
###   @2='liu' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
### DELETE FROM `testdb`.`test2`
### WHERE
###   @1=4 /* INT meta=0 nullable=0 is_null=0 */
###   @2='lei' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
COMMIT
/*!*/;
#190228 10:07:22 server id 3306102  end_log_pos 939 CRC32 0xaacc45b2    Query   thread_id=16    exec_time=0     error_code=0
SET TIMESTAMP=1551319642/*!*/;
#190228 10:07:00 server id 3306102  end_log_pos 764 CRC32 0x3fb04d27    Xid = 132
BEGIN/*!*/;
#190228 10:07:00 server id 3306102  end_log_pos 733 CRC32 0x221071e2    Delete_rows: table id 26 flags: STMT_END_F

BINLOG '
REJ3XBN2cjIANAAAAKACAAAAABoAAAAAAAEABnRlc3RkYgAEdGVzdAACAw8CPAACZNanfg==
REJ3XBl2cjIAPQAAAN0CAAAAABoAAAAAAAEAAv/8AwAAAARjaGVu/AIAAAADbGl1/AEAAAADbGVp
4nEQIg==
'/*!*/;
### DELETE FROM `testdb`.`test`
### WHERE
###   @1=3 /* INT meta=0 nullable=0 is_null=0 */
###   @2='chen' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
### DELETE FROM `testdb`.`test`
### WHERE
###   @1=2 /* INT meta=0 nullable=0 is_null=0 */
###   @2='liu' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
### DELETE FROM `testdb`.`test`
### WHERE
###   @1=1 /* INT meta=0 nullable=0 is_null=0 */
###   @2='lei' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
COMMIT
/*!*/;
#190228 10:06:47 server id 3306102  end_log_pos 502 CRC32 0xbd5d94cf    Query   thread_id=16    exec_time=0     error_code=0
use `testdb`/*!*/;
SET TIMESTAMP=1551319607/*!*/;
SET @@session.pseudo_thread_id=16/*!*/;
SET @@session.foreign_key_checks=1, @@session.sql_auto_is_null=0, @@session.unique_checks=1, @@session.autocommit=1, @@session.check_constraint_checks=1/*!*/;
SET @@session.sql_mode=1411383296/*!*/;
SET @@session.auto_increment_increment=2, @@session.auto_increment_offset=2/*!*/;
/*!\C utf8 *//*!*/;
SET @@session.character_set_client=33,@@session.collation_connection=33,@@session.collation_server=83/*!*/;
SET @@session.lc_time_names=0/*!*/;
SET @@session.collation_database=DEFAULT/*!*/;
COMMIT
/*!*/;
DELIMITER ;
# End of log file
ROLLBACK /* added by mysqlbinlog */;
/*!50003 SET COMPLETION_TYPE=@OLD_COMPLETION_TYPE*/;
/*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=0*/;

查看闪回单表信息

[root@mariadb ~]# mysqlbinlog -vv --start-datetime='2019-02-28 10:06:40' -B -d testdb -T test /var/lib/mysql/archive/mysql-bin.000001 > /root/flushback-test.sql

[root@mariadb ~]# cat flushback-test.sql 
/*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=1*/;
/*!40019 SET @@session.max_insert_delayed_threads=0*/;
/*!50003 SET @OLD_COMPLETION_TYPE=@@COMPLETION_TYPE,COMPLETION_TYPE=0*/;
DELIMITER /*!*/;
#190228 10:06:33 server id 3306102  end_log_pos 256 CRC32 0xf870631d    Start: binlog v 4, server v 10.2.22-MariaDB-log created 190228 10:06:33 at startup
# Warning: this binlog is either in use or was not closed properly.
ROLLBACK/*!*/;
BINLOG '
KUJ3XA92cjIA/AAAAAABAAABAAQAMTAuMi4yMi1NYXJpYURCLWxvZwAAAAAAAAAAAAAAAAAAAAAA
AAAAAAAAAAAAAAAAAAApQndcEzgNAAgAEgAEBAQEEgAA5AAEGggAAAAICAgCAAAACgoKAAAAAAAA
AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
AAAAAAAAAAAEEwQADQgICAoKCgEdY3D4
'/*!*/;
#190228 10:07:00 server id 3306102  end_log_pos 620 CRC32 0x0270792a    Annotate_rows:
#Q> insert into test values(1,'lei'),(2,'liu'),(3,'chen')
#190228 10:07:00 server id 3306102  end_log_pos 672 CRC32 0x7ea7d664    Table_map: `testdb`.`test` mapped to number 26
#190228 10:07:43 server id 3306102  end_log_pos 1203 CRC32 0x9ca76eb2   Xid = 139
BEGIN/*!*/;
COMMIT
/*!*/;
#190228 10:07:22 server id 3306102  end_log_pos 939 CRC32 0xaacc45b2    Query   thread_id=16    exec_time=0     error_code=0
SET TIMESTAMP=1551319642/*!*/;
#190228 10:07:00 server id 3306102  end_log_pos 764 CRC32 0x3fb04d27    Xid = 132
BEGIN/*!*/;
#190228 10:07:00 server id 3306102  end_log_pos 733 CRC32 0x221071e2    Delete_rows: table id 26 flags: STMT_END_F

BINLOG '
REJ3XBN2cjIANAAAAKACAAAAABoAAAAAAAEABnRlc3RkYgAEdGVzdAACAw8CPAACZNanfg==
REJ3XBl2cjIAPQAAAN0CAAAAABoAAAAAAAEAAv/8AwAAAARjaGVu/AIAAAADbGl1/AEAAAADbGVp
4nEQIg==
'/*!*/;
### DELETE FROM `testdb`.`test`
### WHERE
###   @1=3 /* INT meta=0 nullable=0 is_null=0 */
###   @2='chen' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
### DELETE FROM `testdb`.`test`
### WHERE
###   @1=2 /* INT meta=0 nullable=0 is_null=0 */
###   @2='liu' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
### DELETE FROM `testdb`.`test`
### WHERE
###   @1=1 /* INT meta=0 nullable=0 is_null=0 */
###   @2='lei' /* VARSTRING(60) meta=60 nullable=1 is_null=0 */
COMMIT
/*!*/;
#190228 10:06:47 server id 3306102  end_log_pos 502 CRC32 0xbd5d94cf    Query   thread_id=16    exec_time=0     error_code=0
use `testdb`/*!*/;
SET TIMESTAMP=1551319607/*!*/;
SET @@session.pseudo_thread_id=16/*!*/;
SET @@session.foreign_key_checks=1, @@session.sql_auto_is_null=0, @@session.unique_checks=1, @@session.autocommit=1, @@session.check_constraint_checks=1/*!*/;
SET @@session.sql_mode=1411383296/*!*/;
SET @@session.auto_increment_increment=2, @@session.auto_increment_offset=2/*!*/;
/*!\C utf8 *//*!*/;
SET @@session.character_set_client=33,@@session.collation_connection=33,@@session.collation_server=83/*!*/;
SET @@session.lc_time_names=0/*!*/;
SET @@session.collation_database=DEFAULT/*!*/;
COMMIT
/*!*/;
DELIMITER ;
# End of log file
ROLLBACK /* added by mysqlbinlog */;
/*!50003 SET COMPLETION_TYPE=@OLD_COMPLETION_TYPE*/;
/*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=0*/;

恢复操作

[root@mariadb ~]# mysql -uroot -pabc123 < flushback-all.sql 

[root@mariadb ~]# mysql -uroot -pabc123

MariaDB [test]> use testdb
Database changed

MariaDB [testdb]> select * from test;
Empty set (0.00 sec)

MariaDB [testdb]> select * from test2;
Empty set (0.00 sec)

总结

  • MariaDB在10.2.4以上的版本中加入了flashback功能，但是只是针对于DML操作，原理和binlog2sql类似，但是劣势是拥有一定的局限性，优势自然是不需要额外下载软件了
  • 如果我们明确知道回滚的binlog的pos位点，可以使用--start-position生成回滚SQL
  • 使用mysqld启动MariaDB时，加上--flashback选项是代表开启binlog和binlog_format=ROW
文章标签：
云数据库 RDS MySQL 版
关系型数据库
测试技术
SQL
MySQL
相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境，其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
powdba
目录
相关文章
xmlgrg163
|
4月前
|
关系型数据库 MySQL 数据库
xtrabackup 备份还原mysql
通过使用xtrabackup 备份还原mysql数据库
xmlgrg163
42 3
游客ukwzoy5flgnti
|
11月前
|
SQL 存储 算法
Online DDL MySQL&MariaDB
本文主要对Mariadb和MySQL对Online DDL的支持情况做一个对比，方便读者随时参考。MariaDB 10.8引入了Lag Free Alter这个新特性，该特性主要是为了降低DDL引起的复制延迟，本文也给出了MariaDB 对不同DDL，lag free alter的支持情况。Mariadb Online DDL当用户通过ALGORITHM 参数为DDL指定执行算法时，如果用户指定算
游客ukwzoy5flgnti
173 0
MySQL技术
|
SQL 关系型数据库 MySQL
【MySQL】mysqlbinlog_flashback工具使用
mysqlbinlog_back.py 是在线读取row格式的mysqld的binlog,然后生成反向的sql语句的工具。 一般用于数据恢复的目的。 所谓反向的sql语句就是如果是insert，则反向的sql为delete。 如果delete,反向的sql是insert,如果是update, 反向的sql还是update,但是update的值是原来的值。
MySQL技术
167 0
【MySQL】mysqlbinlog_flashback工具使用
刘小四
|
关系型数据库 MySQL 数据库
MySQL-Xtrabackup备份还原
前言 通常我们都是使用xtrabackup工具来备份数据库，它是一个专业的备份工具，先来简单介绍下它。 Xtrabackup percona提供的mysql数据库备份工具，惟一开源的能够对innodb和xtradb数据库，它的增量备份不是基于二进制日志文件来还原数据的，是基于mysql数据块。
刘小四
1771 0
powdba
|
SQL 算法 关系型数据库
MySQL 5.7 online ddl的一些改进
MySQL DBA应该都知道，数据库操作里面，DDL操作（比如CREATE，DROP，ALTER等）代价是非常高的，特别是在单表上千万的情况下，加个索引或改个列类型，就有可能堵塞整个表的读写。 从MySQL 5.6开始，大家期待的Online DDL出现了，可以实现修改表结构的同时，依然允许DML操作（select,insert,update,delete）。
powdba
14226 0
技术小能手
|
SQL 关系型数据库 索引
不用MariaDB/Percona也能查看DDL的进度
如何查看DDL的进度？ 使用MariaDB/Percona版本的一个便利之处就是可以及时查看DDL的进度，进而预估DDL耗时。 其实，在官方版本里也是可以查看DDL进度的，认真看手册的同学就能发现手册中有提到过： You can monitor ALTER TABLE progress for InnoDB tables using Performance Schema. 应该怎么做呢，我们来大概说下。
技术小能手
4010 0
关尚
|
MySQL 关系型数据库
MyFlash MySQL闪回工具
由于运维、DBA的误操作或是业务bug，我们在操作中时不时会出现误删除数据情况。早期要想恢复数据，只能让业务人员根据线上操作日志，构造误删除的数据，或者DBA使用binlog和备份的方式恢复数据，不管那种，都非常费时费力，而且容易出错。
关尚
11298 0
科技小先锋
|
SQL 监控 关系型数据库
mariadb二进制日志和备份恢复
科技小先锋
1267 0
技术小美
|
数据库 内存技术 关系型数据库
Flashback Database 闪回数据库
技术小美
1131 0
科技小先锋
|
存储 缓存 关系型数据库
MariaDB三之DDL，DML的应用
科技小先锋
1102 0
为什么选择阿里云什么是云计算全球基础设施技术领先稳定可靠安全合规分析师报告
产品和定价全部产品免费试用产品动态产品定价价格计算器云上成本管理
解决方案技术解决方案
文档与社区文档开发者社区天池大赛培训与认证
权益中心免费试用高校计划企业扶持计划推荐返现计划
支持与服务基础服务企业增值服务迁云服务官网公告健康看板信任中心
关注阿里云
关注阿里云公众号或下载阿里云APP，关注云资讯，随时随地运维管控云服务
阿里云APP阿里云微信
联系我们：4008013260
法律声明Cookies政策廉正举报安全举报联系我们加入我们
阿里巴巴集团淘宝网天猫全球速卖通阿里巴巴国际交易市场1688阿里妈妈飞猪阿里云计算AliOS万网高德UC友盟优酷钉钉支付宝达摩院淘宝海外阿里云盘饿了么
© 2009-2024 Aliyun.com 版权所有 增值电信业务经营许可证： 浙B2-20080101 域名注册服务机构许可： 浙D3-20210002 京D3-20220015
浙公网安备 33010602009975号浙B2-20080101-4