源端为关系数据库
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"
}
]
}
参数说明
|
参数 |
是否必选 |
类型 |
说明 |
|---|---|---|---|
|
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表分区,多个分区以&分隔,不填则迁移所有分区。 |