Skip to content

Commit

Permalink
optimize code usage
Browse files Browse the repository at this point in the history
  • Loading branch information
seawinde committed Oct 8, 2024
1 parent ef80bdb commit 621dc13
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1683,6 +1683,7 @@ class Suite implements GroovyInterceptable {

// mv not part in rewrite process
def mv_not_part_in = { query_sql, mv_name ->
logger.info("query_sql = " + query_sql)
explain {
sql(" memo plan ${query_sql}")
check { result ->
Expand All @@ -1695,6 +1696,7 @@ class Suite implements GroovyInterceptable {

// multi mv all not part in rewrite process
def mv_all_not_part_in = { query_sql, mv_names ->
logger.info("query_sql = " + query_sql)
explain {
sql(" memo plan ${query_sql}")
check { result ->
Expand All @@ -1711,6 +1713,7 @@ class Suite implements GroovyInterceptable {
// mv part in rewrite process, rewrte success and chosen by cbo
// sync_cbo_rewrite is the bool value which control sync mv is use cbo based mv rewrite
def mv_rewrite_success = { query_sql, mv_name, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand All @@ -1726,6 +1729,7 @@ class Suite implements GroovyInterceptable {

// multi mv part in rewrite process, all rewrte success and chosen by cbo
def mv_rewrite_all_success = { query_sql, mv_names, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand Down Expand Up @@ -1753,6 +1757,7 @@ class Suite implements GroovyInterceptable {

// multi mv part in rewrite process, any of them rewrte success and chosen by cbo
def mv_rewrite_any_success = { query_sql, mv_names, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand Down Expand Up @@ -1780,6 +1785,7 @@ class Suite implements GroovyInterceptable {

// multi mv part in rewrite process, all rewrte success without check if chosen by cbo
def mv_rewrite_all_success_without_check_chosen = { query_sql, mv_names, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand Down Expand Up @@ -1808,6 +1814,7 @@ class Suite implements GroovyInterceptable {

// multi mv part in rewrite process, any of them rewrte success without check if chosen by cbo or not
def mv_rewrite_any_success_without_check_chosen = { query_sql, mv_names, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand Down Expand Up @@ -1835,6 +1842,7 @@ class Suite implements GroovyInterceptable {

// multi mv part in rewrite process, rewrte success without check if chosen by cbo or not
def mv_rewrite_success_without_check_chosen = { query_sql, mv_name, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand All @@ -1853,6 +1861,7 @@ class Suite implements GroovyInterceptable {
// single mv part in rewrite process, rewrte fail
// sync_cbo_rewrite is the bool value which control sync mv is use cbo based mv rewrite
def mv_rewrite_fail = { query_sql, mv_name, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand All @@ -1869,6 +1878,7 @@ class Suite implements GroovyInterceptable {
// multi mv part in rewrite process, all rewrte fail
// sync_cbo_rewrite is the bool value which control sync mv is use cbo based mv rewrite
def mv_rewrite_all_fail = {query_sql, mv_names, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand Down Expand Up @@ -1899,6 +1909,7 @@ class Suite implements GroovyInterceptable {
// multi mv part in rewrite process, any rewrte fail
// sync_cbo_rewrite is the bool value which control sync mv is use cbo based mv rewrite
def mv_rewrite_any_fail = {query_sql, mv_names, sync_cbo_rewrite = true ->
logger.info("query_sql = " + query_sql)
if (!sync_cbo_rewrite) {
explain {
sql("${query_sql}")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -289,7 +289,6 @@ suite("union_all_compensate") {
test_table2 t4 on t3.data_date = t4.data_date
"""
waitingMTMVTaskFinishedByMvName("test_join_mv")
sql """analyze table test_table1 with sync"""

// Data modify
sql """
Expand All @@ -299,7 +298,7 @@ suite("union_all_compensate") {
('2024-09-12 00:20:00', 'a', 1),
('2024-09-12 00:20:00', 'b', 1);
"""
sql """analyze table test_join_mv with sync"""
sql """analyze table test_table1 with sync"""

// Join, if select expression not use the partition column, and the invalid partition is not in the
// grace_period, should union all,and should rewritten successfully
Expand Down

0 comments on commit 621dc13

Please sign in to comment.