一、SAP IQ 离线单表读取节点配置
| 参数 | 说明 |
| 数据来源 | 可用的 SAP IQ 数据源 |
| 库 | 支持选择、或者手动输入需读取的库名称 默认将数据源绑定的数据库作为默认库,其他数据库需手动输入库名称。 当数据源网络不联通导致无法直接拉取库信息时,可手动输入数据库名称。在数据集成网络连通的情况下,仍可进行数据同步。 |
| Schema | 支持选择、或者手动输入需读取的数据模式 |
| 表 | 支持选择、或者手动输入需读取的表名称 |
| 切割键 | 你可以将源数据表中某一列作为切分键,建议使用主键或有索引的列作为切分键,仅支持类型为整型的字段读取数据时,根据配置的字段进行数据分片,实现并发读取,可以提升数据同步效率 |
二、读取
| SAP IQ(Sybase)数据类型 | 内部类型 |
| INTEGER、SMALLINT | Long |
| DECIMAL、FLOAT、REAL | Double |
| CHAR、VARCHAR、TEXT、UNICHAR、UNIVARCHAR | String |
| DATETIME | Date |
| IMAGE | Bytes |
三、写入
| 内部类型 | SAP IQ(Sybase)数据类型 |
| Long | INTEGER、SMALLINT |
| Double | DECIMAL、FLOAT、REAL |
| String | CHAR、VARCHAR、TEXT、UNICHAR、UNIVARCHAR |
| Date | DATE、TIME、TIMESTAMP |
| Bytes | IMAGE |
四、SAP IQ(Sybase) 脚本 Demo
"job": { "content": [ { "reader": { //只支持reader "parameter": { "password": "******", "column": [ //列名 "id", "name" ], "connection": [ { "jdbcUrl": [ "jdbc:sybase:Tds:ip:5000/database?charset=utf8" ], "table": [ //源表 "schema.source_table" ] } ], "where": "id>10", //筛选条件 "splitPk": "id", //切割键 "username": "root" }, "name": "rdbmsreader" } } ], "setting": { "errorLimit": { //脏数据阈值 "record": 0 }, "speed": { "byte": -1, //不限制同步速度,正整数表示设置最大传输速度 byte/s "channel": 1 //并发数量 } }}