[Improve][Transform] Rename sql transform table name from 'fake' to 'dual' (#8298)

Author: hailin0

Diff for: docs/en/concept/config.md

@@ -314,7 +314,7 @@ transform {
     sql {
       plugin_input = "fake_test_table"
       plugin_output = "sql"
-      query = "select * from fake_test_table where name = 'abc' "
+      query = "select * from dual where name = 'abc' "
     }
 
 }

Diff for: docs/en/connector-v2/source-common-options.md

@@ -73,7 +73,7 @@ transform {
     plugin_input = "fake"
     plugin_output = "fake1"
     # the query table name must same as field 'plugin_input'
-    query = "select id, regexp_replace(name, '.+', 'b') as name, age+1 as age, pi() as pi, c_timestamp, c_date, c_map, c_array, c_decimal, c_row from fake"
+    query = "select id, regexp_replace(name, '.+', 'b') as name, age+1 as age, pi() as pi, c_timestamp, c_date, c_map, c_array, c_decimal, c_row from dual"
   }
   # The SQL transform support base function and criteria operation
   # But the complex SQL unsupported yet, include: multi source table/rows JOIN and AGGREGATE operation and the like

Diff for: docs/en/faq.md

@@ -68,7 +68,7 @@ Define the variable in the configuration. For example, in an SQL transformation
 ...
 transform {
   Sql {
-    query = "select * from user_view where city ='${city}' and dt = '${date}'"
+    query = "select * from dual where city ='${city}' and dt = '${date}'"
   }
 }
 ...

Diff for: docs/en/transform-v2/common-options.md

@@ -57,7 +57,7 @@ transform {
     plugin_input = "fake"
     plugin_output = "fake1"
     # the query table name must same as field 'plugin_input'
-    query = "select id, regexp_replace(name, '.+', 'b') as name, age+1 as age, pi() as pi, c_timestamp, c_date, c_map, c_array, c_decimal, c_row from fake"
+    query = "select id, regexp_replace(name, '.+', 'b') as name, age+1 as age, pi() as pi, c_timestamp, c_date, c_map, c_array, c_decimal, c_row from dual"
   }
   # The SQL transform support base function and criteria operation
   # But the complex SQL unsupported yet, include: multi source table/rows JOIN and AGGREGATE operation and the like

Diff for: docs/en/transform-v2/sql-functions.md

@@ -973,7 +973,7 @@ select
     else 0
   end as c_number_0
 from
-  fake
+  dual
 ```
 
 It is used to determine whether the condition is valid and return different values according to different judgments
@@ -1009,7 +1009,7 @@ OUTER EXPLODE will return NULL, while array is NULL or empty
 EXPLODE(SPLIT(FIELD_NAME,separator))Used to split string type. The first parameter of SPLIT function  is the field name, the second parameter is the separator
 EXPLODE(ARRAY(value1,value2)) Used to custom array type.
 ```
-SELECT * FROM fake 
+SELECT * FROM dual 
 	LATERAL VIEW EXPLODE ( SPLIT ( NAME, ',' ) ) AS NAME 
 	LATERAL VIEW EXPLODE ( SPLIT ( pk_id, ';' ) ) AS pk_id 
 	LATERAL VIEW OUTER EXPLODE ( age ) AS age

Diff for: docs/en/transform-v2/sql-udf.md

@@ -112,7 +112,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select id, example(name) as name, age from fake"
+    query = "select id, example(name) as name, age from dual"
   }
 }
 ```

Diff for: docs/en/transform-v2/sql.md

@@ -45,7 +45,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select id, concat(name, '_') as name, age+1 as age from fake where id>0"
+    query = "select id, concat(name, '_') as name, age+1 as age from dual where id>0"
   }
 }
 ```
@@ -139,7 +139,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select id, concat(name, '_') as name, age+1 as age from fake where id>0"
+    query = "select id, concat(name, '_') as name, age+1 as age from dual where id>0"
   }
 }
 

Diff for: docs/zh/concept/config.md

@@ -300,7 +300,7 @@ transform {
     sql {
       plugin_input = "fake_test_table"
       plugin_output = "sql"
-      query = "select * from fake_test_table where name = 'abc' "
+      query = "select * from dual where name = 'abc' "
     }
 
 }

Diff for: docs/zh/connector-v2/source-common-options.md

@@ -73,7 +73,7 @@ transform {
     plugin_input = "fake"
     plugin_output = "fake1"
     # 查询表名必须与字段 'plugin_input' 相同
-    query = "select id, regexp_replace(name, '.+', 'b') as name, age+1 as age, pi() as pi, c_timestamp, c_date, c_map, c_array, c_decimal, c_row from fake"
+    query = "select id, regexp_replace(name, '.+', 'b') as name, age+1 as age, pi() as pi, c_timestamp, c_date, c_map, c_array, c_decimal, c_row from dual"
   }
   # SQL 转换支持基本函数和条件操作
   # 但不支持复杂的 SQL 操作，包括：多源表/行 JOIN 和聚合操作等

Diff for: docs/zh/faq.md

@@ -73,7 +73,7 @@ SeaTunnel 支持一部分数据源的精确一致性，例如支持 MySQL、Post
 ...
 transform {
   Sql {
-    query = "select * from user_view where city ='${city}' and dt = '${date}'"
+    query = "select * from dual where city ='${city}' and dt = '${date}'"
   }
 }
 ...

Diff for: docs/zh/transform-v2/sql-udf.md

@@ -111,7 +111,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select id, example(name) as name, age from fake"
+    query = "select id, example(name) as name, age from dual"
   }
 }
 ```

Diff for: docs/zh/transform-v2/sql.md

@@ -45,7 +45,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select id, concat(name, '_') as name, age+1 as age from fake where id>0"
+    query = "select id, concat(name, '_') as name, age+1 as age from dual where id>0"
   }
 }
 ```
@@ -139,7 +139,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select id, concat(name, '_') as name, age+1 as age from fake where id>0"
+    query = "select id, concat(name, '_') as name, age+1 as age from dual where id>0"
   }
 }
 

Diff for: seatunnel-api/src/test/resources/conf/option-test.conf

@@ -98,7 +98,7 @@ source {
 
 transform {
     sql {
-        sql = "select name,age from fake"
+        sql = "select name,age from dual"
     }
 }
 

Diff for: seatunnel-config/seatunnel-config-shade/src/test/resources/json/spark.batch.conf

@@ -50,7 +50,7 @@ transform {
 
   # you can also use other transform plugins, such as sql
   # sql {
-  #   sql = "select * from accesslog where request_time > 1000"
+  #   sql = "select * from dual where request_time > 1000"
   # }
 
   # If you would like to get more information about how to configure seatunnel and see full list of transform plugins,

Diff for: seatunnel-config/seatunnel-config-shade/src/test/resources/seatunnel/variables.conf

@@ -41,13 +41,13 @@ transform {
 
   sql {
     table_name = "user_view"
-    sql = "select * from user_view where city = '"${city2}"'"
+    sql = "select * from dual where city = '"${city2}"'"
     plugin_output = "result1"
   }
 
   sql {
     table_name = "user_view"
-    sql = "select * from user_view where dt = '"${dt}"'"
+    sql = "select * from dual where dt = '"${dt}"'"
     plugin_output = "result2"
   }
 }

Diff for: seatunnel-connectors-v2/connector-email/src/main/resources/fake_to_emailsink_flink.conf

@@ -37,7 +37,7 @@ source {
 
 transform {
     sql {
-         sql = "select name,age from fake"
+         sql = "select name,age from dual"
     }
 
   # If you would like to get more information about how to configure seatunnel and see full list of transform plugins,

Diff for: seatunnel-connectors-v2/connector-kudu/src/main/resources/kudu_to_kudu_flink.conf

@@ -38,7 +38,7 @@ source {
 
 transform {
     sql {
-      sql = "select id,name,age,sex from studentlyh2"
+      sql = "select id,name,age,sex from dual"
     }
 
   # If you would like to get more information about how to configure seatunnel and see full list of transform plugins,

Diff for: seatunnel-connectors-v2/connector-kudu/src/main/resources/kudu_to_kudu_spark.conf

@@ -43,7 +43,7 @@ source {
 
 transform {
     sql {
-      sql = "select id,name,age,sex from studentlyh2"
+      sql = "select id,name,age,sex from dual"
     }
 
   # If you would like to get more information about how to configure seatunnel and see full list of transform plugins,

Diff for: seatunnel-connectors-v2/connector-maxcompute/src/main/resources/maxcompute_to_maxcompute.conf

@@ -72,7 +72,7 @@ source {
 transform {
   sql {
     plugin_input = "fake"
-    sql = "select * from fake"
+    sql = "select * from dual"
   }
 
   # If you would like to get more information about how to configure seatunnel and see full list of transform plugins,

Diff for: seatunnel-core/seatunnel-core-starter/src/test/resources/flink.batch.conf

@@ -38,7 +38,7 @@ source {
 
 transform {
   Sql {
-    sql = "select * from test"
+    sql = "select * from dual"
   }
 
   # If you would like to get more information about how to configure seatunnel and see full list of filter plugins,

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/resources/mysqlcdc_to_mysql.conf

@@ -45,7 +45,7 @@ transform {
                 f_mediumint_unsigned, f_int, f_int_unsigned, f_integer, f_integer_unsigned, f_bigint, f_bigint_unsigned, f_numeric, f_decimal,
                 f_float, f_double, f_double_precision, f_longtext, f_mediumtext, f_text, f_tinytext, f_varchar, f_date, f_datetime, f_timestamp,
                 f_bit1, f_bit64, f_char, f_enum, f_mediumblob, f_long_varchar, f_real, f_time, f_tinyint, f_tinyint_unsigned, f_json, f_year
-                from customers_mysql_cdc """
+                from dual """
     plugin_output = "trans_mysql_cdc"
   }
 }

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/resources/fake_to_assert.conf

@@ -71,7 +71,7 @@ transform {
     Sql {
         plugin_input = "fake"
         plugin_output = "tmp1"
-        query = """select * from fake"""
+        query = """select * from dual"""
     }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/resources/fake_to_assert_with_compatible_source_and_result_table_name.conf

@@ -49,13 +49,13 @@ transform {
     source_table_name = "fake1"
     result_table_name = "tmp1"
 
-    query = """select * from fake1"""
+    query = """select * from dual"""
   }
   Sql {
     source_table_name = "fake2"
     result_table_name = "tmp2"
 
-    query = """select * from fake2"""
+    query = """select * from dual"""
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf

@@ -80,7 +80,7 @@ transform {
   sql {
     plugin_input = "fake"
     plugin_output = "sqlresult"
-    query = "select * from fake where c_string = 'WArEB'"
+    query = "select * from dual where c_string = 'WArEB'"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/text/local_file_text_lzo_to_assert.conf

@@ -79,7 +79,7 @@ transform {
   sql {
     plugin_input = "fake"
     plugin_output = "sqlresult"
-    query = "select * from fake where c_string = 'MTDna'"
+    query = "select * from dual where c_string = 'MTDna'"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-oss-e2e/src/test/resources/json/oss_file_json_lzo_to_console.conf

@@ -82,7 +82,7 @@ transform {
   sql {
     plugin_input = "fake"
     plugin_output = "sqlresult"
-    query = "select * from fake where c_string = 'WArEB'"
+    query = "select * from dual where c_string = 'WArEB'"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-oss-e2e/src/test/resources/text/oss_file_text_lzo_to_assert.conf

@@ -81,7 +81,7 @@ transform {
   sql {
     plugin_input = "fake"
     plugin_output = "sqlresult"
-    query = "select * from fake where c_string = 'MTDna'"
+    query = "select * from dual where c_string = 'MTDna'"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-s3-e2e/src/test/resources/json/s3_file_json_lzo_to_console.conf

@@ -83,7 +83,7 @@ transform {
   sql {
     plugin_input = "fake"
     plugin_output = "sqlresult"
-    query = "select * from fake where c_string = 'WArEB'"
+    query = "select * from dual where c_string = 'WArEB'"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-s3-e2e/src/test/resources/text/s3_file_text_lzo_to_assert.conf

@@ -82,7 +82,7 @@ transform {
   sql {
     plugin_input = "fake"
     plugin_output = "sqlresult"
-    query = "select * from fake where c_string = 'MTDna'"
+    query = "select * from dual where c_string = 'MTDna'"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/resources/http_streaming_json_to_postgresql.conf

@@ -44,7 +44,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select  CONCAT(c_string, CAST(RAND() AS STRING)) as c_string, c_int from fake"
+    query = "select  CONCAT(c_string, CAST(RAND() AS STRING)) as c_string, c_int from dual"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/protobuf/kafka_protobuf_transform_to_assert.conf

@@ -89,7 +89,7 @@ transform {
     Sql {
         plugin_input = "kafka_table"
         plugin_output = "kafka_table_transform"
-        query = "select Address.city,c_string from kafka_table"
+        query = "select Address.city,c_string from dual"
     }
 }
 

Diff for: seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/batch_fakesource_to_console_error.conf

@@ -39,7 +39,7 @@ transform {
   sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query ="select cast(name as int) as name, id,age from fake"
+    query ="select cast(name as int) as name, id,age from dual"
   }
 }
 sink {

Diff for: seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/unify-env-param-test-resource/unify_flink_table_env_param_fakesource_to_console.conf

@@ -48,7 +48,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select id, concat(name, '_') as name, age as age from fake where id > 0"
+    query = "select id, concat(name, '_') as name, age as age from dual where id > 0"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform.conf

@@ -52,7 +52,7 @@ transform {
     plugin_input = "fake"
     plugin_output = "fake1"
     # the query table name must same as field 'plugin_input'
-    query = "select id, regexp_replace(name, '.+', 'b') as name, age+1 as age, pi() as pi, c_time, c_timestamp, c_date, c_map, c_array, c_decimal, c_row from fake"
+    query = "select id, regexp_replace(name, '.+', 'b') as name, age+1 as age, pi() as pi, c_time, c_timestamp, c_date, c_map, c_array, c_decimal, c_row from dual"
   }
   # The SQL transform support base function and criteria operation
   # But the complex SQL unsupported yet, include: multi source table/rows JOIN and AGGREGATE operation and the like

Diff for: seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/binary_expression.conf

@@ -44,7 +44,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "select id+1 as id, id*4 as id2, price/3 as price, price-34.22 as price2, price%23.12 as price3, name||'_'||id as name from fake"
+    query = "select id+1 as id, id*4 as id2, price/3 as price, price-34.22 as price2, price%23.12 as price3, name||'_'||id as name from dual"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/case_when.conf

@@ -65,7 +65,7 @@ transform {
        case when c_tinyint != 117 or TO_CHAR(c_boolean)='true' then 1 else 0 end as c_tinyint_boolean_or_1,
        case when c_int > 1 and c_bigint >1 and c_float >1 and c_double > 1 and c_decimal > 1 then 1 else 0 end as c_number_1,
        case when c_tinyint <> 117 then 1 else 0 end as c_number_0
-       from fake
+       from dual
     """
   }
 }

Diff for: seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/criteria_filter.conf

@@ -54,7 +54,7 @@ transform {
     plugin_input = "fake"
     plugin_output = "fake1"
     query = """
-      select id, name, age, email from fake
+      select id, name, age, email from dual
               where ( id = 1 or id = 4 or id in (8, 9, 10, 11, 12) )
                   and id != 0 and name <> 'Kin Dom'
                   and ( age >= 20 or age < 22 )

Diff for: seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/explode_transform.conf

@@ -58,7 +58,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "SELECT * FROM fake LATERAL VIEW OUTER EXPLODE(SPLIT(name, ',')) as name LATERAL VIEW OUTER EXPLODE(SPLIT(pk_id, ';')) as pk_id LATERAL VIEW OUTER EXPLODE(age) as age LATERAL VIEW  EXPLODE(ARRAY(1,1)) as num"
+    query = "SELECT * FROM dual LATERAL VIEW OUTER EXPLODE(SPLIT(name, ',')) as name LATERAL VIEW OUTER EXPLODE(SPLIT(pk_id, ';')) as pk_id LATERAL VIEW OUTER EXPLODE(age) as age LATERAL VIEW  EXPLODE(ARRAY(1,1)) as num"
   }
 }
 

Diff for: seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/explode_transform_with_outer.conf

@@ -50,7 +50,7 @@ transform {
   Sql {
     plugin_input = "fake"
     plugin_output = "fake1"
-    query = "SELECT * FROM fake LATERAL VIEW OUTER EXPLODE(age) as age LATERAL VIEW OUTER EXPLODE(ARRAY(null,null)) as num"
+    query = "SELECT * FROM dual LATERAL VIEW OUTER EXPLODE(age) as age LATERAL VIEW OUTER EXPLODE(ARRAY(null,null)) as num"
   }
 }