This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/master by this push:
new ce0bf4353 fix db2 connect issue (#4995)
ce0bf4353 is described below
commit ce0bf4353f055ecbf34dc689fd6b9eda35307f7d
Author: aiceflower <[email protected]>
AuthorDate: Wed Nov 29 14:12:27 2023 +0800
fix db2 connect issue (#4995)
* fix db2 connect issue
* code format
---
.../apache/linkis/metadata/query/service/db2/SqlConnection.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/jdbc/src/main/java/org/apache/linkis/metadata/query/service/db2/SqlConnection.java
b/linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/jdbc/src/main/java/org/apache/linkis/metadata/query/service/db2/SqlConnection.java
index 3f61ac51f..09201d58d 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/jdbc/src/main/java/org/apache/linkis/metadata/query/service/db2/SqlConnection.java
+++
b/linkis-public-enhancements/linkis-datasource/linkis-metadata-query/service/jdbc/src/main/java/org/apache/linkis/metadata/query/service/db2/SqlConnection.java
@@ -18,6 +18,7 @@
package org.apache.linkis.metadata.query.service.db2;
import org.apache.linkis.common.conf.CommonVars;
+import org.apache.linkis.common.exception.LinkisSecurityException;
import org.apache.linkis.metadata.query.service.AbstractSqlConnection;
import org.apache.commons.collections.MapUtils;
@@ -42,6 +43,10 @@ public class SqlConnection extends AbstractSqlConnection {
private static final CommonVars<String> SQL_CONNECT_URL =
CommonVars.apply("wds.linkis.server.mdm.service.db2.url",
"jdbc:db2://%s:%s/%s");
+ /** clientRerouteServerListJNDIName */
+ private static final CommonVars<String> DB2_SENSITIVE_PARAMS =
+ CommonVars.apply("linkis.db2.sensitive.params",
"clientRerouteServerListJNDIName");
+
public SqlConnection(
String host,
Integer port,
@@ -115,6 +120,9 @@ public class SqlConnection extends AbstractSqlConnection {
.collect(Collectors.joining("&"));
url += "?" + extraParamString;
}
+ if
(url.toLowerCase().contains(DB2_SENSITIVE_PARAMS.getValue().toLowerCase())) {
+ throw new LinkisSecurityException(35000, "Invalid db2 connection
params.");
+ }
return DriverManager.getConnection(url, connectMessage.username,
connectMessage.password);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
