1. 程式人生 > 其它 >datax oracle資料同步到oracle (異庫同步傳輸)

datax oracle資料同步到oracle (異庫同步傳輸)

由於要實現兩個不同資料來源的同步,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" } ] } } } ] } }