github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 23:52:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix hologresjdbcwriter: use safer jdbc url replacement

Browse Source
This commit is contained in:
xieruiming.xrm 2024-03-18 17:49:53 +08:00
parent 072b24f673
commit 6e9e11a741
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hologresjdbcwriter/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/BaseWriter.java
View File

@ -167,7 +167,7 @@ public class BaseWriter {
if (null != renderedPreSqls && !renderedPreSqls.isEmpty()) { if (null != renderedPreSqls && !renderedPreSqls.isEmpty()) {
// 说明有 preSql 配置，则此处删除掉 // 说明有 preSql 配置，则此处删除掉
originalConfig.remove(Key.PRE_SQL); originalConfig.remove(Key.PRE_SQL);
String tempJdbcUrl = jdbcUrl.replace("postgresql", "hologres"); String tempJdbcUrl = jdbcUrl.replace("jdbc:postgresql://", "jdbc:hologres://");
try (Connection conn = DriverManager.getConnection( try (Connection conn = DriverManager.getConnection(
tempJdbcUrl, username, password)) { tempJdbcUrl, username, password)) {
LOG.info("Begin to execute preSqls:[{}]. context info:{}.", LOG.info("Begin to execute preSqls:[{}]. context info:{}.",
@ -207,7 +207,7 @@ public class BaseWriter {
if (null != renderedPostSqls && !renderedPostSqls.isEmpty()) { if (null != renderedPostSqls && !renderedPostSqls.isEmpty()) {
// 说明有 postSql 配置，则此处删除掉 // 说明有 postSql 配置，则此处删除掉
originalConfig.remove(Key.POST_SQL); originalConfig.remove(Key.POST_SQL);
String tempJdbcUrl = jdbcUrl.replace("postgresql", "hologres"); String tempJdbcUrl = jdbcUrl.replace("jdbc:postgresql://", "jdbc:hologres://");
try (Connection conn = DriverManager.getConnection( try (Connection conn = DriverManager.getConnection(
tempJdbcUrl, username, password)) { tempJdbcUrl, username, password)) {
LOG.info( LOG.info(