OGG 经典模式下动态扩展同步表的实战指南
1. OGG经典模式动态扩展同步表的核心场景
在真实的数据库运维中，我经常遇到这样的需求：业务系统7×24小时运行，但突然发现某个表的数据出现不一致，或者需要新增同步的表。这时候传统的停机维护方案根本行不通，而OGG的经典模式恰好能解决这个痛点。
动态扩展同步表的核心价值在于业务零中断。想象一下银行的交易系统或者电商的订单系统，如果因为数据同步问题就要停机维护，那损失可就大了。OGG的经典模式允许我们在不停止服务的情况下，通过SCN号精准控制数据同步范围，实现"手术刀式"的数据修复。
这里有个实际案例：去年我们有个客户的核心业务表因为网络闪断导致部分数据丢失，当时就是通过OGG的动态同步功能，在业务高峰期间完成了数据修复。整个过程用户完全无感知，业务监控曲线平稳得像什么都没发生过一样。
2. 完整操作流程拆解
2.1 准备工作与环境检查
在开始操作前，有几个关键点必须确认：
- 确保源端和目标端的OGG版本兼容
- 检查磁盘空间是否足够存放临时导出文件
- 确认网络带宽能够支持数据快速传输
- 准备好回滚方案（这点特别重要，我吃过亏）
建议先用这个命令检查OGG进程状态：
ggsci> info all2.2 关键步骤详解
第一步：暂停相关进程不是简单粗暴地stop all，而是要有策略地暂停。我一般会先停应用进程(replicat)，再停抽取进程(extract)，这样可以避免数据积压。
ggsci> stop REPPROD ggsci> stop EXTPROD第二步：修改抽取进程参数这里有个细节很多人会忽略：新增表的同时要记得加TRANDATA。我有次半夜处理故障就因为这个漏了，结果白折腾两小时。
ggsci> edit param EXTPROD -- 在文件中添加 TABLE SCHEMA.TABLENAME; -- 保存后执行 ggsci> ADD TRANDATA SCHEMA.TABLENAME第三步：获取SCN号这个步骤决定了数据同步的起点，一定要确保准确。我习惯多查几次取最大值：
SQL> select dbms_flashback.get_system_change_number from dual;2.3 数据导出与导入技巧
使用expdp导出时，这几个参数组合实测很稳：
expdp user/pwd directory=DATA_PUMP_DIR dumpfile=export.dmp logfile=export.log tables=SCHEMA.TABLENAME content=DATA_ONLY flashback_scn=123456789目标端导入前，一定要先禁用约束和触发器。我有次导入失败就是因为外键约束没处理：
-- 禁用约束 ALTER TABLE TABLENAME DISABLE CONSTRAINT constraint_name; -- 导入后记得重新启用3. 参数配置的魔鬼细节
3.1 FILTER参数的版本陷阱
OGG 11g和12c在FILTER语法上有重大区别：
- 11g必须用双引号
- 12c开始要用单引号
配置错误会导致这样的报错：
2024-12-14 15:34:05 INFO OGG-01298 Column function diagnostic message: could not find column "transaction".正确的写法应该是：
MAP SCHEMA.TABLENAME, TARGET SCHEMA.TABLENAME, FILTER (@GETENV ('TRANSACTION', 'CSN') > 123456789);3.2 表名大小写处理
如果表名在创建时用了引号（比如"TableName"），在OGG配置中必须保持完全一致。我有次排查了三小时才发现是大小写问题。
4. 实战中的避坑指南
坑一：SCN号过期SCN号保留时间是有限的，如果操作拖延太久可能会遇到：
ORA-08181: specified number is not a valid system change number解决方案是重新获取SCN号，或者调整UNDO_RETENTION参数。
坑二：长事务处理对于大表同步，可能会遇到长事务导致的性能问题。这时候可以：
- 分批导出导入
- 调整OGG的TRANLOGOPTIONS参数
- 在业务低峰期操作
坑三：字符集问题跨平台同步时，记得检查NLS_LANG设置。曾经有个项目因为字符集不一致导致中文变问号，血的教训。
5. 监控与验证方案
同步完成后，不能简单看延迟为0就完事了。我通常会做三层验证：
- 记录数比对
-- 源端 SELECT COUNT(*) FROM TABLENAME; -- 目标端 SELECT COUNT(*) FROM TABLENAME;- 关键字段校验
SELECT SUM(CRC32(TO_CHAR(COL1||COL2||COL3))) FROM TABLENAME;- 业务验证 找业务人员确认关键功能是否正常，这是最后的保险。
6. 性能优化建议
对于TB级大表的同步，这几个技巧很管用：
- 使用PARALLEL参数加速expdp/impdp
- 调整OGG的BATCHSQL参数
- 临时增大PGA内存
- 考虑使用OGG的并行复制功能
expdp ... parallel=4 impdp ... parallel=47. 自动化脚本方案
对于经常需要同步的环境，我开发了一套自动化脚本，主要功能包括：
- 自动获取SCN号
- 校验表结构一致性
- 生成OGG参数模板
- 监控同步进度
核心代码片段：
#!/bin/bash # 获取SCN号 SCN=$(sqlplus -S /nolog <<EOF connect user/pwd set heading off select dbms_flashback.get_system_change_number from dual; exit; EOF)8. 特殊场景处理
DDL同步问题如果需要同步表结构变更，要额外配置DDL参数。但要注意不是所有DDL都适合在线同步，比如字段重命名就可能引发问题。
LOB字段处理对于包含LOB字段的表，expdp需要加特殊参数：
expdp ... include=LOB_STORAGE分区表同步分区表要特别注意分区策略是否一致，我曾经遇到过目标端分区缺失导致数据丢失的情况。