CodeCow/DataX
1
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2026-06-12 21:02:28 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #2075 from xieruiming/fix_replacement

Browse Source 
fix hologresjdbcwriter: use safer jdbc url replacement
This commit is contained in:
Trafalgar 2024-03-18 19:34:31 +08:00 committed by GitHub
commit 9626738ca8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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()) {
// 说明有 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(