本文为您介绍AnalyticDB for PostgreSQL Writer支持的数据类型、写入方式、字段映射和数据源等参数及配置示例。
AnalyticDB for PostgreSQL Writer插件实现了向AnalyticDB for PostgreSQL写入数据。在底层实现上,AnalyticDB
for PostgreSQL Writer通过JDBC连接远程AnalyticDB for PostgreSQL数据库,并执行相应的SQL语句,向AnalyticDB
for PostgreSQL库中写入数据。RDS在公共云提供AnalyticDB for PostgreSQL存储引擎。
说明 开始配置AnalyticDB for PostgreSQL Writer插件前,请首先配置好数据源,详情请参见配置AnalyticDB for PostgreSQL数据源。
类型转换列表
AnalyticDB for PostgreSQL Writer支持大部分AnalyticDB for PostgreSQL类型,但也存在部分类型没有支持的情况,请注意检查您的类型。
AnalyticDB for PostgreSQL Writer针对AnalyticDB for PostgreSQL的类型转换列表,如下所示。
类型分类 | AnalyticDB for PostgreSQL数据类型 |
---|---|
LONG | BIGINT、BIGSERIAL、INTEGER、SMALLINT和SERIAL |
DOUBLE | DOUBLE、PRECISION、MONEY、NUMERIC和REAL |
STRING | VARCHAR、CHAR、TEXT、BIT和INET |
DATE | DATE、TIME和TIMESTAMP |
BOOLEAN | BOOL |
BYTES | BYTEA |
说明
- 除上述罗列字段类型外,其它类型均不支持。
- MONEY、INET和BIT需要您使用
a_inet::varchar
类似的语法进行转换。
参数说明
参数 | 描述 | 是否必选 | 默认值 |
---|---|---|---|
datasource | 数据源名称,脚本模式支持添加数据源,此配置项填写的内容必须要与添加的数据源名称保持一致。 | 是 | 无 |
table | 选取的需要同步的表名称。 | 是 | 无 |
writeMode | 选择导入模式,可以支持insert和copy方式。
|
否 | insert |
column | 目标表需要写入数据的字段,字段之间用英文逗号分隔。例如"column":["id","name","age"] 。如果要依次写入全部列,使用*表示,例如"column":["*"]。
|
是 | 无 |
preSql | 执行数据同步任务之前率先执行的SQL语句。目前向导模式仅允许执行一条SQL语句,脚本模式可以支持多条SQL语句,例如清除旧数据。 | 否 | 无 |
postSql | 执行数据同步任务之后执行的SQL语句。目前向导模式仅允许执行一条SQL语句,脚本模式可以支持多条SQL语句,例如加上某一个时间戳。 | 否 | 无 |
batchSize | 一次性批量提交的记录数大小,该值可以极大减少数据集成与AnalyticDB for PostgreSQL的网络交互次数,并提升整体吞吐量。但是该值设置过大可能会造成数据集成运行进程OOM情况。 | 否 | 1,024 |
向导开发介绍
- 选择数据源。
配置同步任务的数据来源和数据去向。