源端为关系数据库
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”。
说明:
该参数支持配置通配符(*),实现导出以某一前缀开头或者以某一后缀结尾的所有数据库。例如:
|
fromJobConfig.tableName |
是 |
String |
表名,例如:“TBL_EXAMPLE”。
说明:
表名支持配置通配符(*),实现导出以某一前缀开头或者以某一后缀结尾的所有表(要求表中的字段个数和类型都一样)。例如:
|
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表分区,多个分区以&分隔,不填则迁移所有分区。 |