Customer has defined cdr define replicate with below command and
have used --jsonsplname=sp_data_change_capture
$ cat cdr_jsonspl_test.sh
cdr define replicate --conflict=always --ats --ris --scope=row
--jsonsplname=sp_data_change_capture repl_customer \'
"stores_demo@g_informix:informix.customer" "select
t.customer_num, t.fname, t.lname, t.company, t.address1,
t.address2, t.city, t.state, t.zipcode, t.phone from
informix.customer t" \'
"R stores_demo@g_loopback:informix.customer" "select
t.customer_num, t.fname, t.lname, t.company, t.address1,
t.address2, t.city, t.state, t.zipcode, t.phone from
informix.customer t"
$ sh cdr_jsonspl_test.sh
Interpreting this replicate as a master replicate.
Verification of stores_demo@g_informix:informix.customer started
Verification of stores_demo@g_informix:informix.customer is
successful
Verification of stores_demo@g_loopback:informix.customer started
Verification of stores_demo@g_loopback:informix.customer is
successful
but cdr list catalog is showing [17] [16] [15]
$ cdr list catalog --repl
#
# cdr define replicate commands.
#
cdr define replicate --conflict=always --ats --ris --scope=row
[17] [16] [15] repl_customer \'
"stores_demo@g_informix:informix.customer" "select
t.customer_num, t.fname, t.lname, t.company, t.address1,
t.address2, t.city, t.state, t.zipcode, t.phone from
informix.customer t" \'
"R stores_demo@g_loopback:informix.customer" "select
t.customer_num, t.fname, t.lname, t.company, t.address1,
t.address2, t.city, t.state, t.zipcode, t.phone from
informix.customer t"
which means '--jsonsplname=sp_data_change_capture' becomes '[17]
[16] [15]' in cdr list catalog.
$ cdr list repl
CURRENTLY DEFINED REPLICATES
-------------------------------
REPLICATE: repl_customer
STATE: Inactive ON:g_informix
CONFLICT: Always Apply
FREQUENCY: immediate
QUEUE SIZE: 0
PARTICIPANT: stores_demo:informix.customer
OPTIONS: row,ris,ats,fullrow,loopback,repl2spl
REPLID: 65563 / 0x1001b
REPLMODE: PRIMARY ON:g_informix
APPLY-AS: INFORMIX ON:g_informix
REPLTYPE: Master
SPL routine (sp_data_change_capture):
CREATE TABLE data_change_log (data BSON);
CREATE INDEX data_change_log ON data_change_log
(BSON_VALUE_BIGINT(data, 'commit_time')) USING BSON;
CREATE PROCEDURE sp_data_change_capture (data jSON)
INSERT INTO data_change_log VALUES (data);
END PROCEDURE; |
