This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new bbb63ee20db [regression-test](improvement) show line number when
global var defined (#51256)
bbb63ee20db is described below
commit bbb63ee20db40a009d0859067c7a6b84da962068
Author: shuke <[email protected]>
AuthorDate: Wed May 28 14:27:54 2025 +0800
[regression-test](improvement) show line number when global var defined
(#51256)
### What problem does this PR solve?
Issue Number: close #xxx
Related PR: #xxx
Problem Summary:
pick #50482
---
.../doris/regression/util/LoggerUtils.groovy | 14 +++++---
.../suites/account_p0/test_property_session.groovy | 4 +--
.../test_account_management_grant_auth.groovy | 6 ++--
.../test_account_management_role_auth.groovy | 4 +--
.../test_account_management_user_auth.groovy | 6 ++--
.../auth_call/test_assistant_command_auth.groovy | 6 ++--
.../auth_call/test_cluster_management_auth.groovy | 6 ++--
.../auth_call/test_database_management_auth.groovy | 2 +-
.../suites/auth_call/test_ddl_backup_auth.groovy | 4 +--
.../suites/auth_call/test_ddl_catalog_auth.groovy | 14 ++++----
.../auth_call/test_ddl_colocate_group_auth.groovy | 4 +--
.../suites/auth_call/test_ddl_database_auth.groovy | 14 ++++----
.../auth_call/test_ddl_encryptkey_auth.groovy | 4 +--
.../suites/auth_call/test_ddl_file_auth.groovy | 6 ++--
.../suites/auth_call/test_ddl_function_auth.groovy | 6 ++--
.../suites/auth_call/test_ddl_index_auth.groovy | 4 +--
.../suites/auth_call/test_ddl_job_auth.groovy | 4 +--
.../auth_call/test_ddl_mask_view_auth.groovy | 4 +--
.../suites/auth_call/test_ddl_mtmv_auth.groovy | 22 ++++++-------
.../suites/auth_call/test_ddl_mv_auth.groovy | 10 +++---
.../auth_call/test_ddl_part_table_auth.groovy | 6 ++--
.../auth_call/test_ddl_policy_storage_auth.groovy | 4 +--
.../auth_call/test_ddl_repository_auth.groovy | 4 +--
.../suites/auth_call/test_ddl_resource_auth.groovy | 4 +--
.../suites/auth_call/test_ddl_restore_auth.groovy | 6 ++--
.../auth_call/test_ddl_row_policy_auth.groovy | 6 ++--
.../auth_call/test_ddl_sql_block_rule_auth.groovy | 4 +--
.../suites/auth_call/test_ddl_table_auth.groovy | 38 +++++++++++-----------
.../suites/auth_call/test_ddl_view_auth.groovy | 18 +++++-----
.../auth_call/test_ddl_workload_group_auth.groovy | 4 +--
.../suites/auth_call/test_dml_analyze_auth.groovy | 6 ++--
.../auth_call/test_dml_broker_load_auth.groovy | 6 ++--
.../auth_call/test_dml_cancel_profile_auth.groovy | 4 +--
.../auth_call/test_dml_delete_table_auth.groovy | 8 ++---
.../auth_call/test_dml_export_table_auth.groovy | 6 ++--
.../suites/auth_call/test_dml_insert_auth.groovy | 8 ++---
.../test_dml_multi_routine_load_auth.groovy | 8 ++---
.../auth_call/test_dml_mysql_load_auth.groovy | 4 +--
.../suites/auth_call/test_dml_outfile_auth.groovy | 4 +--
.../auth_call/test_dml_routine_load_auth.groovy | 8 ++---
.../auth_call/test_dml_select_udf_auth.groovy | 4 +--
.../auth_call/test_dml_stream_load_auth.groovy | 4 +--
.../auth_call/test_dml_update_table_auth.groovy | 6 ++--
.../auth_call/test_hive_base_case_auth.groovy | 24 +++++++-------
.../suites/auth_call/test_show_backend_auth.groovy | 4 +--
.../suites/auth_call/test_show_broker_auth.groovy | 4 +--
.../suites/auth_call/test_show_charset_auth.groovy | 6 ++--
.../test_show_convert_light_sc_auth.groovy | 4 +--
.../auth_call/test_show_create_table_auth.groovy | 10 +++---
.../suites/auth_call/test_show_data_auth.groovy | 6 ++--
.../auth_call/test_show_database_id_auth.groovy | 4 +--
.../auth_call/test_show_dynamic_table_auth.groovy | 4 +--
.../auth_call/test_show_frontend_auth.groovy | 4 +--
.../suites/auth_call/test_show_grant_auth.groovy | 4 +--
.../suites/auth_call/test_show_proc_auth.groovy | 4 +--
.../auth_call/test_show_query_stats_auth.groovy | 2 +-
.../auth_call/test_show_repository_auth.groovy | 4 +--
.../suites/auth_call/test_show_tablet_auth.groovy | 4 +--
.../auth_call/test_show_typecast_auth.groovy | 2 +-
.../suites/auth_p0/test_catalogs_auth.groovy | 4 +--
.../suites/auth_p0/test_mtmv_auth.groovy | 4 +--
.../auth_p0/test_partition_values_tvf_auth.groovy | 4 +--
.../suites/auth_p0/test_partitions_auth.groovy | 4 +--
.../suites/auth_p0/test_query_tvf_auth.groovy | 4 +--
.../suites/auth_p0/test_select_count_auth.groovy | 6 ++--
.../test_overall_compaction_status.groovy | 2 +-
.../jdbc/test_mysql_jdbc_statistics.groovy | 2 +-
.../external_table_p2/tvf/test_iceberg_meta.groovy | 4 +--
.../test_group_commit_interval_ms_property.groovy | 2 +-
.../suites/mtmv_p0/test_mtmv_outfile.groovy | 2 +-
.../rollup/test_materialized_view_bitmap.groovy | 2 +-
.../rollup/test_materialized_view_hll.groovy | 2 +-
...test_materialized_view_hll_with_light_sc.groovy | 2 +-
.../test_uniq_rollup_schema_change.groovy | 17 +---------
.../suites/variant_p0/complexjson.groovy | 2 +-
75 files changed, 229 insertions(+), 238 deletions(-)
diff --git
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/util/LoggerUtils.groovy
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/util/LoggerUtils.groovy
index bcb04e8e9ea..266d6628631 100644
---
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/util/LoggerUtils.groovy
+++
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/util/LoggerUtils.groovy
@@ -22,7 +22,11 @@ import com.google.common.collect.Sets
class LoggerUtils {
static Tuple2<Integer, String> getErrorInfo(Throwable t, File file) {
if (file.name.endsWith(".groovy")) {
- def st = findRootErrorStackTrace(t, Sets.newLinkedHashSet(), file)
+ // to disable global variables, we've add some content to the
bottom of the groovy file
+ // so if st.getLineNumber > fileLineCt, continue to seek the
original line.
+ def fileLineCt = file.readLines().size()
+
+ def st = findRootErrorStackTrace(t, Sets.newLinkedHashSet(), file,
fileLineCt)
int lineNumber = -1
if (!st.is(null)) {
lineNumber = st.getLineNumber()
@@ -41,12 +45,12 @@ class LoggerUtils {
}
}
- static StackTraceElement findRootErrorStackTrace(Throwable t,
Set<Throwable> throwables, File file) {
+ static StackTraceElement findRootErrorStackTrace(Throwable t,
Set<Throwable> throwables, File file, int fileLineCt) {
throwables.add(t)
def cause = t.getCause()
if (!cause.is(null) && !throwables.contains(cause)) {
- def foundStackTrace = findRootErrorStackTrace(cause, throwables,
file)
+ def foundStackTrace = findRootErrorStackTrace(cause, throwables,
file, fileLineCt)
if (!foundStackTrace.is(null)) {
return foundStackTrace
}
@@ -54,7 +58,9 @@ class LoggerUtils {
for (def st : t.getStackTrace()) {
if (Objects.equals(st.fileName, file.name)) {
- return st
+ if (st.getLineNumber() < fileLineCt) {
+ return st
+ }
}
}
return null
diff --git a/regression-test/suites/account_p0/test_property_session.groovy
b/regression-test/suites/account_p0/test_property_session.groovy
index 57b2dad747b..9715fe1d89b 100644
--- a/regression-test/suites/account_p0/test_property_session.groovy
+++ b/regression-test/suites/account_p0/test_property_session.groovy
@@ -32,7 +32,7 @@ suite("test_property_session") {
sql """GRANT USAGE_PRIV ON CLUSTER `${validCluster}` TO ${userName}""";
}
sql """GRANT select_PRIV ON *.*.* TO ${userName}""";
- connect(user=userName, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(userName, "${pwd}", context.config.jdbcUrl) {
sql """
set query_timeout=1;
"""
@@ -46,7 +46,7 @@ suite("test_property_session") {
// the priority of property should be higher than session
sql """set property for '${userName}' 'query_timeout' = '10';"""
- connect(user=userName, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(userName, "${pwd}", context.config.jdbcUrl) {
sql """
select sleep(3);
"""
diff --git
a/regression-test/suites/auth_call/test_account_management_grant_auth.groovy
b/regression-test/suites/auth_call/test_account_management_grant_auth.groovy
index 28cb71cdeac..eff62e64f88 100644
--- a/regression-test/suites/auth_call/test_account_management_grant_auth.groovy
+++ b/regression-test/suites/auth_call/test_account_management_grant_auth.groovy
@@ -42,7 +42,7 @@ suite("test_account_management_grant_auth","p0,auth_call") {
sql """grant select_priv on regression_test to ${user}"""
sql """create database ${dbName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE USER ${user_derive} IDENTIFIED BY '${pwd}';"""
exception "denied"
@@ -69,7 +69,7 @@ suite("test_account_management_grant_auth","p0,auth_call") {
}
}
sql """grant grant_priv on *.*.* to '${user}'"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE USER ${user_derive} IDENTIFIED BY '${pwd}';"""
sql """ALTER USER ${user_derive} IDENTIFIED BY "${pwd}";"""
sql """SET PASSWORD FOR '${user_derive}' = PASSWORD('${pwd}')"""
@@ -85,7 +85,7 @@ suite("test_account_management_grant_auth","p0,auth_call") {
}
sql """revoke grant_priv on *.*.* from '${user}'"""
sql """grant admin_priv on *.*.* to '${user}'"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE USER ${user_derive} IDENTIFIED BY '${pwd}';"""
sql """ALTER USER ${user_derive} IDENTIFIED BY "${pwd}";"""
sql """SET PASSWORD FOR '${user_derive}' = PASSWORD('${pwd}')"""
diff --git
a/regression-test/suites/auth_call/test_account_management_role_auth.groovy
b/regression-test/suites/auth_call/test_account_management_role_auth.groovy
index 2a90eeedf67..c3b27810081 100644
--- a/regression-test/suites/auth_call/test_account_management_role_auth.groovy
+++ b/regression-test/suites/auth_call/test_account_management_role_auth.groovy
@@ -45,7 +45,7 @@ suite("test_account_management_role_auth","p0,auth_call") {
sql """create database ${dbName}"""
sql """GRANT '${role}' TO ${user};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE ROLE ${role_derive}"""
exception "denied"
@@ -60,7 +60,7 @@ suite("test_account_management_role_auth","p0,auth_call") {
}
}
sql """grant grant_priv on *.*.* to ROLE '${role}'"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE ROLE ${role_derive}"""
sql """ALTER ROLE ${role_derive} COMMENT "this is my first role";"""
sql """DROP ROLE ${role_derive}"""
diff --git
a/regression-test/suites/auth_call/test_account_management_user_auth.groovy
b/regression-test/suites/auth_call/test_account_management_user_auth.groovy
index 936071b1e9d..fe6d6805f47 100644
--- a/regression-test/suites/auth_call/test_account_management_user_auth.groovy
+++ b/regression-test/suites/auth_call/test_account_management_user_auth.groovy
@@ -41,7 +41,7 @@ suite("test_account_management_user_auth","p0,auth_call") {
sql """grant select_priv on regression_test to ${user}"""
sql """create database ${dbName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE USER ${user_derive} IDENTIFIED BY '${pwd}';"""
exception "denied"
@@ -69,7 +69,7 @@ suite("test_account_management_user_auth","p0,auth_call") {
}
sql """grant grant_priv on *.*.* to '${user}'"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE USER ${user_derive} IDENTIFIED BY '${pwd}';"""
sql """ALTER USER ${user_derive} IDENTIFIED BY "${pwd}";"""
sql """SET PASSWORD FOR '${user_derive}' = PASSWORD('${pwd}')"""
@@ -85,7 +85,7 @@ suite("test_account_management_user_auth","p0,auth_call") {
}
sql """revoke grant_priv on *.*.* from '${user}'"""
sql """grant admin_priv on *.*.* to '${user}'"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE USER ${user_derive} IDENTIFIED BY '${pwd}';"""
sql """ALTER USER ${user_derive} IDENTIFIED BY "${pwd}";"""
sql """SET PASSWORD FOR '${user_derive}' = PASSWORD('${pwd}')"""
diff --git
a/regression-test/suites/auth_call/test_assistant_command_auth.groovy
b/regression-test/suites/auth_call/test_assistant_command_auth.groovy
index 339bd86a6c1..1b47e566ff3 100644
--- a/regression-test/suites/auth_call/test_assistant_command_auth.groovy
+++ b/regression-test/suites/auth_call/test_assistant_command_auth.groovy
@@ -60,7 +60,7 @@ suite("test_assistant_command_auth","p0,auth_call") {
);"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """use ${dbName}"""
exception "denied"
@@ -81,13 +81,13 @@ suite("test_assistant_command_auth","p0,auth_call") {
}
sql """grant select_PRIV on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """DESC ${dbName}.${tableName} ALL;"""
}
sql """grant select_PRIV on ${catalogName}.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """REFRESH CATALOG ${catalogName};"""
}
diff --git
a/regression-test/suites/auth_call/test_cluster_management_auth.groovy
b/regression-test/suites/auth_call/test_cluster_management_auth.groovy
index 396bcdc0f9a..2061b9dbca7 100644
--- a/regression-test/suites/auth_call/test_cluster_management_auth.groovy
+++ b/regression-test/suites/auth_call/test_cluster_management_auth.groovy
@@ -75,7 +75,7 @@ suite
("test_cluster_management_auth","nonConcurrent,p0,auth_call") {
// pipeline can't support delete node, it can affect other case
if (is_exists_follower()) {
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """show frontends"""
exception "denied"
@@ -92,7 +92,7 @@ suite
("test_cluster_management_auth","nonConcurrent,p0,auth_call") {
}
if (is_exists_observer()) {
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """show frontends"""
exception "denied"
@@ -109,7 +109,7 @@ suite
("test_cluster_management_auth","nonConcurrent,p0,auth_call") {
}
if (is_exists_backends()) {
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """show backends"""
exception "denied"
diff --git
a/regression-test/suites/auth_call/test_database_management_auth.groovy
b/regression-test/suites/auth_call/test_database_management_auth.groovy
index 33a26959619..c8db5036272 100644
--- a/regression-test/suites/auth_call/test_database_management_auth.groovy
+++ b/regression-test/suites/auth_call/test_database_management_auth.groovy
@@ -39,7 +39,7 @@ suite("test_database_management_auth","p0,auth_call") {
sql """grant select_priv on regression_test to ${user}"""
sql """create database ${dbName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW FRONTEND CONFIG"""
exception "denied"
diff --git a/regression-test/suites/auth_call/test_ddl_backup_auth.groovy
b/regression-test/suites/auth_call/test_ddl_backup_auth.groovy
index 3e2d8d005d3..fdb2d6b2221 100644
--- a/regression-test/suites/auth_call/test_ddl_backup_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_backup_auth.groovy
@@ -76,7 +76,7 @@ suite("test_ddl_backup_auth","p0,auth_call") {
)"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """BACKUP SNAPSHOT ${dbName}.${backupLabelName}
TO ${repositoryName}
@@ -100,7 +100,7 @@ suite("test_ddl_backup_auth","p0,auth_call") {
}
}
sql """grant LOAD_PRIV on ${dbName}.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """BACKUP SNAPSHOT ${dbName}.${backupLabelName}
TO ${repositoryName}
ON (${tableName})
diff --git a/regression-test/suites/auth_call/test_ddl_catalog_auth.groovy
b/regression-test/suites/auth_call/test_ddl_catalog_auth.groovy
index 87c256c770e..80f71a2e16f 100644
--- a/regression-test/suites/auth_call/test_ddl_catalog_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_catalog_auth.groovy
@@ -43,7 +43,7 @@ suite("test_ddl_catalog_auth","p0,auth_call") {
sql """grant select_priv on regression_test to ${user}"""
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create catalog if not exists ${catalogName} properties (
'type'='hms'
@@ -58,7 +58,7 @@ suite("test_ddl_catalog_auth","p0,auth_call") {
);"""
sql """grant Create_priv on ${catalogName}.*.* to ${user}"""
sql """drop catalog ${catalogName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """create catalog if not exists ${catalogName} properties (
'type'='hms'
);"""
@@ -69,14 +69,14 @@ suite("test_ddl_catalog_auth","p0,auth_call") {
// ddl alter
// user alter
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """ALTER CATALOG ${catalogName} RENAME ${catalogNameNew};"""
exception "denied"
}
}
sql """grant ALTER_PRIV on ${catalogName}.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """ALTER CATALOG ${catalogName} RENAME ${catalogNameNew};"""
test {
sql """show create catalog ${catalogNameNew}"""
@@ -87,21 +87,21 @@ suite("test_ddl_catalog_auth","p0,auth_call") {
}
// root alter
sql """ALTER CATALOG ${catalogNameNew} RENAME ${catalogName};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """show create catalog ${catalogName}"""
def ctl_res = sql """show catalogs;"""
assertTrue(ctl_res.size() == 2)
}
// ddl drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """drop CATALOG ${catalogName};"""
exception "denied"
}
}
sql """grant DROP_PRIV on ${catalogName}.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """drop CATALOG ${catalogName};"""
def ctl_res = sql """show catalogs;"""
assertTrue(ctl_res.size() == 1)
diff --git
a/regression-test/suites/auth_call/test_ddl_colocate_group_auth.groovy
b/regression-test/suites/auth_call/test_ddl_colocate_group_auth.groovy
index 3c243facdb4..3d393a31db9 100644
--- a/regression-test/suites/auth_call/test_ddl_colocate_group_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_colocate_group_auth.groovy
@@ -45,7 +45,7 @@ suite("test_ddl_colocate_group_auth","p0,auth_call") {
);"""
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """ALTER COLOCATE GROUP ${dbName}.${colocateGroupName}
SET (
@@ -55,7 +55,7 @@ suite("test_ddl_colocate_group_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """ALTER COLOCATE GROUP ${dbName}.${colocateGroupName}
SET (
"replication_num"="1"
diff --git a/regression-test/suites/auth_call/test_ddl_database_auth.groovy
b/regression-test/suites/auth_call/test_ddl_database_auth.groovy
index 80e6b1b6e76..2821a375ddb 100644
--- a/regression-test/suites/auth_call/test_ddl_database_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_database_auth.groovy
@@ -40,7 +40,7 @@ suite("test_ddl_database_auth","p0,auth_call") {
sql """grant select_priv on regression_test to ${user}"""
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create database ${dbName};"""
exception "denied"
@@ -51,7 +51,7 @@ suite("test_ddl_database_auth","p0,auth_call") {
sql """create database ${dbName};"""
sql """grant Create_priv on ${dbName}.* to ${user}"""
sql """drop database ${dbName};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """create database ${dbName};"""
sql """show create database ${dbName}"""
def db_res = sql """show databases;"""
@@ -60,14 +60,14 @@ suite("test_ddl_database_auth","p0,auth_call") {
// ddl alter
// user alter
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """ALTER database ${dbName} RENAME ${dbNameNew};"""
exception "denied"
}
}
sql """grant ALTER_PRIV on ${dbName}.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """ALTER database ${dbName} RENAME ${dbNameNew};"""
test {
sql """show create database ${dbNameNew}"""
@@ -78,21 +78,21 @@ suite("test_ddl_database_auth","p0,auth_call") {
}
// root alter
sql """ALTER database ${dbNameNew} RENAME ${dbName};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """show create database ${dbName}"""
def db_res = sql """show databases;"""
assertTrue(db_res.size() == 4 || db_res.size() == 2)
}
// ddl drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """drop database ${dbName};"""
exception "denied"
}
}
sql """grant DROP_PRIV on ${dbName}.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """drop database ${dbName};"""
def ctl_res = sql """show databases;"""
assertTrue(ctl_res.size() == 3 || ctl_res.size() == 1)
diff --git a/regression-test/suites/auth_call/test_ddl_encryptkey_auth.groovy
b/regression-test/suites/auth_call/test_ddl_encryptkey_auth.groovy
index e24c88d5586..0749bdab717 100644
--- a/regression-test/suites/auth_call/test_ddl_encryptkey_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_encryptkey_auth.groovy
@@ -38,7 +38,7 @@ suite("test_ddl_encryptkey_auth","p0,auth_call") {
sql """create database ${dbName}"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE ENCRYPTKEY ${encryptkeyName} AS "ABCD123456789";"""
exception "denied"
@@ -53,7 +53,7 @@ suite("test_ddl_encryptkey_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """CREATE ENCRYPTKEY ${encryptkeyName} AS "ABCD123456789";"""
def res = sql """SHOW ENCRYPTKEYS FROM ${dbName}"""
diff --git a/regression-test/suites/auth_call/test_ddl_file_auth.groovy
b/regression-test/suites/auth_call/test_ddl_file_auth.groovy
index 77ca5e6703f..ff4dd4b4a18 100644
--- a/regression-test/suites/auth_call/test_ddl_file_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_file_auth.groovy
@@ -42,7 +42,7 @@ suite("test_ddl_file_auth","p0,auth_call") {
def dataFilePath =
"https://"+"${bucket}"+"."+"${s3_endpoint}"+"/regression/auth_test.key";
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE FILE "${fileName}" IN ${dbName}
PROPERTIES
@@ -62,13 +62,13 @@ suite("test_ddl_file_auth","p0,auth_call") {
}
}
sql """grant select_priv on ${dbName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """SHOW FILE FROM ${dbName};"""
}
sql """revoke select_priv on ${dbName} from ${user}"""
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE FILE "${fileName}" IN ${dbName}
PROPERTIES
(
diff --git a/regression-test/suites/auth_call/test_ddl_function_auth.groovy
b/regression-test/suites/auth_call/test_ddl_function_auth.groovy
index f8fd51cf1cf..2fa524bf424 100644
--- a/regression-test/suites/auth_call/test_ddl_function_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_function_auth.groovy
@@ -40,7 +40,7 @@ suite("test_ddl_function_auth","p0,auth_call") {
sql """grant select_priv on ${dbName}.* to ${user}"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE ALIAS FUNCTION ${dbName}.${functionName}(INT) WITH
PARAMETER(id) AS CONCAT(LEFT(id, 3), '****', RIGHT(id, 4));"""
exception "denied"
@@ -56,7 +56,7 @@ suite("test_ddl_function_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE ALIAS FUNCTION ${dbName}.${functionName}(INT) WITH
PARAMETER(id) AS CONCAT(LEFT(id, 3), '****', RIGHT(id, 4));"""
sql """use ${dbName}"""
def res = sql """show functions"""
@@ -74,7 +74,7 @@ suite("test_ddl_function_auth","p0,auth_call") {
sql """use ${dbName}"""
def func_res = sql """show functions"""
assertTrue(func_res.size() == 1)
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
def res = sql """SHOW CREATE FUNCTION ${dbName}.${functionName}(INT)"""
logger.info("res: " + res)
diff --git a/regression-test/suites/auth_call/test_ddl_index_auth.groovy
b/regression-test/suites/auth_call/test_ddl_index_auth.groovy
index baa8d79f8c7..53ba3a0d4b3 100644
--- a/regression-test/suites/auth_call/test_ddl_index_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_index_auth.groovy
@@ -80,7 +80,7 @@ suite("test_ddl_index_auth","p0,auth_call") {
assertTrue(index_res_tmp.size() == 0)
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE INDEX IF NOT EXISTS ${indexName} ON
${dbName}.${tableName} (username3) USING INVERTED COMMENT 'balabala';"""
exception "denied"
@@ -97,7 +97,7 @@ suite("test_ddl_index_auth","p0,auth_call") {
}
}
sql """grant ALTER_PRIV on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def ss = sql """show grants"""
logger.info("ss:" + ss)
sql """use ${dbName}"""
diff --git a/regression-test/suites/auth_call/test_ddl_job_auth.groovy
b/regression-test/suites/auth_call/test_ddl_job_auth.groovy
index 376cf8efbe9..45798191e48 100644
--- a/regression-test/suites/auth_call/test_ddl_job_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_job_auth.groovy
@@ -50,7 +50,7 @@ suite("test_ddl_job_auth","p0,auth_call") {
sql """create table ${dbName}.${tableNameDst} like
${dbName}.${tableName}"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE JOB ${jobName} ON SCHEDULE AT '2020-01-01 00:00:00'
DO INSERT INTO ${dbName}.${tableNameDst} SELECT * FROM
${dbName}.${tableName};"""
exception "denied"
@@ -75,7 +75,7 @@ suite("test_ddl_job_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE JOB ${jobName} ON SCHEDULE AT '2100-01-01 00:00:00' DO
INSERT INTO ${dbName}.${tableNameDst} SELECT * FROM ${dbName}.${tableName};"""
def res = sql """select * from jobs("type"="insert") where
Name="${jobName}";"""
assertTrue(res.size() == 1)
diff --git a/regression-test/suites/auth_call/test_ddl_mask_view_auth.groovy
b/regression-test/suites/auth_call/test_ddl_mask_view_auth.groovy
index 319eec2963e..590e75781f1 100644
--- a/regression-test/suites/auth_call/test_ddl_mask_view_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_mask_view_auth.groovy
@@ -55,14 +55,14 @@ suite("test_ddl_mask_view_auth","p0,auth_call") {
AS
SELECT mask(id) as k1, mask(username) as v1 FROM
${dbName}.${tableName} GROUP BY k1, v1;"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """select * from ${dbName}.${viewName};"""
exception "denied"
}
}
sql """grant select_PRIV on ${dbName}.${viewName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """select * from ${dbName}.${viewName};"""
assertTrue(res[0][0] == "n")
assertTrue(res[0][1] == "nnnxxxXXX")
diff --git a/regression-test/suites/auth_call/test_ddl_mtmv_auth.groovy
b/regression-test/suites/auth_call/test_ddl_mtmv_auth.groovy
index 3aa146f5889..4db2177ee6c 100644
--- a/regression-test/suites/auth_call/test_ddl_mtmv_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_mtmv_auth.groovy
@@ -48,7 +48,7 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
);"""
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE MATERIALIZED VIEW ${dbName}.${mtmvName}
BUILD IMMEDIATE REFRESH AUTO ON MANUAL
@@ -64,7 +64,7 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
PROPERTIES ('replication_num' = '1')
AS select username, sum(id) as sum_id from
${dbName}.${tableName} group by username"""
sql """grant Create_priv on ${dbName}.${mtmvName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE MATERIALIZED VIEW ${dbName}.${mtmvName}
BUILD IMMEDIATE REFRESH AUTO ON MANUAL
@@ -76,7 +76,7 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
sql """drop MATERIALIZED VIEW ${dbName}.${mtmvName};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE MATERIALIZED VIEW ${dbName}.${mtmvName}
BUILD IMMEDIATE REFRESH AUTO ON MANUAL
DISTRIBUTED BY RANDOM BUCKETS 1
@@ -88,7 +88,7 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
assertTrue(tb_res.size() == 2)
}
sql """revoke select_priv on ${dbName}.${tableName} from ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """refresh MATERIALIZED VIEW ${mtmvName} auto;"""
@@ -122,7 +122,7 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
// ddl alter
// user alter
sql """revoke Create_priv on ${dbName}.${mtmvName} from ${user};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """ALTER MATERIALIZED VIEW ${mtmvName} rename
${mtmvNameNew};"""
exception "denied"
@@ -133,7 +133,7 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
}
}
sql """grant ALTER_PRIV on ${dbName}.${mtmvName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """show create materialized view ${mtmvName}"""
sql """ALTER MATERIALIZED VIEW ${mtmvName} rename ${mtmvNameNew};"""
@@ -148,7 +148,7 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
// root alter
sql """use ${dbName}"""
sql """ALTER MATERIALIZED VIEW ${mtmvNameNew} RENAME ${mtmvName};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """show create materialized view ${mtmvName}"""
def db_res = sql """show tables;"""
@@ -156,20 +156,20 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
}
// dml select
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """select username from ${dbName}.${mtmvName}"""
exception "denied"
}
}
sql """grant select_priv(username) on ${dbName}.${mtmvName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """select username from ${dbName}.${mtmvName}"""
}
sql """revoke select_priv(username) on ${dbName}.${mtmvName} from
${user}"""
// ddl drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """use ${dbName}"""
sql """drop materialized view ${mtmvName};"""
@@ -177,7 +177,7 @@ suite("test_ddl_mtmv_auth","p0,auth_call") {
}
}
sql """grant DROP_PRIV on ${dbName}.${mtmvName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """drop materialized view ${mtmvName};"""
def ctl_res = sql """show tables;"""
diff --git a/regression-test/suites/auth_call/test_ddl_mv_auth.groovy
b/regression-test/suites/auth_call/test_ddl_mv_auth.groovy
index 485343df673..4dbf54fdf0d 100644
--- a/regression-test/suites/auth_call/test_ddl_mv_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_mv_auth.groovy
@@ -54,7 +54,7 @@ suite("test_ddl_mv_auth","p0,auth_call") {
"""
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create materialized view ${mvName} as select username from
${dbName}.${tableName};"""
exception "denied"
@@ -65,7 +65,7 @@ suite("test_ddl_mv_auth","p0,auth_call") {
}
}
sql """grant select_priv(username) on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
test {
sql """create materialized view ${mvName} as select username from
${dbName}.${tableName};"""
@@ -77,7 +77,7 @@ suite("test_ddl_mv_auth","p0,auth_call") {
}
}
sql """grant alter_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """create materialized view ${mvName} as select username from
${dbName}.${tableName};"""
waitingMVTaskFinishedByMvName(dbName, tableName)
@@ -92,7 +92,7 @@ suite("test_ddl_mv_auth","p0,auth_call") {
sql """revoke select_priv(username) on ${dbName}.${tableName} from
${user}"""
// ddl drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """DROP MATERIALIZED VIEW IF EXISTS ${mvName} ON
${dbName}.${tableName};"""
exception "denied"
@@ -103,7 +103,7 @@ suite("test_ddl_mv_auth","p0,auth_call") {
}
}
sql """grant alter_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """DROP MATERIALIZED VIEW IF EXISTS ${mvName} ON ${tableName};"""
sql """ALTER TABLE ${dbName}.${tableName} DROP ROLLUP ${rollupName};"""
diff --git a/regression-test/suites/auth_call/test_ddl_part_table_auth.groovy
b/regression-test/suites/auth_call/test_ddl_part_table_auth.groovy
index 0d1bfb8551f..34e4766e19e 100644
--- a/regression-test/suites/auth_call/test_ddl_part_table_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_part_table_auth.groovy
@@ -52,7 +52,7 @@ suite("test_ddl_part_table_auth","p0,auth_call") {
logger.info("insert_res: " + insert_res)
def partition_info = sql """show partitions from ${dbName}.${tableName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """show partitions from ${dbName}.${tableName}"""
exception "denied"
@@ -63,14 +63,14 @@ suite("test_ddl_part_table_auth","p0,auth_call") {
}
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """show partitions from ${dbName}.${tableName}"""
sql """show query stats"""
}
sql """revoke select_priv on ${dbName}.${tableName} from ${user}"""
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """show partition ${partition_info[0][0]}"""
assertTrue(res.size() == 1)
}
diff --git
a/regression-test/suites/auth_call/test_ddl_policy_storage_auth.groovy
b/regression-test/suites/auth_call/test_ddl_policy_storage_auth.groovy
index 0b79c6d7f08..59b7bf2bc6e 100644
--- a/regression-test/suites/auth_call/test_ddl_policy_storage_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_policy_storage_auth.groovy
@@ -53,7 +53,7 @@ suite("test_ddl_policy_storage_auth","p0,auth_call") {
);"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use regression_test;"""
test {
sql """CREATE STORAGE POLICY ${storagePolicyName}
@@ -77,7 +77,7 @@ suite("test_ddl_policy_storage_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE STORAGE POLICY ${storagePolicyName}
PROPERTIES(
"storage_resource" = "${resourceName}",
diff --git a/regression-test/suites/auth_call/test_ddl_repository_auth.groovy
b/regression-test/suites/auth_call/test_ddl_repository_auth.groovy
index 8e127778f56..bfd1d9cf300 100644
--- a/regression-test/suites/auth_call/test_ddl_repository_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_repository_auth.groovy
@@ -42,7 +42,7 @@ suite("test_ddl_repository_auth","p0,auth_call") {
sql """create database ${dbName}"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE REPOSITORY `${repositoryName}`
WITH S3
@@ -67,7 +67,7 @@ suite("test_ddl_repository_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE REPOSITORY `${repositoryName}`
WITH S3
ON LOCATION "s3://${bucket}/${repositoryName}"
diff --git a/regression-test/suites/auth_call/test_ddl_resource_auth.groovy
b/regression-test/suites/auth_call/test_ddl_resource_auth.groovy
index a9d64ed9017..25cd53d8e19 100644
--- a/regression-test/suites/auth_call/test_ddl_resource_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_resource_auth.groovy
@@ -36,7 +36,7 @@ suite("test_ddl_resource_auth","p0,auth_call") {
sql """create database ${dbName}"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE RESOURCE IF NOT EXISTS "${resourceName}"
PROPERTIES(
@@ -68,7 +68,7 @@ suite("test_ddl_resource_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE RESOURCE IF NOT EXISTS "${resourceName}"
PROPERTIES(
"type" = "s3",
diff --git a/regression-test/suites/auth_call/test_ddl_restore_auth.groovy
b/regression-test/suites/auth_call/test_ddl_restore_auth.groovy
index 91b7c1378fd..635c57a585a 100644
--- a/regression-test/suites/auth_call/test_ddl_restore_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_restore_auth.groovy
@@ -117,14 +117,14 @@ suite("test_ddl_restore_auth","p0,auth_call") {
sql """truncate table ${dbName}.`${tableName}`"""
sql """grant admin_PRIV on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def show_snapshot_res = sql """SHOW SNAPSHOT ON ${repositoryName};"""
logger.info("show_snapshot_res: " + show_snapshot_res)
}
sql """revoke admin_PRIV on *.*.* from ${user}"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW SNAPSHOT ON ${repositoryName};"""
exception "denied"
@@ -154,7 +154,7 @@ suite("test_ddl_restore_auth","p0,auth_call") {
}
}
sql """grant LOAD_PRIV on ${dbName}.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """RESTORE SNAPSHOT ${dbName}.`${restoreLabelName}`
FROM `${repositoryName}`
ON ( `${tableName}` )
diff --git a/regression-test/suites/auth_call/test_ddl_row_policy_auth.groovy
b/regression-test/suites/auth_call/test_ddl_row_policy_auth.groovy
index 106e22d20e9..af1e074f8d7 100644
--- a/regression-test/suites/auth_call/test_ddl_row_policy_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_row_policy_auth.groovy
@@ -48,7 +48,7 @@ suite("test_ddl_row_policy_auth","p0,auth_call") {
);"""
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE ROW POLICY ${rowPolicyName} ON
${dbName}.${tableName} AS RESTRICTIVE TO ${user} USING (id = 1);"""
exception "denied"
@@ -64,7 +64,7 @@ suite("test_ddl_row_policy_auth","p0,auth_call") {
}
sql """grant grant_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE ROW POLICY ${rowPolicyName} ON ${dbName}.${tableName} AS
RESTRICTIVE TO ${user} USING (id = 1);"""
test {
@@ -75,7 +75,7 @@ suite("test_ddl_row_policy_auth","p0,auth_call") {
sql """DROP ROW POLICY ${rowPolicyName} on ${dbName}.${tableName} for
${user}"""
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE ROW POLICY ${rowPolicyName} ON ${dbName}.${tableName} AS
RESTRICTIVE TO ${user} USING (id = 1);"""
def res = sql """SHOW ROW POLICY FOR ${user}"""
assertTrue(res.size() == 1)
diff --git
a/regression-test/suites/auth_call/test_ddl_sql_block_rule_auth.groovy
b/regression-test/suites/auth_call/test_ddl_sql_block_rule_auth.groovy
index f5693686fad..3941897a5e9 100644
--- a/regression-test/suites/auth_call/test_ddl_sql_block_rule_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_sql_block_rule_auth.groovy
@@ -48,7 +48,7 @@ suite("test_ddl_sql_block_rule_auth","p0,auth_call") {
);"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE SQL_BLOCK_RULE ${sqlBlockRuleName}
PROPERTIES(
@@ -75,7 +75,7 @@ suite("test_ddl_sql_block_rule_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE SQL_BLOCK_RULE ${sqlBlockRuleName}
PROPERTIES(
"sql"="select \\\\* from ${dbName}\\\\.${tableName}",
diff --git a/regression-test/suites/auth_call/test_ddl_table_auth.groovy
b/regression-test/suites/auth_call/test_ddl_table_auth.groovy
index 4c74699f55f..c96aeb0d5e2 100644
--- a/regression-test/suites/auth_call/test_ddl_table_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_table_auth.groovy
@@ -68,7 +68,7 @@ suite("test_ddl_table_auth","p0,auth_call") {
}
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create table ${dbName}.${tableName} (
id BIGINT,
@@ -98,7 +98,7 @@ suite("test_ddl_table_auth","p0,auth_call") {
);"""
sql """grant Create_priv on ${dbName}.${tableName} to ${user}"""
sql """drop table ${dbName}.${tableName};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """create table ${dbName}.${tableName} (
id BIGINT,
username VARCHAR(20)
@@ -119,7 +119,7 @@ suite("test_ddl_table_auth","p0,auth_call") {
// ddl alter
// user alter
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """ALTER table ${tableName} RENAME ${tableNameNew};"""
exception "denied"
@@ -132,7 +132,7 @@ suite("test_ddl_table_auth","p0,auth_call") {
assertTrue(res.size() == 0)
}
sql """grant ALTER_PRIV on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """ALTER table ${tableName} RENAME ${tableNameNew};"""
@@ -146,7 +146,7 @@ suite("test_ddl_table_auth","p0,auth_call") {
// root alter
sql """use ${dbName}"""
sql """ALTER table ${tableNameNew} RENAME ${tableName};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """show create table ${tableName}"""
def db_res = sql """show tables;"""
@@ -154,7 +154,7 @@ suite("test_ddl_table_auth","p0,auth_call") {
}
// show
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """ALTER TABLE ${tableName} ADD COLUMN new_col INT KEY DEFAULT
"0";"""
def res = sql """SHOW ALTER TABLE COLUMN;"""
@@ -162,20 +162,20 @@ suite("test_ddl_table_auth","p0,auth_call") {
}
// dml select
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """select id from ${dbName}.${tableName}"""
exception "denied"
}
}
sql """grant select_priv(id) on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """select id from ${dbName}.${tableName}"""
}
sql """revoke select_priv(id) on ${dbName}.${tableName} from ${user}"""
// ddl create table like
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create table ${cteLikeDstDb}.${cteLikeDstTb} like
${dbName}.${tableName};"""
exception "denied"
@@ -185,21 +185,21 @@ suite("test_ddl_table_auth","p0,auth_call") {
sql """create table ${cteLikeDstDb}.${cteLikeDstTb} like
${dbName}.${tableName};"""
sql """grant Create_priv on ${cteLikeDstDb}.${cteLikeDstTb} to ${user}"""
sql """drop table ${cteLikeDstDb}.${cteLikeDstTb};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create table ${cteLikeDstDb}.${cteLikeDstTb} like
${dbName}.${tableName};"""
exception "denied"
}
}
sql """grant SELECT_PRIV on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """create table ${cteLikeDstDb}.${cteLikeDstTb} like
${dbName}.${tableName};"""
}
sql """revoke SELECT_PRIV on ${dbName}.${tableName} from ${user}"""
// ddl create table select
sql """create database ${cteSelectDstDb}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create table ${cteSelectDstDb}.${cteSelectDstTb}(username)
PROPERTIES("replication_num" = "1") as select username from
${dbName}.${tableName};"""
exception "denied"
@@ -208,7 +208,7 @@ suite("test_ddl_table_auth","p0,auth_call") {
sql """create table ${cteSelectDstDb}.${cteSelectDstTb}(username)
PROPERTIES("replication_num" = "1") as select username from
${dbName}.${tableName};"""
sql """grant Create_priv on ${cteSelectDstDb}.${cteSelectDstTb} to
${user}"""
sql """drop table ${cteSelectDstDb}.${cteSelectDstTb}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create table ${cteSelectDstDb}.${cteSelectDstTb}(username)
PROPERTIES("replication_num" = "1") as select username from
${dbName}.${tableName};"""
exception "denied"
@@ -217,20 +217,20 @@ suite("test_ddl_table_auth","p0,auth_call") {
sql """create table ${cteSelectDstDb}.${cteSelectDstTb}(username)
PROPERTIES("replication_num" = "1") as select username from
${dbName}.${tableName};"""
sql """grant LOAD_PRIV on ${cteSelectDstDb}.${cteSelectDstTb} to ${user}"""
sql """drop table ${cteSelectDstDb}.${cteSelectDstTb}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create table ${cteSelectDstDb}.${cteSelectDstTb}(username)
PROPERTIES("replication_num" = "1") as select username from
${dbName}.${tableName};"""
exception "denied"
}
}
sql """grant select_priv(username) on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """create table ${cteSelectDstDb}.${cteSelectDstTb}(username)
PROPERTIES("replication_num" = "1") as select username from
${dbName}.${tableName};"""
}
waitingChangeTaskFinished(dbName)
// ddl truncate
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """use ${dbName}"""
sql """truncate table ${tableName};"""
@@ -238,13 +238,13 @@ suite("test_ddl_table_auth","p0,auth_call") {
}
}
sql """grant LOAD_PRIV on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """truncate table ${tableName};"""
}
// ddl drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """use ${dbName}"""
sql """drop table ${tableName};"""
@@ -252,7 +252,7 @@ suite("test_ddl_table_auth","p0,auth_call") {
}
}
sql """grant DROP_PRIV on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """drop table ${tableName};"""
def ctl_res = sql """show tables;"""
diff --git a/regression-test/suites/auth_call/test_ddl_view_auth.groovy
b/regression-test/suites/auth_call/test_ddl_view_auth.groovy
index f90bab9dc8e..d503b3bc642 100644
--- a/regression-test/suites/auth_call/test_ddl_view_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_view_auth.groovy
@@ -53,7 +53,7 @@ suite("test_ddl_view_auth","p0,auth_call") {
"""
// ddl create
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE VIEW ${dbName}.${viewName} (k1, v1)
AS
@@ -67,7 +67,7 @@ suite("test_ddl_view_auth","p0,auth_call") {
}
}
sql """grant Create_priv on ${dbName}.${viewName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE VIEW ${dbName}.${viewName} (k1, v1)
AS
@@ -82,7 +82,7 @@ suite("test_ddl_view_auth","p0,auth_call") {
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE VIEW ${dbName}.${viewName} (k1, v1)
AS
SELECT id as k1, SUM(id) FROM ${dbName}.${tableName}
@@ -94,7 +94,7 @@ suite("test_ddl_view_auth","p0,auth_call") {
// ddl alter
// user alter
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """alter VIEW ${dbName}.${viewName} (k1, v1)
AS
@@ -104,7 +104,7 @@ suite("test_ddl_view_auth","p0,auth_call") {
}
}
sql """grant ALTER_PRIV on ${dbName}.${viewName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """alter VIEW ${dbName}.${viewName} (k1, v1)
AS
SELECT id as k1, SUM(id) FROM ${dbName}.${tableName}
@@ -112,26 +112,26 @@ suite("test_ddl_view_auth","p0,auth_call") {
}
// dml show
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """select * from ${dbName}.${viewName};"""
exception "denied"
}
}
sql """grant select_PRIV on ${dbName}.${viewName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """select * from ${dbName}.${viewName};"""
}
// ddl drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """drop table ${dbName}.${viewName};"""
exception 'denied'
}
}
sql """grant DROP_PRIV on ${dbName}.${viewName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """drop view ${viewName};"""
def ctl_res = sql """show tables;"""
diff --git
a/regression-test/suites/auth_call/test_ddl_workload_group_auth.groovy
b/regression-test/suites/auth_call/test_ddl_workload_group_auth.groovy
index 7657055d9d4..32589515c6b 100644
--- a/regression-test/suites/auth_call/test_ddl_workload_group_auth.groovy
+++ b/regression-test/suites/auth_call/test_ddl_workload_group_auth.groovy
@@ -39,7 +39,7 @@ suite("test_ddl_workload_group_auth","p0,auth_call") {
sql """create database ${dbName}"""
// ddl create,show,drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """CREATE WORKLOAD GROUP "${workloadGroupName}"
PROPERTIES (
@@ -64,7 +64,7 @@ suite("test_ddl_workload_group_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """CREATE WORKLOAD GROUP "${workloadGroupName}"
PROPERTIES (
"cpu_share"="10"
diff --git a/regression-test/suites/auth_call/test_dml_analyze_auth.groovy
b/regression-test/suites/auth_call/test_dml_analyze_auth.groovy
index 5db5da61f94..59706f140e6 100644
--- a/regression-test/suites/auth_call/test_dml_analyze_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_analyze_auth.groovy
@@ -48,7 +48,7 @@ suite("test_dml_analyze_auth","p0,auth_call") {
"replication_num" = "1"
);"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
analyze table ${dbName}.${tableName} with sync;
@@ -69,7 +69,7 @@ suite("test_dml_analyze_auth","p0,auth_call") {
}
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
analyze table ${dbName}.${tableName} with sync;
"""
@@ -80,7 +80,7 @@ suite("test_dml_analyze_auth","p0,auth_call") {
sql """show table stats ${dbName}.${tableName};"""
}
sql """grant select_priv on ${dbName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """show table status from ${dbName};"""
}
diff --git a/regression-test/suites/auth_call/test_dml_broker_load_auth.groovy
b/regression-test/suites/auth_call/test_dml_broker_load_auth.groovy
index 524513a570c..3ec26146699 100644
--- a/regression-test/suites/auth_call/test_dml_broker_load_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_broker_load_auth.groovy
@@ -68,7 +68,7 @@ suite("test_dml_broker_load_auth","p0,auth_call") {
);"""
sql """use ${dbName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
LOAD LABEL ${loadLabelName} (
@@ -104,7 +104,7 @@ suite("test_dml_broker_load_auth","p0,auth_call") {
}
}
sql """grant load_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName};"""
sql """
LOAD LABEL ${loadLabelName} (
@@ -149,7 +149,7 @@ suite("test_dml_broker_load_auth","p0,auth_call") {
}
sql """grant load_priv on ${dbName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """SHOW LOAD FROM ${dbName} WHERE LABEL LIKE
'${loadLabelName}'"""
logger.info("res: " + res)
assertTrue(res.size() == 1)
diff --git
a/regression-test/suites/auth_call/test_dml_cancel_profile_auth.groovy
b/regression-test/suites/auth_call/test_dml_cancel_profile_auth.groovy
index 82656726e65..6aab08b9337 100644
--- a/regression-test/suites/auth_call/test_dml_cancel_profile_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_cancel_profile_auth.groovy
@@ -35,7 +35,7 @@
suite("test_dml_cancel_profile_auth","p0,auth_call,nonConcurrent") {
sql """CREATE USER '${user}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
CLEAN ALL PROFILE;
@@ -44,7 +44,7 @@
suite("test_dml_cancel_profile_auth","p0,auth_call,nonConcurrent") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
CLEAN ALL PROFILE;
"""
diff --git a/regression-test/suites/auth_call/test_dml_delete_table_auth.groovy
b/regression-test/suites/auth_call/test_dml_delete_table_auth.groovy
index 4a0d9fa32c2..bdb65b57f37 100644
--- a/regression-test/suites/auth_call/test_dml_delete_table_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_delete_table_auth.groovy
@@ -54,7 +54,7 @@ suite("test_dml_delete_table_auth","p0,auth_call") {
(3, "333");
"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """DELETE FROM ${dbName}.${tableName} WHERE id = 3;"""
exception "denied"
@@ -105,7 +105,7 @@ suite("test_dml_delete_table_auth","p0,auth_call") {
(4),
(5);"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """DELETE FROM ${dbName}.${tableName1}
USING ${dbName}.${tableName2} INNER JOIN
${dbName}.${tableName3}
@@ -115,7 +115,7 @@ suite("test_dml_delete_table_auth","p0,auth_call") {
}
}
sql """grant load_priv on ${dbName}.${tableName1} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """set enable_fallback_to_original_planner=false;"""
test {
sql """DELETE FROM ${dbName}.${tableName1}
@@ -128,7 +128,7 @@ suite("test_dml_delete_table_auth","p0,auth_call") {
sql """grant select_priv on ${dbName}.${tableName1} to ${user}"""
sql """grant select_priv on ${dbName}.${tableName2} to ${user}"""
sql """grant select_priv on ${dbName}.${tableName3} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """DELETE FROM ${dbName}.${tableName1}
USING ${dbName}.${tableName2} INNER JOIN ${dbName}.${tableName3}
ON ${dbName}.${tableName2}.id = ${dbName}.${tableName3}.id
diff --git a/regression-test/suites/auth_call/test_dml_export_table_auth.groovy
b/regression-test/suites/auth_call/test_dml_export_table_auth.groovy
index aceea0771f8..d45ca91ac02 100644
--- a/regression-test/suites/auth_call/test_dml_export_table_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_export_table_auth.groovy
@@ -66,7 +66,7 @@ suite("test_dml_export_table_auth","p0,auth_call") {
String region = getS3Region()
String bucket = context.config.otherConfigs.get("s3BucketName");
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """EXPORT TABLE ${dbName}.${tableName} TO
"s3://${bucket}/test_outfile/exp_${exportLabel}"
PROPERTIES(
@@ -91,7 +91,7 @@ suite("test_dml_export_table_auth","p0,auth_call") {
}
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """EXPORT TABLE ${dbName}.${tableName} TO
"s3://${bucket}/test_outfile/exp_${exportLabel}"
PROPERTIES(
"format" = "csv",
@@ -109,7 +109,7 @@ suite("test_dml_export_table_auth","p0,auth_call") {
assertTrue(res.size() == 1)
}
sql """grant select_priv on ${dbName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
def res = sql """show export;"""
logger.info("res: " + res)
diff --git a/regression-test/suites/auth_call/test_dml_insert_auth.groovy
b/regression-test/suites/auth_call/test_dml_insert_auth.groovy
index 6a04281b1c0..6cfe66cb10c 100644
--- a/regression-test/suites/auth_call/test_dml_insert_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_insert_auth.groovy
@@ -63,7 +63,7 @@ suite("test_dml_insert_auth","p0,auth_call") {
(3, "333")
"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def insert_res = sql """SHOW LAST INSERT"""
logger.info("insert_res: " + insert_res)
test {
@@ -83,7 +83,7 @@ suite("test_dml_insert_auth","p0,auth_call") {
}
}
sql """grant load_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
INSERT INTO ${dbName}.${tableName} (id, username)
VALUES (1, "111"),
@@ -101,7 +101,7 @@ suite("test_dml_insert_auth","p0,auth_call") {
assertTrue(rows[0][0] == 3)
// insert overwrite
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
INSERT OVERWRITE table ${dbName}.${tableName} VALUES (4, "444");
"""
@@ -110,7 +110,7 @@ suite("test_dml_insert_auth","p0,auth_call") {
assertTrue(rows[0][0] == 1)
sql """grant select_priv on ${dbName}.${srcTableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """INSERT OVERWRITE table ${dbName}.${tableName} SELECT * FROM
${dbName}.${srcTableName};"""
}
rows = sql """select count() from ${dbName}.${tableName}"""
diff --git
a/regression-test/suites/auth_call/test_dml_multi_routine_load_auth.groovy
b/regression-test/suites/auth_call/test_dml_multi_routine_load_auth.groovy
index 1d9c6b83956..11fd6c43db4 100644
--- a/regression-test/suites/auth_call/test_dml_multi_routine_load_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_multi_routine_load_auth.groovy
@@ -69,7 +69,7 @@ suite("test_dml_multi_routine_load_auth","p0,auth_call") {
sql new File("""${context.file.parent}/ddl/${tableName1}.sql""").text
sql new File("""${context.file.parent}/ddl/${tableName2}.sql""").text
- connect(user = user, password = "${pwd}", url =
context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
CREATE ROUTINE LOAD ${dbName}.${labelName}
@@ -92,7 +92,7 @@ suite("test_dml_multi_routine_load_auth","p0,auth_call") {
}
sql """grant load_priv on ${dbName}.${tableName1} to ${user}"""
- connect(user = user, password = "${pwd}", url =
context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
CREATE ROUTINE LOAD ${dbName}.${labelName}
@@ -114,7 +114,7 @@ suite("test_dml_multi_routine_load_auth","p0,auth_call") {
}
}
sql """grant load_priv on ${dbName}.${tableName2} to ${user}"""
- connect(user = user, password = "${pwd}", url =
context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
CREATE ROUTINE LOAD ${dbName}.${labelName}
@@ -136,7 +136,7 @@ suite("test_dml_multi_routine_load_auth","p0,auth_call") {
}
}
sql """grant load_priv on ${dbName}.* to ${user}"""
- connect(user = user, password = "${pwd}", url =
context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
CREATE ROUTINE LOAD ${dbName}.${labelName}
COLUMNS TERMINATED BY "|"
diff --git a/regression-test/suites/auth_call/test_dml_mysql_load_auth.groovy
b/regression-test/suites/auth_call/test_dml_mysql_load_auth.groovy
index 6010b4b8b74..3963fe9433e 100644
--- a/regression-test/suites/auth_call/test_dml_mysql_load_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_mysql_load_auth.groovy
@@ -50,7 +50,7 @@ suite("test_dml_mysql_load_auth","p0,auth_call") {
sql """use ${dbName}"""
def path_file =
"${context.file.parent}/../../data/auth_call/stream_load_data.csv"
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
LOAD DATA LOCAL
@@ -64,7 +64,7 @@ suite("test_dml_mysql_load_auth","p0,auth_call") {
}
}
sql """grant load_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName};"""
sql """
LOAD DATA LOCAL
diff --git a/regression-test/suites/auth_call/test_dml_outfile_auth.groovy
b/regression-test/suites/auth_call/test_dml_outfile_auth.groovy
index 5318b1dbe31..7edf476883a 100644
--- a/regression-test/suites/auth_call/test_dml_outfile_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_outfile_auth.groovy
@@ -58,7 +58,7 @@ suite("test_dml_outfile_auth","p0,auth_call") {
String region = getS3Region()
String bucket = context.config.otherConfigs.get("s3BucketName")
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
SELECT * FROM ${dbName}.${tableName} t ORDER BY id
@@ -74,7 +74,7 @@ suite("test_dml_outfile_auth","p0,auth_call") {
}
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
SELECT * FROM ${dbName}.${tableName} t ORDER BY id
INTO OUTFILE "s3://${bucket}/outfile/auth/exp_"
diff --git a/regression-test/suites/auth_call/test_dml_routine_load_auth.groovy
b/regression-test/suites/auth_call/test_dml_routine_load_auth.groovy
index 2f6c078567f..ebad84283c7 100644
--- a/regression-test/suites/auth_call/test_dml_routine_load_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_routine_load_auth.groovy
@@ -68,7 +68,7 @@ suite("test_dml_routine_load_auth","p0,auth_call") {
PROPERTIES("replication_num" = "1");
;"""
- connect(user = user, password = "${pwd}", url =
context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
CREATE ROUTINE LOAD ${dbName}.${labelName} ON ${tableName}
@@ -86,7 +86,7 @@ suite("test_dml_routine_load_auth","p0,auth_call") {
}
sql """grant load_priv on ${dbName}.${tableName} to ${user}"""
- connect(user = user, password = "${pwd}", url =
context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
CREATE ROUTINE LOAD ${dbName}.${labelName} ON ${tableName}
COLUMNS(a,b),
@@ -101,7 +101,7 @@ suite("test_dml_routine_load_auth","p0,auth_call") {
}
sql """revoke load_priv on ${dbName}.${tableName} from ${user}"""
- connect(user = user, password = "${pwd}", url =
context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
ALTER ROUTINE LOAD FOR ${dbName}.${labelName}
@@ -130,7 +130,7 @@ suite("test_dml_routine_load_auth","p0,auth_call") {
}
}
sql """grant load_priv on ${dbName}.${tableName} to ${user}"""
- connect(user = user, password = "${pwd}", url =
context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """PAUSE ROUTINE LOAD FOR ${dbName}.${labelName};"""
sql """
ALTER ROUTINE LOAD FOR ${dbName}.${labelName}
diff --git a/regression-test/suites/auth_call/test_dml_select_udf_auth.groovy
b/regression-test/suites/auth_call/test_dml_select_udf_auth.groovy
index 72413b3e292..b2f565fc02e 100644
--- a/regression-test/suites/auth_call/test_dml_select_udf_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_select_udf_auth.groovy
@@ -61,14 +61,14 @@ suite("test_dml_select_udf_auth","p0,auth_call") {
"""
sql """ INSERT INTO ${dbName}.${tableName} VALUES ("abc"), ("123"),
("123"); """
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """ SELECT ${dbName}.${udfName}(col_1) as a FROM
${dbName}.${tableName} ORDER BY a; """
exception "Can not found function"
}
}
sql """grant select_priv on ${dbName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """ SELECT ${dbName}.${udfName}(col_1) as a FROM
${dbName}.${tableName} ORDER BY a; """
}
diff --git a/regression-test/suites/auth_call/test_dml_stream_load_auth.groovy
b/regression-test/suites/auth_call/test_dml_stream_load_auth.groovy
index 240fdde6f69..1a01f68d5b9 100644
--- a/regression-test/suites/auth_call/test_dml_stream_load_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_stream_load_auth.groovy
@@ -90,7 +90,7 @@ suite("test_dml_stream_load_auth","p0,auth_call") {
int pos3 = sout.indexOf(":", pos1)
def tsc_id = sout.substring(pos3+2, pos2)
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW TRANSACTION FROM ${dbName} WHERE ID=${tsc_id};"""
exception "denied"
@@ -105,7 +105,7 @@ suite("test_dml_stream_load_auth","p0,auth_call") {
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def transaction_res = sql """SHOW TRANSACTION FROM ${dbName} WHERE
ID=${tsc_id};"""
assertTrue(transaction_res.size() == 1)
}
diff --git a/regression-test/suites/auth_call/test_dml_update_table_auth.groovy
b/regression-test/suites/auth_call/test_dml_update_table_auth.groovy
index 10c9a3fcb80..153dad5026a 100644
--- a/regression-test/suites/auth_call/test_dml_update_table_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_update_table_auth.groovy
@@ -55,21 +55,21 @@ suite("test_dml_update_table_auth","p0,auth_call") {
(3, "333");
"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """UPDATE ${dbName}.${tableName} SET username = "444" WHERE
id=1;"""
exception "denied"
}
}
sql """grant load_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """UPDATE ${dbName}.${tableName} SET username = "444" WHERE
id=1;"""
exception "denied"
}
}
sql """grant select_priv(id) on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """UPDATE ${dbName}.${tableName} SET username = "444" WHERE
id=1;"""
}
diff --git a/regression-test/suites/auth_call/test_hive_base_case_auth.groovy
b/regression-test/suites/auth_call/test_hive_base_case_auth.groovy
index b1f432ddfb2..271015bec7c 100644
--- a/regression-test/suites/auth_call/test_hive_base_case_auth.groovy
+++ b/regression-test/suites/auth_call/test_hive_base_case_auth.groovy
@@ -52,7 +52,7 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
sql """grant select_priv on regression_test to ${user}"""
// create catalog
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create catalog if not exists ${catalogName} properties (
'type'='hms'
@@ -67,7 +67,7 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
);"""
sql """grant Create_priv on ${catalogName}.*.* to ${user}"""
try_sql """drop catalog if exists ${catalogName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """create catalog if not exists ${catalogName} properties (
'type'='hms',
'hive.metastore.uris' =
'thrift://${externalEnvIp}:${hms_port}',
@@ -81,7 +81,7 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
sql """revoke Create_priv on ${catalogName}.*.* from ${user}"""
// create database
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create database ${catalogName}.${dbName};"""
exception "denied"
@@ -91,13 +91,13 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
sql """grant Create_priv on ${catalogName}.${dbName}.* to ${user}"""
sql """drop table if exists ${catalogName}.${dbName}.${tableName};"""
sql """drop database ${catalogName}.${dbName};"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """create database ${catalogName}.${dbName};"""
}
sql """revoke Create_priv on ${catalogName}.${dbName}.* from ${user}"""
// create table
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """create table ${catalogName}.${dbName}.${tableName} (
id BIGINT,
@@ -118,7 +118,7 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
);"""
sql """grant Create_priv on ${catalogName}.${dbName}.${tableName} to
${user}"""
sql """drop table ${catalogName}.${dbName}.${tableName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """create table ${catalogName}.${dbName}.${tableName} (
id BIGINT,
username VARCHAR(20)
@@ -135,7 +135,7 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
sql """revoke Create_priv on ${catalogName}.${dbName}.${tableName}
from ${user}"""
// load
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
insert into ${catalogName}.${dbName}.${tableName} values
@@ -146,7 +146,7 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
}
}
sql """grant LOAD_PRIV on ${catalogName}.${dbName}.${tableName} to
${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
insert into ${catalogName}.${dbName}.${tableName} values
(1, "111"),
@@ -156,21 +156,21 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
sql """revoke LOAD_PRIV on ${catalogName}.${dbName}.${tableName} from
${user}"""
// alter
-// connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+// connect(user, "${pwd}", context.config.jdbcUrl) {
// test {
// sql """ALTER table ${catalogName}.${dbName}.${tableName}
RENAME ${tableNameNew};"""
// exception "denied"
// }
// }
// sql """grant ALTER_PRIV on ${catalogName}.${dbName}.${tableName} to
${user}"""
-// connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+// connect(user, "${pwd}", context.config.jdbcUrl) {
// sql """ALTER table ${catalogName}.${dbName}.${tableName} RENAME
${tableNameNew};"""
// }
// sql """revoke ALTER_PRIV on ${catalogName}.${dbName}.${tableName}
from ${user}"""
// sql """ALTER table ${catalogName}.${dbName}.${tableNameNew} RENAME
${tableName};"""
// drop
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """drop catalog ${catalogName}"""
exception "denied"
@@ -185,7 +185,7 @@ suite("test_hive_base_case_auth", "p0,auth_call") {
}
}
sql """grant DROP_PRIV on ${catalogName}.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """drop table ${catalogName}.${dbName}.${tableName}"""
sql """drop database ${catalogName}.${dbName}"""
sql """drop catalog ${catalogName}"""
diff --git a/regression-test/suites/auth_call/test_show_backend_auth.groovy
b/regression-test/suites/auth_call/test_show_backend_auth.groovy
index 16df2a6c10b..adccf3637e6 100644
--- a/regression-test/suites/auth_call/test_show_backend_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_backend_auth.groovy
@@ -33,14 +33,14 @@ suite("test_show_backend_auth","p0,auth_call") {
sql """CREATE USER '${user}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW BACKENDS"""
exception "denied"
}
}
sql """grant node_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """SHOW BACKENDS"""
assertTrue(res.size() > 0)
}
diff --git a/regression-test/suites/auth_call/test_show_broker_auth.groovy
b/regression-test/suites/auth_call/test_show_broker_auth.groovy
index 6ce1c4b361a..d8fa9bd10eb 100644
--- a/regression-test/suites/auth_call/test_show_broker_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_broker_auth.groovy
@@ -33,14 +33,14 @@ suite("test_show_broker_auth","p0,auth_call") {
sql """CREATE USER '${user}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW BROKER;"""
exception "denied"
}
}
sql """grant node_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """SHOW BROKER;"""
}
diff --git a/regression-test/suites/auth_call/test_show_charset_auth.groovy
b/regression-test/suites/auth_call/test_show_charset_auth.groovy
index 803810dc204..3ca23f7f6be 100644
--- a/regression-test/suites/auth_call/test_show_charset_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_charset_auth.groovy
@@ -36,7 +36,7 @@ suite("test_show_no_auth","p0,auth_call") {
sql """CREATE USER '${user1}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """SHOW CHARSET"""
sql """SHOW DATA TYPES"""
sql """SHOW ENGINES"""
@@ -57,7 +57,7 @@ suite("test_show_no_auth","p0,auth_call") {
}
}
sql """grant grant_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """show PROPERTY for ${user1}"""
logger.info("res: " + res)
assertTrue(res.size() > 0)
@@ -68,7 +68,7 @@ suite("test_show_no_auth","p0,auth_call") {
}
sql """revoke grant_priv on *.*.* from ${user}"""
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """SHOW TRASH;"""
logger.info("res: " + res)
assertTrue(res.size() >= 1)
diff --git
a/regression-test/suites/auth_call/test_show_convert_light_sc_auth.groovy
b/regression-test/suites/auth_call/test_show_convert_light_sc_auth.groovy
index c7a765fe9a3..d54862f1710 100644
--- a/regression-test/suites/auth_call/test_show_convert_light_sc_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_convert_light_sc_auth.groovy
@@ -33,14 +33,14 @@ suite("test_show_convert_light_sc_auth","p0,auth_call") {
sql """CREATE USER '${user}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW CONVERT_LIGHT_SCHEMA_CHANGE_PROCESS;"""
exception "denied"
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """SHOW CONVERT_LIGHT_SCHEMA_CHANGE_PROCESS;"""
}
diff --git
a/regression-test/suites/auth_call/test_show_create_table_auth.groovy
b/regression-test/suites/auth_call/test_show_create_table_auth.groovy
index 6152806ce6f..2a85ea42e6c 100644
--- a/regression-test/suites/auth_call/test_show_create_table_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_create_table_auth.groovy
@@ -45,7 +45,7 @@ suite("test_show_create_table_auth","p0,auth_call") {
"replication_num" = "1"
);"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """show create table ${dbName}.${tableName}"""
exception "denied"
@@ -56,7 +56,7 @@ suite("test_show_create_table_auth","p0,auth_call") {
}
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """show create table ${tableName}"""
sql """SHOW DATA SKEW FROM ${tableName};"""
@@ -64,7 +64,7 @@ suite("test_show_create_table_auth","p0,auth_call") {
sql """revoke select_priv on ${dbName}.${tableName} from ${user}"""
sql """grant create_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """show create table ${tableName}"""
sql """SHOW DATA SKEW FROM ${tableName};"""
@@ -72,7 +72,7 @@ suite("test_show_create_table_auth","p0,auth_call") {
sql """revoke create_priv on ${dbName}.${tableName} from ${user}"""
sql """grant drop_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """show create table ${tableName}"""
sql """SHOW DATA SKEW FROM ${tableName};"""
@@ -80,7 +80,7 @@ suite("test_show_create_table_auth","p0,auth_call") {
sql """revoke drop_priv on ${dbName}.${tableName} from ${user}"""
sql """grant alter_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """show create table ${tableName}"""
sql """SHOW DATA SKEW FROM ${tableName};"""
diff --git a/regression-test/suites/auth_call/test_show_data_auth.groovy
b/regression-test/suites/auth_call/test_show_data_auth.groovy
index 84bf9497f54..c6f3b6dd153 100644
--- a/regression-test/suites/auth_call/test_show_data_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_data_auth.groovy
@@ -55,7 +55,7 @@ suite("test_show_data_auth","p0,auth_call") {
"replication_num" = "1"
);"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """show data from ${dbName}.${tableName}"""
exception "denied"
@@ -68,7 +68,7 @@ suite("test_show_data_auth","p0,auth_call") {
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use ${dbName}"""
sql """show data from ${dbName}.${tableName}"""
test {
@@ -80,7 +80,7 @@ suite("test_show_data_auth","p0,auth_call") {
sql """revoke select_priv on ${dbName}.${tableName} from ${user}"""
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """SHOW DATA;"""
}
diff --git a/regression-test/suites/auth_call/test_show_database_id_auth.groovy
b/regression-test/suites/auth_call/test_show_database_id_auth.groovy
index 0a0d44be074..e30dc8d0db7 100644
--- a/regression-test/suites/auth_call/test_show_database_id_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_database_id_auth.groovy
@@ -37,7 +37,7 @@ suite("test_show_database_id_auth","p0,auth_call") {
sql """grant select_priv on regression_test to ${user}"""
sql """create database ${dbName}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """show database 1001"""
exception "denied"
@@ -52,7 +52,7 @@ suite("test_show_database_id_auth","p0,auth_call") {
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """show database 1001"""
sql """show table 1001"""
sql """SHOW CATALOG RECYCLE BIN;"""
diff --git
a/regression-test/suites/auth_call/test_show_dynamic_table_auth.groovy
b/regression-test/suites/auth_call/test_show_dynamic_table_auth.groovy
index e144d87749c..7718a115b65 100644
--- a/regression-test/suites/auth_call/test_show_dynamic_table_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_dynamic_table_auth.groovy
@@ -52,12 +52,12 @@ suite("test_show_dynamic_table_auth","p0,auth_call") {
"dynamic_partition.start_day_of_month" = "3"
);"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """SHOW DYNAMIC PARTITION TABLES from ${dbName};"""
assertTrue(res.size() == 0)
}
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """SHOW DYNAMIC PARTITION TABLES from ${dbName};"""
assertTrue(res.size() == 1)
}
diff --git a/regression-test/suites/auth_call/test_show_frontend_auth.groovy
b/regression-test/suites/auth_call/test_show_frontend_auth.groovy
index 2844ee992c2..f4a9bc15b07 100644
--- a/regression-test/suites/auth_call/test_show_frontend_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_frontend_auth.groovy
@@ -33,7 +33,7 @@ suite("test_show_frontend_auth","p0,auth_call") {
sql """CREATE USER '${user}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW frontends"""
exception "denied"
@@ -44,7 +44,7 @@ suite("test_show_frontend_auth","p0,auth_call") {
}
}
sql """grant node_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """SHOW frontends"""
assertTrue(res.size() > 0)
diff --git a/regression-test/suites/auth_call/test_show_grant_auth.groovy
b/regression-test/suites/auth_call/test_show_grant_auth.groovy
index 5c6c3f069e3..1223faf6739 100644
--- a/regression-test/suites/auth_call/test_show_grant_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_grant_auth.groovy
@@ -33,7 +33,7 @@ suite("test_show_grant_auth","p0,auth_call") {
sql """CREATE USER '${user}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """show grants;"""
test {
sql """show all grants;"""
@@ -46,7 +46,7 @@ suite("test_show_grant_auth","p0,auth_call") {
}
}
sql """grant grant_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """show grants;"""
sql """show all grants;"""
sql """show roles;"""
diff --git a/regression-test/suites/auth_call/test_show_proc_auth.groovy
b/regression-test/suites/auth_call/test_show_proc_auth.groovy
index 725a9785a7a..1daf8d97f70 100644
--- a/regression-test/suites/auth_call/test_show_proc_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_proc_auth.groovy
@@ -33,14 +33,14 @@ suite("test_show_proc_auth","p0,auth_call") {
sql """CREATE USER '${user}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW PROC "/";"""
exception "denied"
}
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """SHOW PROC "/";"""
}
diff --git a/regression-test/suites/auth_call/test_show_query_stats_auth.groovy
b/regression-test/suites/auth_call/test_show_query_stats_auth.groovy
index 1a9e8898fff..ba951a47465 100644
--- a/regression-test/suites/auth_call/test_show_query_stats_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_query_stats_auth.groovy
@@ -34,7 +34,7 @@ suite("test_show_query_stats_auth","p0,auth_call") {
sql """grant select_priv on regression_test to ${user}"""
logger.info("context.config.jdbcUrl: " + context.config.jdbcUrl)
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """show query stats;"""
logger.info("res:" + res)
}
diff --git a/regression-test/suites/auth_call/test_show_repository_auth.groovy
b/regression-test/suites/auth_call/test_show_repository_auth.groovy
index 5d7c51ed59c..43f6785e0ea 100644
--- a/regression-test/suites/auth_call/test_show_repository_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_repository_auth.groovy
@@ -52,7 +52,7 @@ suite("test_show_repository_auth","p0,auth_call") {
"s3.secret_key" = "${sk}"
)"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW CREATE REPOSITORY for ${repositoryName};"""
exception "denied"
@@ -64,7 +64,7 @@ suite("test_show_repository_auth","p0,auth_call") {
}
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """SHOW CREATE REPOSITORY for ${repositoryName};"""
def res = sql """SHOW REPOSITORIES;"""
diff --git a/regression-test/suites/auth_call/test_show_tablet_auth.groovy
b/regression-test/suites/auth_call/test_show_tablet_auth.groovy
index 03f8ed58a8e..c96cd904b01 100644
--- a/regression-test/suites/auth_call/test_show_tablet_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_tablet_auth.groovy
@@ -52,7 +52,7 @@ suite("test_show_tablet_auth","p0,auth_call") {
"""
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """SHOW TABLETS FROM ${dbName}.${tableName}"""
exception "denied"
@@ -73,7 +73,7 @@ suite("test_show_tablet_auth","p0,auth_call") {
sql """revoke select_priv on ${dbName}.${tableName} from ${user}"""
sql """grant admin_priv on *.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def res = sql """SHOW TABLETS FROM ${dbName}.${tableName}"""
def tablet_res = sql """SHOW TABLET ${res[0][0]}"""
diff --git a/regression-test/suites/auth_call/test_show_typecast_auth.groovy
b/regression-test/suites/auth_call/test_show_typecast_auth.groovy
index 104e8107e1f..8df4a2e2dc1 100644
--- a/regression-test/suites/auth_call/test_show_typecast_auth.groovy
+++ b/regression-test/suites/auth_call/test_show_typecast_auth.groovy
@@ -33,7 +33,7 @@ suite("test_show_typecast_auth","p0,auth_call") {
sql """CREATE USER '${user}' IDENTIFIED BY '${pwd}'"""
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """use regression_test"""
sql """show type_cast;"""
}
diff --git a/regression-test/suites/auth_p0/test_catalogs_auth.groovy
b/regression-test/suites/auth_p0/test_catalogs_auth.groovy
index 96ebcef7cf8..f7f8752502d 100644
--- a/regression-test/suites/auth_p0/test_catalogs_auth.groovy
+++ b/regression-test/suites/auth_p0/test_catalogs_auth.groovy
@@ -41,7 +41,7 @@ suite("test_catalogs_auth","p0,auth") {
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def showRes = sql """show catalogs;"""
logger.info("showRes: " + showRes.toString())
assertFalse(showRes.toString().contains("${catalogName}"))
@@ -53,7 +53,7 @@ suite("test_catalogs_auth","p0,auth") {
sql """grant select_priv on ${catalogName}.*.* to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def showRes = sql """show catalogs;"""
logger.info("showRes: " + showRes.toString())
assertTrue(showRes.toString().contains("${catalogName}"))
diff --git a/regression-test/suites/auth_p0/test_mtmv_auth.groovy
b/regression-test/suites/auth_p0/test_mtmv_auth.groovy
index 52ecbebb70b..7c64d308065 100644
--- a/regression-test/suites/auth_p0/test_mtmv_auth.groovy
+++ b/regression-test/suites/auth_p0/test_mtmv_auth.groovy
@@ -63,7 +63,7 @@ suite("test_mtmv_auth","p0,auth") {
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def mvsRes = sql """select * from mv_infos("database"="${dbName}");"""
logger.info("mvsRes: " + mvsRes.toString())
assertFalse(mvsRes.toString().contains("${mvName}"))
@@ -80,7 +80,7 @@ suite("test_mtmv_auth","p0,auth") {
sql """grant select_priv on ${dbName}.${mvName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
def mvsRes = sql """select * from mv_infos("database"="${dbName}");"""
logger.info("mvsRes: " + mvsRes.toString())
assertTrue(mvsRes.toString().contains("${mvName}"))
diff --git
a/regression-test/suites/auth_p0/test_partition_values_tvf_auth.groovy
b/regression-test/suites/auth_p0/test_partition_values_tvf_auth.groovy
index 3f0ae7ea8d5..c6fbb4203b6 100644
--- a/regression-test/suites/auth_p0/test_partition_values_tvf_auth.groovy
+++ b/regression-test/suites/auth_p0/test_partition_values_tvf_auth.groovy
@@ -48,7 +48,7 @@ suite("test_partition_values_tvf_auth","p0,auth") {
}
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl)
{
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
select * from partition_values("catalog" =
"${catalog_name}", "database" = "multi_catalog", "table" =
"orc_partitioned_columns") order by t_int, t_float;
@@ -57,7 +57,7 @@ suite("test_partition_values_tvf_auth","p0,auth") {
}
}
sql """grant select_priv on
${catalog_name}.multi_catalog.orc_partitioned_columns to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
select * from partition_values("catalog" =
"${catalog_name}", "database" = "multi_catalog", "table" =
"orc_partitioned_columns") order by t_int, t_float;
"""
diff --git a/regression-test/suites/auth_p0/test_partitions_auth.groovy
b/regression-test/suites/auth_p0/test_partitions_auth.groovy
index 0b769f11567..963e4f073e0 100644
--- a/regression-test/suites/auth_p0/test_partitions_auth.groovy
+++ b/regression-test/suites/auth_p0/test_partitions_auth.groovy
@@ -53,7 +53,7 @@ suite("test_partitions_auth","p0,auth") {
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
show partitions from ${dbName}.${tableName};
@@ -70,7 +70,7 @@ suite("test_partitions_auth","p0,auth") {
sql """grant select_priv on ${dbName}.${tableName} to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
show partitions from ${dbName}.${tableName};
"""
diff --git a/regression-test/suites/auth_p0/test_query_tvf_auth.groovy
b/regression-test/suites/auth_p0/test_query_tvf_auth.groovy
index 746eb47ce5b..8c2efd89404 100644
--- a/regression-test/suites/auth_p0/test_query_tvf_auth.groovy
+++ b/regression-test/suites/auth_p0/test_query_tvf_auth.groovy
@@ -53,7 +53,7 @@ suite("test_query_tvf_auth",
"p0,auth,external,external_docker") {
sql """grant select_priv on regression_test to ${dorisuser}"""
- connect(user=dorisuser, password="${dorispwd}",
url=context.config.jdbcUrl) {
+ connect(dorisuser, "${dorispwd}", context.config.jdbcUrl) {
test {
sql """
select * from query('catalog' = '${catalog_name}',
'query' = 'select * from doris_test.all_types');
@@ -62,7 +62,7 @@ suite("test_query_tvf_auth",
"p0,auth,external,external_docker") {
}
}
sql """grant select_priv on ${catalog_name}.*.* to ${dorisuser}"""
- connect(user=dorisuser, password="${dorispwd}",
url=context.config.jdbcUrl) {
+ connect(dorisuser, "${dorispwd}", context.config.jdbcUrl) {
sql """
select * from query('catalog' = '${catalog_name}', 'query' =
'select * from doris_test.all_types');
"""
diff --git a/regression-test/suites/auth_p0/test_select_count_auth.groovy
b/regression-test/suites/auth_p0/test_select_count_auth.groovy
index ccea1a4a580..9f037cba82c 100644
--- a/regression-test/suites/auth_p0/test_select_count_auth.groovy
+++ b/regression-test/suites/auth_p0/test_select_count_auth.groovy
@@ -34,7 +34,7 @@ suite("test_select_count_auth","p0,auth") {
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
select count(*) from __internal_schema.audit_log;
@@ -57,7 +57,7 @@ suite("test_select_count_auth","p0,auth") {
sql """grant select_priv(query_id) on __internal_schema.audit_log to
${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
select count(*) from __internal_schema.audit_log;
@@ -77,7 +77,7 @@ suite("test_select_count_auth","p0,auth") {
sql """grant select_priv on __internal_schema.audit_log to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
select count(*) from __internal_schema.audit_log;
"""
diff --git
a/regression-test/suites/compaction/test_overall_compaction_status.groovy
b/regression-test/suites/compaction/test_overall_compaction_status.groovy
index 7623d4118db..f8f93852d32 100644
--- a/regression-test/suites/compaction/test_overall_compaction_status.groovy
+++ b/regression-test/suites/compaction/test_overall_compaction_status.groovy
@@ -25,7 +25,7 @@ suite("test_overall_compaction_status") {
backend_id = backendId_to_backendIP.keySet()[0]
// test be's overall compaction status api
- (code, out, err) =
be_get_overall_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
be_get_overall_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Get overall compaction status: code=" + code + ", out=" + out
+ ", err=" + err)
assertEquals(code, 0)
assertTrue(out.toLowerCase().contains("basecompaction"))
diff --git
a/regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_statistics.groovy
b/regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_statistics.groovy
index 617644cda99..6a5fb022235 100644
---
a/regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_statistics.groovy
+++
b/regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_statistics.groovy
@@ -38,7 +38,7 @@ suite("test_mysql_jdbc_statistics",
"p0,external,mysql,external_docker,external_
sql """use ${catalog_name}.doris_test"""
sql """analyze table ex_tb0 with sync"""
- result = sql """show column stats ex_tb0 (name)"""
+ def result = sql """show column stats ex_tb0 (name)"""
assertEquals(result.size(), 1)
assertEquals(result[0][0], "name")
assertEquals(result[0][2], "5.0")
diff --git
a/regression-test/suites/external_table_p2/tvf/test_iceberg_meta.groovy
b/regression-test/suites/external_table_p2/tvf/test_iceberg_meta.groovy
index 557eaf5b061..71a35b165a9 100644
--- a/regression-test/suites/external_table_p2/tvf/test_iceberg_meta.groovy
+++ b/regression-test/suites/external_table_p2/tvf/test_iceberg_meta.groovy
@@ -67,7 +67,7 @@ suite("test_iceberg_meta",
"p2,external,iceberg,external_remote,external_remote_
}
sql """grant select_priv on regression_test to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
test {
sql """
select committed_at, snapshot_id, parent_id, operation
from iceberg_meta(
@@ -78,7 +78,7 @@ suite("test_iceberg_meta",
"p2,external,iceberg,external_remote,external_remote_
}
}
sql """grant select_priv on
${iceberg_catalog_name}.${db}.multi_partition to ${user}"""
- connect(user=user, password="${pwd}", url=context.config.jdbcUrl) {
+ connect(user, "${pwd}", context.config.jdbcUrl) {
sql """
select committed_at, snapshot_id, parent_id, operation from
iceberg_meta(
"table" =
"${iceberg_catalog_name}.${db}.multi_partition",
diff --git
a/regression-test/suites/insert_p0/test_group_commit_interval_ms_property.groovy
b/regression-test/suites/insert_p0/test_group_commit_interval_ms_property.groovy
index abaa416f3b0..980e38e5350 100644
---
a/regression-test/suites/insert_p0/test_group_commit_interval_ms_property.groovy
+++
b/regression-test/suites/insert_p0/test_group_commit_interval_ms_property.groovy
@@ -43,7 +43,7 @@ suite("test_group_commit_interval_ms_property") {
for (item in ["legacy", "nereids"]) {
try {
- test_table = table + "_" + item;
+ def test_table = table + "_" + item;
sql """ drop table if exists ${test_table} force; """
sql """
CREATE table ${test_table} (
diff --git a/regression-test/suites/mtmv_p0/test_mtmv_outfile.groovy
b/regression-test/suites/mtmv_p0/test_mtmv_outfile.groovy
index 693df86e014..28c76a5bdd8 100644
--- a/regression-test/suites/mtmv_p0/test_mtmv_outfile.groovy
+++ b/regression-test/suites/mtmv_p0/test_mtmv_outfile.groovy
@@ -64,7 +64,7 @@ suite("test_mtmv_outfile","mtmv") {
String ak = getS3AK()
String sk = getS3SK()
String s3_endpoint = getS3Endpoint()
- String region = region = getS3Region()
+ String region = getS3Region()
String bucket = context.config.otherConfigs.get("s3BucketName");
def outfile_to_S3_directly = {
diff --git a/regression-test/suites/rollup/test_materialized_view_bitmap.groovy
b/regression-test/suites/rollup/test_materialized_view_bitmap.groovy
index 4e1ba749c50..2feaeb25837 100644
--- a/regression-test/suites/rollup/test_materialized_view_bitmap.groovy
+++ b/regression-test/suites/rollup/test_materialized_view_bitmap.groovy
@@ -33,7 +33,7 @@ suite("test_materialized_view_bitmap", "rollup") {
"""
sql "CREATE MATERIALIZED VIEW test_neg as select
k1,bitmap_union(to_bitmap(k2)), bitmap_union(to_bitmap(k3)) FROM ${tbName1}
GROUP BY k1;"
- max_try_secs = 60
+ def max_try_secs = 60
while (max_try_secs--) {
String res = getJobState(tbName1)
if (res == "FINISHED" || res == "CANCELLED") {
diff --git a/regression-test/suites/rollup/test_materialized_view_hll.groovy
b/regression-test/suites/rollup/test_materialized_view_hll.groovy
index a6b8b77444d..5409c0f147a 100644
--- a/regression-test/suites/rollup/test_materialized_view_hll.groovy
+++ b/regression-test/suites/rollup/test_materialized_view_hll.groovy
@@ -35,7 +35,7 @@ suite("test_materialized_view_hll", "rollup") {
"""
sql "CREATE materialized VIEW amt_count AS SELECT store_id,
hll_union(hll_hash(sale_amt)) FROM ${tbName1} GROUP BY store_id;"
- max_try_secs = 60
+ def max_try_secs = 60
while (max_try_secs--) {
String res = getJobState(tbName1)
if (res == "FINISHED" || res == "CANCELLED") {
diff --git
a/regression-test/suites/rollup/test_materialized_view_hll_with_light_sc.groovy
b/regression-test/suites/rollup/test_materialized_view_hll_with_light_sc.groovy
index 310b97bbdee..3a39dd30fe2 100644
---
a/regression-test/suites/rollup/test_materialized_view_hll_with_light_sc.groovy
+++
b/regression-test/suites/rollup/test_materialized_view_hll_with_light_sc.groovy
@@ -35,7 +35,7 @@ suite("test_materialized_view_hll_with_light_sc", "rollup") {
"""
sql "CREATE materialized VIEW amt_count1 AS SELECT store_id,
hll_union(hll_hash(sale_amt)) FROM ${tbName1} GROUP BY store_id;"
- max_try_secs = 60
+ def max_try_secs = 60
while (max_try_secs--) {
String res = getJobState(tbName1)
if (res == "FINISHED" || res == "CANCELLED") {
diff --git
a/regression-test/suites/schema_change_p0/test_uniq_rollup_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_uniq_rollup_schema_change.groovy
index f291fd98fac..78c99e5ddb4 100644
---
a/regression-test/suites/schema_change_p0/test_uniq_rollup_schema_change.groovy
+++
b/regression-test/suites/schema_change_p0/test_uniq_rollup_schema_change.groovy
@@ -131,7 +131,7 @@ suite ("test_uniq_rollup_schema_change") {
ALTER TABLE ${tableName} DROP COLUMN cost
"""
- max_try_time = 3000
+ def max_try_time = 3000
while (max_try_time--){
String result = getJobState(tableName)
if (result == "FINISHED") {
@@ -175,21 +175,6 @@ suite ("test_uniq_rollup_schema_change") {
// compaction
trigger_and_wait_compaction(tableName, "cumulative")
- // wait for all compactions done
- for (String[] tablet in tablets) {
- boolean running = true
- do {
- Thread.sleep(100)
- String tablet_id = tablet[0]
- backend_id = tablet[2]
- def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
- logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
- assertEquals(code, 0)
- def compactionStatus = parseJson(out.trim())
- assertEquals("success", compactionStatus.status.toLowerCase())
- running = compactionStatus.run_status
- } while (running)
- }
qt_sc """ select count(*) from ${tableName} """
qt_sc """ SELECT * FROM ${tableName} WHERE user_id=2 """
diff --git a/regression-test/suites/variant_p0/complexjson.groovy
b/regression-test/suites/variant_p0/complexjson.groovy
index cd6a0716fda..81de6d0ec4f 100644
--- a/regression-test/suites/variant_p0/complexjson.groovy
+++ b/regression-test/suites/variant_p0/complexjson.groovy
@@ -29,7 +29,7 @@ suite("regression_test_variant_complexjson",
"variant_type_complex_json") {
properties("replication_num" = "1", "disable_auto_compaction" =
"true");
"""
}
- table_name = "complexjson"
+ def table_name = "complexjson"
create_table table_name
sql """insert into ${table_name} values (1, '{
"id": 1,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
