datax oracle資料同步到oracle (異庫同步傳輸)
阿新 • • 發佈:2021-07-05
由於要實現兩個不同資料來源的同步,datax可以高效的傳輸,故在做海量資料同步和遷移時,可以考慮此方法,其中json檔案如下。
{ "job": { "setting": { "speed": { "channel": 3, "byte": 1048576 }, "errorLimit": { "record": 0, "percentage": 0.02 } }, "content": [ { "reader": {"name": "oraclereader", "parameter": { "username": "oH5SM8rgxl7TYB", "password": "mm35Q8kT7Mdvr", "splitPk": "", "connection": [ { "querySql": [ "select t.ins_order_id,t.request_type,t.trad_time,t.app_time from pqx.TRADE_INSURANCE_ORDER_HIS t where 1=1 and t.create_time >= trunc(sysdate -1 ,'dd') and t.create_time < trunc(sysdate ,'dd')" ], "jdbcUrl": [ "jdbc:oracle:thin:@192.168.81.63:1521:sxzs" ] } ] } }, "writer": { "name": "oraclewriter", "parameter": { "username": "nE+PJZb+RbE","password": "Hdearye73A9", "column": [ "\"INS_ORDER_ID\"", "\"REQUEST_TYPE\"", "\"TRAD_TIME\"", "\"APP_TIME\"" ], "preSql": [ "delete from i_w.TRADE_INSURANCE_ORDER_HIS t where t.create_time >= trunc(sysdate -1 ,'dd') and t.create_time < trunc(sysdate ,'dd')" ], "connection": [ { "table": [ "TRADE_INSURANCE_ORDER_HIS" ], "jdbcUrl": "jdbc:oracle:thin:@//192.168.32.10:1521/oppdb" } ] } } } ] } }