PingKai Logo下载

FLASHBACK CLUSTER

TiDB v6.4.0 引入了 FLASHBACK CLUSTER TO TIMESTAMP 语法。你可以使用该语法将集群恢复到某个特定的时间点。在指定时间戳时,你可以设置一个 datetime 值或使用时间函数。datetime 的格式类似于 '2016-10-08 16:45:26.999',最小时间单位为毫秒。但在大多数情况下,指定以秒为单位的时间戳就足够了,例如 '2016-10-08 16:45:26'。

从 v6.5.6、v7.1.3、v7.5.1 和 v7.6.0 开始,TiDB 引入了 FLASHBACK CLUSTER TO TSO 语法。该语法允许你使用 TSO 来指定更精确的数据恢复时间点,从而提升数据恢复的灵活性。

语法

FLASHBACK CLUSTER TO TIMESTAMP '2022-09-21 16:02:50';
FLASHBACK CLUSTER TO TSO 445494839813079041;

语法说明

FlashbackToTimestampStmt
FLASHBACK CLUSTER TO TIMESTAMP stringLit TSO LengthNum

注意事项

  • FLASHBACK 语句中指定的时间必须在垃圾回收(GC)生命周期内。系统变量 tidb_gc_life_time(默认值:10m0s)定义了行的历史版本的保留时间。可以通过以下查询获取当前垃圾回收已执行到的 safePoint:

    SELECT * FROM mysql.tidb WHERE variable_name = 'tikv_gc_safe_point';
  • 只有拥有 SUPER 权限的用户才能执行 FLASHBACK CLUSTER SQL 语句。
  • FLASHBACK CLUSTER 不支持回滚修改 PD 相关信息的 DDL 语句,如 ALTER TABLE ATTRIBUTE、ALTER TABLE REPLICA 和 CREATE PLACEMENT POLICY。
  • 在 FLASHBACK 语句指定的时间点,不能存在未完全执行的 DDL 语句。如果存在此类 DDL,TiDB 会拒绝执行。
  • 在执行 FLASHBACK CLUSTER 前,TiDB 会断开所有相关连接,并禁止对这些表的读写操作,直到 FLASHBACK CLUSTER 语句执行完成。
  • FLASHBACK CLUSTER 语句在执行后无法取消,TiDB 会持续重试直到成功。
  • 如果 FLASHBACK CLUSTER 语句导致元数据(表结构、数据库结构)回滚,相关修改将不会被 TiCDC 同步。因此,你需要手动暂停任务,等待 FLASHBACK CLUSTER 完成后,手动同步上下游的 schema 定义以确保一致。之后需要重新创建 TiCDC changefeed。

示例

以下示例展示了如何将集群 flashback 到某个特定时间戳,以恢复新插入的数据:

mysql> CREATE TABLE t(a INT);
Query OK, 0 rows affected (0.09 sec)

mysql> SELECT * FROM t;
Empty set (0.01 sec)

mysql> SELECT now();
+---------------------+
| now()               |
+---------------------+
| 2022-09-28 17:24:16 |
+---------------------+
1 row in set (0.02 sec)

mysql> INSERT INTO t VALUES (1);
Query OK, 1 row affected (0.02 sec)

mysql> SELECT * FROM t;
+------+
| a    |
+------+
|    1 |
+------+
1 row in set (0.01 sec)

mysql> FLASHBACK CLUSTER TO TIMESTAMP '2022-09-28 17:24:16';
Query OK, 0 rows affected (0.20 sec)

mysql> SELECT * FROM t;
Empty set (0.00 sec)

以下示例展示了如何将集群 flashback 到某个特定 TSO,以精确恢复误删的数据:

mysql> INSERT INTO t VALUES (1);
Query OK, 1 row affected (0.02 sec)

mysql> SELECT * FROM t;
+------+
| a    |
+------+
|    1 |
+------+
1 row in set (0.01 sec)


mysql> BEGIN;
Query OK, 0 rows affected (0.00 sec)

mysql> SELECT @@tidb_current_ts;  -- 获取当前 TSO
+--------------------+
| @@tidb_current_ts  |
+--------------------+
| 446113975683252225 |
+--------------------+
1 row in set (0.00 sec)

mysql> ROLLBACK;
Query OK, 0 rows affected (0.00 sec)


mysql> DELETE FROM t;
Query OK, 1 rows affected (0.00 sec)


mysql> FLASHBACK CLUSTER TO TSO 446113975683252225;
Query OK, 0 rows affected (0.20 sec)

mysql> SELECT * FROM t;
+------+
| a    |
+------+
|    1 |
+------+
1 row in set (0.01 sec)

如果在 FLASHBACK 语句指定的时间点存在未完全执行的 DDL 语句,则 FLASHBACK 语句会执行失败:

mysql> ALTER TABLE t ADD INDEX k(a);
Query OK, 0 rows affected (0.56 sec)

mysql> ADMIN SHOW DDL JOBS 1;
+--------+---------+-----------------------+------------------------+--------------+-----------+----------+-----------+---------------------+---------------------+---------------------+--------+
| JOB_ID | DB_NAME | TABLE_NAME            | JOB_TYPE               | SCHEMA_STATE | SCHEMA_ID | TABLE_ID | ROW_COUNT | CREATE_TIME         | START_TIME          | END_TIME            | STATE  |
+--------+---------+-----------------------+------------------------+--------------+-----------+----------+-----------+---------------------+---------------------+---------------------+--------+
|     84 | test    | t                     | add index /* ingest */ | public       |         2 |       82 |         0 | 2023-01-29 14:33:11 | 2023-01-29 14:33:11 | 2023-01-29 14:33:12 | synced |
+--------+---------+-----------------------+------------------------+--------------+-----------+----------+-----------+---------------------+---------------------+---------------------+--------+
1 rows in set (0.01 sec)

mysql> FLASHBACK CLUSTER TO TIMESTAMP '2023-01-29 14:33:12';
ERROR 1105 (HY000): Detected another DDL job at 2023-01-29 14:33:12 +0800 CST, can't do flashback

你可以通过日志获取 FLASHBACK 的执行进度。以下为示例:

[2022/10/09 17:25:59.316 +08:00] [INFO] [cluster.go:463] ["flashback cluster stats"] ["complete regions"=9] ["total regions"=10] []

MySQL 兼容性

该语句是 TiDB 对 MySQL 语法的扩展。