You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by pa...@apache.org on 2022/11/25 05:33:20 UTC

[shardingsphere] branch master updated: Add new IT scenario passthrough for ShardingSphere-Proxy (#22401)

This is an automated email from the ASF dual-hosted git repository.

panjuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 6d70c4c125f Add new IT scenario passthrough for ShardingSphere-Proxy (#22401)
6d70c4c125f is described below

commit 6d70c4c125fe6daafcdbb5071f9d146fe8b30033
Author: 吴伟杰 <wu...@apache.org>
AuthorDate: Fri Nov 25 13:33:12 2022 +0800

    Add new IT scenario passthrough for ShardingSphere-Proxy (#22401)
    
    * Add new IT scenario passthrough for ShardingSphere-Proxy
    
    * Update IT actions
---
 .github/workflows/it.yml                           |  5 +++-
 ...insert_max_values_into_single_table_integer.xml |  4 +--
 ...insert_min_values_into_single_table_integer.xml |  4 +--
 ...t_negative_values_into_single_table_integer.xml |  4 +--
 ...insert_min_values_into_single_table_integer.xml |  4 +--
 ...negative_smallint_into_single_table_integer.xml |  4 +--
 ...t_negative_values_into_single_table_integer.xml |  4 +--
 .../cases/dml/dml-integration-test-cases.xml       |  4 +--
 .../rql/dataset/tbl/count_single_table_rule.xml    |  2 +-
 .../cases/rql/dataset/tbl/show_single_tables.xml   |  1 -
 .../passthrough/data/actual/databases.xml}         | 12 +++------
 .../scenario/passthrough/data/actual/dataset.xml}  |  5 ++--
 .../data/actual/init-sql/mysql/01-actual-init.sql  | 24 ++++++++++++++++++
 .../actual/init-sql/opengauss/01-actual-init.sql   | 25 +++++++++++++++++++
 .../actual/init-sql/postgresql/01-actual-init.sql  | 25 +++++++++++++++++++
 .../passthrough/data/expected/databases.xml}       | 12 +++------
 .../passthrough/data/expected/dataset.xml}         |  5 ++--
 .../expected/init-sql/mysql/01-expected-init.sql   | 24 ++++++++++++++++++
 .../init-sql/opengauss/01-expected-init.sql        | 26 +++++++++++++++++++
 .../init-sql/postgresql/01-expected-init.sql       | 26 +++++++++++++++++++
 .../proxy/conf/mysql/config-passthrough.yaml       | 29 ++++++++++++++++++++++
 .../proxy/conf/opengauss/config-passthrough.yaml   | 29 ++++++++++++++++++++++
 .../proxy/conf/postgresql/config-passthrough.yaml  | 29 ++++++++++++++++++++++
 .../env/scenario/tbl/data/actual/dataset.xml       |  8 ------
 .../tbl/data/actual/init-sql/h2/01-actual-init.sql |  2 --
 .../data/actual/init-sql/mysql/01-actual-init.sql  |  1 -
 .../actual/init-sql/opengauss/01-actual-init.sql   |  2 --
 .../actual/init-sql/postgresql/01-actual-init.sql  |  2 --
 .../env/scenario/tbl/data/expected/dataset.xml     |  8 ------
 .../data/expected/init-sql/h2/01-expected-init.sql |  2 --
 .../expected/init-sql/mysql/01-expected-init.sql   |  1 -
 .../init-sql/opengauss/01-expected-init.sql        |  2 --
 .../init-sql/postgresql/01-expected-init.sql       |  2 --
 33 files changed, 268 insertions(+), 69 deletions(-)

diff --git a/.github/workflows/it.yml b/.github/workflows/it.yml
index e8cabf0e3c3..4c89b9ce292 100644
--- a/.github/workflows/it.yml
+++ b/.github/workflows/it.yml
@@ -104,7 +104,10 @@ jobs:
       matrix:
         adapter: [ proxy, jdbc ]
         database: [ MySQL, PostgreSQL, openGauss ]
-        scenario: [ empty_rules, rdl_empty_rules ]
+        scenario: [ empty_rules, rdl_empty_rules, passthrough ]
+        exclude:
+          - adapter: jdbc
+            scenario: passthrough
     steps:
       - uses: actions/checkout@v3
       - uses: actions/cache@v3
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_max_values_into_single_table_integer.xml b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_max_values_into_single_table_integer.xml
similarity index 86%
rename from test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_max_values_into_single_table_integer.xml
rename to test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_max_values_into_single_table_integer.xml
index 1aad1926f60..65fc7fe899c 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_max_values_into_single_table_integer.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_max_values_into_single_table_integer.xml
@@ -16,7 +16,7 @@
   -->
 
 <dataset update-count="1">
-    <metadata data-nodes="tbl.t_single_table_integer">
+    <metadata data-nodes="passthrough.t_data_type_integer">
         <column name="id" type="numeric" />
         <column name="col_bigint" type="numeric" />
         <column name="col_int" type="numeric" />
@@ -24,5 +24,5 @@
         <column name="col_smallint" type="numeric" />
         <column name="col_tinyint" type="numeric" />
     </metadata>
-    <row data-node="tbl.t_single_table_integer" values="1, 9223372036854775807, 2147483647, 8388607, 32767, 127" />
+    <row data-node="passthrough.t_data_type_integer" values="1, 9223372036854775807, 2147483647, 8388607, 32767, 127" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_min_values_into_single_table_integer.xml b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_min_values_into_single_table_integer.xml
similarity index 86%
rename from test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_min_values_into_single_table_integer.xml
rename to test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_min_values_into_single_table_integer.xml
index 2815518daf1..641b1a393dc 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_min_values_into_single_table_integer.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_min_values_into_single_table_integer.xml
@@ -16,7 +16,7 @@
   -->
 
 <dataset update-count="1">
-    <metadata data-nodes="tbl.t_single_table_integer">
+    <metadata data-nodes="passthrough.t_data_type_integer">
         <column name="id" type="numeric" />
         <column name="col_bigint" type="numeric" />
         <column name="col_int" type="numeric" />
@@ -24,5 +24,5 @@
         <column name="col_smallint" type="numeric" />
         <column name="col_tinyint" type="numeric" />
     </metadata>
-    <row data-node="tbl.t_single_table_integer" values="2, -9223372036854775808, -2147483648, -8388608, -32768, -128" />
+    <row data-node="passthrough.t_data_type_integer" values="2, -9223372036854775808, -2147483648, -8388608, -32768, -128" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_negative_values_into_single_table_integer.xml b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_negative_values_into_single_table_integer.xml
similarity index 88%
rename from test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_negative_values_into_single_table_integer.xml
rename to test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_negative_values_into_single_table_integer.xml
index 9a8e2a311f8..4e222a624ea 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/insert_negative_values_into_single_table_integer.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/insert_negative_values_into_single_table_integer.xml
@@ -16,7 +16,7 @@
   -->
 
 <dataset update-count="1">
-    <metadata data-nodes="tbl.t_single_table_integer">
+    <metadata data-nodes="passthrough.t_data_type_integer">
         <column name="id" type="numeric" />
         <column name="col_bigint" type="numeric" />
         <column name="col_int" type="numeric" />
@@ -24,5 +24,5 @@
         <column name="col_smallint" type="numeric" />
         <column name="col_tinyint" type="numeric" />
     </metadata>
-    <row data-node="tbl.t_single_table_integer" values="3, -1, -1, -1, -1, -1" />
+    <row data-node="passthrough.t_data_type_integer" values="3, -1, -1, -1, -1, -1" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_min_values_into_single_table_integer.xml b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_min_values_into_single_table_integer.xml
similarity index 86%
rename from test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_min_values_into_single_table_integer.xml
rename to test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_min_values_into_single_table_integer.xml
index ea54617ed70..d2fc5704b32 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_min_values_into_single_table_integer.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_min_values_into_single_table_integer.xml
@@ -16,7 +16,7 @@
   -->
 
 <dataset update-count="1">
-    <metadata data-nodes="tbl.t_single_table_integer">
+    <metadata data-nodes="passthrough.t_data_type_integer">
         <column name="id" type="numeric" />
         <column name="col_bigint" type="numeric" />
         <column name="col_int" type="numeric" />
@@ -24,5 +24,5 @@
         <column name="col_smallint" type="numeric" />
         <column name="col_tinyint" type="numeric" />
     </metadata>
-    <row data-node="tbl.t_single_table_integer" values="2, -9223372036854775808, -2147483648, -8388608, 0, -128" />
+    <row data-node="passthrough.t_data_type_integer" values="2, -9223372036854775808, -2147483648, -8388608, 0, -128" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_negative_smallint_into_single_table_integer.xml
similarity index 89%
copy from test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml
copy to test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_negative_smallint_into_single_table_integer.xml
index 91b02503257..682cefa3625 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_negative_smallint_into_single_table_integer.xml
@@ -16,7 +16,7 @@
   -->
 
 <dataset update-count="1">
-    <metadata data-nodes="tbl.t_single_table_integer">
+    <metadata data-nodes="passthrough.t_data_type_integer">
         <column name="id" type="numeric" />
         <column name="col_bigint" type="numeric" />
         <column name="col_int" type="numeric" />
@@ -24,5 +24,5 @@
         <column name="col_smallint" type="numeric" />
         <column name="col_tinyint" type="numeric" />
     </metadata>
-    <row data-node="tbl.t_single_table_integer" values="4, 0, 0, 0, -1, 0" />
+    <row data-node="passthrough.t_data_type_integer" values="4, 0, 0, 0, -1, 0" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_values_into_single_table_integer.xml b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_negative_values_into_single_table_integer.xml
similarity index 89%
rename from test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_values_into_single_table_integer.xml
rename to test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_negative_values_into_single_table_integer.xml
index 813918db1f1..8115164f13e 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_values_into_single_table_integer.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/passthrough/mysql/insert_negative_values_into_single_table_integer.xml
@@ -16,7 +16,7 @@
   -->
 
 <dataset update-count="1">
-    <metadata data-nodes="tbl.t_single_table_integer">
+    <metadata data-nodes="passthrough.t_data_type_integer">
         <column name="id" type="numeric" />
         <column name="col_bigint" type="numeric" />
         <column name="col_int" type="numeric" />
@@ -24,5 +24,5 @@
         <column name="col_smallint" type="numeric" />
         <column name="col_tinyint" type="numeric" />
     </metadata>
-    <row data-node="tbl.t_single_table_integer" values="3, -1, -1, -1, 0, -1" />
+    <row data-node="passthrough.t_data_type_integer" values="3, -1, -1, -1, 0, -1" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dml-integration-test-cases.xml b/test/integration-test/test-suite/src/test/resources/cases/dml/dml-integration-test-cases.xml
index abd3ae6ebb4..ff293ddc3cd 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dml-integration-test-cases.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/dml/dml-integration-test-cases.xml
@@ -290,14 +290,14 @@
         <assertion parameters="0:int, 4:int, 5:int" expected-data-file="shadow_delete_order_by_user_id.xml" />
     </test-case>
     
-    <test-case sql="INSERT INTO t_single_table_integer (id, col_bigint, col_int, col_mediumint, col_smallint, col_tinyint) values (?, ?, ?, ?, ?, ?)" db-types="MySQL" scenario-types="tbl">
+    <test-case sql="INSERT INTO t_data_type_integer (id, col_bigint, col_int, col_mediumint, col_smallint, col_tinyint) values (?, ?, ?, ?, ?, ?)" db-types="MySQL" scenario-types="passthrough">
         <assertion parameters="1:int, 9223372036854775807:long, 2147483647:int, 8388607:int, 32767:smallint, 127:tinyint" expected-data-file="insert_max_values_into_single_table_integer.xml" />
         <!-- TODO Support negative value of smallint & tinyint. https://github.com/apache/shardingsphere/issues/21902 -->
         <assertion parameters="2:int, -9223372036854775808:long, -2147483648:int, -8388608:int, 0:smallint, -128:tinyint" expected-data-file="insert_min_values_into_single_table_integer.xml" />
         <assertion parameters="3:int, -1:long, -1:int, -1:int, 0:smallint, -1:tinyint" expected-data-file="insert_negative_values_into_single_table_integer.xml" />
         <!-- <assertion parameters="4:int, 0:int, 0:int, 0:int, -1:smallint, 0:int" expected-data-file="insert_negative_smallint_into_single_table_integer.xml" />-->
     </test-case>
-    <test-case sql="INSERT INTO t_single_table_integer (id, col_bigint, col_int, col_mediumint, col_smallint, col_tinyint) values (?, ?, ?, ?, ?, ?)" db-types="PostgreSQL,openGauss" scenario-types="tbl">
+    <test-case sql="INSERT INTO t_data_type_integer (id, col_bigint, col_int, col_mediumint, col_smallint, col_tinyint) values (?, ?, ?, ?, ?, ?)" db-types="PostgreSQL,openGauss" scenario-types="passthrough">
         <assertion parameters="1:int, 9223372036854775807:long, 2147483647:int, 8388607:int, 32767:smallint, 127:tinyint" expected-data-file="insert_max_values_into_single_table_integer.xml" />
         <assertion parameters="2:int, -9223372036854775808:long, -2147483648:int, -8388608:int, -32768:smallint, -128:tinyint" expected-data-file="insert_min_values_into_single_table_integer.xml" />
         <assertion parameters="3:int, -1:long, -1:int, -1:int, -1:smallint, -1:tinyint" expected-data-file="insert_negative_values_into_single_table_integer.xml" />
diff --git a/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml b/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml
index 4cae2d07a0f..7913d252c80 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml
@@ -21,5 +21,5 @@
         <column name="database"/>
         <column name="count"/>
     </metadata>
-    <row values="single_table| tbl| 2"/>
+    <row values="single_table| tbl| 1"/>
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/show_single_tables.xml b/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/show_single_tables.xml
index c2bb9e24995..366d068001d 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/show_single_tables.xml
+++ b/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/show_single_tables.xml
@@ -21,5 +21,4 @@
         <column name="resource_name" />
     </metadata>
     <row values="t_single_table| tbl" />
-    <row values="t_single_table_integer| tbl" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/databases.xml
similarity index 80%
copy from test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml
copy to test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/databases.xml
index 4cae2d07a0f..64f34de2865 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/databases.xml
@@ -1,3 +1,4 @@
+<?xml version="1.0" encoding="UTF-8"?>
 <!--
   ~ Licensed to the Apache Software Foundation (ASF) under one or more
   ~ contributor license agreements.  See the NOTICE file distributed with
@@ -15,11 +16,6 @@
   ~ limitations under the License.
   -->
 
-<dataset>
-    <metadata>
-        <column name="rule_name"/>
-        <column name="database"/>
-        <column name="count"/>
-    </metadata>
-    <row values="single_table| tbl| 2"/>
-</dataset>
+<databases>
+    <database>passthrough</database>
+</databases>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/dataset.xml
similarity index 87%
copy from test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml
copy to test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/dataset.xml
index 91b02503257..92b264c1a87 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/dataset.xml
@@ -15,8 +15,8 @@
   ~ limitations under the License.
   -->
 
-<dataset update-count="1">
-    <metadata data-nodes="tbl.t_single_table_integer">
+<dataset>
+    <metadata data-nodes="passthrough.t_data_type_integer">
         <column name="id" type="numeric" />
         <column name="col_bigint" type="numeric" />
         <column name="col_int" type="numeric" />
@@ -24,5 +24,4 @@
         <column name="col_smallint" type="numeric" />
         <column name="col_tinyint" type="numeric" />
     </metadata>
-    <row data-node="tbl.t_single_table_integer" values="4, 0, 0, 0, -1, 0" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/mysql/01-actual-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/mysql/01-actual-init.sql
new file mode 100644
index 00000000000..9fe5ba19289
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/mysql/01-actual-init.sql
@@ -0,0 +1,24 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one or more
+-- contributor license agreements.  See the NOTICE file distributed with
+-- this work for additional information regarding copyright ownership.
+-- The ASF licenses this file to You under the Apache License, Version 2.0
+-- (the "License"); you may not use this file except in compliance with
+-- the License.  You may obtain a copy of the License at
+--
+--     http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing, software
+-- distributed under the License is distributed on an "AS IS" BASIS,
+-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+-- See the License for the specific language governing permissions and
+-- limitations under the License.
+--
+
+SET character_set_database='utf8';
+SET character_set_server='utf8';
+
+DROP DATABASE IF EXISTS passthrough;
+
+CREATE DATABASE passthrough;
+CREATE TABLE passthrough.t_data_type_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint MEDIUMINT NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint TINYINT NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/opengauss/01-actual-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/opengauss/01-actual-init.sql
new file mode 100644
index 00000000000..c5eaf210003
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/opengauss/01-actual-init.sql
@@ -0,0 +1,25 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one or more
+-- contributor license agreements.  See the NOTICE file distributed with
+-- this work for additional information regarding copyright ownership.
+-- The ASF licenses this file to You under the Apache License, Version 2.0
+-- (the "License"); you may not use this file except in compliance with
+-- the License.  You may obtain a copy of the License at
+--
+--     http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing, software
+-- distributed under the License is distributed on an "AS IS" BASIS,
+-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+-- See the License for the specific language governing permissions and
+-- limitations under the License.
+--
+
+CREATE DATABASE passthrough;
+
+GRANT ALL PRIVILEGES ON DATABASE passthrough TO test_user;
+
+\c passthrough
+
+DROP TABLE IF EXISTS t_data_type_integer;
+CREATE TABLE t_data_type_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint INT4 NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint INT2 NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/postgresql/01-actual-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/postgresql/01-actual-init.sql
new file mode 100644
index 00000000000..c5eaf210003
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/actual/init-sql/postgresql/01-actual-init.sql
@@ -0,0 +1,25 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one or more
+-- contributor license agreements.  See the NOTICE file distributed with
+-- this work for additional information regarding copyright ownership.
+-- The ASF licenses this file to You under the Apache License, Version 2.0
+-- (the "License"); you may not use this file except in compliance with
+-- the License.  You may obtain a copy of the License at
+--
+--     http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing, software
+-- distributed under the License is distributed on an "AS IS" BASIS,
+-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+-- See the License for the specific language governing permissions and
+-- limitations under the License.
+--
+
+CREATE DATABASE passthrough;
+
+GRANT ALL PRIVILEGES ON DATABASE passthrough TO test_user;
+
+\c passthrough
+
+DROP TABLE IF EXISTS t_data_type_integer;
+CREATE TABLE t_data_type_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint INT4 NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint INT2 NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/databases.xml
similarity index 80%
copy from test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml
copy to test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/databases.xml
index 4cae2d07a0f..9e98dc8baea 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/rql/dataset/tbl/count_single_table_rule.xml
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/databases.xml
@@ -1,3 +1,4 @@
+<?xml version="1.0" encoding="UTF-8"?>
 <!--
   ~ Licensed to the Apache Software Foundation (ASF) under one or more
   ~ contributor license agreements.  See the NOTICE file distributed with
@@ -15,11 +16,6 @@
   ~ limitations under the License.
   -->
 
-<dataset>
-    <metadata>
-        <column name="rule_name"/>
-        <column name="database"/>
-        <column name="count"/>
-    </metadata>
-    <row values="single_table| tbl| 2"/>
-</dataset>
+<databases>
+    <database>expected_dataset</database>
+</databases>
diff --git a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/dataset.xml
similarity index 87%
rename from test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml
rename to test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/dataset.xml
index 91b02503257..87d4ca5eb00 100644
--- a/test/integration-test/test-suite/src/test/resources/cases/dml/dataset/tbl/mysql/insert_negative_smallint_into_single_table_integer.xml
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/dataset.xml
@@ -15,8 +15,8 @@
   ~ limitations under the License.
   -->
 
-<dataset update-count="1">
-    <metadata data-nodes="tbl.t_single_table_integer">
+<dataset>
+    <metadata data-nodes="expected_dataset.t_data_type_integer">
         <column name="id" type="numeric" />
         <column name="col_bigint" type="numeric" />
         <column name="col_int" type="numeric" />
@@ -24,5 +24,4 @@
         <column name="col_smallint" type="numeric" />
         <column name="col_tinyint" type="numeric" />
     </metadata>
-    <row data-node="tbl.t_single_table_integer" values="4, 0, 0, 0, -1, 0" />
 </dataset>
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/mysql/01-expected-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/mysql/01-expected-init.sql
new file mode 100644
index 00000000000..bcadcb255e9
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/mysql/01-expected-init.sql
@@ -0,0 +1,24 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one or more
+-- contributor license agreements.  See the NOTICE file distributed with
+-- this work for additional information regarding copyright ownership.
+-- The ASF licenses this file to You under the Apache License, Version 2.0
+-- (the "License"); you may not use this file except in compliance with
+-- the License.  You may obtain a copy of the License at
+--
+--     http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing, software
+-- distributed under the License is distributed on an "AS IS" BASIS,
+-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+-- See the License for the specific language governing permissions and
+-- limitations under the License.
+--
+
+SET character_set_database='utf8';
+SET character_set_server='utf8';
+
+DROP DATABASE IF EXISTS expected_dataset;
+CREATE DATABASE expected_dataset;
+
+CREATE TABLE expected_dataset.t_data_type_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint MEDIUMINT NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint TINYINT NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/opengauss/01-expected-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/opengauss/01-expected-init.sql
new file mode 100644
index 00000000000..5429517de9d
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/opengauss/01-expected-init.sql
@@ -0,0 +1,26 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one or more
+-- contributor license agreements.  See the NOTICE file distributed with
+-- this work for additional information regarding copyright ownership.
+-- The ASF licenses this file to You under the Apache License, Version 2.0
+-- (the "License"); you may not use this file except in compliance with
+-- the License.  You may obtain a copy of the License at
+--
+--     http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing, software
+-- distributed under the License is distributed on an "AS IS" BASIS,
+-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+-- See the License for the specific language governing permissions and
+-- limitations under the License.
+--
+
+DROP DATABASE IF EXISTS expected_dataset;
+CREATE DATABASE expected_dataset;
+
+GRANT ALL PRIVILEGES ON DATABASE expected_dataset TO test_user;
+
+\c expected_dataset;
+
+DROP TABLE IF EXISTS t_data_type_integer;
+CREATE TABLE t_data_type_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint INT4 NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint INT2 NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/postgresql/01-expected-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/postgresql/01-expected-init.sql
new file mode 100644
index 00000000000..7240393b823
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/data/expected/init-sql/postgresql/01-expected-init.sql
@@ -0,0 +1,26 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one or more
+-- contributor license agreements.  See the NOTICE file distributed with
+-- this work for additional information regarding copyright ownership.
+-- The ASF licenses this file to You under the Apache License, Version 2.0
+-- (the "License"); you may not use this file except in compliance with
+-- the License.  You may obtain a copy of the License at
+--
+--     http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing, software
+-- distributed under the License is distributed on an "AS IS" BASIS,
+-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+-- See the License for the specific language governing permissions and
+-- limitations under the License.
+--
+
+DROP DATABASE IF EXISTS expected_dataset;
+CREATE DATABASE expected_dataset;
+
+GRANT ALL PRIVILEGES ON DATABASE expected_dataset TO test_user;
+
+\c expected_dataset;
+    
+DROP TABLE IF EXISTS t_data_type_integer;
+CREATE TABLE t_data_type_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint INT4 NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint INT2 NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/mysql/config-passthrough.yaml b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/mysql/config-passthrough.yaml
new file mode 100644
index 00000000000..a2e09df7ded
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/mysql/config-passthrough.yaml
@@ -0,0 +1,29 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+databaseName: passthrough
+
+dataSources:
+  passthrough:
+    url: jdbc:mysql://mysql.passthrough.host:3306/passthrough?serverTimezone=UTC&useSSL=false&characterEncoding=utf-8
+    username: test_user
+    password: Test@123
+    connectionTimeoutMilliseconds: 30000
+    idleTimeoutMilliseconds: 60000
+    maxLifetimeMilliseconds: 1800000
+    maxPoolSize: 2
+    minPoolSize: 2
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/opengauss/config-passthrough.yaml b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/opengauss/config-passthrough.yaml
new file mode 100644
index 00000000000..6cb8262676e
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/opengauss/config-passthrough.yaml
@@ -0,0 +1,29 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+databaseName: passthrough
+
+dataSources:
+  passthrough:
+    url: jdbc:opengauss://opengauss.passthrough.host:5432/passthrough
+    username: test_user
+    password: Test@123
+    connectionTimeoutMilliseconds: 30000
+    idleTimeoutMilliseconds: 60000
+    maxLifetimeMilliseconds: 1800000
+    maxPoolSize: 2
+    minPoolSize: 2
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/postgresql/config-passthrough.yaml b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/postgresql/config-passthrough.yaml
new file mode 100644
index 00000000000..9cf78cfea2c
--- /dev/null
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/passthrough/proxy/conf/postgresql/config-passthrough.yaml
@@ -0,0 +1,29 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+databaseName: passthrough
+
+dataSources:
+  passthrough:
+    url: jdbc:postgresql://postgresql.passthrough.host:5432/passthrough
+    username: test_user
+    password: Test@123
+    connectionTimeoutMilliseconds: 30000
+    idleTimeoutMilliseconds: 60000
+    maxLifetimeMilliseconds: 1800000
+    maxPoolSize: 2
+    minPoolSize: 2
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/dataset.xml b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/dataset.xml
index 32228e8e35f..9b819ef2211 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/dataset.xml
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/dataset.xml
@@ -37,14 +37,6 @@
         <column name="id" type="numeric" />
         <column name="status" type="varchar" />
     </metadata>
-    <metadata data-nodes="tbl.t_single_table_integer">
-        <column name="id" type="numeric" />
-        <column name="col_bigint" type="numeric" />
-        <column name="col_int" type="numeric" />
-        <column name="col_mediumint" type="numeric" />
-        <column name="col_smallint" type="numeric" />
-        <column name="col_tinyint" type="numeric" />
-    </metadata>
     <metadata data-nodes="tbl.t_broadcast_table">
         <column name="id" type="numeric" />
         <column name="status" type="varchar" />
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/h2/01-actual-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/h2/01-actual-init.sql
index 511a59a4bd9..b8c15f1415e 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/h2/01-actual-init.sql
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/h2/01-actual-init.sql
@@ -41,7 +41,6 @@ DROP TABLE IF EXISTS t_order_9;
 DROP TABLE IF EXISTS t_order_item_9;
 DROP TABLE IF EXISTS t_broadcast_table;
 DROP TABLE IF EXISTS t_single_table;
-DROP TABLE IF EXISTS t_single_table_integer;
 
 CREATE TABLE t_order_0(order_id INT PRIMARY KEY, user_id INT NOT NULL, status VARCHAR(50) NOT NULL, merchant_id INT NOT NULL, remark VARCHAR(50) NOT NULL, creation_date DATE NOT NULL);
 CREATE TABLE t_order_item_0(item_id INT PRIMARY KEY, order_id INT NOT NULL, user_id INT NOT NULL, product_id INT NOT NULL, quantity INT NOT NULL, creation_date DATE NOT NULL);
@@ -90,4 +89,3 @@ CREATE INDEX order_index_t_order_9 ON t_order_9 (order_id);
 CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
 
 CREATE TABLE t_single_table (single_id INT NOT NULL, id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (single_id));
-CREATE TABLE t_single_table_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint MEDIUMINT NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint TINYINT NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/mysql/01-actual-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/mysql/01-actual-init.sql
index 296e6027398..34ae2e4038d 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/mysql/01-actual-init.sql
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/mysql/01-actual-init.sql
@@ -69,4 +69,3 @@ CREATE INDEX order_index_t_order_9 ON tbl.t_order_9 (order_id);
 CREATE TABLE tbl.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
 
 CREATE TABLE tbl.t_single_table (single_id INT NOT NULL, id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (single_id));
-CREATE TABLE tbl.t_single_table_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint MEDIUMINT NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint TINYINT NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/opengauss/01-actual-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/opengauss/01-actual-init.sql
index b5e6296f408..d8a08e8713c 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/opengauss/01-actual-init.sql
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/opengauss/01-actual-init.sql
@@ -47,7 +47,6 @@ DROP TABLE IF EXISTS t_order_9;
 DROP TABLE IF EXISTS t_order_item_9;
 DROP TABLE IF EXISTS t_broadcast_table;
 DROP TABLE IF EXISTS t_single_table;
-DROP TABLE IF EXISTS t_single_table_integer;
 
 CREATE TABLE t_order_0(order_id INT PRIMARY KEY, user_id INT NOT NULL, status VARCHAR(50) NOT NULL, merchant_id INT NOT NULL, remark VARCHAR(50) NOT NULL, creation_date DATE NOT NULL);
 CREATE TABLE t_order_item_0(item_id INT PRIMARY KEY, order_id INT NOT NULL, user_id INT NOT NULL, product_id INT NOT NULL, quantity INT NOT NULL, creation_date DATE NOT NULL);
@@ -96,4 +95,3 @@ CREATE INDEX order_index_t_order_9 ON t_order_9 (order_id);
 CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
 
 CREATE TABLE t_single_table (single_id INT NOT NULL, id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (single_id));
-CREATE TABLE t_single_table_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint INT4 NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint INT2 NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/postgresql/01-actual-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/postgresql/01-actual-init.sql
index b5e6296f408..d8a08e8713c 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/postgresql/01-actual-init.sql
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/actual/init-sql/postgresql/01-actual-init.sql
@@ -47,7 +47,6 @@ DROP TABLE IF EXISTS t_order_9;
 DROP TABLE IF EXISTS t_order_item_9;
 DROP TABLE IF EXISTS t_broadcast_table;
 DROP TABLE IF EXISTS t_single_table;
-DROP TABLE IF EXISTS t_single_table_integer;
 
 CREATE TABLE t_order_0(order_id INT PRIMARY KEY, user_id INT NOT NULL, status VARCHAR(50) NOT NULL, merchant_id INT NOT NULL, remark VARCHAR(50) NOT NULL, creation_date DATE NOT NULL);
 CREATE TABLE t_order_item_0(item_id INT PRIMARY KEY, order_id INT NOT NULL, user_id INT NOT NULL, product_id INT NOT NULL, quantity INT NOT NULL, creation_date DATE NOT NULL);
@@ -96,4 +95,3 @@ CREATE INDEX order_index_t_order_9 ON t_order_9 (order_id);
 CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
 
 CREATE TABLE t_single_table (single_id INT NOT NULL, id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (single_id));
-CREATE TABLE t_single_table_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint INT4 NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint INT2 NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/dataset.xml b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/dataset.xml
index 24989df3c11..d6e0104ea0b 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/dataset.xml
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/dataset.xml
@@ -37,14 +37,6 @@
         <column name="id" type="numeric" />
         <column name="status" type="varchar" />
     </metadata>
-    <metadata data-nodes="expected_dataset.t_single_table_integer">
-        <column name="id" type="numeric" />
-        <column name="col_bigint" type="numeric" />
-        <column name="col_int" type="numeric" />
-        <column name="col_mediumint" type="numeric" />
-        <column name="col_smallint" type="numeric" />
-        <column name="col_tinyint" type="numeric" />
-    </metadata>
     <metadata data-nodes="expected_dataset.t_broadcast_table">
         <column name="id" type="numeric" />
         <column name="status" type="varchar" />
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/h2/01-expected-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/h2/01-expected-init.sql
index dbd47759925..8b8618a68f1 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/h2/01-expected-init.sql
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/h2/01-expected-init.sql
@@ -18,7 +18,6 @@
 DROP TABLE IF EXISTS t_order;
 DROP TABLE IF EXISTS t_order_item;
 DROP TABLE IF EXISTS t_single_table;
-DROP TABLE IF EXISTS t_single_table_integer;
 DROP TABLE IF EXISTS t_broadcast_table;
 DROP TABLE IF EXISTS t_order_federate_sharding;
 DROP TABLE IF EXISTS t_order_item_federate_sharding;
@@ -29,6 +28,5 @@ CREATE TABLE t_single_table (single_id INT NOT NULL, id INT NOT NULL, status VAR
 CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
 CREATE TABLE t_order_federate_sharding (order_id_sharding INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id_sharding));
 CREATE TABLE t_order_item_federate_sharding (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, remarks VARCHAR(45) NULL, PRIMARY KEY (item_id));
-CREATE TABLE t_single_table_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint MEDIUMINT NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint TINYINT NOT NULL);
 
 CREATE INDEX order_index_t_order ON t_order (order_id);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/mysql/01-expected-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/mysql/01-expected-init.sql
index 0bdce6ea30d..6efde829beb 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/mysql/01-expected-init.sql
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/mysql/01-expected-init.sql
@@ -27,6 +27,5 @@ CREATE TABLE expected_dataset.t_single_table (single_id INT NOT NULL, id INT NOT
 CREATE TABLE expected_dataset.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
 CREATE TABLE expected_dataset.t_order_federate_sharding (order_id_sharding INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id_sharding));
 CREATE TABLE expected_dataset.t_order_item_federate_sharding (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, remarks VARCHAR(45) NULL, PRIMARY KEY (item_id));
-CREATE TABLE expected_dataset.t_single_table_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint MEDIUMINT NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint TINYINT NOT NULL);
 
 CREATE INDEX order_index_t_order ON expected_dataset.t_order (order_id);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/opengauss/01-expected-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/opengauss/01-expected-init.sql
index ffaa197d87c..7b5fa2a077a 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/opengauss/01-expected-init.sql
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/opengauss/01-expected-init.sql
@@ -28,7 +28,6 @@ DROP TABLE IF EXISTS t_single_table;
 DROP TABLE IF EXISTS t_broadcast_table;
 DROP TABLE IF EXISTS t_order_federate_sharding;
 DROP TABLE IF EXISTS t_order_item_federate_sharding;
-DROP TABLE IF EXISTS t_single_table_integer;
 
 CREATE TABLE t_order(order_id INT PRIMARY KEY, user_id INT NOT NULL, status VARCHAR(50) NOT NULL, merchant_id INT NOT NULL, remark VARCHAR(50) NOT NULL, creation_date DATE NOT NULL);
 CREATE TABLE t_order_item(item_id INT PRIMARY KEY, order_id INT NOT NULL, user_id INT NOT NULL, product_id INT NOT NULL, quantity INT NOT NULL, creation_date DATE NOT NULL);
@@ -38,4 +37,3 @@ CREATE TABLE t_order_federate_sharding (order_id_sharding INT NOT NULL, user_id
 CREATE TABLE t_order_item_federate_sharding (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, remarks VARCHAR(45) NULL, PRIMARY KEY (item_id));
 
 CREATE INDEX order_index_t_order ON t_order (order_id);
-CREATE TABLE t_single_table_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint INT4 NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint INT2 NOT NULL);
diff --git a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/postgresql/01-expected-init.sql b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/postgresql/01-expected-init.sql
index ffaa197d87c..7b5fa2a077a 100644
--- a/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/postgresql/01-expected-init.sql
+++ b/test/integration-test/test-suite/src/test/resources/env/scenario/tbl/data/expected/init-sql/postgresql/01-expected-init.sql
@@ -28,7 +28,6 @@ DROP TABLE IF EXISTS t_single_table;
 DROP TABLE IF EXISTS t_broadcast_table;
 DROP TABLE IF EXISTS t_order_federate_sharding;
 DROP TABLE IF EXISTS t_order_item_federate_sharding;
-DROP TABLE IF EXISTS t_single_table_integer;
 
 CREATE TABLE t_order(order_id INT PRIMARY KEY, user_id INT NOT NULL, status VARCHAR(50) NOT NULL, merchant_id INT NOT NULL, remark VARCHAR(50) NOT NULL, creation_date DATE NOT NULL);
 CREATE TABLE t_order_item(item_id INT PRIMARY KEY, order_id INT NOT NULL, user_id INT NOT NULL, product_id INT NOT NULL, quantity INT NOT NULL, creation_date DATE NOT NULL);
@@ -38,4 +37,3 @@ CREATE TABLE t_order_federate_sharding (order_id_sharding INT NOT NULL, user_id
 CREATE TABLE t_order_item_federate_sharding (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, remarks VARCHAR(45) NULL, PRIMARY KEY (item_id));
 
 CREATE INDEX order_index_t_order ON t_order (order_id);
-CREATE TABLE t_single_table_integer (id INT PRIMARY KEY, col_bigint BIGINT NOT NULL, col_int INT NOT NULL, col_mediumint INT4 NOT NULL, col_smallint SMALLINT NOT NULL, col_tinyint INT2 NOT NULL);