更新时间:2022-02-25 GMT+08:00
分享

源端为关系数据库

JSON样例

"from-config-values": {
        "configs": [
          {
            "inputs": [
              {
                "name": "fromJobConfig.useSql",
                "value": "false"
              },
              {
                "name": "fromJobConfig.schemaName",
                "value": "rf_database"
              },
              {
                "name": "fromJobConfig.tableName",
                "value": "rf_from"
              },
              {
                "name": "fromJobConfig.columnList",
                "value": "AA&BB"
              },
              {
                "name": "fromJobConfig.incrMigration",
                "value": "false"
              },
              {
                "name": "fromJobConfig.createOutTable",
                "value": "false"
              }
            ],
            "name": "fromJobConfig"
          }
        ]
      }

参数说明

参数

是否必选

类型

说明

fromJobConfig.useSql

Boolean

导出关系型数据库的数据时,可以选择是否使用自定义SQL语句导出。

fromJobConfig.sql

String

可以在这里输入自定义的SQL语句,CDM将根据该语句导出数据。

fromJobConfig.schemaName

String

数据库模式或表空间,例如:“public”

说明:
该参数支持配置通配符(*),实现导出以某一前缀开头或者以某一后缀结尾的所有数据库。例如:
  • SCHEMA*表示导出所有以“SCHEMA”开头的数据库。
  • *SCHEMA表示导出所有以“SCHEMA”结尾的数据库。
  • *SCHEMA*表示数据库名称中只要有“SCHEMA”字符串,就全部导出。

fromJobConfig.tableName

String

表名,例如:“TBL_EXAMPLE”

说明:
表名支持配置通配符(*),实现导出以某一前缀开头或者以某一后缀结尾的所有表(要求表中的字段个数和类型都一样)。例如
  • table*表示导出所有以“table”开头的表。
  • *table表示导出所有以“table”结尾的表。
  • *table*表示表名中只要有“table”字符串,就全部导出。

fromJobConfig.whereClause

String

指定抽取的Where子句,不指定则抽取整表,例如:“age > 18 and age <= 60”

fromJobConfig.columnList

String

需要抽取的字段列表,字段名之间使用“&”分割,例如:“id&gid&name”

fromJobConfig.partitionColumn

String

抽取分区字段,依据此字段将作业分割为多个任务并发执行,例如:“id”

fromJobConfig.usePartition

Boolean

从Oracle导出数据时,支持从分区表的各个分区并行抽取数据。启用该功能时,可以通过下面的“fromJobConfig.partitionList”参数指定具体的Oracle表分区,该功能不支持非分区表。

fromJobConfig.partitionList

String

输入需要迁移数据的Oracle表分区,多个分区以&分隔,不填则迁移所有分区。

分享:

    相关文档

    相关产品

close