用 Bintrail 给 MySQL 加上"时间旅行"查询

MySQL 是主流关系型数据库中唯一没有内置时态查询（temporal querying）能力的——PostgreSQL、Oracle、SQL Server 都能直接 SELECT ... AS OF TIMESTAMP，而 MySQL 只能靠翻 binlog 人肉还原。Bintrail 的出现填补了这个空白：它在 ProxySQL 后面挂了一层索引化的 binlog，不需要改 MySQL 本身，也不需要改应用代码，就能让用户查"某个时间点的数据"或"某行的变更历史"。对恢复和审计场景来说，这是从手工翻日志到结构化查询的质变。

MySQL 的时态查询缺口

时态查询的核心需求有两类：

• Point-in-time query：查某张表在某个历史时刻的数据状态，比如"上周三下午 2 点这条订单是什么金额"。
• Row-history lookup：查某一行从创建到现在的所有变更记录，比如"用户 ID 42 的邮箱改了几次、每次改成了什么"。

其他数据库的方案各不相同，但都内置了支持：PostgreSQL 有 temporal table 扩展，Oracle 有 Flashback Query，SQL Server 有 Temporal Tables。MySQL 的 binlog 虽然记录了所有行级变更，但它是个追加式的二进制流，没有索引，没有结构化查询接口。想回答上面两类问题，只能用 mysqlbinlog 把日志导出再人工解析——耗时且容易出错。

Bintrail 的做法是：把 binlog 索引化，放在 ProxySQL 后面做中间层，让普通 SQL 查询直接穿越到过去。

架构：不改 MySQL，不改应用

Bintrail 的关键设计决策是零侵入：

1. MySQL 本身不做任何修改，binlog 的配置和产出保持原样。
2. 应用代码不需要改——查询走 ProxySQL 路由，Bintrail 在中间拦截时态查询并翻译成对索引化 binlog 的读取。
3. 新能力以 SQL 扩展语法的形式暴露，对现有查询完全透明。

这意味着你可以在生产环境上叠加 Bintrail，不需要停机，不需要迁移数据，不需要重新写业务 SQL。对已经在跑的审计和恢复流程来说，这是最低风险的接入方式。

底层原理：Bintrail 消费 MySQL 的 binlog 流，把每条行级变更事件（INSERT、UPDATE、DELETE）解析后写入自己的索引存储。索引按时间戳和主键组织，使得"给定时间点 + 给定主键范围"的查找可以高效完成，而不是线性扫描整条 binlog。

能查什么：两个核心场景

场景一：Point-in-time 查询

查某张表在过去某个时刻的快照。典型用途是数据恢复——误操作后想知道"删掉之前数据是什么样子"，或者审计时需要回溯某个业务时刻的状态。

-- 查 orders 表在 2024-06-01 14:00:00 时的全部数据
SELECT * FROM orders
AS OF TIMESTAMP '2024-06-01 14:00:00';

-- 加上过滤条件，只查特定订单在那个时刻的状态
SELECT order_id, amount, status
FROM orders
AS OF TIMESTAMP '2024-06-01 14:00:00'
WHERE order_id = 1024;

Bintrail 在 ProxySQL 层识别 AS OF TIMESTAMP 语法，将其路由到索引化 binlog 存储而非 MySQL 本体。对应用来说，这就是一条普通 SQL。

场景二：行变更历史

查某一行从创建到现在的所有变更，包括每次变更的时间、操作类型和前后值。典型用途是审计追踪——合规要求证明某字段何时被谁改成了什么。

-- 查 order_id = 1024 这条订单的全部变更历史
SELECT *
FROM HISTORY OF orders
WHERE order_id = 1024;

返回结果类似：

每行对应一次 binlog 事件，operation 标明是插入、更新还是删除。

实操：最小可跑的接入路径

以下是一个从零接入 Bintrail 的最小配置流程。假设你已有一台运行中的 MySQL 8.0 实例。

第一步：确保 MySQL 开启行级 binlog

Bintrail 需要行格式的 binlog（ROW 格式），这是它解析行变更的前提。检查并配置：

# 查看当前 binlog 格式
mysql -e "SHOW VARIABLES LIKE 'binlog_format';"

# 如果结果是 STATEMENT 或 MIXED，改成 ROW
# 在 my.cnf 中添加：

[mysqld]
binlog_format = ROW
binlog_row_image = FULL   # 记录变更前后的完整行，Bintrail 需要这个
server_id = 1
log_bin = mysql-bin
binlog_expire_logs_seconds = 604800  # 保留 7 天，根据审计需求调整

# 重启 MySQL 使配置生效
systemctl restart mysql

# 验证
mysql -e "SHOW VARIABLES LIKE 'binlog_format';"
mysql -e "SHOW VARIABLES LIKE 'binlog_row_image';"

binlog_row_image = FULL 很关键——它让 binlog 同时记录 UPDATE/DELETE 操作前后的完整行内容，而不是只记录最小差异列。没有这个设置，行历史查询会丢失变更前的值。

第二步：部署 ProxySQL + Bintrail

Bintrail 以 ProxySQL 后端模块的形式工作。最小部署：

# 安装 ProxySQL（Debian/Ubuntu 示例）
apt-get install proxysql

# 启动 ProxySQL
systemctl start proxysql

# 登录 ProxySQL 管理接口
mysql -u admin -padmin -h 127.0.0.1 -P 6032

在 ProxySQL 中配置 MySQL 后端和 Bintrail 路由：

-- ProxySQL 管理接口中执行

-- 添加 MySQL 后端
INSERT INTO mysql_servers (hostgroup_id, hostname, port, weight)
VALUES (0, '127.0.0.1', 3306, 1);

-- 配置 MySQL 用户
INSERT INTO mysql_users (username, password, default_hostgroup)
VALUES ('app_user', 'app_pass', 0);

LOAD MYSQL SERVERS TO RUNTIME;
LOAD MYSQL USERS TO RUNTIME;
SAVE MYSQL SERVERS TO DISK;
SAVE MYSQL USERS TO DISK;

Bintrail 的索引服务需要单独部署（具体方式取决于其发布形式——可能是独立进程或 ProxySQL 插件）。核心配置项包括：

# bintrail.yaml - 简化示意配置
mysql_host: "127.0.0.1"
mysql_port: 3306
mysql_user: "bintrail_repl"
mysql_password: "repl_pass"

# binlog 消费起点
start_binlog_file: "mysql-bin.000001"
start_binlog_position: 4

# 索引存储（本地或远程）
index_storage:
  type: "rocksdb"          # 或其他支持的存储引擎
  path: "/var/lib/bintrail/index"

# 需要索引的库和表
tracked_schemas:
  - schema: "shopdb"
    tables: ["orders", "users", "payments"]

# ProxySQL 对接
proxysql_admin_host: "127.0.0.1"
proxysql_admin_port: 6032
proxysql_admin_user: "admin"
proxysql_admin_password: "admin"

# 启动 Bintrail 索引服务
bintrail serve --config bintrail.yaml

第三步：验证时态查询

应用连接 ProxySQL 的业务端口（默认 6033），而不是直连 MySQL：

# 通过 ProxySQL 连接（应用侧）
mysql -u app_user -papp_pass -h 127.0.0.1 -P 6033 -D shopdb

-- 正常查询：走 MySQL 后端，和没加 Bintrail 一样
SELECT * FROM orders WHERE order_id = 1024;

-- 时态查询：ProxySQL 识别 AS OF 语法，路由到 Bintrail
SELECT * FROM orders
AS OF TIMESTAMP '2024-06-01 14:00:00'
WHERE order_id = 1024;

-- 行历史查询
SELECT * FROM HISTORY OF orders WHERE order_id = 1024;

如果一切正常，时态查询会返回历史数据，普通查询照常走 MySQL——业务代码完全无感。

接入前的考量

存储成本。Bintrail 的索引存储会持续增长，增长速率取决于你的写入量。tracked_schemas 只索引需要的表，不要全库追踪。同时，MySQL 的 binlog_expire_logs_seconds 决定了可回溯的时间窗口——7 天的 binlog 只能查 7 天内的历史，更早的数据已被 MySQL 清理，Bintrail 也无法索引。

查询延迟。Point-in-time 查询需要从索引中重建快照，复杂度取决于目标时刻到现在的变更次数。一行改了 100 次，重建就要回溯 100 个版本。对高频变更的热点表，查询可能比直连 MySQL 慢一个数量级——这是审计场景可以接受的，但不要把它当常规查询用。

一致性边界。Bintrail 消费 binlog 有延迟（通常秒级），这意味着"刚刚发生的事"可能还没进索引。如果你要查 5 秒前的状态，可能查不到。对秒级恢复需求，还是得靠 MySQL 原生的 flashback 工具或备份。

只读约束。时态查询是只读的——你不能 UPDATE ... AS OF TIMESTAMP 把数据改回过去。Bintrail 解决的是"看过去"，不是"改回过去"。实际恢复操作仍需人工或脚本执行。

适用场景清单：

• ✅ 审计合规：证明某字段在某个时刻的值
• ✅ 误操作排查：查删改之前的数据状态
• ✅ 数据对比：对比同一行在不同时刻的差异
• ✅ 变更溯源：追踪一行数据的完整生命周期
• ⚠️ 实时恢复：有秒级延迟，不适合秒级 RTO
• ❌ 常规业务查询：延迟高于直连 MySQL，不要替代正常 SELECT

Bintrail 把 MySQL 从"只能靠人肉翻 binlog"推进到了"用 SQL 查历史"的阶段。对任何有审计或恢复需求的 MySQL 用户来说，这是值得评估的工具——接入成本极低，收益立即可见。起步时只追踪最关键的几张表，观察索引增长和查询延迟，再逐步扩大覆盖范围。