【datax】参数模板

{
  "job": {
    "setting": {
      "speed": {
        "channel": 8,
        "batchSize": 2048,
        "concurrent": 4
      },
    },
    "content": [
      {
        "reader": {
          "name": "oraclereader",
          "parameter": {
            "username": "DdEYAvAW374bO0k8zJyScA==",
            "password": "kTH+EDRu64O/dN1LuuQ0kA==",
            "column": [
              "\"MLDZID\"",
              "\"JLXDM\"",
              "\"XZQHDM\"",
              "\"DZMC\"",
              "\"MPHHZ\"",
              "\"MPHHZ_HFH\"",
              "\"MPHHZ_ZHFH\"",
              "\"SFLJ\"",
              "\"SHIID\"",
              "\"QXGXID\"",
              "\"XZJDBSCID\"",
              "\"SQDM\"",
              "\"SFSCFW\"",
              "\"MPZBX\"",
              "\"MPZBY\"",
              "\"BZ\"",
              "\"XT_LRSJ\"",
              "\"XT_LRRXM\"",
              "\"XT_LRRID\"",
              "\"XT_LRRBM\"",
              "\"XT_LRRBMID\"",
              "\"XT_LRRBMID\"",
              "\"XT_ZHXGSJ\"",
              "\"XT_ZHXGRXM\"",
              "\"XT_ZHXGRID\"",
              "\"XT_ZHXGRBM\"",
              "\"XT_ZHXGRBMID\"",
              "\"XT_ZHXGIP\"",
              "\"XT_ZXBZ\"",
              "\"XT_ZXYY\"",
              "\"XT_TIMESTAMP\""
            ],
            "splitPk": "MLDZID",
            "where": "XT_TIMESTAMP >= TO_DATE('2017-06-18 09:08:54','yyyy-MM-dd HH24:mi:ss') and XT_TIMESTAMP < TO_DATE('2018-07-27 00:00:00','yyyy-MM-dd HH24:mi:ss')",
            "connection": [
              {
                "table": [
                  "TMDCWW_BZDZ_ADD_MLDZDXB"
                ],
                "jdbcUrl": [
                  "jdbc:oracle:thin:@//oracle.jwzh.online:51521/oradb"
                ]
              }
            ]
          }
        },
        "transformer": [
          {
            "name": "dx_groovy",
            "parameter": {
              "code": "Column column = record.getColumn(5);String str = column.asString();String newStr=null;if(str?.trim() && str.isInteger()){record.setColumn(5, new LongColumn(str.replaceAll(' ', '')));return record};record.setColumn(5, new LongColumn(null));return record",
              "extraPackage": [
                "import groovy.json.JsonSlurper;"
              ]
            }
          }
        ],
        "writer": {
          "name": "mysqlwriter",
          "parameter": {
            "writeMode": "insert ignore",
            "username": "yRjwDFuoPKlqya9h9H2Amg==",
            "password": "yRjwDFuoPKlqya9h9H2Amg==",
            "column": [
              "`id`",
              "`jlxid`",
              "`xzqhdm`",
              "`dzmc`",
              "`dzhzlx`",
              "`hfh`",
              "`zhfh`",
              "`sflj`",
              "`xzgx_sid`",
              "`xzgx_qxid`",
              "`xzgx_xzjdbscid`",
              "`xzgx_cjwhid`",
              "`sffw`",
              "`zbx`",
              "`zby`",
              "`bz`",
              "`xt_lrsj`",
              "`xt_lrrxm`",
              "`xt_lrrid`",
              "`xt_lrrbm`",
              "`xt_lrrbmid`",
              "`xt_lrip`",
              "`xt_zhxgsj`",
              "`xt_zhxgrxm`",
              "`xt_zhxgrid`",
              "`xt_zhxgrbm`",
              "`xt_zhxgrbmid`",
              "`xt_zhxgip`",
              "`xt_zxbz`",
              "`xt_zxyy`",
              "`xt_timestamp`"
            ],
            "preSql": [
              "select now()"
            ],
            "connection": [
              {
                "table": [
                  "bzdz_add_mldzdxb"
                ],
                "jdbcUrl": "jdbc:mysql://192.168.160.40:3323/jwzh_dw"
              }
            ]
          }
        }
      }
    ]
  }
}