Debezium捕获Oracle物化视图数据异常：更新被识别为删插求助

核心原因拆解 #

Oracle物化视图的"快速刷新"并不一定等价于行级更新操作：

• 对于只读型快速刷新物化视图（比如包含聚合、复杂多表关联的场景），Oracle的快速刷新逻辑本质是先删除旧的计算结果行，再插入新的结果行，而非直接对现有行执行UPDATE。Debezium捕获的是数据库实际执行的SQL操作，所以会输出DELETE+INSERT事件，这是正常行为，并非Connector的BUG。
• 只有可更新物化视图（Updatable Materialized View）才能将更新同步回基表，这类物化视图的刷新才会产生UPDATE事件，但前提是物化视图和基表的关联配置满足可更新要求。

排查与解决步骤 #

1. 确认物化视图类型与刷新逻辑 #

执行以下SQL查看物化视图属性，确认是否为可更新类型：

SELECT mview_name, updatable, refresh_method 
FROM user_mviews 
WHERE mview_name = 'YOUR_MVIEW_NAME';

• 如果updatable为NO，说明该物化视图是只读的，快速刷新必然是删插逻辑，Debezium的捕获结果符合预期。此时若要获取基表的UPDATE事件，应该直接监听基表而非物化视图。
• 如果updatable为YES，但仍捕获到删插，继续下一步排查。

2. 检查物化视图日志的完整性 #

基表的物化视图日志必须包含ROWID和INCLUDING NEW VALUES，否则Debezium无法关联刷新前后的行关系，只能识别为删插操作。重新创建或修改日志：

-- 先删除旧日志（如果存在）
DROP MATERIALIZED VIEW LOG ON YOUR_BASE_TABLE;
-- 创建包含必要属性的日志
CREATE MATERIALIZED VIEW LOG ON YOUR_BASE_TABLE 
WITH ROWID, INCLUDING NEW VALUES 
FOR FAST REFRESH;

3. 调整Debezium Connector配置 #

• 避免监听物化视图：如果目标是同步基表的更新，将table.include.list配置为基表名称，而非物化视图。Connector直接捕获基表的CDC事件，就能得到原始的UPDATE操作。
• 检查快照模式：推荐使用snapshot.mode=schema_only（仅同步表结构，不做全量数据快照），避免全量快照过程干扰增量捕获。
• 验证日志挖掘策略：Oracle 12c+版本默认的log.mining.strategy=online_catalog即可，旧版本可尝试切换为log.mining.strategy=catalog。

4. 确认数据库实际执行的操作 #

快速刷新物化视图后，查询V$SQL视图验证数据库执行的SQL：

SELECT sql_text 
FROM v$sql 
WHERE lower(sql_text) LIKE '%refresh materialized view%' 
AND lower(sql_text) LIKE '%delete%' 
AND lower(sql_text) LIKE '%insert%';

如果结果中确实存在DELETE和INSERT语句，说明数据库本身就是以删插方式刷新，此时Debezium的捕获是准确的，需要调整数据同步方案（比如直接监听基表）。

内容的提问来源于stack exchange，提问作者Sherwin Amihan