Here is the script generated by the add cdc operation.
alter table `sakila`.`TSUBSCRIBERS` modify `TALEND_CDC_TABLE_TO_WATCH` VARCHAR(255)
INSERT INTO `sakila`.`TSUBSCRIBERS`
(
`TALEND_CDC_TABLE_TO_WATCH`,
`TALEND_CDC_SUBSCRIBER_NAME`,
`TALEND_CDC_CREATION_DATE`
)
values ('entries1.customer','APP1',sysdate()) ;
CREATE TABLE `sakila`.`TCDC_customer`
(
`TALEND_CDC_SUBSCRIBERS_NAME` VARCHAR(50) NOT NULL,
`TALEND_CDC_STATE` VARCHAR(1),
`TALEND_CDC_TYPE` VARCHAR(1),
`TALEND_CDC_CREATION_DATE` DATETIME,
`customerId` INT(10) NOT NULL
) ;
CREATE OR REPLACE VIEW `sakila`.`TCDC_VIEW_customer` AS
SELECT
SRC.`TALEND_CDC_TYPE` TALEND_CDC_TYPE,
SRC.`TALEND_CDC_SUBSCRIBERS_NAME` TALEND_CDC_SUBSCRIBERS_NAME,
max(SRC.`TALEND_CDC_CREATION_DATE`) TALEND_CDC_CREATION_DATE,
SRC.`customerId` customerId,
TARG.`name` name,
TARG.`countryOfResidence` countryOfResidence
FROM `sakila`.`TCDC_customer` SRC LEFT JOIN `entries1`.`customer` TARG
ON SRC.`customerId`=TARG.`customerId`
WHERE SRC.`TALEND_CDC_STATE`='1'
GROUP BY SRC.`TALEND_CDC_SUBSCRIBERS_NAME`, SRC.`customerId`,
SRC.`TALEND_CDC_TYPE` ;
CREATE TRIGGER `entries1`.`TCDC_TG_customer_I`
AFTER INSERT ON `entries1`.`customer`
FOR each row
INSERT INTO `sakila`.`TCDC_customer`
(
`TALEND_CDC_SUBSCRIBERS_NAME`,
`TALEND_CDC_STATE`,
`TALEND_CDC_TYPE`,
`TALEND_CDC_CREATION_DATE`,
`customerId`
) SELECT
`TALEND_CDC_SUBSCRIBER_NAME`,
'0',
'I',
sysdate(),
new.`customerId`
FROM `sakila`.`TSUBSCRIBERS`
WHERE `TALEND_CDC_TABLE_TO_WATCH`='entries1.customer' ;
CREATE TRIGGER `entries1`.`TCDC_TG_customer_U`
AFTER UPDATE ON `entries1`.`customer`
FOR each row
INSERT INTO `sakila`.`TCDC_customer`
(
`TALEND_CDC_SUBSCRIBERS_NAME`,
`TALEND_CDC_STATE`,
`TALEND_CDC_TYPE`,
`TALEND_CDC_CREATION_DATE`,
`customerId`
) SELECT
`TALEND_CDC_SUBSCRIBER_NAME`,
'0',
'U',
sysdate(),
new.`customerId`
FROM `sakila`.`TSUBSCRIBERS`
WHERE `TALEND_CDC_TABLE_TO_WATCH`='entries1.customer' ;
CREATE TRIGGER `entries1`.`TCDC_TG_customer_D`
AFTER DELETE ON `entries1`.`customer`
FOR each row
INSERT INTO `sakila`.`TCDC_customer`
(
`TALEND_CDC_SUBSCRIBERS_NAME`,
`TALEND_CDC_STATE`,
`TALEND_CDC_TYPE`,
`TALEND_CDC_CREATION_DATE`,
`customerId`
) SELECT
`TALEND_CDC_SUBSCRIBER_NAME`,
'0',
'D',
sysdate(),
old.`customerId`
FROM `sakila`.`TSUBSCRIBERS`
WHERE `TALEND_CDC_TABLE_TO_WATCH`='entries1.customer' ;
