[hotfix] [connector-cdc-oracle ] support read partition table

[zhangshenghang]

Purpose of this pull request

• close [Bug] [connector-cdc-oracle ] Unsupport read partition table #8229

Does this PR introduce any user-facing change?

How was this patch tested?

Check list

• If any new Jar binary package adding in your PR, please add License Notice according
  New License Guide
• If necessary, please update the documentation to describe the new feature. https://github.com/apache/seatunnel/tree/dev/docs
• If you are contributing the connector code, please check that the following files are updated:
  1. Update plugin-mapping.properties and add new connector information in it
  2. Update the pom file of seatunnel-dist
  3. Add ci label in label-scope-conf
  4. Add e2e testcase in seatunnel-e2e
  5. Update connector plugin_config
• Update the release-note.

[hailin0]

waiting for this pr start ci
#8262

[dailai]

Please use rebase to merge the code

[zhangshenghang]

@hailin0 @dailai @Carl-Zhou-CN @Hisoka-X

I encountered an issue where the update data in the e2e is:

> Insert delete can run successfully


After debugging and printing the logs, I found that Debezium modified it to the following:

update "DEBEZIUM"."PARTITION_SOURCE_TABLE" set "VAL_VARCHAR" = 'vc3' where "VAL_VARCHAR" = 'vc2';

The full content:


LogMinerEventRow{scn=2168886, tableId='ORCLCDB.DEBEZIUM.PARTITION_SOURCE_TABLE', tableName='PARTITION_SOURCE_TABLE', tablespaceName='DEBEZIUM', eventType=UPDATE, changeTime=2024-12-11T10:53:49Z, transactionId='0a000700fe040000', operation='UPDATE', userName='DEBEZIUM', rowId='AAAR4PAAHAAABGeAAA', rollbackFlag=false, rsId= 0x000006.0000264f.0010 , ssn=0, redoSql='update "DEBEZIUM"."PARTITION_SOURCE_TABLE" set "VAL_VARCHAR" = 'vc3' where "VAL_VARCHAR" = 'vc2';'}



However, for non-partitioned tables, Debezium can correctly capture the SQL.



I wonder if this is a bug in Debezium?

Flink CDC also does not support this feature, although there is PR, it has not been merged: apache/flink-cdc#2479

Looking forward to your advice！

[hailin0]

Try to start logminer query sql logs form sql cmd

ref
https://www.modb.pro/db/394933

[hailin0]

I tested everything is ok

2024-12-25 18:42:54,602 INFO  org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0  rowIndex=4:  SeaTunnelRow#tableId=ORCL.QA_SOURCE.TEST_PARTITION SeaTunnelRow#kind=UPDATE_BEFORE : 1, 1, true
2024-12-25 18:42:54,602 INFO  org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0  rowIndex=5:  SeaTunnelRow#tableId=ORCL.QA_SOURCE.TEST_PARTITION SeaTunnelRow#kind=UPDATE_AFTER : 1, 1, false
2024-12-25 18:43:44,499 INFO  org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0  rowIndex=6:  SeaTunnelRow#tableId=ORCL.QA_SOURCE.TEST_PARTITION SeaTunnelRow#kind=UPDATE_BEFORE : 2, 1, true
2024-12-25 18:43:44,499 INFO  org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0  rowIndex=7:  SeaTunnelRow#tableId=ORCL.QA_SOURCE.TEST_PARTITION SeaTunnelRow#kind=UPDATE_AFTER : 2, 1, false
2024-12-25 18:51:30,481 INFO  org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0  rowIndex=8:  SeaTunnelRow#tableId=ORCL.QA_SOURCE.TEST_PARTITION SeaTunnelRow#kind=DELETE : 1, 1, false

[hailin0]

LGTM

[Hisoka-X]

LGTM if ci passes