|
@@ -47,8 +47,8 @@ class PostgreSQLWriter(Writer):
|
|
|
self.config_parser.get(self.plugin_type, POSTGRE_SQL_WRITER_PARAMETER_POST_SQL).split(';') or []
|
|
self.config_parser.get(self.plugin_type, POSTGRE_SQL_WRITER_PARAMETER_POST_SQL).split(';') or []
|
|
|
self.parameter[POSTGRE_SQL_WRITER_PARAMETER_PRE_SQL] = \
|
|
self.parameter[POSTGRE_SQL_WRITER_PARAMETER_PRE_SQL] = \
|
|
|
self.config_parser.get(self.plugin_type, POSTGRE_SQL_WRITER_PARAMETER_PRE_SQL).split(';') or []
|
|
self.config_parser.get(self.plugin_type, POSTGRE_SQL_WRITER_PARAMETER_PRE_SQL).split(';') or []
|
|
|
- self.parameter[POSTGRE_SQL_WRITER_PARAMETER_WRITE_MODE] = \
|
|
|
|
|
- self.config_parser.get(self.plugin_type, POSTGRE_SQL_WRITER_PARAMETER_WRITE_MODE) or 'insert'
|
|
|
|
|
|
|
+ # DataX 官方 postgresqlwriter 不支持 writeMode 参数(PG 仅通过 insert SQL 插入;
|
|
|
|
|
+ # 幂等靠 preSql TRUNCATE 或 ON CONFLICT),塞 writeMode 会被 writer init 拒绝
|
|
|
self.parameter[POSTGRE_SQL_WRITER_PARAMETER_BATCH_SIZE] = \
|
|
self.parameter[POSTGRE_SQL_WRITER_PARAMETER_BATCH_SIZE] = \
|
|
|
self.config_parser.get(self.plugin_type, POSTGRE_SQL_WRITER_PARAMETER_BATCH_SIZE) or '1024'
|
|
self.config_parser.get(self.plugin_type, POSTGRE_SQL_WRITER_PARAMETER_BATCH_SIZE) or '1024'
|
|
|
|
|
|