更新时间：2023-11-29 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"
}
]
}
参数说明
|
参数 |
是否必选 |
类型 |
说明 |
|---|---|---|---|
|
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表分区，多个分区以&分隔，不填则迁移所有分区。 |
