Datax-Web 增量配置说明

1、页面任务配置

• 1.辅助参数选择时间自增
• 2.增量开始时间选择，即sql中查询时间的开始时间，用户使用此选项方便第一次的全量同步。第一次同步完成后，该时间被更新为上一次的任务触发时间，任务失败不更新。
• 3.增量时间字段,-DlastTime='%s' -DcurrentTime='%s' 先来解析下这段字符串

2、JSON配置

{
  "job": {
    "setting": {
      "speed": {
        "channel": 3,
        "byte": 1048576
      },
      "errorLimit": {
        "record": 0,
        "percentage": 0.02
      }
    },
    "content": [
      {
        "reader": {
          "name": "mysqlreader",
          "parameter": {
            "username": "yRjwDFuoPKlqya9h9H2Amg==",
            "password": "Ua8POlNqaXkZRh5rx4DI3X8sxuRddOv83hdqDOVR+i0=",
            "column": [
              "`id`",
              "`k`",
              "`c`",
              "`pad`",
              "`ts`"
            ],
            "splitPk": "",
            "connection": [
              {
                "jdbcUrl": [
                  "jdbc:mysql://10.10.14.230:22066/sbtest"
                ],
                "querySql": [
                  "select * from sbtest1 where ts >= FROM_UNIXTIME(${lastTime}) and ts < FROM_UNIXTIME(${currentTime})"
                ]
              }
            ]
          }
        },
        "writer": {
          "name": "mysqlwriter",
          "parameter": {
            "username": "yRjwDFuoPKlqya9h9H2Amg==",
            "password": "Ua8POlNqaXkZRh5rx4DI3X8sxuRddOv83hdqDOVR+i0=",
            "column": [
              "`id`",
              "`k`",
              "`c`",
              "`pad`",
              "`ts`"
            ],
            "writeMode": "update",
            "connection": [
              {
                "table": [
                  "sbtest1_copy1"
                ],
                "jdbcUrl": "jdbc:mysql://10.10.14.230:22066/sbtest"
              }
            ]
          }
        }
      }
    ]
  }
}

注意：

在reader中的querySql解析

select * from sbtest1 where ts >= FROM_UNIXTIME(${lastTime}) and ts < FROM_UNIXTIME(${currentTime})

• 1.此处的关键点在${lastTime}，${currentTime}，${}是DataX动态参数的固定格式，lastTime，currentTime就是我们页面配置中 -DlastTime='%s' -DcurrentTime='%s'中的lastTime，currentTime，注意字段一定要一致。

• 2.如果任务配置页面，时间类型选择为时间戳但是数据库时间格式不是时间戳，例如是：2019-11-26 11:40:57 此时可以用FROM_UNIXTIME(${lastTime})进行转换。