请问怎么在H2数据中实施CDC？
我正在尝试为H2数据库实现Change Data Capturing。为此，我创建了一个名为的静态类CDKeeper，它保存已更改的数据对象。（现在说Strings）我将改变的数据存储在从H2的类中调用的CDKeeper时候。CDC机制是客户端应用程序从静态获取更改数据。insertRows()org.h2.command.dml.InsertCDKeeper
当从同一个Java应用程序完成插入和捕获时，更改数据捕获正在工作。（单独的线程）
从H2控制台服务器或其他Java应用程序插入时，提到的CDC机制不起作用。
该怎么办？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
在H2数据库中实现Change Data Capture (CDC)时，如果直接从H2控制台或另一个独立的Java应用程序插入数据时捕获不到变更，这可能是因为你的CDKeeper类或者插入逻辑没有以一种全局可见的方式集成到H2数据库中。H2作为一个轻量级的数据库，其本身并不直接支持像Oracle的GoldenGate或SQL Server的CDC那样的原生CDC功能。因此，你需要通过自定义的方式来实现这一需求。
以下是一些可能的解决方案和建议：
-
监听数据库日志：H2数据库支持写前日志（WAL）模式，你可以考虑监听H2的日志文件来捕捉数据变更。这需要你编写代码解析日志文件并提取出变更信息。
-
使用触发器：在H2数据库中创建触发器是最常见的自定义CDC方法之一。为每个需要监控变更的表创建INSERT、UPDATE、DELETE触发器，这些触发器可以调用你的CDKeeper类来记录变更。例如：
CREATE TRIGGER trg_insert_table_name
AFTER INSERT ON table_name
REFERENCING NEW ROW AS newRow
FOR EACH ROW
CALL "your.package.CDKeeper.insertRows"(newRow);
确保CDKeeper.insertRows()是一个可公开访问的存储过程或者Java方法，并且已正确注册到H2数据库中。
-
集成第三方库：虽然不是特定于H2的，但有些开源项目如Debezium提供了与各种数据库集成的CDC解决方案，它们通常基于日志监听或触发器机制。尽管可能需要额外的工作来适配H2，但这可能是更通用和成熟的方法。
-
应用层集成：如果你的应用程序是唯一修改数据库的实体，确保所有对数据库的操作都经过CDKeeper类或相应服务，这样可以在应用层面实现一个简化的CDC逻辑，而不是依赖数据库级别的事件。
-
多线程和并发问题：确保你的CDKeeper类及其调用方法是线程安全的，尤其是在多线程环境下操作共享数据时。这可能涉及到同步锁或其他并发控制机制。
-
配置检查：确认当通过H2控制台或外部应用连接数据库时，使用的数据库模式（如是否也是WAL模式）、用户权限等与你的测试环境一致，因为不同的配置可能会导致行为差异。
综上所述，采用触发器可能是最直接且符合你当前尝试的方法，它能确保无论数据如何被更改（无论是通过应用程序还是其他方式），都能触发你的CDKeeper逻辑。您也可以通过ECS一键诊断全面排查并修复ECS问题。
