小叨：MySQLNeng像Git那样玩版本控制吗？

先说实话，听到这个需求，我脑子里立马蹦出“哈哈，这也太酷了吧”。

我跟你们说Git是代码的王者，MySQL是数据的老大。

把它俩扯在一起，就像把老妈的菜谱搬进程序员的IDE，奇怪又有意思。

不过别急，别急，咱们慢慢聊。先说说为啥有人会想把数据库当成Git来玩。

想象一下你在Zuo业务报表，每天dou要往Excel里手工改几行数据。

改完后又怕哪天回滚不出来于是就想：“要不把每次改动dou存个快照吧”。

这时候，你会想到Git——提交、分支、合并、回滚，一套全流程。

于是灵感来了：把MySQL的表也包装一层，让它像Git一样记录每一次变geng。

这不光是为了审计，geng是为了防止“我昨天删了这条记录，现在找不到了”。

先说个大概念：

全量基线——第一次提交时把整张表的所有数据序列化成JSON，存进版本表。

增量快照——以后每次提交，只记录新增、修改、删除的那几行。

主键映射——用表的主键当唯一标识，这样对比时才Neng精准定位到底是哪条记录变了。

听起来有点技术范儿，但其实实现起来并不算高深。

CREATE TABLE `dg_table_version` (
  `id` int NOT NULL AUTO_INCREMENT COMMENT '全局版本ID',
  `table_name` varchar NOT NULL COMMENT '业务表名',
  `table_version_num` int NOT NULL COMMENT '自增版号',
  `snapshot_type` varchar NOT NULL COMMENT 'FULL/INCREMENT',
  `snapshot_content` longtext NOT NULL COMMENT 'JSON内容',
  `table_structure_hash` char NOT NULL COMMENT 'MD5哈希防结构变geng',
  `operator` varchar NOT NULL,
  `operate_time` datetime NOT NULL,
  PRIMARY KEY ,
  UNIQUE KEY `uk_table_version` 
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `dg_table_structure_version` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `table_name` varchar NOT NULL,
  `structure_sql` longtext NOT NULL,
  `structure_hash` varchar NOT NULL,
  `operator` varchar NOT NULL,
  `operate_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY ,
  UNIQUE KEY `uk_table_hash` 
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

这俩表就是咱们的“git仓库”，一个装快照，一个装结构历史。

你可Neng会问：“为啥不直接用Long？” 哈哈，那是因为有些业务表用的是UUID或者char型主键。

所以我干脆把所有主键dou转成String，这样后面比较和拼接dou统一啦。

这里我用了Jackson，因为它支持LocalDateTime自动序列化，还Neng配置忽略未知属性，防止后面升级报错。

Map oldData = queryPrevVersion;
Map newData = queryCurrentTable;
List changes = new ArrayList<>;
// 新增
for ) {
    if ) {
        changes.add, null));
    }
}
// 删除
for ) {
    if ) {
        changes.add));
    }
}
// 修改
for ) {
    if  && !oldData.get.equals)) {
        changes.add, oldData.get));
    }
}

这个过程其实跟Git内部Zuo的diff差不多，只不过我们自己写而Yi。那个那个……别笑，我写的时候真是debug到凌晨三点。

第一次提交肯定走全量；后面只要检查一下当前版本号是否为0，就Ke以决定走增量路径啦。

步骤如下：

A. 锁表，防止回滚期间有人写入；

B. 根据目标版号，把对应的全量基线和随后所有增量逐个apply到内存Map里；

C. TRUNCATE目标表，然后批量INSERT合并后的Map；

D. 再自动提交一次“回滚后的状态”作为新版本，以免下次再回滚找不到基准。

A：兄弟，你们项目上线后发现搜索引擎抓不到页面？常见原因有：

- 没有robots.txt放行或者被误拦住；

- 页面渲染依赖大量JS，爬虫kan不到实际内容；

- 响应码不是200。

@Service
@RequiredArgsConstructor
public class TableVersionService {
    private final TableVersionMapper versionMapper;
    private final StructureVersionMapper structMapper;
    private final JdbcTemplate jdbcTemplate;
    private final JsonUtil jsonUtil;
    private final TableStructureUtil tsUtil;
    private final IncrementCompareUtil compareUtil;
    public void commit {
        // 检查结构是否变化
        String curHash = tsUtil.calculateTableStructureHash;
        checkAndSaveStructure;
        // 锁表避免并发写冲突
        lockTable;
        try {
            int lastVer = versionMapper.selectMaxVersionNum;
            int newVer = lastVer + 1;
            TableVersionEntity entity = new TableVersionEntity;
            entity.setTableName;
            entity.setTableVersionNum;
            entity.setOperator;
            entity.setOperateTime);
            entity.setTableStructureHash;
            entity.setVersionDesc;
            if  { // 第一次全量快照
                Map all = tsUtil.queryTableData;
                FullSnapshot full = new FullSnapshot;
                entity.setSnapshotType);
                entity.setSnapshotContent);
            } else { // 增量快照
                Map prev = mergeToVersion;
                Map cur = tsUtil.queryTableData;
                IncrementSnapshot inc = compareUtil.compare;
                entity.setSnapshotType);
                entity.setSnapshotContent);
            }
            versionMapper.insert;
        } finally {
            unlockTable;
        }
    }
    // …其余 rollback / compare / list 方法省略…
}

*注意*：这里用了`lock table … write` , 实际生产环境建议换成Redis分布式锁，不然高并发下会卡死整个库。哈哈，我之前忘记这点，被同事笑死了：“兄弟，你这是在玩‘单机版git’，还敢上生产？” 不对不对，我应该直接用Redisson才对嘛…😅

@Component
public class TableStructureUtil {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    public String getPrimaryKey {
        String sql = "SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE " +
                     "WHERE TABLE_SCHEMA=DATABASE AND TABLE_NAME=? AND CONSTRAINT_NAME='PRIMARY'";
        List list = jdbcTemplate.queryForList;
        if ) throw new IllegalStateException;
        return list.get; // 暂时只支持单主键
    }
    public String calculateTableStructureHash {
        String sql = "SHOW CREATE TABLE " + table;
        Map map = jdbcTemplate.queryForMap;
        String createSql =  map.get;
        return DigestUtils.md5Hex);
    }
    public Map queryTableData{
        String pk = getPrimaryKey;
        List rows = jdbcTemplate.queryForList;
        Map result=new HashMap<>;
        for{
            Object v=row.get;
            result.put,row);
        }
        return result;
    }
}

A公司每天生成一张叫 `daily_report` `id`, `dept_id`, `amount`, `create_time`, …

A 同事经常手动改 `amount` , 然后 Excel 那边要追溯是谁改了多少。于是我们把上述方案直接搬进去：

- 每天凌晨跑一个定时任务 @Scheduled , 调用 .commit;

- Ru果当天有人手动修改，就会产生增量快照;

- 想kan某天的数据，只需要查询对应版本号，用 .compare; kan差异即可;

。 # 常见坑与调试技巧

- **保留关键字**：Ru果字段名恰好是 MySQL 保留字，一定要在拼SQL时加反引号，否则会报错。刚开始我就是忘记加反引号，错误信息一直是 “syntax error near ‘desc’”，搞得我怀疑自己是不是装错 MySQL。后来才明白啊啊啊！;

- **主键类型兼容**：有些老系统用了 `bigint unsigned` ，转换成 Java Long 时可Neng溢出。Zui稳妥的办法就是统一转成字符串再比较；

- **大批量插入**：千万别一次性塞几万条进 INSERT，一定要分批，否则事务会卡死甚至 OOM；