From 6e9e11a741ab8fc2b276300c21dd674726a332e4 Mon Sep 17 00:00:00 2001 From: "xieruiming.xrm" Date: Mon, 18 Mar 2024 17:49:53 +0800 Subject: [PATCH] fix hologresjdbcwriter: use safer jdbc url replacement --- .../datax/plugin/writer/hologresjdbcwriter/BaseWriter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hologresjdbcwriter/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/BaseWriter.java b/hologresjdbcwriter/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/BaseWriter.java index 6f562cf0..03349e37 100644 --- a/hologresjdbcwriter/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/BaseWriter.java +++ b/hologresjdbcwriter/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/BaseWriter.java @@ -167,7 +167,7 @@ public class BaseWriter { if (null != renderedPreSqls && !renderedPreSqls.isEmpty()) { // 说明有 preSql 配置，则此处删除掉 originalConfig.remove(Key.PRE_SQL); - String tempJdbcUrl = jdbcUrl.replace("postgresql", "hologres"); + String tempJdbcUrl = jdbcUrl.replace("jdbc:postgresql://", "jdbc:hologres://"); try (Connection conn = DriverManager.getConnection( tempJdbcUrl, username, password)) { LOG.info("Begin to execute preSqls:[{}]. context info:{}.", @@ -207,7 +207,7 @@ public class BaseWriter { if (null != renderedPostSqls && !renderedPostSqls.isEmpty()) { // 说明有 postSql 配置，则此处删除掉 originalConfig.remove(Key.POST_SQL); - String tempJdbcUrl = jdbcUrl.replace("postgresql", "hologres"); + String tempJdbcUrl = jdbcUrl.replace("jdbc:postgresql://", "jdbc:hologres://"); try (Connection conn = DriverManager.getConnection( tempJdbcUrl, username, password)) { LOG.info(