Skip to content

Commit

Permalink
[Enhencement](test) enhencement regression test of java udf (apache#1…
Browse files Browse the repository at this point in the history
…7251)

when run regression test of java udf many times.
if failed in some reason, the next time will meet error like: function already exist

Issue Number: close #xxx
  • Loading branch information
zhangstar333 authored Mar 1, 2023
1 parent e687f3b commit 774f66c
Show file tree
Hide file tree
Showing 27 changed files with 97 additions and 47 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,8 @@ suite("test_javaudf_groupcount") {

qt_select """ SELECT group_count(col_1) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION group_count(string); """
} finally {
try_sql("DROP FUNCTION IF EXISTS group_count(string);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,9 @@ suite("test_javaudf_murmurhash3") {

qt_select """ SELECT murmurhash3(col_1) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION murmurhash3(string); """

} finally {
try_sql("DROP FUNCTION IF EXISTS murmurhash3(string);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,9 @@ suite("test_javaudf_sessionize") {

qt_select """ SELECT sessionize(col_1, col_2, col_3) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION sessionize(string, bigint, int); """

} finally {
try_sql("DROP FUNCTION IF EXISTS sessionize(string, bigint, int);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,9 @@ suite("test_javaudf_adddays") {

qt_select """ SELECT add_days(col_1, 1) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION add_days(string, int); """

} finally {
try_sql("DROP FUNCTION IF EXISTS add_days(string, int);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,9 @@ suite("test_javaudf_addisoperioud") {

qt_select """ SELECT add_days(col_1, 'YYYYMMdd', 'PT02H00M') as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION add_days(string, string, string); """

} finally {
try_sql("DROP FUNCTION IF EXISTS add_days(string, string, string);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -52,8 +52,9 @@ suite("test_javaudf_daydiff") {

qt_select """ SELECT day_diff(col_1, col_2) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION day_diff(string, string); """

} finally {
try_sql("DROP FUNCTION IF EXISTS day_diff(string, string);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,9 @@ suite("test_javaudf_convertfromcamelcase") {

qt_select """ SELECT convert_from_camel(col_1) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION convert_from_camel(string); """

} finally {
try_sql("DROP FUNCTION IF EXISTS convert_from_camel(string); ")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,9 @@ suite("test_javaudf_converttocamelcase") {

qt_select """ SELECT convert_to_camel(col_1) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION convert_to_camel(string); """

} finally {
try_sql("DROP FUNCTION IF EXISTS convert_to_camel(string); ")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,9 @@ suite("test_javaudf_assertequal") {

qt_select """ SELECT asser_equal(col_1, col_2) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION asser_equal(double, double); """

} finally {
try_sql("DROP FUNCTION IF EXISTS asser_equal(double, double); ")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,9 @@ suite("test_javaudf_assertlessthan") {

qt_select """ SELECT asser_lessthan(col_1, col_2) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION asser_lessthan(double, double); """

} finally {
try_sql("DROP FUNCTION IF EXISTS asser_lessthan(double, double); ")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,9 @@ suite("test_javaudf_assertudf") {

qt_select """ SELECT assert(true, "not OK"); """

sql """ DROP FUNCTION assert(boolean, string); """

} finally {
try_sql("DROP FUNCTION IF EXISTS assert(boolean, string); ")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,9 @@ suite("test_javaudf_md5") {

qt_select """ SELECT md5(col_1) as a FROM ${tableName} ORDER BY a; """

sql """ DROP FUNCTION md5(string); """

} finally {
try_sql("DROP FUNCTION IF EXISTS md5(string); ")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ suite("test_javaudaf_my_date_datetime") {

qt_select2 """ select user_id, udaf_my_day_datev2(datev2_col) from ${tableName} group by user_id order by user_id; """

sql """ DROP FUNCTION udaf_my_day_datev2(datev2); """


// test date
sql """ CREATE AGGREGATE FUNCTION udaf_my_day_date(date) RETURNS date PROPERTIES (
Expand All @@ -83,7 +83,7 @@ suite("test_javaudaf_my_date_datetime") {

qt_select4 """ select user_id, udaf_my_day_date(date_col) from ${tableName} group by user_id order by user_id; """

sql """ DROP FUNCTION udaf_my_day_date(date); """


// test datetimev2
sql """ CREATE AGGREGATE FUNCTION udaf_my_hour_datetimev2(datetimev2) RETURNS datetimev2 PROPERTIES (
Expand All @@ -97,7 +97,7 @@ suite("test_javaudaf_my_date_datetime") {

qt_select6 """ select user_id, udaf_my_hour_datetimev2(datetimev2_col) from ${tableName} group by user_id order by user_id; """

sql """ DROP FUNCTION udaf_my_hour_datetimev2(datetimev2); """


// test datetime
sql """ CREATE AGGREGATE FUNCTION udaf_my_hour_datetime(datetime) RETURNS datetime PROPERTIES (
Expand All @@ -111,9 +111,13 @@ suite("test_javaudaf_my_date_datetime") {

qt_select6 """ select user_id, udaf_my_hour_datetime(datetime_col) from ${tableName} group by user_id order by user_id; """

sql """ DROP FUNCTION udaf_my_hour_datetime(datetime); """


} finally {
try_sql("DROP FUNCTION IF EXISTS udaf_my_hour_datetime(datetime)")
try_sql("DROP FUNCTION IF EXISTS udaf_my_day_datev2(datev2);")
try_sql("DROP FUNCTION IF EXISTS udaf_my_day_date(date);")
try_sql("DROP FUNCTION IF EXISTS udaf_my_hour_datetimev2(datetimev2);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -66,8 +66,9 @@ suite("test_javaudaf_mygroupconcat_string") {

qt_select1 """ SELECT user_id, udaf_mygroupconcat_string(varchar_col) result FROM ${tableName} GROUP BY user_id order by user_id; """

sql """ DROP FUNCTION udaf_mygroupconcat_string(string); """

} finally {
try_sql("DROP FUNCTION IF EXISTS udaf_mygroupconcat_string(string);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -62,8 +62,9 @@ suite("test_javaudaf_mysum_decimal") {
qt_select2 """ select user_id, udaf_my_sum_decimal(cost_1) from ${tableName} group by user_id order by user_id; """


sql """ DROP FUNCTION udaf_my_sum_decimal(decimal(27,9)); """

} finally {
try_sql("DROP FUNCTION IF EXISTS udaf_my_sum_decimal(decimal(27,9));")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ suite("test_javaudaf_mysum_float_double") {

qt_select2 """ select user_id, udaf_my_sum_double(double_col,double_col) from ${tableName} group by user_id order by user_id; """

sql """ DROP FUNCTION udaf_my_sum_double(double,double); """


sql """ CREATE AGGREGATE FUNCTION udaf_my_sum_float(float) RETURNS float PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -81,9 +81,10 @@ suite("test_javaudaf_mysum_float_double") {

qt_select4 """ select user_id, udaf_my_sum_float(float_col) from ${tableName} group by user_id order by user_id; """

sql """ DROP FUNCTION udaf_my_sum_float(float); """

} finally {
try_sql("DROP FUNCTION IF EXISTS udaf_my_sum_float(float);")
try_sql("DROP FUNCTION IF EXISTS udaf_my_sum_double(double,double);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,9 @@ suite("test_javaudaf_mysum_int") {

qt_select4 """ select user_id, udaf_my_sum_int(user_id), sum(user_id) from ${tableName} group by user_id order by user_id; """

sql """ DROP FUNCTION udaf_my_sum_int(int); """

} finally {
try_sql("DROP FUNCTION IF EXISTS udaf_my_sum_int(int);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -69,8 +69,9 @@ suite("test_javaudaf_null_test") {
qt_select2 """ select user_id, udaf_null_test_int(user_id) from ${tableName} group by user_id order by user_id; """

qt_select3 """ SELECT udaf_null_test_int(1) result FROM ${tableName}; """
sql """ DROP FUNCTION udaf_null_test_int(int); """

} finally {
try_sql("DROP FUNCTION IF EXISTS udaf_null_test_int(int);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
6 changes: 6 additions & 0 deletions regression-test/suites/javaudf_p0/test_javaudf_array.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,12 @@ suite("test_javaudf_array") {
qt_select_13 """ SELECT java_udf_array_date_test(array(datev2_col)), tinyint_col as result FROM ${tableName} ORDER BY result; """

} finally {
try_sql("DROP FUNCTION IF EXISTS java_udf_array_int_test(array<int>);")
try_sql("DROP FUNCTION IF EXISTS java_udf_array_return_int_test(array<int>);")
try_sql("DROP FUNCTION IF EXISTS java_udf_array_return_string_test(array<string>);")
try_sql("DROP FUNCTION IF EXISTS java_udf_array_string_test(array<string>);")
try_sql("DROP FUNCTION IF EXISTS java_udf_array_datatime_test(array<datetime>);")
try_sql("DROP FUNCTION IF EXISTS java_udf_array_date_test(array<date>);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -63,8 +63,9 @@ suite("test_javaudf_boolean") {
qt_select """ SELECT user_id,java_udf_boolean_test(boo_1) as result FROM ${tableName} order by user_id; """


sql """ DROP FUNCTION java_udf_boolean_test(BOOLEAN); """

} finally {
try_sql("DROP FUNCTION IF EXISTS java_udf_boolean_test(BOOLEAN);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
3 changes: 2 additions & 1 deletion regression-test/suites/javaudf_p0/test_javaudf_case.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -61,8 +61,9 @@ suite("test_javaudf_case") {
qt_select """ SELECT starttime,java_udf_dateCase_test(starttime,start,end) as sum FROM ${tableName} order by starttime; """


sql """ DROP FUNCTION java_udf_dateCase_test(date,int,int); """

} finally {
try_sql("DROP FUNCTION IF EXISTS java_udf_dateCase_test(date,int,int);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
36 changes: 24 additions & 12 deletions regression-test/suites/javaudf_p0/test_javaudf_date.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ suite("test_javaudf_date") {
qt_select """ SELECT java_udf_date_test1('2011-01-01', '2011-01-01') result FROM ${tableName} ORDER BY result; """
qt_select """ SELECT java_udf_date_test1(null, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_date_test1(date, date); """


sql """ CREATE FUNCTION java_udf_date_test2(date, date) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -79,7 +79,7 @@ suite("test_javaudf_date") {
qt_select """ SELECT java_udf_date_test2('2011-01-01', '2011-01-01') result FROM ${tableName} ORDER BY result; """
qt_select """ SELECT java_udf_date_test2(null, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_date_test2(date, date); """


sql """ CREATE FUNCTION java_udf_date_test3(date, date) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -91,7 +91,7 @@ suite("test_javaudf_date") {
qt_select """ SELECT java_udf_date_test3('2011-01-01', '2011-01-01') result FROM ${tableName} ORDER BY result; """
qt_select """ SELECT java_udf_date_test3(null, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_date_test3(date, date); """


sql """ CREATE FUNCTION java_udf_datetime_test1(datetime, datetime) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -103,7 +103,7 @@ suite("test_javaudf_date") {
qt_select """ SELECT java_udf_datetime_test1('2011-01-01', '2011-01-01') result FROM ${tableName} ORDER BY result; """
qt_select """ SELECT java_udf_datetime_test1(null, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datetime_test1(datetime, datetime); """


sql """ CREATE FUNCTION java_udf_datetime_test2(datetime, datetime) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -115,7 +115,7 @@ suite("test_javaudf_date") {
qt_select """ SELECT java_udf_datetime_test2('2011-01-01', '2011-01-01') result FROM ${tableName} ORDER BY result; """
qt_select """ SELECT java_udf_datetime_test2(null, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datetime_test2(datetime, datetime); """


sql """ CREATE FUNCTION java_udf_datetime_test3(datetime, datetime) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -127,7 +127,7 @@ suite("test_javaudf_date") {
qt_select """ SELECT java_udf_datetime_test3('2011-01-01', '2011-01-01') result FROM ${tableName} ORDER BY result; """
qt_select """ SELECT java_udf_datetime_test3(null, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datetime_test3(datetime, datetime); """



sql """ CREATE FUNCTION java_udf_datev2_test1(datev2, datev2) RETURNS boolean PROPERTIES (
Expand All @@ -138,7 +138,7 @@ suite("test_javaudf_date") {

qt_select """ SELECT java_udf_datev2_test1(datev2_col, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datev2_test1(datev2, datev2); """


sql """ CREATE FUNCTION java_udf_datev2_test2(datev2, datev2) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -148,7 +148,7 @@ suite("test_javaudf_date") {

qt_select """ SELECT java_udf_datev2_test2(datev2_col, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datev2_test2(datev2, datev2); """


sql """ CREATE FUNCTION java_udf_datev2_test3(datev2, datev2) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -158,7 +158,7 @@ suite("test_javaudf_date") {

qt_select """ SELECT java_udf_datev2_test3(datev2_col, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datev2_test3(datev2, datev2); """


sql """ CREATE FUNCTION java_udf_datetimev2_test1(datetimev2, datetimev2) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -168,7 +168,7 @@ suite("test_javaudf_date") {

qt_select """ SELECT java_udf_datetimev2_test1(datetimev2_col, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datetimev2_test1(datetimev2, datetimev2); """


sql """ CREATE FUNCTION java_udf_datetimev2_test2(datetimev2, datetimev2) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -178,7 +178,7 @@ suite("test_javaudf_date") {

qt_select """ SELECT java_udf_datetimev2_test2(datetimev2_col, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datetimev2_test2(datetimev2, datetimev2); """


sql """ CREATE FUNCTION java_udf_datetimev2_test3(datetimev2, datetimev2) RETURNS boolean PROPERTIES (
"file"="file://${jarPath}",
Expand All @@ -188,8 +188,20 @@ suite("test_javaudf_date") {

qt_select """ SELECT java_udf_datetimev2_test3(datetimev2_col, '2011-01-01') result FROM ${tableName} ORDER BY result; """

sql """ DROP FUNCTION java_udf_datetimev2_test3(datetimev2, datetimev2); """

} finally {
try_sql("DROP FUNCTION IF EXISTS java_udf_date_test3(date, date);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datetime_test1(datetime, datetime);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datetime_test2(datetime, datetime);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datetime_test3(datetime, datetime);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datev2_test1(datev2, datev2);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datev2_test2(datev2, datev2);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datev2_test3(datev2, datev2);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datetimev2_test1(datetimev2, datetimev2);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datetimev2_test2(datetimev2, datetimev2);")
try_sql("DROP FUNCTION IF EXISTS java_udf_datetimev2_test3(datetimev2, datetimev2);")
try_sql("DROP FUNCTION IF EXISTS java_udf_date_test2(date, date);")
try_sql("DROP FUNCTION IF EXISTS java_udf_date_test1(date, date);")
try_sql("DROP TABLE IF EXISTS ${tableName}")
}
}
Loading

0 comments on commit 774f66c

Please sign in to comment.