This is an automated email from the ASF dual-hosted git repository.
zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new d2b0abd4fc [Improvement-18142][Datasource] Normalize the use of the
DataSourceConstants class (#18143)
d2b0abd4fc is described below
commit d2b0abd4fcbd169bc77fc4ae52dd8170926642bc
Author: njnu-seafish <[email protected]>
AuthorDate: Wed Apr 8 14:05:46 2026 +0800
[Improvement-18142][Datasource] Normalize the use of the
DataSourceConstants class (#18143)
---
.../api/service/DataSourceServiceTest.java | 2 +-
.../common/constants/DataSourceConstants.java | 132 --------
.../api/constants/DataSourceConstants.java | 344 +--------------------
.../plugin/datasource/api/utils/CommonUtils.java | 23 --
.../datasource/api/utils/CommonUtilsTest.java | 2 +-
.../param/AthenaDataSourceProcessorTest.java | 2 +-
.../param/SQLServerDataSourceProcessorTest.java | 2 +-
.../param/DamengDataSourceProcessorTest.java | 2 +-
.../param/DatabendDataSourceProcessorTest.java | 2 +-
.../db2/param/Db2DataSourceProcessorTest.java | 2 +-
.../param/DolphinDBDataSourceProcessor.java | 2 +-
.../param/DolphinDBDataSourceProcessorTest.java | 2 +-
.../doris/param/DorisDataSourceProcessorTest.java | 2 +-
.../hana/param/HanaDataSourceProcessorTest.java | 2 +-
.../hive/param/HiveDataSourceProcessorTest.java | 2 +-
.../param/KyuubiDataSourceProcessorTest.java | 2 +-
.../mysql/param/MySQLDataSourceProcessorTest.java | 2 +-
.../param/OracleDataSourceProcessorTest.java | 2 +-
.../param/PostgreSQLDataSourceProcessorTest.java | 4 +-
.../param/PrestoDataSourceProcessorTest.java | 2 +-
.../param/RedshiftDataSourceProcessorTest.java | 2 +-
.../param/SnowflakeDataSourceProcessorTest.java | 2 +-
.../spark/param/SparkDataSourceProcessorTest.java | 2 +-
.../param/SQLServerDataSourceProcessorTest.java | 2 +-
.../trino/TrinoDataSourceChannelTest.java | 2 +-
.../trino/param/TrinoDataSourceProcessorTest.java | 2 +-
.../param/VerticaDataSourceProcessorTest.java | 2 +-
27 files changed, 37 insertions(+), 512 deletions(-)
diff --git
a/dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/DataSourceServiceTest.java
b/dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/DataSourceServiceTest.java
index 6ba50e2f13..ec0adfef33 100644
---
a/dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/DataSourceServiceTest.java
+++
b/dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/DataSourceServiceTest.java
@@ -27,7 +27,6 @@ import
org.apache.dolphinscheduler.api.permission.ResourcePermissionCheckService
import org.apache.dolphinscheduler.api.service.impl.BaseServiceImpl;
import org.apache.dolphinscheduler.api.service.impl.DataSourceServiceImpl;
import org.apache.dolphinscheduler.api.utils.PageInfo;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
import org.apache.dolphinscheduler.common.enums.AuthorizationType;
import org.apache.dolphinscheduler.common.enums.UserType;
import org.apache.dolphinscheduler.common.utils.JSONUtils;
@@ -35,6 +34,7 @@ import org.apache.dolphinscheduler.common.utils.PropertyUtils;
import org.apache.dolphinscheduler.dao.entity.DataSource;
import org.apache.dolphinscheduler.dao.entity.User;
import org.apache.dolphinscheduler.dao.mapper.DataSourceMapper;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import
org.apache.dolphinscheduler.plugin.datasource.api.datasource.BaseDataSourceParamDTO;
import
org.apache.dolphinscheduler.plugin.datasource.api.datasource.DataSourceProcessor;
import
org.apache.dolphinscheduler.plugin.datasource.api.plugin.DataSourceClientProvider;
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/DataSourceConstants.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/DataSourceConstants.java
deleted file mode 100644
index 138ed3dac6..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/DataSourceConstants.java
+++ /dev/null
@@ -1,132 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.constants;
-
-public class DataSourceConstants {
-
- public static final String DATASOURCE = "datasource";
-
- /**
- * driver
- */
- public static final String ORG_POSTGRESQL_DRIVER = "org.postgresql.Driver";
- public static final String COM_MYSQL_CJ_JDBC_DRIVER =
"com.mysql.cj.jdbc.Driver";
- public static final String COM_MYSQL_JDBC_DRIVER = "com.mysql.jdbc.Driver";
- public static final String ORG_APACHE_HIVE_JDBC_HIVE_DRIVER =
"org.apache.hive.jdbc.HiveDriver";
- public static final String COM_CLICKHOUSE_JDBC_DRIVER =
"com.clickhouse.jdbc.ClickHouseDriver";
- public static final String COM_DATABEND_JDBC_DRIVER =
"com.databend.jdbc.DatabendDriver";
- public static final String COM_ORACLE_JDBC_DRIVER =
"oracle.jdbc.OracleDriver";
- public static final String COM_SQLSERVER_JDBC_DRIVER =
"com.microsoft.sqlserver.jdbc.SQLServerDriver";
- public static final String COM_DB2_JDBC_DRIVER =
"com.ibm.db2.jcc.DB2Driver";
- public static final String COM_PRESTO_JDBC_DRIVER =
"com.facebook.presto.jdbc.PrestoDriver";
- public static final String COM_REDSHIFT_JDBC_DRIVER =
"com.amazon.redshift.jdbc42.Driver";
- public static final String COM_ATHENA_JDBC_DRIVER =
"com.simba.athena.jdbc.Driver";
- public static final String COM_TRINO_JDBC_DRIVER =
"io.trino.jdbc.TrinoDriver";
- public static final String COM_DAMENG_JDBC_DRIVER =
"dm.jdbc.driver.DmDriver";
- public static final String ORG_APACHE_KYUUBI_JDBC_DRIVER =
"org.apache.kyuubi.jdbc.KyuubiHiveDriver";
- public static final String COM_OCEANBASE_JDBC_DRIVER =
"com.oceanbase.jdbc.Driver";
- public static final String NET_SNOWFLAKE_JDBC_DRIVER =
"net.snowflake.client.jdbc.SnowflakeDriver";
- public static final String COM_VERTICA_JDBC_DRIVER =
"com.vertica.jdbc.Driver";
- public static final String COM_HANA_DB_JDBC_DRIVER =
"com.sap.db.jdbc.Driver";
- public static final String COM_DOLPHINDB_JDBC_DRIVER =
"com.dolphindb.jdbc.Driver";
-
- /**
- * validation Query
- */
- public static final String POSTGRESQL_VALIDATION_QUERY = "select
version()";
- public static final String MYSQL_VALIDATION_QUERY = "select 1";
- public static final String HIVE_VALIDATION_QUERY = "select 1";
- public static final String CLICKHOUSE_VALIDATION_QUERY = "select 1";
- public static final String DATABEND_VALIDATION_QUERY = "select 1";
- public static final String ORACLE_VALIDATION_QUERY = "select 1 from dual";
- public static final String SQLSERVER_VALIDATION_QUERY = "select 1";
- public static final String DB2_VALIDATION_QUERY = "select 1 from
sysibm.sysdummy1";
- public static final String PRESTO_VALIDATION_QUERY = "select 1";
- public static final String REDHIFT_VALIDATION_QUERY = "select 1";
- public static final String ATHENA_VALIDATION_QUERY = "select 1";
- public static final String TRINO_VALIDATION_QUERY = "select 1";
- public static final String DAMENG_VALIDATION_QUERY = "select 1";
- public static final String SNOWFLAKE_VALIDATION_QUERY = "select 1";
-
- public static final String KYUUBI_VALIDATION_QUERY = "select 1";
- public static final String VERTICA_VALIDATION_QUERY = "select 1";
-
- public static final String HANA_VALIDATION_QUERY = "select 1 from DUMMY";
- public static final String DOLPHINDB_VALIDATION_QUERY = "select 1";
-
- /**
- * jdbc url
- */
- public static final String JDBC_MYSQL = "jdbc:mysql://";
- public static final String JDBC_MYSQL_LOADBALANCE =
"jdbc:mysql:loadbalance://";
- public static final String JDBC_POSTGRESQL = "jdbc:postgresql://";
- public static final String JDBC_HIVE_2 = "jdbc:hive2://";
- public static final String JDBC_KYUUBI = "jdbc:kyuubi://";
- public static final String JDBC_CLICKHOUSE = "jdbc:clickhouse://";
- public static final String JDBC_DATABEND = "jdbc:databend://";
- public static final String JDBC_ORACLE_SID = "jdbc:oracle:thin:@";
- public static final String JDBC_ORACLE_SERVICE_NAME =
"jdbc:oracle:thin:@//";
- public static final String JDBC_SQLSERVER = "jdbc:sqlserver://";
- public static final String JDBC_DB2 = "jdbc:db2://";
- public static final String JDBC_PRESTO = "jdbc:presto://";
- public static final String JDBC_REDSHIFT = "jdbc:redshift://";
- public static final String JDBC_REDSHIFT_IAM = "jdbc:redshift:iam://";
- public static final String JDBC_ATHENA = "jdbc:awsathena://";
- public static final String JDBC_TRINO = "jdbc:trino://";
- public static final String JDBC_DAMENG = "jdbc:dm://";
- public static final String JDBC_OCEANBASE = "jdbc:oceanbase://";
- public static final String JDBC_SNOWFLAKE = "jdbc:snowflake://";
- public static final String JDBC_VERTICA = "jdbc:vertica://";
- public static final String JDBC_HANA = "jdbc:sap://";
- public static final String JDBC_DOLPHINDB = "jdbc:dolphindb://";
-
- /**
- * database type
- */
- public static final String MYSQL = "MYSQL";
- public static final String HIVE = "HIVE";
-
- /**
- * dataSource sensitive param
- */
- public static final String DATASOURCE_PASSWORD_REGEX =
- "(?<=((?i)password((\" :
\")|(\":\")|(\\\\\":\\\\\")|(=')))).*?(?=((\")|(\\\\\")|(')))";
-
- /**
- * datasource encryption salt
- */
- public static final String DATASOURCE_ENCRYPTION_SALT_DEFAULT = "!@#$%^&*";
- public static final String DATASOURCE_ENCRYPTION_ENABLE =
"datasource.encryption.enable";
- public static final String DATASOURCE_ENCRYPTION_SALT =
"datasource.encryption.salt";
-
- /**
- * datasource config
- */
- public static final String SPRING_DATASOURCE_MIN_IDLE =
"spring.datasource.minIdle";
-
- public static final String SPRING_DATASOURCE_MAX_ACTIVE =
"spring.datasource.maxActive";
-
- public static final String SPRING_DATASOURCE_TEST_ON_BORROW =
"spring.datasource.testOnBorrow";
-
- /**
- * azure static websites
- */
- public static final String AZURE_SQL_DATABASE_SPN =
"https://database.windows.net/";;
- public static final String AZURE_SQL_DATABASE_TOKEN_SCOPE = "/.default";
-
-}
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/constants/DataSourceConstants.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/constants/DataSourceConstants.java
index 46b81a4165..c1e5e08306 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/constants/DataSourceConstants.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/constants/DataSourceConstants.java
@@ -17,22 +17,16 @@
package org.apache.dolphinscheduler.plugin.datasource.api.constants;
-import org.apache.dolphinscheduler.common.constants.DateConstants;
-
-import java.time.Duration;
-import java.util.Set;
-import java.util.regex.Pattern;
-
import lombok.experimental.UtilityClass;
-import com.google.common.collect.Sets;
-
@UtilityClass
public class DataSourceConstants {
+ /**
+ * driver
+ */
public static final String ORG_POSTGRESQL_DRIVER = "org.postgresql.Driver";
public static final String COM_MYSQL_CJ_JDBC_DRIVER =
"com.mysql.cj.jdbc.Driver";
- public static final String COM_MYSQL_JDBC_DRIVER = "com.mysql.jdbc.Driver";
public static final String ORG_APACHE_HIVE_JDBC_HIVE_DRIVER =
"org.apache.hive.jdbc.HiveDriver";
public static final String COM_CLICKHOUSE_JDBC_DRIVER =
"com.clickhouse.jdbc.ClickHouseDriver";
public static final String COM_DATABEND_JDBC_DRIVER =
"com.databend.jdbc.DatabendDriver";
@@ -49,7 +43,11 @@ public class DataSourceConstants {
public static final String NET_SNOWFLAKE_JDBC_DRIVER =
"net.snowflake.client.jdbc.SnowflakeDriver";
public static final String COM_VERTICA_JDBC_DRIVER =
"com.vertica.jdbc.Driver";
public static final String COM_HANA_DB_JDBC_DRIVER =
"com.sap.db.jdbc.Driver";
+ public static final String COM_DOLPHINDB_JDBC_DRIVER =
"com.dolphindb.jdbc.Driver";
+ /**
+ * jdbc url
+ */
public static final String JDBC_MYSQL = "jdbc:mysql://";
public static final String JDBC_MYSQL_LOADBALANCE =
"jdbc:mysql:loadbalance://";
public static final String JDBC_POSTGRESQL = "jdbc:postgresql://";
@@ -71,7 +69,11 @@ public class DataSourceConstants {
public static final String JDBC_SNOWFLAKE = "jdbc:snowflake://";
public static final String JDBC_VERTICA = "jdbc:vertica://";
public static final String JDBC_HANA = "jdbc:sap://";
+ public static final String JDBC_DOLPHINDB = "jdbc:dolphindb://";
+ /**
+ * validation Query
+ */
public static final String POSTGRESQL_VALIDATION_QUERY = "select
version()";
public static final String MYSQL_VALIDATION_QUERY = "select 1";
public static final String HIVE_VALIDATION_QUERY = "select 1";
@@ -86,280 +88,14 @@ public class DataSourceConstants {
public static final String TRINO_VALIDATION_QUERY = "select 1";
public static final String DAMENG_VALIDATION_QUERY = "select 1";
public static final String SNOWFLAKE_VALIDATION_QUERY = "select 1";
-
public static final String KYUUBI_VALIDATION_QUERY = "select 1";
public static final String VERTICA_VALIDATION_QUERY = "select 1";
-
public static final String HANA_VALIDATION_QUERY = "select 1 from DUMMY";
+ public static final String DOLPHINDB_VALIDATION_QUERY = "select 1";
public static final String SPRING_DATASOURCE_MIN_IDLE =
"spring.datasource.minIdle";
-
public static final String SPRING_DATASOURCE_MAX_ACTIVE =
"spring.datasource.maxActive";
- public static final String SUPPORT_HIVE_ONE_SESSION =
"support.hive.oneSession";
- /**
- * QUESTION ?
- */
- public static final String QUESTION = "?";
-
- /**
- * comma ,
- */
- public static final String COMMA = ",";
-
- /**
- * hyphen
- */
- public static final String HYPHEN = "-";
-
- /**
- * slash /
- */
- public static final String SLASH = "/";
-
- /**
- * COLON :
- */
- public static final String COLON = ":";
-
- /**
- * SPACE " "
- */
- public static final String SPACE = " ";
-
- /**
- * SINGLE_SLASH /
- */
- public static final String SINGLE_SLASH = "/";
-
- /**
- * DOUBLE_SLASH //
- */
- public static final String DOUBLE_SLASH = "//";
-
- /**
- * SINGLE_QUOTES "'"
- */
- public static final String SINGLE_QUOTES = "'";
- /**
- * DOUBLE_QUOTES "\""
- */
- public static final String DOUBLE_QUOTES = "\"";
-
- /**
- * SEMICOLON ;
- */
- public static final String SEMICOLON = ";";
-
- /**
- * EQUAL SIGN
- */
- public static final String EQUAL_SIGN = "=";
- /**
- * AT SIGN
- */
- public static final String AT_SIGN = "@";
- /**
- * UNDERLINE
- */
- public static final String UNDERLINE = "_";
-
- /**
- * sleep time
- */
- public static final int SLEEP_TIME_MILLIS = 1000;
-
- /**
- * exit code failure
- */
- public static final int EXIT_CODE_FAILURE = -1;
-
- /**
- * exit code success
- */
- public static final int EXIT_CODE_SUCCESS = 0;
- /**
- * running code
- */
- public static final int RUNNING_CODE = 1;
-
- public static final String SH = "sh";
-
- /**
- * log flush interval?output when reach the interval
- */
- public static final int DEFAULT_LOG_FLUSH_INTERVAL = 1000;
-
- /**
- * pstree, get pud and sub pid
- */
- public static final String PSTREE = "pstree";
-
- public static final String RWXR_XR_X = "rwxr-xr-x";
-
- /**
- * date format of yyyyMMddHHmmss
- */
- public static final String PARAMETER_FORMAT_TIME = "yyyyMMddHHmmss";
-
- /**
- * new
- * schedule time
- */
- public static final String PARAMETER_SHECDULE_TIME = "schedule.time";
-
- /**
- * system date(yyyyMMddHHmmss)
- */
- public static final String PARAMETER_DATETIME =
DateConstants.PARAMETER_DATETIME;
-
- /**
- * system date(yyyymmdd) today
- */
- public static final String PARAMETER_CURRENT_DATE =
DateConstants.PARAMETER_CURRENT_DATE;
-
- /**
- * system date(yyyymmdd) yesterday
- */
- public static final String PARAMETER_BUSINESS_DATE =
DateConstants.PARAMETER_BUSINESS_DATE;
-
- /**
- * the absolute path of current executing task
- */
- public static final String PARAMETER_TASK_EXECUTE_PATH =
"system.task.execute.path";
-
- /**
- * the instance id of current task
- */
- public static final String PARAMETER_TASK_INSTANCE_ID =
"system.task.instance.id";
-
- /**
- * the definition code of current task
- */
- public static final String PARAMETER_TASK_DEFINITION_CODE =
"system.task.definition.code";
-
- /**
- * the definition name of current task
- */
- public static final String PARAMETER_TASK_DEFINITION_NAME =
"system.task.definition.name";
-
- /**
- * the instance id of the workflow to which current task belongs
- */
- public static final String PARAMETER_WORKFLOW_INSTANCE_ID =
"system.workflow.instance.id";
-
- /**
- * the definition code of the workflow to which current task belongs
- */
- public static final String PARAMETER_WORKFLOW_DEFINITION_CODE =
"system.workflow.definition.code";
-
- /**
- * the definition name of the workflow to which current task belongs
- */
- public static final String PARAMETER_WORKFLOW_DEFINITION_NAME =
"system.workflow.definition.name";
-
- /**
- * the code of the project to which current task belongs
- */
- public static final String PARAMETER_PROJECT_CODE = "system.project.code";
-
- /**
- * the name of the project to which current task belongs
- */
- public static final String PARAMETER_PROJECT_NAME = "system.project.name";
- /**
- * month_begin
- */
- public static final String MONTH_BEGIN = "month_begin";
- /**
- * add_months
- */
- public static final String ADD_MONTHS = "add_months";
- /**
- * month_end
- */
- public static final String MONTH_END = "month_end";
- /**
- * week_begin
- */
- public static final String WEEK_BEGIN = "week_begin";
- /**
- * week_end
- */
- public static final String WEEK_END = "week_end";
- /**
- * this_day
- */
- public static final String THIS_DAY = "this_day";
- /**
- * last_day
- */
- public static final String LAST_DAY = "last_day";
-
- /**
- * month_first_day
- */
- public static final String MONTH_FIRST_DAY = "month_first_day";
-
- /**
- * month_last_day
- */
- public static final String MONTH_LAST_DAY = "month_last_day";
-
- /**
- * week_first_day
- */
- public static final String WEEK_FIRST_DAY = "week_first_day";
-
- /**
- * week_last_day
- */
- public static final String WEEK_LAST_DAY = "week_last_day";
-
- /**
- * year_week
- */
- public static final String YEAR_WEEK = "year_week";
- /**
- * timestamp
- */
- public static final String TIMESTAMP = "timestamp";
- public static final char SUBTRACT_CHAR = '-';
- public static final char ADD_CHAR = '+';
- public static final char MULTIPLY_CHAR = '*';
- public static final char DIVISION_CHAR = '/';
- public static final char LEFT_BRACE_CHAR = '(';
- public static final char RIGHT_BRACE_CHAR = ')';
- public static final String ADD_STRING = "+";
- public static final String MULTIPLY_STRING = "*";
- public static final String DIVISION_STRING = "/";
- public static final String LEFT_BRACE_STRING = "(";
- public static final char P = 'P';
- public static final char N = 'N';
- public static final String SUBTRACT_STRING = "-";
- public static final String LOCAL_PARAMS_LIST = "localParamsList";
- public static final String TASK_TYPE = "taskType";
- public static final String QUEUE = "queue";
- /**
- * default display rows
- */
- public static final int DEFAULT_DISPLAY_ROWS = 10;
-
- /**
- * jar
- */
- public static final String JAR = "jar";
-
- /**
- * hadoop
- */
- public static final String HADOOP = "hadoop";
-
- /**
- * -D <property>=<value>
- */
- public static final String D = "-D";
-
/**
* datasource encryption salt
*/
@@ -408,62 +144,6 @@ public class DataSourceConstants {
public static final String HADOOP_SECURITY_AUTHENTICATION_STARTUP_STATE =
"hadoop.security.authentication.startup.state";
- /**
- * hdfs/s3 configuration
- * resource.storage.upload.base.path
- */
- public static final String RESOURCE_UPLOAD_PATH =
"resource.storage.upload.base.path";
-
- public static final Set<String> TASK_TYPE_SET_K8S = Sets.newHashSet("K8S",
"KUBEFLOW");
-
- /**
- * azure config
- */
- public static final String AZURE_CLIENT_ID = "resource.azure.client.id";
- public static final String AZURE_CLIENT_SECRET =
"resource.azure.client.secret";
- public static final String AZURE_ACCESS_SUB_ID = "resource.azure.subId";
- public static final String AZURE_SECRET_TENANT_ID =
"resource.azure.tenant.id";
- public static final String QUERY_INTERVAL = "resource.query.interval";
-
- /**
- * use for k8s task
- */
- public static final String API_VERSION = "batch/v1";
- public static final String RESTART_POLICY = "Never";
- public static final String MEMORY = "memory";
- public static final String CPU = "cpu";
- public static final String LAYER_LABEL = "k8s.cn/layer";
- public static final String LAYER_LABEL_VALUE = "batch";
- public static final String NAME_LABEL = "k8s.cn/name";
- public static final String TASK_INSTANCE_ID = "taskInstanceId";
- public static final String MI = "Mi";
- public static final int JOB_TTL_SECONDS = 300;
- public static final int LOG_LINES = 500;
- public static final String NAMESPACE_NAME = "name";
- public static final String CLUSTER = "cluster";
-
- /**
- * spark / flink on k8s label name
- */
- public static final String UNIQUE_LABEL_NAME = "dolphinscheduler-label";
-
- /**
- * conda config used by jupyter task plugin
- */
- public static final String CONDA_PATH = "conda.path";
-
- // Loop task constants
- public static final Duration DEFAULT_LOOP_STATUS_INTERVAL =
Duration.ofSeconds(5L);
-
- /**
- * sql params regex
- */
- public static final String GROUP_NAME1 = "paramName1";
- public static final String GROUP_NAME2 = "paramName2";
- public static final String SQL_PARAMS_REGEX =
- String.format("['\"]\\$\\{(?<%s>.*?)}['\"]|\\$\\{(?<%s>.*?)}",
GROUP_NAME1, GROUP_NAME2);
- public static final Pattern SQL_PARAMS_PATTERN =
Pattern.compile(SQL_PARAMS_REGEX);
-
public static final String AZURE_SQL_DATABASE_SPN =
"https://database.windows.net/";;
public static final String AZURE_SQL_DATABASE_TOKEN_SCOPE = "/.default";
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java
index 7e5fb6555a..4886850d83 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java
@@ -25,7 +25,6 @@ import static
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSo
import static
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants.KERBEROS;
import static
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants.LOGIN_USER_KEY_TAB_PATH;
import static
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants.LOGIN_USER_KEY_TAB_USERNAME;
-import static
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants.RESOURCE_UPLOAD_PATH;
import org.apache.dolphinscheduler.common.constants.Constants;
import org.apache.dolphinscheduler.common.enums.StorageType;
@@ -125,26 +124,4 @@ public class CommonUtils {
return false;
}
- /**
- * @param tenantCode tenant code
- * @return file directory of tenants on hdfs
- */
- public static String getHdfsTenantDir(String tenantCode) {
- return String.format("%s/%s", getHdfsDataBasePath(), tenantCode);
- }
-
- /**
- * get data hdfs path
- *
- * @return data hdfs path
- */
- public static String getHdfsDataBasePath() {
- String resourceUploadPath =
PropertyUtils.getString(RESOURCE_UPLOAD_PATH, "/dolphinscheduler");
- if ("/".equals(resourceUploadPath)) {
- // if basepath is configured to /, the generated url may be
//default/resources (with extra leading /)
- return "";
- } else {
- return resourceUploadPath;
- }
- }
}
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/test/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtilsTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/test/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtilsTest.java
index b9646d47a4..d8734244b0 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/test/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtilsTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/test/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtilsTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.api.utils;
-import static
org.apache.dolphinscheduler.common.constants.DataSourceConstants.DATASOURCE_ENCRYPTION_ENABLE;
+import static
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants.DATASOURCE_ENCRYPTION_ENABLE;
import org.apache.dolphinscheduler.common.constants.Constants;
import org.apache.dolphinscheduler.common.utils.PropertyUtils;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-athena/src/test/java/org/apache/dolphinscheduler/plugin/datasource/athena/param/AthenaDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-athena/src/test/java/org/apache/dolphinscheduler/plugin/datasource/athena/param/AthenaDataSourceProcessorTest.java
index bd3b3e4d6f..ceab46be75 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-athena/src/test/java/org/apache/dolphinscheduler/plugin/datasource/athena/param/AthenaDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-athena/src/test/java/org/apache/dolphinscheduler/plugin/datasource/athena/param/AthenaDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.athena.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-azure-sql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/azuresql/param/SQLServerDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-azure-sql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/azuresql/param/SQLServerDataSourceProcessorTest.java
index 5a25ce3816..134d504e5b 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-azure-sql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/azuresql/param/SQLServerDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-azure-sql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/azuresql/param/SQLServerDataSourceProcessorTest.java
@@ -17,8 +17,8 @@
package org.apache.dolphinscheduler.plugin.datasource.azuresql.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
import org.apache.dolphinscheduler.common.utils.JSONUtils;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dameng/src/test/java/org/apache/dolphinscheduler/plugin/datasource/dameng/param/DamengDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dameng/src/test/java/org/apache/dolphinscheduler/plugin/datasource/dameng/param/DamengDataSourceProcessorTest.java
index b724a3c106..08b9c82cf2 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dameng/src/test/java/org/apache/dolphinscheduler/plugin/datasource/dameng/param/DamengDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dameng/src/test/java/org/apache/dolphinscheduler/plugin/datasource/dameng/param/DamengDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.dameng.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-databend/src/test/java/org/apache/dolphinscheduler/plugin/datasource/databend/param/DatabendDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-databend/src/test/java/org/apache/dolphinscheduler/plugin/datasource/databend/param/DatabendDataSourceProcessorTest.java
index 60903f4b97..4b947cdd25 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-databend/src/test/java/org/apache/dolphinscheduler/plugin/datasource/databend/param/DatabendDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-databend/src/test/java/org/apache/dolphinscheduler/plugin/datasource/databend/param/DatabendDataSourceProcessorTest.java
@@ -17,8 +17,8 @@
package org.apache.dolphinscheduler.plugin.datasource.databend.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
import org.apache.dolphinscheduler.common.utils.JSONUtils;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.CommonUtils;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.DataSourceUtils;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-db2/src/test/java/org/apache/dolphinscheduler/plugin/datasource/db2/param/Db2DataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-db2/src/test/java/org/apache/dolphinscheduler/plugin/datasource/db2/param/Db2DataSourceProcessorTest.java
index d5289afcf2..fbbb799c11 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-db2/src/test/java/org/apache/dolphinscheduler/plugin/datasource/db2/param/Db2DataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-db2/src/test/java/org/apache/dolphinscheduler/plugin/datasource/db2/param/Db2DataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.db2.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dolphindb/src/main/java/org/apache/dolphinscheduler/plugin/datasource/dolphindb/param/DolphinDBDataSourceProcessor.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dolphindb/src/main/java/org/apache/dolphinscheduler/plugin/datasource/dolphindb/param/DolphinDBDataSourceProcessor.java
index 8284bbe749..cfa2f531b7 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dolphindb/src/main/java/org/apache/dolphinscheduler/plugin/datasource/dolphindb/param/DolphinDBDataSourceProcessor.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dolphindb/src/main/java/org/apache/dolphinscheduler/plugin/datasource/dolphindb/param/DolphinDBDataSourceProcessor.java
@@ -18,8 +18,8 @@
package org.apache.dolphinscheduler.plugin.datasource.dolphindb.param;
import org.apache.dolphinscheduler.common.constants.Constants;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
import org.apache.dolphinscheduler.common.utils.JSONUtils;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import
org.apache.dolphinscheduler.plugin.datasource.api.datasource.AbstractDataSourceProcessor;
import
org.apache.dolphinscheduler.plugin.datasource.api.datasource.BaseDataSourceParamDTO;
import
org.apache.dolphinscheduler.plugin.datasource.api.datasource.DataSourceProcessor;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dolphindb/src/test/java/org/apache/dolphinscheduler/plugin/datasource/dolphindb/param/DolphinDBDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dolphindb/src/test/java/org/apache/dolphinscheduler/plugin/datasource/dolphindb/param/DolphinDBDataSourceProcessorTest.java
index b59cbaa5fe..5ab7e7696d 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dolphindb/src/test/java/org/apache/dolphinscheduler/plugin/datasource/dolphindb/param/DolphinDBDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-dolphindb/src/test/java/org/apache/dolphinscheduler/plugin/datasource/dolphindb/param/DolphinDBDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.dolphindb.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-doris/src/test/java/org/apache/dolphinscheduler/plugin/doris/param/DorisDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-doris/src/test/java/org/apache/dolphinscheduler/plugin/doris/param/DorisDataSourceProcessorTest.java
index 192429689c..029b98734c 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-doris/src/test/java/org/apache/dolphinscheduler/plugin/doris/param/DorisDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-doris/src/test/java/org/apache/dolphinscheduler/plugin/doris/param/DorisDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.doris.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-hana/src/test/java/org/apache/dolphinscheduler/plugin/datasource/hana/param/HanaDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-hana/src/test/java/org/apache/dolphinscheduler/plugin/datasource/hana/param/HanaDataSourceProcessorTest.java
index c457eb3e73..63be6301bd 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-hana/src/test/java/org/apache/dolphinscheduler/plugin/datasource/hana/param/HanaDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-hana/src/test/java/org/apache/dolphinscheduler/plugin/datasource/hana/param/HanaDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.hana.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-hive/src/test/java/org/apache/dolphinscheduler/plugin/datasource/hive/param/HiveDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-hive/src/test/java/org/apache/dolphinscheduler/plugin/datasource/hive/param/HiveDataSourceProcessorTest.java
index ef5e71729c..6b0b8a4a15 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-hive/src/test/java/org/apache/dolphinscheduler/plugin/datasource/hive/param/HiveDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-hive/src/test/java/org/apache/dolphinscheduler/plugin/datasource/hive/param/HiveDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.hive.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.CommonUtils;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-kyuubi/src/test/java/org/apache/dolphinscheduler/plugin/datasource/kyuubi/param/KyuubiDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-kyuubi/src/test/java/org/apache/dolphinscheduler/plugin/datasource/kyuubi/param/KyuubiDataSourceProcessorTest.java
index fc063371f8..c97a86848b 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-kyuubi/src/test/java/org/apache/dolphinscheduler/plugin/datasource/kyuubi/param/KyuubiDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-kyuubi/src/test/java/org/apache/dolphinscheduler/plugin/datasource/kyuubi/param/KyuubiDataSourceProcessorTest.java
@@ -17,8 +17,8 @@
package org.apache.dolphinscheduler.plugin.datasource.kyuubi.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
import org.apache.dolphinscheduler.common.utils.JSONUtils;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.CommonUtils;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.DataSourceUtils;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-mysql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/mysql/param/MySQLDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-mysql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/mysql/param/MySQLDataSourceProcessorTest.java
index f4a00c1e45..2577ecf9b0 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-mysql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/mysql/param/MySQLDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-mysql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/mysql/param/MySQLDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.mysql.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-oracle/src/test/java/org/apache/dolphinscheduler/plugin/datasource/oracle/param/OracleDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-oracle/src/test/java/org/apache/dolphinscheduler/plugin/datasource/oracle/param/OracleDataSourceProcessorTest.java
index 2f9133463d..a11c605c1b 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-oracle/src/test/java/org/apache/dolphinscheduler/plugin/datasource/oracle/param/OracleDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-oracle/src/test/java/org/apache/dolphinscheduler/plugin/datasource/oracle/param/OracleDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.oracle.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbConnectType;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-postgresql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/postgresql/param/PostgreSQLDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-postgresql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/postgresql/param/PostgreSQLDataSourceProcessorTest.java
index 92907be425..86828c0fb8 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-postgresql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/postgresql/param/PostgreSQLDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-postgresql/src/test/java/org/apache/dolphinscheduler/plugin/datasource/postgresql/param/PostgreSQLDataSourceProcessorTest.java
@@ -17,8 +17,8 @@
package org.apache.dolphinscheduler.plugin.datasource.postgresql.param;
-import static
org.apache.dolphinscheduler.common.constants.DataSourceConstants.ORG_POSTGRESQL_DRIVER;
-import static
org.apache.dolphinscheduler.common.constants.DataSourceConstants.POSTGRESQL_VALIDATION_QUERY;
+import static
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants.ORG_POSTGRESQL_DRIVER;
+import static
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants.POSTGRESQL_VALIDATION_QUERY;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-presto/src/test/java/org/apache/dolphinscheduler/plugin/datasource/presto/param/PrestoDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-presto/src/test/java/org/apache/dolphinscheduler/plugin/datasource/presto/param/PrestoDataSourceProcessorTest.java
index 61790b9a73..00e479fcbc 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-presto/src/test/java/org/apache/dolphinscheduler/plugin/datasource/presto/param/PrestoDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-presto/src/test/java/org/apache/dolphinscheduler/plugin/datasource/presto/param/PrestoDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.presto.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-redshift/src/test/java/org/apache/dolphinscheduler/plugin/datasource/redshift/param/RedshiftDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-redshift/src/test/java/org/apache/dolphinscheduler/plugin/datasource/redshift/param/RedshiftDataSourceProcessorTest.java
index 2e61f71536..6ca6bcc3ba 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-redshift/src/test/java/org/apache/dolphinscheduler/plugin/datasource/redshift/param/RedshiftDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-redshift/src/test/java/org/apache/dolphinscheduler/plugin/datasource/redshift/param/RedshiftDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.redshift.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-snowflake/src/test/java/org/apache/dolphinscheduler/plugin/datasource/snowflake/param/SnowflakeDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-snowflake/src/test/java/org/apache/dolphinscheduler/plugin/datasource/snowflake/param/SnowflakeDataSourceProcessorTest.java
index c60e70576f..200066496e 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-snowflake/src/test/java/org/apache/dolphinscheduler/plugin/datasource/snowflake/param/SnowflakeDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-snowflake/src/test/java/org/apache/dolphinscheduler/plugin/datasource/snowflake/param/SnowflakeDataSourceProcessorTest.java
@@ -17,8 +17,8 @@
package org.apache.dolphinscheduler.plugin.datasource.snowflake.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
import org.apache.dolphinscheduler.common.utils.JSONUtils;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.CommonUtils;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.DataSourceUtils;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-spark/src/test/java/org/apache/dolphinscheduler/plugin/datasource/spark/param/SparkDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-spark/src/test/java/org/apache/dolphinscheduler/plugin/datasource/spark/param/SparkDataSourceProcessorTest.java
index a0b0cfc930..c98f85382e 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-spark/src/test/java/org/apache/dolphinscheduler/plugin/datasource/spark/param/SparkDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-spark/src/test/java/org/apache/dolphinscheduler/plugin/datasource/spark/param/SparkDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.spark.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.CommonUtils;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-sqlserver/src/test/java/org/apache/dolphinscheduler/plugin/datasource/sqlserver/param/SQLServerDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-sqlserver/src/test/java/org/apache/dolphinscheduler/plugin/datasource/sqlserver/param/SQLServerDataSourceProcessorTest.java
index 7d34755d65..9c0b0d335b 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-sqlserver/src/test/java/org/apache/dolphinscheduler/plugin/datasource/sqlserver/param/SQLServerDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-sqlserver/src/test/java/org/apache/dolphinscheduler/plugin/datasource/sqlserver/param/SQLServerDataSourceProcessorTest.java
@@ -19,8 +19,8 @@ package
org.apache.dolphinscheduler.plugin.datasource.sqlserver.param;
import static com.google.common.truth.Truth.assertThat;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
import org.apache.dolphinscheduler.common.utils.JSONUtils;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-trino/src/test/java/org/apache/dolphinscheduler/plugin/datasource/trino/TrinoDataSourceChannelTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-trino/src/test/java/org/apache/dolphinscheduler/plugin/datasource/trino/TrinoDataSourceChannelTest.java
index c34261e36d..23805e8a72 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-trino/src/test/java/org/apache/dolphinscheduler/plugin/datasource/trino/TrinoDataSourceChannelTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-trino/src/test/java/org/apache/dolphinscheduler/plugin/datasource/trino/TrinoDataSourceChannelTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.trino;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import
org.apache.dolphinscheduler.plugin.datasource.trino.param.TrinoConnectionParam;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-trino/src/test/java/org/apache/dolphinscheduler/plugin/datasource/trino/param/TrinoDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-trino/src/test/java/org/apache/dolphinscheduler/plugin/datasource/trino/param/TrinoDataSourceProcessorTest.java
index d24af09fda..f8650dab73 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-trino/src/test/java/org/apache/dolphinscheduler/plugin/datasource/trino/param/TrinoDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-trino/src/test/java/org/apache/dolphinscheduler/plugin/datasource/trino/param/TrinoDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.trino.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-vertica/src/test/java/org/apache/dolphinscheduler/plugin/datasource/vertica/param/VerticaDataSourceProcessorTest.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-vertica/src/test/java/org/apache/dolphinscheduler/plugin/datasource/vertica/param/VerticaDataSourceProcessorTest.java
index 95767d6611..8987bda43b 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-vertica/src/test/java/org/apache/dolphinscheduler/plugin/datasource/vertica/param/VerticaDataSourceProcessorTest.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-vertica/src/test/java/org/apache/dolphinscheduler/plugin/datasource/vertica/param/VerticaDataSourceProcessorTest.java
@@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.datasource.vertica.param;
-import org.apache.dolphinscheduler.common.constants.DataSourceConstants;
+import
org.apache.dolphinscheduler.plugin.datasource.api.constants.DataSourceConstants;
import org.apache.dolphinscheduler.plugin.datasource.api.utils.PasswordUtils;
import org.apache.dolphinscheduler.spi.enums.DbType;
