??????????

[wjw_bigd...@163.com]

????



---- ???????????? ----
| ?????? | ????????<402987...@qq.com.INVALID> |
| ???? | 2024??06??26?? 16:38 |
| ?????? | user-zh<user-zh@flink.apache.org> |
| ?????? | |
| ???? | ?????????? |
????







&nbsp;





------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<15171440...@163.com&gt;;
????????:&nbsp;2024??6??26??(??????) ????4:36
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;??????????






















?? 2024-06-26 15:07:45??"15868861416" <15868861...@163.com&gt; ??????
&gt;????????????ID??PRICE??????????NUMBER??????????????flink-sql????number??????????iceberg??decimal????????????
&gt;
&gt;
&gt;| |
&gt;????
&gt;|
&gt;|
&gt;15868861...@163.com
&gt;|
&gt;
&gt;
&gt;---- ???????????? ----
&gt;| ?????? | Yanquan Lv<decq12y...@gmail.com&gt; |
&gt;| ???????? | 2024??06??26?? 14:46 |
&gt;| ?????? | <user-zh@flink.apache.org&gt; |
&gt;| ???? | Re: ??????cdc????oracle???????????? |
&gt;?????????? ID ?? PRINCE ?????????? decimal ????decimal ???????????????????? 
BASE64 ????
&gt;
&gt;????????????????????????????????????????
&gt;
&gt;Map<String, Object&gt; customConverterConfigs = new HashMap<&gt;();
&gt;customConverterConfigs.put(JsonConverterConfig.DECIMAL_FORMAT_CONFIG,
&gt;"numeric");
&gt;JsonDebeziumDeserializationSchema schema = new
&gt;JsonDebeziumDeserializationSchema(includeSchema,
&gt;customConverterConfigs);
&gt;
&gt;
&gt;
&gt;
&gt;ha.fen...@aisino.com <ha.fen...@aisino.com&gt; ??2024??6??25?????? 
17:26??????
&gt;
&gt;??????????
&gt;"ID" "NAME"&nbsp;&nbsp; 
"ADDTIME"&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
"PRICE"
&gt;1 "aa"&nbsp;&nbsp;&nbsp;&nbsp; 2024-6-25 
14:21:33&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 12.22
&gt;
&gt;???????? 15868861416
&gt;?????????? 2024-06-25 17:19
&gt;???????? user-zh@flink.apache.org
&gt;?????? ??????cdc????oracle????????????
&gt;????????oracle????DEBEZIUM.PRODUCTS????????????????????????????????
&gt;
&gt;
&gt;
&gt;
&gt;| |
&gt;????
&gt;|
&gt;|
&gt;15868861...@163.com
&gt;|
&gt;
&gt;
&gt;---- ???????????? ----
&gt;| ?????? | ha.fen...@aisino.com<ha.fen...@aisino.com&gt; |
&gt;| ???????? | 2024??06??25?? 15:54 |
&gt;| ?????? | user-zh<user-zh@flink.apache.org&gt; |
&gt;| ???? | cdc????oracle???????????? |
&gt;??????????????
&gt;JdbcIncrementalSource<String&gt; oracleChangeEventSource =
&gt;new OracleSourceBuilder()
&gt;.hostname("host")
&gt;.port(1521)
&gt;.databaseList("ORCLCDB")
&gt;.schemaList("DEBEZIUM")
&gt;.tableList("DEBEZIUM.PRODUCTS")
&gt;.username("username")
&gt;.password("password")
&gt;.deserializer(new JsonDebeziumDeserializationSchema())
&gt;.includeSchemaChanges(true) // output the schema changes as well
&gt;.startupOptions(StartupOptions.initial())
&gt;.debeziumProperties(debeziumProperties)
&gt;.splitSize(2)
&gt;.build();
&gt;????????????
&gt;
&gt;{"before":null,"after":{"ID":{"scale":0,"value":"AQ=="},"NAME":"aa","ADDTIME":1719325293000,"PRICE":"BMY="},"source":{"version":"1.9.8.Final","connector":"oracle","name":"oracle_logminer","ts_ms":0,"snapshot":"false","db":"ORCL","sequence":null,"schema":"CDC","table":"ORDER_CDC","txId":null,"scn":"0","commit_scn":null,"lcr_position":null,"rs_id":null,"ssn":0,"redo_thread":null},"op":"r","ts_ms":1719301769186,"transaction":null}
&gt;
&gt;??????????PRICE????????????ID??????????????????????????
&gt;