wenybing commented on issue #10512:
URL: https://github.com/apache/seatunnel/issues/10512#issuecomment-3957214625
1. The version of Seatunnel I am using is 2.3.12 Release.
2. The DDL for the source table is as follows:
CREATE TABLE DWSCDC.USERINFO2_C (
USERCODE VARCHAR2(64),
USERNAME CLOB,
SEX CLOB,
AGE NUMBER(38,0),
UNITCODE CLOB,
DEPTCODE CLOB,
TELEPHONE VARCHAR2(64),
CREATETIME TIMESTAMP,
UPDATETIME DATE,
CONSTRAINT SYS_C0021295 CHECK ("USERCODE" IS NOT NULL),
CONSTRAINT USERINFO2_C_PRIMARYKEY PRIMARY KEY (USERCODE)
);
CREATE UNIQUE INDEX USERINFO2_C_PRIMARYKEY ON DWSCDC.USERINFO2_C (USERCODE);
3. The SeaTunnel job config is as follows:
{
"env": {
"shade.identifier": "base64",
"job.mode": "STREAMING",
"parallelism": 1,
"job.name": "oracle-cdc2mysql-lob开启",
"checkpoint.interval": 10000
},
"source": [
{
"username": "ZHdzY2Rj",
"password": "cHJpbWV0b24wMDAwMDA=",
"plugin_name": "Oracle-CDC",
"result_table_name": "CDCSource1770778672419",
"database-names": [
"ORCL3"
],
"table-names": [
"ORCL3.DWSCDC.USERINFO2_C"
],
"table-names-config": [
{
"table": "ORCL3.DWSCDC.USERINFO2_C",
"primaryKeys": [
"USERCODE"
]
}
],
"base-url": "jdbc:oracle:thin:@127.0.0.1:1521:orcl3sid",
"startup.mode": "latest",
"exactly_once": true,
"debezium": {
"lob.enabled": "true"
},
"format": "default",
"schema-changes.enabled": false,
"schema-names": [
"DWSCDC"
],
"handle_blob_as_string": true,
"use_select_count": false,
"skip_analyze": false,
"decimal_type_narrowing": false
}
],
"transform": [],
"sink": [
{
"user": "cm9vdA==",
"password": "cHJpbWV0b24wMDAwMDA=",
"url":
"jdbc:mysql://127.0.0.1:3306/dwstest?allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&serverTimezone=GMT+8&allowLoadLocalInfile=true&useSSL=false",
"driver": "com.mysql.cj.jdbc.Driver",
"database": "dws_720",
"table": "USERINFO2_C",
"exactlyOnce": false,
"plugin_name": "Jdbc",
"source_table_name": "CDCSource1770778672419",
"connection_check_timeout_sec": 30,
"max_retries": 3,
"batch_size": 1000,
"batch_interval_ms": 1000,
"is_exactly_once": false,
"generate_sink_sql": true,
"max_commit_attempts": 3,
"transaction_timeout_sec": -1,
"auto_commit": true,
"schema_save_mode": "CREATE_SCHEMA_WHEN_NOT_EXIST",
"data_save_mode": "APPEND_DATA",
"field_ide": "ORIGINAL",
"use_copy_statement": false,
"handle_blob_as_string": true,
"primary_keys": [
"USERCODE"
]
}
]
}
4. Run the CDC job
5. The data of the source table is as follows：
<img width="2386" height="652" alt="Image"
src="https://github.com/user-attachments/assets/3322535c-9b84-4345-b56e-dbf8da185ea9";
/>
6. Modify one row of data，The UPDATE statement is as follows:
UPDATE DWSCDC.USERINFO2_C
SET USERNAME='王林11'
WHERE USERCODE='11';
7. The result of synchronization to the target table:
<img width="2148" height="718" alt="Image"
src="https://github.com/user-attachments/assets/889039e0-16ad-4c24-b604-e025b48422fe";
/>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
