This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 767b5a1770e [test](external_table_p0)append log in external_table_p0
for debug unknown table case (#27212)
767b5a1770e is described below
commit 767b5a1770e33cfa4c2acf813bcc214c79320ef7
Author: daidai <[email protected]>
AuthorDate: Sun Nov 19 22:47:32 2023 +0800
[test](external_table_p0)append log in external_table_p0 for debug unknown
table case (#27212)
---
.../hive/test_hive_basic_type.groovy | 206 ++++++++-------
.../jdbc/test_clickhouse_jdbc_catalog.groovy | 90 ++++---
.../jdbc/test_mysql_jdbc_catalog.groovy | 286 ++++++++++++---------
.../jdbc/test_sqlserver_jdbc_catalog.groovy | 75 +++---
4 files changed, 367 insertions(+), 290 deletions(-)
diff --git
a/regression-test/suites/external_table_p0/hive/test_hive_basic_type.groovy
b/regression-test/suites/external_table_p0/hive/test_hive_basic_type.groovy
index 84720216fe0..af262e57c96 100644
--- a/regression-test/suites/external_table_p0/hive/test_hive_basic_type.groovy
+++ b/regression-test/suites/external_table_p0/hive/test_hive_basic_type.groovy
@@ -34,103 +34,115 @@ suite("test_hive_basic_type",
"external_docker,hive,external_docker_hive,p0,exte
sql """switch ${catalog_name}"""
- order_qt_2 """select * from
${catalog_name}.${ex_db_name}.parquet_partition_table order by l_orderkey limit
1;"""
- order_qt_3 """select * from
${catalog_name}.${ex_db_name}.parquet_delta_binary_packed order by int_value
limit 1;"""
- order_qt_4 """select * from
${catalog_name}.${ex_db_name}.parquet_alltypes_tiny_pages order by id desc
limit 5;"""
- order_qt_5 """select * from
${catalog_name}.${ex_db_name}.orc_all_types_partition order by bigint_col desc
limit 3;"""
- order_qt_6 """select * from
${catalog_name}.${ex_db_name}.csv_partition_table order by k1 limit 1;"""
- order_qt_9 """select * from
${catalog_name}.${ex_db_name}.csv_all_types limit 1;"""
- order_qt_10 """select * from
${catalog_name}.${ex_db_name}.text_all_types limit 1;"""
-
- // parquet bloom
- order_qt_11 """select * from
${catalog_name}.${ex_db_name}.bloom_parquet_table limit 1;"""
-
- // orc bloom
- order_qt_12 """select * from
${catalog_name}.${ex_db_name}.bloom_orc_table limit 1;"""
-
- // orc predicate
- order_qt_13 """select * from
${catalog_name}.${ex_db_name}.orc_predicate_table where column_primitive_bigint
= 6 limit 10;"""
- order_qt_14 """select count(1) from
${catalog_name}.${ex_db_name}.orc_predicate_table where column_primitive_bigint
= 6;"""
- order_qt_15 """select * from
${catalog_name}.${ex_db_name}.orc_predicate_table where column_primitive_bigint
= 1 limit 10;"""
- order_qt_16 """select count(1) from
${catalog_name}.${ex_db_name}.orc_predicate_table where column_primitive_bigint
= 1;"""
- order_qt_17 """select * from
${catalog_name}.${ex_db_name}.orc_predicate_table where
column_primitive_integer = 3 and column_primitive_bigint = 6 limit 10;"""
-
- // parquet predicate
- order_qt_18 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_bigint = 1 limit 10;"""
- order_qt_19 """select count(1) from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_bigint = 1;"""
- order_qt_20 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 3 limit 10;"""
- order_qt_21 """select count(1) from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 3;"""
- order_qt_22 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 1 limit 10;"""
- order_qt_23 """select count(1) from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 1;"""
-
- // only null parquet file test
- order_qt_24 """select * from
${catalog_name}.${ex_db_name}.only_null;"""
- order_qt_25 """select * from ${catalog_name}.${ex_db_name}.only_null
where x is null;"""
- order_qt_26 """select * from ${catalog_name}.${ex_db_name}.only_null
where x is not null;"""
-
- // parquet timestamp millis test
- order_qt_27 """desc
${catalog_name}.${ex_db_name}.parquet_timestamp_millis;"""
- order_qt_28 """select * from
${catalog_name}.${ex_db_name}.parquet_timestamp_millis order by test;"""
-
- // parquet timestamp micros test
- order_qt_29 """desc
${catalog_name}.${ex_db_name}.parquet_timestamp_micros;"""
- order_qt_30 """select * from
${catalog_name}.${ex_db_name}.parquet_timestamp_micros order by test;"""
-
- // parquet timestamp nanos test
- order_qt_31 """desc
${catalog_name}.${ex_db_name}.parquet_timestamp_nanos;"""
- order_qt_32 """select * from
${catalog_name}.${ex_db_name}.parquet_timestamp_nanos order by test;"""
-
- order_qt_7 """select * from
${catalog_name}.${ex_db_name}.orc_all_types_t limit 1;"""
-
- // parquet predicate
- order_qt_38 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_bigint = 6 limit 10;"""
- order_qt_39 """select count(1) from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_bigint = 6;"""
- order_qt_40 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 3 and column_primitive_bigint = 6 limit 10;"""
-
- order_qt_33 """select * from
${catalog_name}.${ex_db_name}.parquet_all_types limit 1;"""
-
- order_qt_36 """select * from
${catalog_name}.${ex_db_name}.parquet_gzip_all_types limit 1;"""
-
- // hive tables of json classes do not necessarily support column
separation to identify errors
- //order_qt_8 """select * from
${catalog_name}.${ex_db_name}.json_all_types limit 1;"""
-
- // At present, doris only supports three formats of orc parquet
textfile, while others are not supported
-
- // hive tables in avro format are not supported
- //order_qt_34 """select * from
${catalog_name}.${ex_db_name}.avro_all_types limit 1;"""
-
- // hive tables in SEQUENCEFILE format are not supported
- //order_qt_35 """select * from
${catalog_name}.${ex_db_name}.sequence_all_types limit 1;"""
-
- // hive tables in rcbinary format are not supported
- //order_qt_37 """select * from
${catalog_name}.${ex_db_name}.rcbinary_all_types limit 1;"""
-
- // orc_all_types_t predicate test
- order_qt_41 """select * from
${catalog_name}.${ex_db_name}.orc_all_types_t where t_int = 3;"""
-
- //test parquet byte_array_decimal and rle_bool
- order_qt_parquet """ select count(*) from
${catalog_name}.${ex_db_name}.parquet_decimal_bool """
- order_qt_parquet1 """ select * from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
- where decimals is not null and bool_rle is not null order by
decimals,bool_rle limit 7 """
- order_qt_parquet2 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
- where decimals is not null and decimals > 1 order by decimals
limit 7 """
- order_qt_parquet3 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
- where decimals = 123.456 order by decimals limit 7 """
- order_qt_parquet4 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
- where decimals != -7871.416 and decimals is not null order by
decimals limit 7 """
-
- order_qt_parquet5 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
- where decimals is not null and decimals < 0 order by decimals
limit 7 """
-
- order_qt_parquet7 """ select bool_rle from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
- where bool_rle is not null and bool_rle = 1 limit 7 """
- order_qt_parquet8 """ select bool_rle from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
- where bool_rle is not null and bool_rle = 1 limit 7 """
- order_qt_parquet9 """ select count(bool_rle) from
${catalog_name}.${ex_db_name}.parquet_decimal_bool; """
- order_qt_parquet10 """ select count(decimals) from
${catalog_name}.${ex_db_name}.parquet_decimal_bool; """
- order_qt_parquet11 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
- where decimals is not null and decimals > 1 order by decimals
limit 7 """
-
+ def res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from `${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} => tables =
"+tbs.toString())
+ }
+ try {
+ order_qt_2 """select * from
${catalog_name}.${ex_db_name}.parquet_partition_table order by l_orderkey limit
1;"""
+ order_qt_3 """select * from
${catalog_name}.${ex_db_name}.parquet_delta_binary_packed order by int_value
limit 1;"""
+ order_qt_4 """select * from
${catalog_name}.${ex_db_name}.parquet_alltypes_tiny_pages order by id desc
limit 5;"""
+ order_qt_5 """select * from
${catalog_name}.${ex_db_name}.orc_all_types_partition order by bigint_col desc
limit 3;"""
+ order_qt_6 """select * from
${catalog_name}.${ex_db_name}.csv_partition_table order by k1 limit 1;"""
+ order_qt_9 """select * from
${catalog_name}.${ex_db_name}.csv_all_types limit 1;"""
+ order_qt_10 """select * from
${catalog_name}.${ex_db_name}.text_all_types limit 1;"""
+
+ // parquet bloom
+ order_qt_11 """select * from
${catalog_name}.${ex_db_name}.bloom_parquet_table limit 1;"""
+
+ // orc bloom
+ order_qt_12 """select * from
${catalog_name}.${ex_db_name}.bloom_orc_table limit 1;"""
+
+ // orc predicate
+ order_qt_13 """select * from
${catalog_name}.${ex_db_name}.orc_predicate_table where column_primitive_bigint
= 6 limit 10;"""
+ order_qt_14 """select count(1) from
${catalog_name}.${ex_db_name}.orc_predicate_table where column_primitive_bigint
= 6;"""
+ order_qt_15 """select * from
${catalog_name}.${ex_db_name}.orc_predicate_table where column_primitive_bigint
= 1 limit 10;"""
+ order_qt_16 """select count(1) from
${catalog_name}.${ex_db_name}.orc_predicate_table where column_primitive_bigint
= 1;"""
+ order_qt_17 """select * from
${catalog_name}.${ex_db_name}.orc_predicate_table where
column_primitive_integer = 3 and column_primitive_bigint = 6 limit 10;"""
+
+ // parquet predicate
+ order_qt_18 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_bigint = 1 limit 10;"""
+ order_qt_19 """select count(1) from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_bigint = 1;"""
+ order_qt_20 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 3 limit 10;"""
+ order_qt_21 """select count(1) from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 3;"""
+ order_qt_22 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 1 limit 10;"""
+ order_qt_23 """select count(1) from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 1;"""
+
+ // only null parquet file test
+ order_qt_24 """select * from
${catalog_name}.${ex_db_name}.only_null;"""
+ order_qt_25 """select * from
${catalog_name}.${ex_db_name}.only_null where x is null;"""
+ order_qt_26 """select * from
${catalog_name}.${ex_db_name}.only_null where x is not null;"""
+
+ // parquet timestamp millis test
+ order_qt_27 """desc
${catalog_name}.${ex_db_name}.parquet_timestamp_millis;"""
+ order_qt_28 """select * from
${catalog_name}.${ex_db_name}.parquet_timestamp_millis order by test;"""
+
+ // parquet timestamp micros test
+ order_qt_29 """desc
${catalog_name}.${ex_db_name}.parquet_timestamp_micros;"""
+ order_qt_30 """select * from
${catalog_name}.${ex_db_name}.parquet_timestamp_micros order by test;"""
+
+ // parquet timestamp nanos test
+ order_qt_31 """desc
${catalog_name}.${ex_db_name}.parquet_timestamp_nanos;"""
+ order_qt_32 """select * from
${catalog_name}.${ex_db_name}.parquet_timestamp_nanos order by test;"""
+
+ order_qt_7 """select * from
${catalog_name}.${ex_db_name}.orc_all_types_t limit 1;"""
+
+ // parquet predicate
+ order_qt_38 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_bigint = 6 limit 10;"""
+ order_qt_39 """select count(1) from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_bigint = 6;"""
+ order_qt_40 """select * from
${catalog_name}.${ex_db_name}.parquet_predicate_table where
column_primitive_integer = 3 and column_primitive_bigint = 6 limit 10;"""
+
+ order_qt_33 """select * from
${catalog_name}.${ex_db_name}.parquet_all_types limit 1;"""
+
+ order_qt_36 """select * from
${catalog_name}.${ex_db_name}.parquet_gzip_all_types limit 1;"""
+
+ // hive tables of json classes do not necessarily
support column separation to identify errors
+ //order_qt_8 """select * from
${catalog_name}.${ex_db_name}.json_all_types limit 1;"""
+
+ // At present, doris only supports three formats of orc
parquet textfile, while others are not supported
+
+ // hive tables in avro format are not supported
+ //order_qt_34 """select * from
${catalog_name}.${ex_db_name}.avro_all_types limit 1;"""
+
+ // hive tables in SEQUENCEFILE format are not supported
+ //order_qt_35 """select * from
${catalog_name}.${ex_db_name}.sequence_all_types limit 1;"""
+
+ // hive tables in rcbinary format are not supported
+ //order_qt_37 """select * from
${catalog_name}.${ex_db_name}.rcbinary_all_types limit 1;"""
+
+ // orc_all_types_t predicate test
+ order_qt_41 """select * from
${catalog_name}.${ex_db_name}.orc_all_types_t where t_int = 3;"""
+
+ //test parquet byte_array_decimal and rle_bool
+ order_qt_parquet """ select count(*) from
${catalog_name}.${ex_db_name}.parquet_decimal_bool """
+ order_qt_parquet1 """ select * from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
+ where decimals is not null and
bool_rle is not null order by decimals,bool_rle limit 7 """
+ order_qt_parquet2 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
+ where decimals is not null and decimals
> 1 order by decimals limit 7 """
+ order_qt_parquet3 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
+ where decimals = 123.456 order by
decimals limit 7 """
+ order_qt_parquet4 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
+ where decimals != -7871.416 and
decimals is not null order by decimals limit 7 """
+
+ order_qt_parquet5 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
+ where decimals is not null and decimals
< 0 order by decimals limit 7 """
+
+ order_qt_parquet7 """ select bool_rle from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
+ where bool_rle is not null and bool_rle
= 1 limit 7 """
+ order_qt_parquet8 """ select bool_rle from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
+ where bool_rle is not null and bool_rle
= 1 limit 7 """
+ order_qt_parquet9 """ select count(bool_rle) from
${catalog_name}.${ex_db_name}.parquet_decimal_bool; """
+ order_qt_parquet10 """ select count(decimals) from
${catalog_name}.${ex_db_name}.parquet_decimal_bool; """
+ order_qt_parquet11 """ select decimals from
${catalog_name}.${ex_db_name}.parquet_decimal_bool
+ where decimals is not null and decimals
> 1 order by decimals limit 7 """
+ }finally {
+ res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from
`${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} =>
tables = "+tbs.toString())
+ }
+ }
//sql """drop catalog if exists ${catalog_name} """
}
}
diff --git
a/regression-test/suites/external_table_p0/jdbc/test_clickhouse_jdbc_catalog.groovy
b/regression-test/suites/external_table_p0/jdbc/test_clickhouse_jdbc_catalog.groovy
index 294ee63e583..274bf7a7016 100644
---
a/regression-test/suites/external_table_p0/jdbc/test_clickhouse_jdbc_catalog.groovy
+++
b/regression-test/suites/external_table_p0/jdbc/test_clickhouse_jdbc_catalog.groovy
@@ -44,7 +44,7 @@ suite("test_clickhouse_jdbc_catalog",
"p0,external,clickhouse,external_docker,ex
sql """use ${internal_db_name}"""
sql """ drop table if exists ${internal_db_name}.${inDorisTable} """
sql """
- CREATE TABLE ${internal_db_name}.${inDorisTable} (
+ CREATE TABLE ${internal_db_name}.${inDorisTable} (
`id` INT NULL COMMENT "主键id",
`name` string NULL COMMENT "名字",
`age` INT NULL COMMENT "年龄"
@@ -53,46 +53,60 @@ suite("test_clickhouse_jdbc_catalog",
"p0,external,clickhouse,external_docker,ex
"""
sql """ switch ${catalog_name} """
- sql """ use ${ex_db_name} """
+ def res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from `${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} => tables =
"+tbs.toString())
+ }
+ try {
+ sql """ use ${ex_db_name} """
- order_qt_type """ select * from type order by k1; """
- order_qt_type_null """ select * from type_null order by id; """
- sql """drop table if exists internal.${internal_db_name}.ck_type_null
"""
- order_qt_ctas_type_null """create table
internal.${internal_db_name}.ck_type_null PROPERTIES("replication_num" = "1")
as select * from type_null """;
- order_qt_query_ctas_type_null """ select * from
internal.${internal_db_name}.ck_type_null order by id; """
- order_qt_number """ select * from number order by k6; """
- order_qt_arr """ select * from arr order by id; """
- order_qt_arr_null """ select * from arr_null order by id; """
- sql """ drop table if exists
internal.${internal_db_name}.ck_arr_null"""
- order_qt_ctas_arr_null """create table
internal.${internal_db_name}.ck_arr_null PROPERTIES("replication_num" = "1") as
select * from arr_null """;
- order_qt_query_ctas_arr_null """ select * from
internal.${internal_db_name}.ck_arr_null order by id; """
- sql """ insert into internal.${internal_db_name}.${inDorisTable}
select * from student; """
- order_qt_in_tb """ select id, name, age from
internal.${internal_db_name}.${inDorisTable} order by id; """
- order_qt_system """ show tables from `system`; """
- order_qt_filter """ select k1,k2 from type where 1 = 1 order by 1 ;
"""
- order_qt_filter2 """ select k1,k2 from type where 1 = 1 and k1 =
true order by 1 ; """
- order_qt_filter3 """ select k1,k2 from type where k1 = true order by
1 ; """
- sql "set jdbc_clickhouse_query_final = true;"
- order_qt_final1 """select * from final_test"""
- sql "set jdbc_clickhouse_query_final = false;"
- order_qt_final2 """select * from final_test"""
- order_qt_func_push """select * from ts where
from_unixtime(ts,'yyyyMMdd') >= '2022-01-01';"""
- explain {
- sql("select * from ts where from_unixtime(ts,'yyyyMMdd') >=
'2022-01-01';")
- contains """QUERY: SELECT "id", "ts" FROM "doris_test"."ts" WHERE
(FROM_UNIXTIME(ts, '%Y%m%d') >= '2022-01-01')"""
- }
- explain {
- sql("select * from ts where nvl(ts,null) >= '2022-01-01';")
- contains """QUERY: SELECT "id", "ts" FROM "doris_test"."ts"""
- }
- order_qt_func_push2 """select * from ts where ts <=
unix_timestamp(from_unixtime(ts,'yyyyMMdd'));"""
- explain {
- sql("select * from ts where ts <=
unix_timestamp(from_unixtime(ts,'yyyy-MM-dd'));")
- contains """QUERY: SELECT "id", "ts" FROM "doris_test"."ts" WHERE
("ts" <= toUnixTimestamp(FROM_UNIXTIME(ts, '%Y-%m-%d')))"""
- }
+ order_qt_type """ select * from type order by k1; """
+ order_qt_type_null """ select * from type_null order by id; """
+ sql """drop table if exists
internal.${internal_db_name}.ck_type_null """
+ order_qt_ctas_type_null """create table
internal.${internal_db_name}.ck_type_null PROPERTIES("replication_num" = "1")
as select * from type_null """;
+ order_qt_query_ctas_type_null """ select * from
internal.${internal_db_name}.ck_type_null order by id; """
+ order_qt_number """ select * from number order by k6; """
+ order_qt_arr """ select * from arr order by id; """
+ order_qt_arr_null """ select * from arr_null order by id; """
+ sql """ drop table if exists
internal.${internal_db_name}.ck_arr_null"""
+ order_qt_ctas_arr_null """create table
internal.${internal_db_name}.ck_arr_null PROPERTIES("replication_num" = "1") as
select * from arr_null """;
+ order_qt_query_ctas_arr_null """ select * from
internal.${internal_db_name}.ck_arr_null order by id; """
+ sql """ insert into internal.${internal_db_name}.${inDorisTable}
select * from student; """
+ order_qt_in_tb """ select id, name, age from
internal.${internal_db_name}.${inDorisTable} order by id; """
+ order_qt_system """ show tables from `system`; """
+ order_qt_filter """ select k1,k2 from type where 1 = 1 order by 1
; """
+ order_qt_filter2 """ select k1,k2 from type where 1 = 1 and k1 =
true order by 1 ; """
+ order_qt_filter3 """ select k1,k2 from type where k1 = true order
by 1 ; """
+ sql "set jdbc_clickhouse_query_final = true;"
+ order_qt_final1 """select * from final_test"""
+ sql "set jdbc_clickhouse_query_final = false;"
+ order_qt_final2 """select * from final_test"""
+ order_qt_func_push """select * from ts where
from_unixtime(ts,'yyyyMMdd') >= '2022-01-01';"""
+ explain {
+ sql("select * from ts where from_unixtime(ts,'yyyyMMdd') >=
'2022-01-01';")
+ contains """QUERY: SELECT "id", "ts" FROM "doris_test"."ts"
WHERE (FROM_UNIXTIME(ts, '%Y%m%d') >= '2022-01-01')"""
+ }
+ explain {
+ sql("select * from ts where nvl(ts,null) >= '2022-01-01';")
+ contains """QUERY: SELECT "id", "ts" FROM "doris_test"."ts"""
+ }
+ order_qt_func_push2 """select * from ts where ts <=
unix_timestamp(from_unixtime(ts,'yyyyMMdd'));"""
+ explain {
+ sql("select * from ts where ts <=
unix_timestamp(from_unixtime(ts,'yyyy-MM-dd'));")
+ contains """QUERY: SELECT "id", "ts" FROM "doris_test"."ts"
WHERE ("ts" <= toUnixTimestamp(FROM_UNIXTIME(ts, '%Y-%m-%d')))"""
+ }
- order_qt_dt_with_tz """ select * from dt_with_tz order by id; """
+ order_qt_dt_with_tz """ select * from dt_with_tz order by id; """
+ }finally {
+ res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from
`${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} =>
tables = "+tbs.toString())
+ }
+ }
+
sql """ drop catalog if exists ${catalog_name} """
}
}
diff --git
a/regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_catalog.groovy
b/regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_catalog.groovy
index f7896b66f1b..534f16ecc45 100644
---
a/regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_catalog.groovy
+++
b/regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_catalog.groovy
@@ -133,74 +133,86 @@ suite("test_mysql_jdbc_catalog",
"p0,external,mysql,external_docker,external_doc
qt_sql """select current_catalog()"""
sql """switch ${catalog_name}"""
qt_sql """select current_catalog()"""
- sql """ use ${ex_db_name}"""
-
- order_qt_ex_tb0 """ select id, name from ${ex_tb0} order by id; """
- sql """ insert into internal.${internal_db_name}.${inDorisTable}
select id, name from ${ex_tb0}; """
- order_qt_in_tb """ select id, name from
internal.${internal_db_name}.${inDorisTable} order by id; """
-
- order_qt_ex_tb1 """ select * from ${ex_tb1} order by id; """
- order_qt_ex_tb2 """ select * from ${ex_tb2} order by id; """
- order_qt_ex_tb3 """ select * from ${ex_tb3} order by game_code; """
- order_qt_ex_tb4 """ select * from ${ex_tb4} order by products_id; """
- order_qt_ex_tb5 """ select * from ${ex_tb5} order by id; """
- order_qt_ex_tb6 """ select * from ${ex_tb6} order by id; """
- order_qt_ex_tb7 """ select * from ${ex_tb7} order by id; """
- order_qt_ex_tb8 """ select * from ${ex_tb8} order by uid; """
- order_qt_ex_tb9 """ select * from ${ex_tb9} order by c_date; """
- order_qt_ex_tb10 """ select * from ${ex_tb10} order by aa; """
- order_qt_ex_tb11 """ select * from ${ex_tb11} order by aa; """
- order_qt_ex_tb12 """ select * from ${ex_tb12} order by cc; """
- order_qt_ex_tb13 """ select * from ${ex_tb13} order by name; """
- order_qt_ex_tb14 """ select * from ${ex_tb14} order by tid; """
- order_qt_ex_tb15 """ select * from ${ex_tb15} order by col1; """
- order_qt_ex_tb16 """ select * from ${ex_tb16} order by id; """
- order_qt_ex_tb17 """ select * from ${ex_tb17} order by id; """
- order_qt_ex_tb18 """ select * from ${ex_tb18} order by num_tinyint;
"""
- order_qt_ex_tb19 """ select * from ${ex_tb19} order by date_value; """
- order_qt_ex_tb20 """ select * from ${ex_tb20} order by
decimal_normal; """
- order_qt_ex_tb21 """ select `key`, `id` from ${ex_tb21} where `key` =
2 order by id;"""
- order_qt_information_schema """ show tables from information_schema;
"""
- order_qt_auto_default_t """insert into ${auto_default_t}(name)
values('a'); """
- order_qt_dt """select * from ${dt}; """
- order_qt_dt_null """select * from ${dt_null} order by 1; """
- order_qt_test_dz """select * from ${test_zd} order by 1; """
-
- // test insert
- String uuid1 = UUID.randomUUID().toString();
- connect(user=user, password="${pwd}", url=url) {
- try {
- sql """ insert into
${catalog_name}.${ex_db_name}.${test_insert} values ('${uuid1}', 'doris1', 18)
"""
- fail()
- } catch (Exception e) {
- log.info(e.getMessage())
+ def res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from `${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} => tables =
"+tbs.toString())
+ }
+ try {
+
+ sql """ use ${ex_db_name}"""
+
+ order_qt_ex_tb0 """ select id, name from ${ex_tb0} order by id;
"""
+ sql """ insert into internal.${internal_db_name}.${inDorisTable}
select id, name from ${ex_tb0}; """
+ order_qt_in_tb """ select id, name from
internal.${internal_db_name}.${inDorisTable} order by id; """
+
+ order_qt_ex_tb1 """ select * from ${ex_tb1} order by id; """
+ order_qt_ex_tb2 """ select * from ${ex_tb2} order by id; """
+ order_qt_ex_tb3 """ select * from ${ex_tb3} order by game_code;
"""
+ order_qt_ex_tb4 """ select * from ${ex_tb4} order by products_id;
"""
+ order_qt_ex_tb5 """ select * from ${ex_tb5} order by id; """
+ order_qt_ex_tb6 """ select * from ${ex_tb6} order by id; """
+ order_qt_ex_tb7 """ select * from ${ex_tb7} order by id; """
+ order_qt_ex_tb8 """ select * from ${ex_tb8} order by uid; """
+ order_qt_ex_tb9 """ select * from ${ex_tb9} order by c_date; """
+ order_qt_ex_tb10 """ select * from ${ex_tb10} order by aa; """
+ order_qt_ex_tb11 """ select * from ${ex_tb11} order by aa; """
+ order_qt_ex_tb12 """ select * from ${ex_tb12} order by cc; """
+ order_qt_ex_tb13 """ select * from ${ex_tb13} order by name; """
+ order_qt_ex_tb14 """ select * from ${ex_tb14} order by tid; """
+ order_qt_ex_tb15 """ select * from ${ex_tb15} order by col1; """
+ order_qt_ex_tb16 """ select * from ${ex_tb16} order by id; """
+ order_qt_ex_tb17 """ select * from ${ex_tb17} order by id; """
+ order_qt_ex_tb18 """ select * from ${ex_tb18} order by
num_tinyint; """
+ order_qt_ex_tb19 """ select * from ${ex_tb19} order by
date_value; """
+ order_qt_ex_tb20 """ select * from ${ex_tb20} order by
decimal_normal; """
+ order_qt_ex_tb21 """ select `key`, `id` from ${ex_tb21} where
`key` = 2 order by id;"""
+ order_qt_information_schema """ show tables from
information_schema; """
+ order_qt_auto_default_t """insert into ${auto_default_t}(name)
values('a'); """
+ order_qt_dt """select * from ${dt}; """
+ order_qt_dt_null """select * from ${dt_null} order by 1; """
+ order_qt_test_dz """select * from ${test_zd} order by 1; """
+
+ // test insert
+ String uuid1 = UUID.randomUUID().toString();
+ connect(user=user, password="${pwd}", url=url) {
+ try {
+ sql """ insert into
${catalog_name}.${ex_db_name}.${test_insert} values ('${uuid1}', 'doris1', 18)
"""
+ fail()
+ } catch (Exception e) {
+ log.info(e.getMessage())
+ }
}
- }
- sql """GRANT LOAD_PRIV ON ${catalog_name}.${ex_db_name}.${test_insert}
TO ${user}"""
+ sql """GRANT LOAD_PRIV ON
${catalog_name}.${ex_db_name}.${test_insert} TO ${user}"""
- connect(user=user, password="${pwd}", url=url) {
- try {
- sql """ insert into
${catalog_name}.${ex_db_name}.${test_insert} values ('${uuid1}', 'doris1', 18)
"""
- } catch (Exception e) {
- fail();
+ connect(user=user, password="${pwd}", url=url) {
+ try {
+ sql """ insert into
${catalog_name}.${ex_db_name}.${test_insert} values ('${uuid1}', 'doris1', 18)
"""
+ } catch (Exception e) {
+ fail();
+ }
}
- }
-
- order_qt_test_insert1 """ select name, age from ${test_insert} where
id = '${uuid1}' order by age """
-
- String uuid2 = UUID.randomUUID().toString();
- sql """ insert into ${test_insert} values ('${uuid2}', 'doris2', 19),
('${uuid2}', 'doris3', 20) """
- order_qt_test_insert2 """ select name, age from ${test_insert} where
id = '${uuid2}' order by age """
-
- sql """ insert into ${test_insert} select * from ${test_insert} where
id = '${uuid2}' """
- order_qt_test_insert3 """ select name, age from ${test_insert} where
id = '${uuid2}' order by age """
-
- String uuid3 = UUID.randomUUID().toString();
- sql """ INSERT INTO ${test_insert2} VALUES
- ('${uuid3}', true, 'abcHa1.12345', '1.123450xkalowadawd',
'2022-10-01', 3.14159, 1, 2, 0, 100000, 1.2345678, 24.000, '07:09:51', '2022',
'2022-11-27 07:09:51', '2022-11-27 07:09:51'); """
- order_qt_test_insert4 """ select
k1,k2,k3,k4,k5,k6,k7,k8,k9,k10,k11,k12,k13,k14,k15 from ${test_insert2} where
id = '${uuid3}' """
-
+ order_qt_test_insert1 """ select name, age from ${test_insert}
where id = '${uuid1}' order by age """
+
+ String uuid2 = UUID.randomUUID().toString();
+ sql """ insert into ${test_insert} values ('${uuid2}', 'doris2',
19), ('${uuid2}', 'doris3', 20) """
+ order_qt_test_insert2 """ select name, age from ${test_insert}
where id = '${uuid2}' order by age """
+
+ sql """ insert into ${test_insert} select * from ${test_insert}
where id = '${uuid2}' """
+ order_qt_test_insert3 """ select name, age from ${test_insert}
where id = '${uuid2}' order by age """
+
+ String uuid3 = UUID.randomUUID().toString();
+ sql """ INSERT INTO ${test_insert2} VALUES
+ ('${uuid3}', true, 'abcHa1.12345', '1.123450xkalowadawd',
'2022-10-01', 3.14159, 1, 2, 0, 100000, 1.2345678, 24.000, '07:09:51', '2022',
'2022-11-27 07:09:51', '2022-11-27 07:09:51'); """
+ order_qt_test_insert4 """ select
k1,k2,k3,k4,k5,k6,k7,k8,k9,k10,k11,k12,k13,k14,k15 from ${test_insert2} where
id = '${uuid3}' """
+ } finally {
+ res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from
`${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} =>
tables = "+tbs.toString())
+ }
+ }
sql """ drop catalog if exists ${catalog_name} """
// test only_specified_database argument
@@ -285,28 +297,41 @@ suite("test_mysql_jdbc_catalog",
"p0,external,mysql,external_docker,external_doc
"jdbc.driver_class" = "com.mysql.cj.jdbc.Driver");
"""
sql """ switch ${catalog_name} """
- sql """ use ${ex_db_name} """
- order_qt_ex_tb1 """ select * from ${ex_tb1} order by id; """
-
- // test all types supported by MySQL
- sql """use doris_test;"""
- qt_mysql_all_types """select * from all_types order by tinyint_u;"""
-
- // test insert into internal.db.table select * from all_types
- sql """ insert into
internal.${internal_db_name}.${test_insert_all_types} select * from all_types;
"""
- order_qt_select_insert_all_types """ select * from
internal.${internal_db_name}.${test_insert_all_types} order by tinyint_u; """
-
- // test CTAS
- sql """ drop table if exists
internal.${internal_db_name}.${test_ctas} """
- sql """ create table internal.${internal_db_name}.${test_ctas}
- PROPERTIES("replication_num" = "1")
- AS select * from all_types;
- """
-
- order_qt_ctas """select * from
internal.${internal_db_name}.${test_ctas} order by tinyint_u;"""
-
- order_qt_ctas_desc """desc
internal.${internal_db_name}.${test_ctas};"""
+ res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from `${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} => tables =
"+tbs.toString())
+ }
+ try {
+ sql """ use ${ex_db_name} """
+ order_qt_ex_tb1 """ select * from ${ex_tb1} order by id; """
+
+ // test all types supported by MySQL
+ sql """use doris_test;"""
+ qt_mysql_all_types """select * from all_types order by
tinyint_u;"""
+
+ // test insert into internal.db.table select * from all_types
+ sql """ insert into
internal.${internal_db_name}.${test_insert_all_types} select * from all_types;
"""
+ order_qt_select_insert_all_types """ select * from
internal.${internal_db_name}.${test_insert_all_types} order by tinyint_u; """
+
+ // test CTAS
+ sql """ drop table if exists
internal.${internal_db_name}.${test_ctas} """
+ sql """ create table internal.${internal_db_name}.${test_ctas}
+ PROPERTIES("replication_num" = "1")
+ AS select * from all_types;
+ """
+
+ order_qt_ctas """select * from
internal.${internal_db_name}.${test_ctas} order by tinyint_u;"""
+
+ order_qt_ctas_desc """desc
internal.${internal_db_name}.${test_ctas};"""
+ } finally {
+ res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from
`${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} =>
tables = "+tbs.toString())
+ }
+ }
sql """ drop catalog if exists ${catalog_name} """
// test mysql view
@@ -333,45 +358,58 @@ suite("test_mysql_jdbc_catalog",
"p0,external,mysql,external_docker,external_doc
"""
sql """switch mysql_fun_push_catalog"""
- sql """ use ${ex_db_name}"""
- sql """ admin set frontend config ("enable_func_pushdown" = "true");
"""
- order_qt_filter1 """select * from ${ex_tb17} where id = 1; """
- order_qt_filter2 """select * from ${ex_tb17} where 1=1 order by 1; """
- order_qt_filter3 """select * from ${ex_tb17} where id = 1 and 1 = 1;
"""
- order_qt_date_trunc """ SELECT timestamp0 from dt where
DATE_TRUNC(date_sub(timestamp0,INTERVAL 9 HOUR),'hour') > '2011-03-03
17:39:05'; """
- order_qt_money_format """ select k8 from test1 where money_format(k8)
= '1.00'; """
- explain {
- sql("select k8 from test1 where money_format(k8) = '1.00';")
-
- contains "QUERY: SELECT `k8` FROM `doris_test`.`test1`"
- }
- explain {
- sql ("SELECT timestamp0 from dt where
DATE_TRUNC(date_sub(timestamp0,INTERVAL 9 HOUR),'hour') > '2011-03-03
17:39:05';")
-
- contains "QUERY: SELECT `timestamp0` FROM `doris_test`.`dt`"
- }
- explain {
- sql ("SELECT timestamp0 from dt where
DATE_TRUNC(date_sub(timestamp0,INTERVAL 9 HOUR),'hour') > '2011-03-03 17:39:05'
and timestamp0 > '2022-01-01';")
-
- contains "QUERY: SELECT `timestamp0` FROM `doris_test`.`dt` WHERE
(timestamp0 > '2022-01-01 00:00:00')"
- }
- explain {
- sql ("select k6, k8 from test1 where nvl(k6, null) = 1;")
-
- contains "QUERY: SELECT `k6`, `k8` FROM `doris_test`.`test1` WHERE
(ifnull(k6, NULL) = 1)"
- }
- explain {
- sql ("select k6, k8 from test1 where nvl(nvl(k6, null),null) = 1;")
-
- contains "QUERY: SELECT `k6`, `k8` FROM `doris_test`.`test1` WHERE
(ifnull(ifnull(k6, NULL), NULL) = 1)"
- }
- sql """ admin set frontend config ("enable_func_pushdown" = "false");
"""
- explain {
- sql ("select k6, k8 from test1 where nvl(k6, null) = 1 and k8 =
1;")
-
- contains "QUERY: SELECT `k6`, `k8` FROM `doris_test`.`test1` WHERE
(`k8` = 1)"
- }
- sql """ admin set frontend config ("enable_func_pushdown" = "true");
"""
+ res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from `${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} => tables =
"+tbs.toString())
+ }
+ try {
+ sql """ use ${ex_db_name}"""
+ sql """ admin set frontend config ("enable_func_pushdown" =
"true"); """
+ order_qt_filter1 """select * from ${ex_tb17} where id = 1; """
+ order_qt_filter2 """select * from ${ex_tb17} where 1=1 order by 1;
"""
+ order_qt_filter3 """select * from ${ex_tb17} where id = 1 and 1 =
1; """
+ order_qt_date_trunc """ SELECT timestamp0 from dt where
DATE_TRUNC(date_sub(timestamp0,INTERVAL 9 HOUR),'hour') > '2011-03-03
17:39:05'; """
+ order_qt_money_format """ select k8 from test1 where
money_format(k8) = '1.00'; """
+ explain {
+ sql("select k8 from test1 where money_format(k8) = '1.00';")
+
+ contains "QUERY: SELECT `k8` FROM `doris_test`.`test1`"
+ }
+ explain {
+ sql ("SELECT timestamp0 from dt where
DATE_TRUNC(date_sub(timestamp0,INTERVAL 9 HOUR),'hour') > '2011-03-03
17:39:05';")
+
+ contains "QUERY: SELECT `timestamp0` FROM `doris_test`.`dt`"
+ }
+ explain {
+ sql ("SELECT timestamp0 from dt where
DATE_TRUNC(date_sub(timestamp0,INTERVAL 9 HOUR),'hour') > '2011-03-03 17:39:05'
and timestamp0 > '2022-01-01';")
+
+ contains "QUERY: SELECT `timestamp0` FROM `doris_test`.`dt`
WHERE (timestamp0 > '2022-01-01 00:00:00')"
+ }
+ explain {
+ sql ("select k6, k8 from test1 where nvl(k6, null) = 1;")
+
+ contains "QUERY: SELECT `k6`, `k8` FROM `doris_test`.`test1`
WHERE (ifnull(k6, NULL) = 1)"
+ }
+ explain {
+ sql ("select k6, k8 from test1 where nvl(nvl(k6, null),null) =
1;")
+
+ contains "QUERY: SELECT `k6`, `k8` FROM `doris_test`.`test1`
WHERE (ifnull(ifnull(k6, NULL), NULL) = 1)"
+ }
+ sql """ admin set frontend config ("enable_func_pushdown" =
"false"); """
+ explain {
+ sql ("select k6, k8 from test1 where nvl(k6, null) = 1 and k8
= 1;")
+
+ contains "QUERY: SELECT `k6`, `k8` FROM `doris_test`.`test1`
WHERE (`k8` = 1)"
+ }
+ sql """ admin set frontend config ("enable_func_pushdown" =
"true"); """
+ } finally {
+ res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from
`${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} =>
tables = "+tbs.toString())
+ }
+ }
sql """ drop catalog if exists mysql_fun_push_catalog; """
}
}
diff --git
a/regression-test/suites/external_table_p0/jdbc/test_sqlserver_jdbc_catalog.groovy
b/regression-test/suites/external_table_p0/jdbc/test_sqlserver_jdbc_catalog.groovy
index 234c27749cb..fde19f7a606 100644
---
a/regression-test/suites/external_table_p0/jdbc/test_sqlserver_jdbc_catalog.groovy
+++
b/regression-test/suites/external_table_p0/jdbc/test_sqlserver_jdbc_catalog.groovy
@@ -53,42 +53,55 @@ suite("test_sqlserver_jdbc_catalog",
"p0,external,sqlserver,external_docker,exte
"""
sql """ switch ${catalog_name} """
- sql """ use ${ex_db_name} """
+ def res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from `${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} => tables =
"+tbs.toString())
+ }
+ try {
+ sql """ use ${ex_db_name} """
- order_qt_test0 """ select * from student order by id; """
- sql """ insert into internal.${internal_db_name}.${inDorisTable}
select * from student; """
- order_qt_in_tb """ select id, name, age from
internal.${internal_db_name}.${inDorisTable} order by id; """
+ order_qt_test0 """ select * from student order by id; """
+ sql """ insert into internal.${internal_db_name}.${inDorisTable}
select * from student; """
+ order_qt_in_tb """ select id, name, age from
internal.${internal_db_name}.${inDorisTable} order by id; """
- order_qt_test1 """ select * from test_int order by id; """
- order_qt_test2 """ select * from test_float order by id; """
- order_qt_test3 """ select * from test_char order by id; """
- order_qt_test5 """ select * from test_time order by id; """
- order_qt_test6 """ select * from test_money order by id; """
- order_qt_test7 """ select * from test_decimal order by id; """
- order_qt_test8 """ select * from test_text order by id; """
- order_qt_dt """ select * from DateAndTime; """
- order_qt_filter1 """ select * from test_char where 1 = 1 order by id;
"""
- order_qt_filter2 """ select * from test_char where 1 = 1 and id = 1
order by id; """
- order_qt_filter3 """ select * from test_char where id = 1 order by
id; """
- order_qt_id """ select count(*) from (select * from t_id) as a; """
- order_qt_all_type """ select * from all_type order by id; """
- sql """ drop table if exists internal.${internal_db_name}.all_type; """
- order_qt_ctas """ create table
internal.${internal_db_name}.ctas_all_type PROPERTIES("replication_num" = "1")
as select * from all_type; """
- qt_desc_query_ctas """ desc
internal.${internal_db_name}.ctas_all_type; """
- order_qt_query_ctas """ select * from
internal.${internal_db_name}.ctas_all_type order by id; """
+ order_qt_test1 """ select * from test_int order by id; """
+ order_qt_test2 """ select * from test_float order by id; """
+ order_qt_test3 """ select * from test_char order by id; """
+ order_qt_test5 """ select * from test_time order by id; """
+ order_qt_test6 """ select * from test_money order by id; """
+ order_qt_test7 """ select * from test_decimal order by id; """
+ order_qt_test8 """ select * from test_text order by id; """
+ order_qt_dt """ select * from DateAndTime; """
+ order_qt_filter1 """ select * from test_char where 1 = 1 order by
id; """
+ order_qt_filter2 """ select * from test_char where 1 = 1 and id =
1 order by id; """
+ order_qt_filter3 """ select * from test_char where id = 1 order
by id; """
+ order_qt_id """ select count(*) from (select * from t_id) as a; """
+ order_qt_all_type """ select * from all_type order by id; """
+ sql """ drop table if exists
internal.${internal_db_name}.all_type; """
+ order_qt_ctas """ create table
internal.${internal_db_name}.ctas_all_type PROPERTIES("replication_num" = "1")
as select * from all_type; """
+ qt_desc_query_ctas """ desc
internal.${internal_db_name}.ctas_all_type; """
+ order_qt_query_ctas """ select * from
internal.${internal_db_name}.ctas_all_type order by id; """
- sql """ drop catalog if exists ${catalog_name} """
+ sql """ drop catalog if exists ${catalog_name} """
- sql """ create catalog if not exists ${catalog_name} properties(
- "type"="jdbc",
- "user"="sa",
- "password"="Doris123456",
- "jdbc_url" =
"jdbc:sqlserver://${externalEnvIp}:${sqlserver_port};encrypt=false;databaseName=doris_test;trustServerCertificate=false",
- "driver_url" = "${driver_url}",
- "driver_class" =
"com.microsoft.sqlserver.jdbc.SQLServerDriver"
- );"""
+ sql """ create catalog if not exists ${catalog_name} properties(
+ "type"="jdbc",
+ "user"="sa",
+ "password"="Doris123456",
+ "jdbc_url" =
"jdbc:sqlserver://${externalEnvIp}:${sqlserver_port};encrypt=false;databaseName=doris_test;trustServerCertificate=false",
+ "driver_url" = "${driver_url}",
+ "driver_class" =
"com.microsoft.sqlserver.jdbc.SQLServerDriver"
+ );"""
- order_qt_sql """ show databases from ${catalog_name} """
+ order_qt_sql """ show databases from ${catalog_name} """
+ } finally {
+ res_dbs_log = sql "show databases;"
+ for(int i = 0;i < res_dbs_log.size();i++) {
+ def tbs = sql "show tables from
`${res_dbs_log[i][0]}`"
+ log.info( "database = ${res_dbs_log[i][0]} =>
tables = "+tbs.toString())
+ }
+ }
sql """ drop catalog if exists ${catalog_name} """
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
