- 最后登录
- 2017-5-4
- 在线时间
- 81 小时
- 威望
- 999
- 金钱
- 2391
- 注册时间
- 2013-9-11
- 阅读权限
- 150
- 帖子
- 1124
- 精华
- 5
- 积分
- 999
- UID
- 1220
|
1#
发表于 2013-11-27 21:24:47
|
查看: 3962 |
回复: 0
错误描述:
TABLE demo_src.people, FILTER (age > 50);
添加后无法正常工作,update时filter不起作用
注意:在过滤出现问题时OGG并不报告错误
错误分析:
该配置从语法看没有错误,但是对比的列age如果不是主键,则update在日志中不存在该列值,也就没有办法通过该列进行比较
解决方法为Add trandata demo_src.people, cols (age)强制为该列加入附加日志
注:也可通过fetch从数据库中读取该记录进行比较(只能在源端抽取进程),如下所示(此方法每条记录均需要访问数据库,导致复制效率降低):
TABLE demo_src.people, FETCHBEFOREFILTER, FETCHCOLS (age), FILTER (age > 50);
|
|