返回首页

gbase数据、南大通用产品文档:GBase8agcluster_kafka_primarykey_can_be_null

更新日期:2024年09月11日

功能
控制增量同步时delete 和update 是否允许primary key 的值为空。
默认值为0,即如果delete 和update 时primary key 的值为空则报错;
值为1时,
增量同步delete和update允许primary key的值为空,
这时kafka consumer
会正常进行同步,但是不保证同步结果与原数据库完全一致。
举例:
update t1 set A=2 where primarykey=1;
update t1 set A=2 where A=1;
{
"table":"BDTEST.T1",
"op_type":"U",
"op_ts":"2022-01-16 09:32:33.705303",
"current_ts":"2022-01-16T17:32:36.839000",
"pos":"00000000030000002612",
"primary_keys":{"A"},
"before":{
"A":1
}
"after":{
"A":2
}
}

Input value is not valid
此数据类型不接受此输入值。请确保此输入值是对该数据类型是一个有效输入。

要从表删除行,
程序执行 DELETE 语句。
DELETE 语句可以常规方式以 WHERE 子句指
定行,或它可引用单个行,通过指定的游标访存最后一行。
每当您删除行时,您必须考虑其他表中的行是否依赖于删除了的行。在 修改数据 中论述
协调删除的这个问题。当从程序内删除时,问题是一样的。