Skip to content

Latest commit

 

History

History
156 lines (111 loc) · 3.26 KB

oraclewriter.md

File metadata and controls

156 lines (111 loc) · 3.26 KB

Oracle写入插件（oraclewriter）

1. 配置样例

{"job": {
    "content": [
      {
        "reader": {
          "parameter": {
            "password": "wujing",
            "where": "3 > 1",
            "column": [
              "ID1",
              "C1",
              "C2"
            ],
            "connection": [
              {
                "jdbcUrl": [
                  "jdbc:oracle:thin:@//172.16.8.121:1521/dtstack"
                ],
                "table": [
                  "SB1"
                ]
              }
            ],
            "splitPk": "ID1",
            "username": "wujing"
          },
          "name": "oraclereader"
        },
        "writer": {
          "parameter": {
            "password": "wujing",
            "column": [
              "ID",
              "C1",
              "C2"
            ],
            "connection": [
              {
                "jdbcUrl": "jdbc:oracle:thin:@//172.16.8.121:1521/dtstack",
                "table": [
                  "SB2"
                ]
              }
            ],
            "writeMode": "replace",
            "username": "wujing"
          },
          "name": "oraclewriter"
        }
      }
    ],
    "setting": {
      "errorLimit": {
        "record": 100
      },
      "speed": {
        "bytes": 1048576,
        "channel": 2
      }
    }
  }
}

2. 参数说明

  • name

    • 描述：插件名，此处只能填oraclewriter，否则Flinkx将无法正常加载该插件包。

    • 必选：是

    • 默认值：无

  • jdbcUrl

    • 描述：针对mysql数据库的jdbc连接字符串

      jdbcUrl按照Oracle官方规范，并可以填写连接附件控制信息。具体请参看Oracle官方文档。

    • 必选：是

    • 默认值：无

  • username

    • 描述：数据源的用户名

    • 必选：是

    • 默认值：无

  • password

    • 描述：数据源指定用户名的密码

    • 必选：是

    • 默认值：无

  • column

    • 描述：目的表需要写入数据的字段,字段之间用英文逗号分隔。例如: "column": ["id","name","age"]。

    • 必选：是

    • 默认值：否

    • 默认值：无

  • preSql

    • 描述：写入数据到目的表前，会先执行这里的一组标准语句。

    • 必选：否

    • 默认值：无

  • postSql

    • 描述：写入数据到目的表后，会执行这里的一组标准语句。

    • 必选：否

    • 默认值：无

  • table

    • 描述：目的表的表名称。目前只支持配置单个表，后续会支持多表。

           注意：table 和 jdbcUrl 必须包含在 connection 配置单元中

    • 必选：是

    • 默认值：无

  • writeMode

    • 描述：控制写入数据到目标表采用 insert into 或者 replace into 或者 ON DUPLICATE KEY UPDATE 语句
      ** 在oracle中, 用merge into模拟后两种插入语义。 **

    • 必选：是

    • 所有选项：insert/replace/update

    • 默认值：insert

  • batchSize

    • 描述：一次性批量提交的记录数大小

    • 必选：否

    • 默认值：1024