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 2021/02/22 02:55:32 UTC
[shardingsphere] branch master updated: add it of Encryption (#9452)
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 8786d87 add it of Encryption (#9452)
8786d87 is described below
commit 8786d8789cd7f141317560c060fcc05ce22c8ce7
Author: Jieker <ji...@163.com>
AuthorDate: Mon Feb 22 10:55:00 2021 +0800
add it of Encryption (#9452)
* add encrypt cases of t_user
* add config of t_user
* dml fixed
* dal fixed
---
.../mysql}/show_databases.xml | 0
.../insert_multiple_values_for_order_1_2.xml | 66 +++++++++++++
.../dataset/db/select_encrypt.xml} | 8 +-
.../cases/dql/dataset/db/select_join_encrypt.xml | 44 +++++++++
.../dbtbl_with_replica_query/select_encrypt.xml} | 8 +-
.../select_join_encrypt.xml | 108 +++++++++++++++++++++
.../dataset/replica_query/select_encrypt.xml} | 8 +-
.../dataset/replica_query/select_join_encrypt.xml | 44 +++++++++
.../dataset/tbl/select_encrypt.xml} | 8 +-
.../cases/dql/dataset/tbl/select_join_encrypt.xml | 68 +++++++++++++
.../cases/dql/dql-integration-test-cases.xml | 9 ++
.../resources/docker/db/proxy/conf/config-db.yaml | 1 +
.../conf/config-dbtbl-with-replica-query.yaml | 1 +
.../proxy/conf/config-replica-query.yaml | 7 +-
.../docker/tbl/proxy/conf/config-tbl.yaml | 1 +
.../src/test/resources/env/db/dataset.xml | 44 +++++++++
.../src/test/resources/env/db/init-sql/h2/init.sql | 3 +
.../test/resources/env/db/init-sql/mysql/init.sql | 20 ++++
.../test/resources/env/db/init-sql/oracle/init.sql | 20 ++++
.../resources/env/db/init-sql/postgresql/init.sql | 2 +
.../resources/env/db/init-sql/sqlserver/init.sql | 20 ++++
.../src/test/resources/env/db/rules.yaml | 1 +
.../env/dbtbl_with_replica_query/dataset.xml | 84 ++++++++++++++++
.../dbtbl_with_replica_query/init-sql/h2/init.sql | 3 +
.../init-sql/mysql/init.sql | 40 ++++++++
.../init-sql/oracle/init.sql | 40 ++++++++
.../init-sql/postgresql/init.sql | 2 +
.../init-sql/sqlserver/init.sql | 40 ++++++++
.../env/dbtbl_with_replica_query/rules.yaml | 1 +
.../test/resources/env/replica_query/dataset.xml | 16 +++
.../env/replica_query/init-sql/h2/init.sql | 3 +
.../env/replica_query/init-sql/mysql/init.sql | 6 ++
.../env/replica_query/init-sql/oracle/init.sql | 6 ++
.../env/replica_query/init-sql/postgresql/init.sql | 2 +
.../env/replica_query/init-sql/sqlserver/init.sql | 6 ++
.../test/resources/env/replica_query/rules.yaml | 1 +
.../src/test/resources/env/tbl/dataset.xml | 8 ++
.../test/resources/env/tbl/init-sql/h2/init.sql | 4 +
.../test/resources/env/tbl/init-sql/mysql/init.sql | 3 +
.../resources/env/tbl/init-sql/oracle/init.sql | 3 +
.../resources/env/tbl/init-sql/postgresql/init.sql | 3 +
.../resources/env/tbl/init-sql/sqlserver/init.sql | 3 +
.../src/test/resources/env/tbl/rules.yaml | 1 +
43 files changed, 755 insertions(+), 11 deletions(-)
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt/mysql/show_databases.xml
similarity index 100%
copy from shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
copy to shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt/mysql/show_databases.xml
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_multiple_values_for_order_1_2.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_multiple_values_for_order_1_2.xml
new file mode 100644
index 0000000..6130f9d
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_multiple_values_for_order_1_2.xml
@@ -0,0 +1,66 @@
+<!--
+ ~ 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.
+ -->
+
+<dataset update-count="2">
+ <metadata data-nodes="encrypt.t_order">
+ <column name="order_id" type="numeric" />
+ <column name="user_id" type="numeric" />
+ <column name="status" type="varchar" />
+ </metadata>
+ <row data-node="encrypt.t_order" values="1, 1, init" />
+ <row data-node="encrypt.t_order" values="2, 2, init" />
+ <row data-node="encrypt.t_order" values="1000, 10, init" />
+ <row data-node="encrypt.t_order" values="1001, 10, init" />
+ <row data-node="encrypt.t_order" values="1100, 11, init" />
+ <row data-node="encrypt.t_order" values="1101, 11, init" />
+ <row data-node="encrypt.t_order" values="1200, 12, init" />
+ <row data-node="encrypt.t_order" values="1201, 12, init" />
+ <row data-node="encrypt.t_order" values="1300, 13, init" />
+ <row data-node="encrypt.t_order" values="1301, 13, init" />
+ <row data-node="encrypt.t_order" values="1400, 14, init" />
+ <row data-node="encrypt.t_order" values="1401, 14, init" />
+ <row data-node="encrypt.t_order" values="1500, 15, init" />
+ <row data-node="encrypt.t_order" values="1501, 15, init" />
+ <row data-node="encrypt.t_order" values="1600, 16, init" />
+ <row data-node="encrypt.t_order" values="1601, 16, init" />
+ <row data-node="encrypt.t_order" values="1700, 17, init" />
+ <row data-node="encrypt.t_order" values="1701, 17, init" />
+ <row data-node="encrypt.t_order" values="1800, 18, init" />
+ <row data-node="encrypt.t_order" values="1801, 18, init" />
+ <row data-node="encrypt.t_order" values="1900, 19, init" />
+ <row data-node="encrypt.t_order" values="1901, 19, init" />
+ <row data-node="encrypt.t_order" values="2000, 20, init" />
+ <row data-node="encrypt.t_order" values="2001, 20, init" />
+ <row data-node="encrypt.t_order" values="2100, 21, init" />
+ <row data-node="encrypt.t_order" values="2101, 21, init" />
+ <row data-node="encrypt.t_order" values="2200, 22, init" />
+ <row data-node="encrypt.t_order" values="2201, 22, init" />
+ <row data-node="encrypt.t_order" values="2300, 23, init" />
+ <row data-node="encrypt.t_order" values="2301, 23, init" />
+ <row data-node="encrypt.t_order" values="2400, 24, init" />
+ <row data-node="encrypt.t_order" values="2401, 24, init" />
+ <row data-node="encrypt.t_order" values="2500, 25, init" />
+ <row data-node="encrypt.t_order" values="2501, 25, init" />
+ <row data-node="encrypt.t_order" values="2600, 26, init" />
+ <row data-node="encrypt.t_order" values="2601, 26, init" />
+ <row data-node="encrypt.t_order" values="2700, 27, init" />
+ <row data-node="encrypt.t_order" values="2701, 27, init" />
+ <row data-node="encrypt.t_order" values="2800, 28, init" />
+ <row data-node="encrypt.t_order" values="2801, 28, init" />
+ <row data-node="encrypt.t_order" values="2900, 29, init" />
+ <row data-node="encrypt.t_order" values="2901, 29, init" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/db/select_encrypt.xml
similarity index 82%
copy from shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
copy to shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/db/select_encrypt.xml
index 84ccc33..996c92f 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/db/select_encrypt.xml
@@ -17,7 +17,11 @@
<dataset>
<metadata>
- <column name="schema_name" />
+ <column name="user_id" />
+ <column name="pwd" />
</metadata>
- <row values="encrypt" />
+ <row values="10, abc" />
+ <row values="11, def" />
+ <row values="12, hig" />
+ <row values="13, kli" />
</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/db/select_join_encrypt.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/db/select_join_encrypt.xml
new file mode 100644
index 0000000..2db62ac
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/db/select_join_encrypt.xml
@@ -0,0 +1,44 @@
+<!--
+ ~ 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.
+ -->
+
+<dataset>
+ <metadata>
+ <column name="user_id" />
+ <column name="pwd" />
+ <column name="item_id" />
+ <column name="order_id" />
+ <column name="user_id" />
+ <column name="status" />
+ <column name="creation_date" />
+ </metadata>
+ <row values="10, abc, 100001, 1000, 10, init, 2017-08-08" />
+ <row values="10, abc, 100002, 1000, 10, init, 2017-08-08" />
+ <row values="10, abc, 100101, 1001, 10, init, 2017-08-08" />
+ <row values="10, abc, 100102, 1001, 10, init, 2017-08-08" />
+ <row values="11, def, 110001, 1100, 11, init, 2017-08-08" />
+ <row values="11, def, 110002, 1100, 11, init, 2017-08-08" />
+ <row values="11, def, 110101, 1101, 11, init, 2017-08-08" />
+ <row values="11, def, 110102, 1101, 11, init, 2017-08-08" />
+ <row values="12, hig, 120001, 1200, 12, init, 2017-08-08" />
+ <row values="12, hig, 120002, 1200, 12, init, 2017-08-08" />
+ <row values="12, hig, 120101, 1201, 12, init, 2017-08-08" />
+ <row values="12, hig, 120102, 1201, 12, init, 2017-08-08" />
+ <row values="13, kli, 130001, 1300, 13, init, 2017-08-08" />
+ <row values="13, kli, 130002, 1300, 13, init, 2017-08-08" />
+ <row values="13, kli, 130101, 1301, 13, init, 2017-08-08" />
+ <row values="13, kli, 130102, 1301, 13, init, 2017-08-08" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/dbtbl_with_replica_query/select_encrypt.xml
similarity index 82%
copy from shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
copy to shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/dbtbl_with_replica_query/select_encrypt.xml
index 84ccc33..996c92f 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/dbtbl_with_replica_query/select_encrypt.xml
@@ -17,7 +17,11 @@
<dataset>
<metadata>
- <column name="schema_name" />
+ <column name="user_id" />
+ <column name="pwd" />
</metadata>
- <row values="encrypt" />
+ <row values="10, abc" />
+ <row values="11, def" />
+ <row values="12, hig" />
+ <row values="13, kli" />
</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/dbtbl_with_replica_query/select_join_encrypt.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/dbtbl_with_replica_query/select_join_encrypt.xml
new file mode 100644
index 0000000..f3ce1f1
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/dbtbl_with_replica_query/select_join_encrypt.xml
@@ -0,0 +1,108 @@
+<!--
+ ~ 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.
+ -->
+
+<dataset>
+ <metadata>
+ <column name="user_id" />
+ <column name="pwd" />
+ <column name="item_id" />
+ <column name="order_id" />
+ <column name="user_id" />
+ <column name="status" />
+ <column name="creation_date" />
+ </metadata>
+ <row values="10, abc, 100000, 1000, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100001, 1000, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100100, 1001, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100101, 1001, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100200, 1002, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100201, 1002, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100300, 1003, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100301, 1003, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100400, 1004, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100401, 1004, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100500, 1005, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100501, 1005, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100600, 1006, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100601, 1006, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100700, 1007, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100701, 1007, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100800, 1008, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100801, 1008, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100900, 1009, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100901, 1009, 10, init_replica, 2017-08-08" />
+ <row values="11, def, 110000, 1100, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110001, 1100, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110100, 1101, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110101, 1101, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110200, 1102, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110201, 1102, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110300, 1103, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110301, 1103, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110400, 1104, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110401, 1104, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110500, 1105, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110501, 1105, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110600, 1106, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110601, 1106, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110700, 1107, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110701, 1107, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110800, 1108, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110801, 1108, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110900, 1109, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110901, 1109, 11, init_replica, 2017-08-08" />
+ <row values="12, hig, 120000, 1200, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120001, 1200, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120100, 1201, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120101, 1201, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120200, 1202, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120201, 1202, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120300, 1203, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120301, 1203, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120400, 1204, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120401, 1204, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120500, 1205, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120501, 1205, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120600, 1206, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120601, 1206, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120700, 1207, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120701, 1207, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120800, 1208, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120801, 1208, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120900, 1209, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120901, 1209, 12, init_replica, 2017-08-08" />
+ <row values="13, kli, 130000, 1300, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130001, 1300, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130100, 1301, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130101, 1301, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130200, 1302, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130201, 1302, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130300, 1303, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130301, 1303, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130400, 1304, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130401, 1304, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130500, 1305, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130501, 1305, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130600, 1306, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130601, 1306, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130700, 1307, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130701, 1307, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130800, 1308, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130801, 1308, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130900, 1309, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130901, 1309, 13, init_replica, 2017-08-08" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/replica_query/select_encrypt.xml
similarity index 82%
copy from shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
copy to shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/replica_query/select_encrypt.xml
index 84ccc33..996c92f 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/replica_query/select_encrypt.xml
@@ -17,7 +17,11 @@
<dataset>
<metadata>
- <column name="schema_name" />
+ <column name="user_id" />
+ <column name="pwd" />
</metadata>
- <row values="encrypt" />
+ <row values="10, abc" />
+ <row values="11, def" />
+ <row values="12, hig" />
+ <row values="13, kli" />
</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/replica_query/select_join_encrypt.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/replica_query/select_join_encrypt.xml
new file mode 100644
index 0000000..8e507b6
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/replica_query/select_join_encrypt.xml
@@ -0,0 +1,44 @@
+<!--
+ ~ 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.
+ -->
+
+<dataset>
+ <metadata>
+ <column name="user_id" />
+ <column name="pwd" />
+ <column name="item_id" />
+ <column name="order_id" />
+ <column name="user_id" />
+ <column name="status" />
+ <column name="creation_date" />
+ </metadata>
+ <row values="10, abc, 100001, 1000, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100002, 1000, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100101, 1001, 10, init_replica, 2017-08-08" />
+ <row values="10, abc, 100102, 1001, 10, init_replica, 2017-08-08" />
+ <row values="11, def, 110001, 1100, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110002, 1100, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110101, 1101, 11, init_replica, 2017-08-08" />
+ <row values="11, def, 110102, 1101, 11, init_replica, 2017-08-08" />
+ <row values="12, hig, 120001, 1200, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120002, 1200, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120101, 1201, 12, init_replica, 2017-08-08" />
+ <row values="12, hig, 120102, 1201, 12, init_replica, 2017-08-08" />
+ <row values="13, kli, 130001, 1300, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130002, 1300, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130101, 1301, 13, init_replica, 2017-08-08" />
+ <row values="13, kli, 130102, 1301, 13, init_replica, 2017-08-08" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/tbl/select_encrypt.xml
similarity index 82%
rename from shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
rename to shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/tbl/select_encrypt.xml
index 84ccc33..996c92f 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dal/dataset/encrypt.mysql/show_databases.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/tbl/select_encrypt.xml
@@ -17,7 +17,11 @@
<dataset>
<metadata>
- <column name="schema_name" />
+ <column name="user_id" />
+ <column name="pwd" />
</metadata>
- <row values="encrypt" />
+ <row values="10, abc" />
+ <row values="11, def" />
+ <row values="12, hig" />
+ <row values="13, kli" />
</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/tbl/select_join_encrypt.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/tbl/select_join_encrypt.xml
new file mode 100644
index 0000000..c0bd9ca
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dataset/tbl/select_join_encrypt.xml
@@ -0,0 +1,68 @@
+<!--
+ ~ 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.
+ -->
+
+<dataset>
+ <metadata>
+ <column name="user_id" />
+ <column name="pwd" />
+ <column name="item_id" />
+ <column name="order_id" />
+ <column name="user_id" />
+ <column name="status" />
+ <column name="creation_date" />
+ </metadata>
+ <row values="10, abc, 100000, 1000, 10, init, 2017-08-08" />
+ <row values="10, abc, 100001, 1000, 10, init, 2017-08-08" />
+ <row values="11, def, 110000, 1100, 11, init, 2017-08-18" />
+ <row values="11, def, 110001, 1100, 11, init, 2017-08-18" />
+ <row values="10, abc, 100100, 1001, 10, init, 2017-08-08" />
+ <row values="10, abc, 100101, 1001, 10, init, 2017-08-08" />
+ <row values="11, def, 110100, 1101, 11, init, 2017-08-18" />
+ <row values="11, def, 110101, 1101, 11, init, 2017-08-18" />
+ <row values="10, abc, 100200, 1002, 10, init, 2017-08-08" />
+ <row values="10, abc, 100201, 1002, 10, init, 2017-08-08" />
+ <row values="11, def, 110200, 1102, 11, init, 2017-08-18" />
+ <row values="11, def, 110201, 1102, 11, init, 2017-08-18" />
+ <row values="10, abc, 100300, 1003, 10, init, 2017-08-08" />
+ <row values="10, abc, 100301, 1003, 10, init, 2017-08-08" />
+ <row values="11, def, 110300, 1103, 11, init, 2017-08-18" />
+ <row values="11, def, 110301, 1103, 11, init, 2017-08-18" />
+ <row values="10, abc, 100400, 1004, 10, init, 2017-08-08" />
+ <row values="10, abc, 100401, 1004, 10, init, 2017-08-08" />
+ <row values="11, def, 110400, 1104, 11, init, 2017-08-18" />
+ <row values="11, def, 110401, 1104, 11, init, 2017-08-18" />
+ <row values="10, abc, 100500, 1005, 10, init, 2017-08-09" />
+ <row values="10, abc, 100501, 1005, 10, init, 2017-08-09" />
+ <row values="11, def, 110500, 1105, 11, init, 2017-08-19" />
+ <row values="11, def, 110501, 1105, 11, init, 2017-08-19" />
+ <row values="10, abc, 100600, 1006, 10, init, 2017-08-09" />
+ <row values="10, abc, 100601, 1006, 10, init, 2017-08-09" />
+ <row values="11, def, 110600, 1106, 11, init, 2017-08-19" />
+ <row values="11, def, 110601, 1106, 11, init, 2017-08-19" />
+ <row values="10, abc, 100700, 1007, 10, init, 2017-08-09" />
+ <row values="10, abc, 100701, 1007, 10, init, 2017-08-09" />
+ <row values="11, def, 110700, 1107, 11, init, 2017-08-19" />
+ <row values="11, def, 110701, 1107, 11, init, 2017-08-19" />
+ <row values="10, abc, 100800, 1008, 10, init, 2017-08-09" />
+ <row values="10, abc, 100801, 1008, 10, init, 2017-08-09" />
+ <row values="11, def, 110800, 1108, 11, init, 2017-08-19" />
+ <row values="11, def, 110801, 1108, 11, init, 2017-08-19" />
+ <row values="10, abc, 100900, 1009, 10, init, 2017-08-09" />
+ <row values="10, abc, 100901, 1009, 10, init, 2017-08-09" />
+ <row values="11, def, 110900, 1109, 11, init, 2017-08-19" />
+ <row values="11, def, 110901, 1109, 11, init, 2017-08-19" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dql-integration-test-cases.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dql-integration-test-cases.xml
index bb61281..9f3fa19 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dql-integration-test-cases.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dql/dql-integration-test-cases.xml
@@ -486,4 +486,13 @@
<test-case sql="SELECT * FROM t_broadcast_table">
<assertion expected-data-file="select_for_broadcast_table.xml"/>
</test-case>
+
+ <test-case sql="SELECT * FROM t_user">
+ <assertion expected-data-file="select_encrypt.xml"/>
+ </test-case>
+
+ <!--TODO fix me! about Column 'user_id' in field list is ambiguous -->
+ <!-- <test-case sql="SELECT * FROM t_user u INNER JOIN t_order_item m ON u.user_id=m.user_id">-->
+ <!-- <assertion expected-data-file="select_join_encrypt.xml"/>-->
+ <!-- </test-case>-->
</integration-test-cases>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/db/proxy/conf/config-db.yaml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/db/proxy/conf/config-db.yaml
index 4f9c14c..bd40e84 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/db/proxy/conf/config-db.yaml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/db/proxy/conf/config-db.yaml
@@ -146,6 +146,7 @@ rules:
bindingTables:
- t_order,t_order_item,t_order_details
broadcastTables:
+ - t_user
- t_broadcast_table
- t_broadcast_table_for_ddl
shardingAlgorithms:
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/dbtbl_with_replica_query/proxy/conf/config-dbtbl-with-replica-query.yaml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/dbtbl_with_replica_query/proxy/conf/config-dbtbl-with-replica-query.yaml
index 139f789..611c926 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/dbtbl_with_replica_query/proxy/conf/config-dbtbl-with-replica-query.yaml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/dbtbl_with_replica_query/proxy/conf/config-dbtbl-with-replica-query.yaml
@@ -260,6 +260,7 @@ rules:
bindingTables:
- t_order,t_order_item,t_order_details
broadcastTables:
+ - t_user
- t_broadcast_table
- t_broadcast_table_for_ddl
shardingAlgorithms:
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/replica_query/proxy/conf/config-replica-query.yaml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/replica_query/proxy/conf/config-replica-query.yaml
index b16264a..6f7b0b2 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/replica_query/proxy/conf/config-replica-query.yaml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/replica_query/proxy/conf/config-replica-query.yaml
@@ -71,10 +71,11 @@ rules:
databaseStrategy:
none:
bindingTables:
- - t_order,t_order_item,t_order_details
+ - t_order,t_order_item,t_order_details
broadcastTables:
- - t_broadcast_table
- - t_broadcast_table_for_ddl
+ - t_user
+ - t_broadcast_table
+ - t_broadcast_table_for_ddl
- !REPLICA_QUERY
dataSources:
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/tbl/proxy/conf/config-tbl.yaml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/tbl/proxy/conf/config-tbl.yaml
index 12c9198..50d3c72 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/tbl/proxy/conf/config-tbl.yaml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/docker/tbl/proxy/conf/config-tbl.yaml
@@ -56,6 +56,7 @@ rules:
bindingTables:
- t_order,t_order_item,t_order_details
broadcastTables:
+ - t_user
- t_broadcast_table
- t_broadcast_table_for_ddl
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/dataset.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/dataset.xml
index 65b57f0..6dea560 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/dataset.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/dataset.xml
@@ -32,6 +32,50 @@
<column name="id" type="numeric" />
<column name="status" type="varchar" />
</metadata>
+ <metadata data-nodes="db_${0..9}.t_user">
+ <column name="user_id" type="numeric" />
+ <column name="pwd" type="varchar" />
+ </metadata>
+ <row data-node="db_0.t_user" values="10, abc" />
+ <row data-node="db_0.t_user" values="11, def" />
+ <row data-node="db_0.t_user" values="12, hig" />
+ <row data-node="db_0.t_user" values="13, kli" />
+ <row data-node="db_1.t_user" values="10, abc" />
+ <row data-node="db_1.t_user" values="11, def" />
+ <row data-node="db_1.t_user" values="12, hig" />
+ <row data-node="db_1.t_user" values="13, kli" />
+ <row data-node="db_2.t_user" values="10, abc" />
+ <row data-node="db_2.t_user" values="11, def" />
+ <row data-node="db_2.t_user" values="12, hig" />
+ <row data-node="db_2.t_user" values="13, kli" />
+ <row data-node="db_3.t_user" values="10, abc" />
+ <row data-node="db_3.t_user" values="11, def" />
+ <row data-node="db_3.t_user" values="12, hig" />
+ <row data-node="db_3.t_user" values="13, kli" />
+ <row data-node="db_4.t_user" values="10, abc" />
+ <row data-node="db_4.t_user" values="11, def" />
+ <row data-node="db_4.t_user" values="12, hig" />
+ <row data-node="db_4.t_user" values="13, kli" />
+ <row data-node="db_5.t_user" values="10, abc" />
+ <row data-node="db_5.t_user" values="11, def" />
+ <row data-node="db_5.t_user" values="12, hig" />
+ <row data-node="db_5.t_user" values="13, kli" />
+ <row data-node="db_6.t_user" values="10, abc" />
+ <row data-node="db_6.t_user" values="11, def" />
+ <row data-node="db_6.t_user" values="12, hig" />
+ <row data-node="db_6.t_user" values="13, kli" />
+ <row data-node="db_7.t_user" values="10, abc" />
+ <row data-node="db_7.t_user" values="11, def" />
+ <row data-node="db_7.t_user" values="12, hig" />
+ <row data-node="db_7.t_user" values="13, kli" />
+ <row data-node="db_8.t_user" values="10, abc" />
+ <row data-node="db_8.t_user" values="11, def" />
+ <row data-node="db_8.t_user" values="12, hig" />
+ <row data-node="db_8.t_user" values="13, kli" />
+ <row data-node="db_9.t_user" values="10, abc" />
+ <row data-node="db_9.t_user" values="11, def" />
+ <row data-node="db_9.t_user" values="12, hig" />
+ <row data-node="db_9.t_user" values="13, kli" />
<row data-node="db_0.t_order" values="1000, 10, init" />
<row data-node="db_0.t_order" values="1001, 10, init" />
<row data-node="db_0.t_order" values="2000, 20, init" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/h2/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/h2/init.sql
index 0fd19c9..52df056 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/h2/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/h2/init.sql
@@ -18,8 +18,11 @@
DROP TABLE IF EXISTS t_order;
DROP TABLE IF EXISTS t_order_item;
DROP TABLE IF EXISTS t_broadcast_table;
+DROP TABLE IF EXISTS t_user;
+CREATE TABLE t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON t_user (user_id);
CREATE INDEX order_index_t_order ON t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/mysql/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/mysql/init.sql
index 989ea86..3588f1e 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/mysql/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/mysql/init.sql
@@ -43,52 +43,72 @@ CREATE DATABASE db_7;
CREATE DATABASE db_8;
CREATE DATABASE db_9;
+CREATE TABLE db_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_0.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_0.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_0.t_user (user_id);
CREATE INDEX order_index_t_order ON db_0.t_order (order_id);
+CREATE TABLE db_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_1.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_1.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_1.t_user (user_id);
CREATE INDEX order_index_t_order ON db_1.t_order (order_id);
+CREATE TABLE db_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_2.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_2.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_2.t_user (user_id);
CREATE INDEX order_index_t_order ON db_2.t_order (order_id);
+CREATE TABLE db_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_3.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_3.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_3.t_user (user_id);
CREATE INDEX order_index_t_order ON db_3.t_order (order_id);
+CREATE TABLE db_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_4.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_4.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_4.t_user (user_id);
CREATE INDEX order_index_t_order ON db_4.t_order (order_id);
+CREATE TABLE db_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_5.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_5.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_5.t_user (user_id);
CREATE INDEX order_index_t_order ON db_5.t_order (order_id);
+CREATE TABLE db_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_6.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_6.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_6.t_user (user_id);
CREATE INDEX order_index_t_order ON db_6.t_order (order_id);
+CREATE TABLE db_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_7.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_7.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_7.t_user (user_id);
CREATE INDEX order_index_t_order ON db_7.t_order (order_id);
+CREATE TABLE db_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_8.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_8.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_8.t_user (user_id);
CREATE INDEX order_index_t_order ON db_8.t_order (order_id);
+CREATE TABLE db_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_9.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_9.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_9.t_user (user_id);
CREATE INDEX order_index_t_order ON db_9.t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/oracle/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/oracle/init.sql
index f4a7468..0abe690 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/oracle/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/oracle/init.sql
@@ -40,52 +40,72 @@ CREATE SCHEMA db_7;
CREATE SCHEMA db_8;
CREATE SCHEMA db_9;
+CREATE TABLE db_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_0.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_0.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_0.t_user (user_id);
CREATE INDEX order_index_t_order ON db_0.t_order (order_id);
+CREATE TABLE db_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_1.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_1.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_1.t_user (user_id);
CREATE INDEX order_index_t_order ON db_1.t_order (order_id);
+CREATE TABLE db_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_2.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_2.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_2.t_user (user_id);
CREATE INDEX order_index_t_order ON db_2.t_order (order_id);
+CREATE TABLE db_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_3.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_3.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_3.t_user (user_id);
CREATE INDEX order_index_t_order ON db_3.t_order (order_id);
+CREATE TABLE db_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_4.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_4.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_4.t_user (user_id);
CREATE INDEX order_index_t_order ON db_4.t_order (order_id);
+CREATE TABLE db_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_5.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_5.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_5.t_user (user_id);
CREATE INDEX order_index_t_order ON db_5.t_order (order_id);
+CREATE TABLE db_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_6.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_6.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_6.t_user (user_id);
CREATE INDEX order_index_t_order ON db_6.t_order (order_id);
+CREATE TABLE db_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_7.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_7.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_7.t_user (user_id);
CREATE INDEX order_index_t_order ON db_7.t_order (order_id);
+CREATE TABLE db_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_8.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_8.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_8.t_user (user_id);
CREATE INDEX order_index_t_order ON db_8.t_order (order_id);
+CREATE TABLE db_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_9.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_9.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_9.t_user (user_id);
CREATE INDEX order_index_t_order ON db_9.t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/postgresql/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/postgresql/init.sql
index d639b18..9d0b608 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/postgresql/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/postgresql/init.sql
@@ -15,7 +15,9 @@
-- limitations under the License.
--
+CREATE TABLE t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON t_user (user_id);
CREATE INDEX order_index_t_order ON t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/sqlserver/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/sqlserver/init.sql
index 83ed233..be5308e 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/sqlserver/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init-sql/sqlserver/init.sql
@@ -40,52 +40,72 @@ CREATE DATABASE db_7;
CREATE DATABASE db_8;
CREATE DATABASE db_9;
+CREATE TABLE db_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_0.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_0.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_0.t_user (user_id);
CREATE INDEX order_index_t_order ON db_0.t_order (order_id);
+CREATE TABLE db_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_1.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_1.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_1.t_user (user_id);
CREATE INDEX order_index_t_order ON db_1.t_order (order_id);
+CREATE TABLE db_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_2.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_2.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_2.t_user (user_id);
CREATE INDEX order_index_t_order ON db_2.t_order (order_id);
+CREATE TABLE db_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_3.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_3.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_3.t_user (user_id);
CREATE INDEX order_index_t_order ON db_3.t_order (order_id);
+CREATE TABLE db_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_4.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_4.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_4.t_user (user_id);
CREATE INDEX order_index_t_order ON db_4.t_order (order_id);
+CREATE TABLE db_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_5.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_5.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_5.t_user (user_id);
CREATE INDEX order_index_t_order ON db_5.t_order (order_id);
+CREATE TABLE db_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_6.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_6.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_6.t_user (user_id);
CREATE INDEX order_index_t_order ON db_6.t_order (order_id);
+CREATE TABLE db_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_7.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_7.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_7.t_user (user_id);
CREATE INDEX order_index_t_order ON db_7.t_order (order_id);
+CREATE TABLE db_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_8.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_8.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_8.t_user (user_id);
CREATE INDEX order_index_t_order ON db_8.t_order (order_id);
+CREATE TABLE db_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE db_9.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE db_9.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE db_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON db_9.t_user (user_id);
CREATE INDEX order_index_t_order ON db_9.t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/rules.yaml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/rules.yaml
index d8b5a09..7e207f0 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/rules.yaml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/rules.yaml
@@ -42,6 +42,7 @@ rules:
bindingTables:
- t_order,t_order_item,t_order_details
broadcastTables:
+ - t_user
- t_broadcast_table
- t_broadcast_table_for_ddl
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/dataset.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/dataset.xml
index b72d2c8..286b7e9 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/dataset.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/dataset.xml
@@ -32,6 +32,90 @@
<column name="id" type="numeric" />
<column name="status" type="varchar" />
</metadata>
+ <metadata data-nodes="primary_ds_${0..9}.t_user,replica_ds_${0..9}.t_user">
+ <column name="user_id" type="numeric" />
+ <column name="pwd" type="varchar" />
+ </metadata>
+ <row data-node="primary_ds_0.t_user" values="10, abc" />
+ <row data-node="primary_ds_0.t_user" values="11, def" />
+ <row data-node="primary_ds_0.t_user" values="12, hig" />
+ <row data-node="primary_ds_0.t_user" values="13, kli" />
+ <row data-node="primary_ds_1.t_user" values="10, abc" />
+ <row data-node="primary_ds_1.t_user" values="11, def" />
+ <row data-node="primary_ds_1.t_user" values="12, hig" />
+ <row data-node="primary_ds_1.t_user" values="13, kli" />
+ <row data-node="primary_ds_2.t_user" values="10, abc" />
+ <row data-node="primary_ds_2.t_user" values="11, def" />
+ <row data-node="primary_ds_2.t_user" values="12, hig" />
+ <row data-node="primary_ds_2.t_user" values="13, kli" />
+ <row data-node="primary_ds_3.t_user" values="10, abc" />
+ <row data-node="primary_ds_3.t_user" values="11, def" />
+ <row data-node="primary_ds_3.t_user" values="12, hig" />
+ <row data-node="primary_ds_3.t_user" values="13, kli" />
+ <row data-node="primary_ds_4.t_user" values="10, abc" />
+ <row data-node="primary_ds_4.t_user" values="11, def" />
+ <row data-node="primary_ds_4.t_user" values="12, hig" />
+ <row data-node="primary_ds_4.t_user" values="13, kli" />
+ <row data-node="primary_ds_5.t_user" values="10, abc" />
+ <row data-node="primary_ds_5.t_user" values="11, def" />
+ <row data-node="primary_ds_5.t_user" values="12, hig" />
+ <row data-node="primary_ds_5.t_user" values="13, kli" />
+ <row data-node="primary_ds_6.t_user" values="10, abc" />
+ <row data-node="primary_ds_6.t_user" values="11, def" />
+ <row data-node="primary_ds_6.t_user" values="12, hig" />
+ <row data-node="primary_ds_6.t_user" values="13, kli" />
+ <row data-node="primary_ds_7.t_user" values="10, abc" />
+ <row data-node="primary_ds_7.t_user" values="11, def" />
+ <row data-node="primary_ds_7.t_user" values="12, hig" />
+ <row data-node="primary_ds_7.t_user" values="13, kli" />
+ <row data-node="primary_ds_8.t_user" values="10, abc" />
+ <row data-node="primary_ds_8.t_user" values="11, def" />
+ <row data-node="primary_ds_8.t_user" values="12, hig" />
+ <row data-node="primary_ds_8.t_user" values="13, kli" />
+ <row data-node="primary_ds_9.t_user" values="10, abc" />
+ <row data-node="primary_ds_9.t_user" values="11, def" />
+ <row data-node="primary_ds_9.t_user" values="12, hig" />
+ <row data-node="primary_ds_9.t_user" values="13, kli" />
+ <row data-node="replica_ds_0.t_user" values="10, abc" />
+ <row data-node="replica_ds_0.t_user" values="11, def" />
+ <row data-node="replica_ds_0.t_user" values="12, hig" />
+ <row data-node="replica_ds_0.t_user" values="13, kli" />
+ <row data-node="replica_ds_1.t_user" values="10, abc" />
+ <row data-node="replica_ds_1.t_user" values="11, def" />
+ <row data-node="replica_ds_1.t_user" values="12, hig" />
+ <row data-node="replica_ds_1.t_user" values="13, kli" />
+ <row data-node="replica_ds_2.t_user" values="10, abc" />
+ <row data-node="replica_ds_2.t_user" values="11, def" />
+ <row data-node="replica_ds_2.t_user" values="12, hig" />
+ <row data-node="replica_ds_2.t_user" values="13, kli" />
+ <row data-node="replica_ds_3.t_user" values="10, abc" />
+ <row data-node="replica_ds_3.t_user" values="11, def" />
+ <row data-node="replica_ds_3.t_user" values="12, hig" />
+ <row data-node="replica_ds_3.t_user" values="13, kli" />
+ <row data-node="replica_ds_4.t_user" values="10, abc" />
+ <row data-node="replica_ds_4.t_user" values="11, def" />
+ <row data-node="replica_ds_4.t_user" values="12, hig" />
+ <row data-node="replica_ds_4.t_user" values="13, kli" />
+ <row data-node="replica_ds_5.t_user" values="10, abc" />
+ <row data-node="replica_ds_5.t_user" values="11, def" />
+ <row data-node="replica_ds_5.t_user" values="12, hig" />
+ <row data-node="replica_ds_5.t_user" values="13, kli" />
+ <row data-node="replica_ds_6.t_user" values="10, abc" />
+ <row data-node="replica_ds_6.t_user" values="11, def" />
+ <row data-node="replica_ds_6.t_user" values="12, hig" />
+ <row data-node="replica_ds_6.t_user" values="13, kli" />
+ <row data-node="replica_ds_7.t_user" values="10, abc" />
+ <row data-node="replica_ds_7.t_user" values="11, def" />
+ <row data-node="replica_ds_7.t_user" values="12, hig" />
+ <row data-node="replica_ds_7.t_user" values="13, kli" />
+ <row data-node="replica_ds_8.t_user" values="10, abc" />
+ <row data-node="replica_ds_8.t_user" values="11, def" />
+ <row data-node="replica_ds_8.t_user" values="12, hig" />
+ <row data-node="replica_ds_8.t_user" values="13, kli" />
+ <row data-node="replica_ds_9.t_user" values="10, abc" />
+ <row data-node="replica_ds_9.t_user" values="11, def" />
+ <row data-node="replica_ds_9.t_user" values="12, hig" />
+ <row data-node="replica_ds_9.t_user" values="13, kli" />
<row data-node="primary_ds_0.t_order_0" values="1000, 10, init" />
<row data-node="primary_ds_0.t_order_1" values="1001, 10, init" />
<row data-node="primary_ds_0.t_order_2" values="1002, 10, init" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/h2/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/h2/init.sql
index 63f093f..e886ad1 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/h2/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/h2/init.sql
@@ -36,7 +36,9 @@ DROP TABLE IF EXISTS t_order_item_8;
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_user;
+CREATE TABLE t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -58,6 +60,7 @@ CREATE TABLE t_order_item_8 (item_id INT NOT NULL, order_id INT NOT NULL, user_i
CREATE TABLE t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON t_user (user_id);
CREATE INDEX order_index_t_order_0 ON t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON t_order_2 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/mysql/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/mysql/init.sql
index 14ae2ba..d68faeb 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/mysql/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/mysql/init.sql
@@ -63,6 +63,7 @@ CREATE DATABASE replica_ds_7;
CREATE DATABASE replica_ds_8;
CREATE DATABASE replica_ds_9;
+CREATE TABLE primary_ds_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_0.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_0.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_0.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -84,6 +85,7 @@ CREATE TABLE primary_ds_0.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_0.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_0.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_0.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_0.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_0.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_0.t_order_2 (order_id);
@@ -95,6 +97,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_0.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_0.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_0.t_order_9 (order_id);
+CREATE TABLE primary_ds_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_1.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_1.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_1.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -116,6 +119,7 @@ CREATE TABLE primary_ds_1.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_1.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_1.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_1.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_1.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_1.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_1.t_order_2 (order_id);
@@ -127,6 +131,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_1.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_1.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_1.t_order_9 (order_id);
+CREATE TABLE primary_ds_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_2.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_2.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_2.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -148,6 +153,7 @@ CREATE TABLE primary_ds_2.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_2.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_2.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_2.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_2.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_2.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_2.t_order_2 (order_id);
@@ -159,6 +165,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_2.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_2.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_2.t_order_9 (order_id);
+CREATE TABLE primary_ds_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_3.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_3.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_3.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -180,6 +187,7 @@ CREATE TABLE primary_ds_3.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_3.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_3.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_3.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_3.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_3.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_3.t_order_2 (order_id);
@@ -191,6 +199,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_3.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_3.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_3.t_order_9 (order_id);
+CREATE TABLE primary_ds_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_4.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_4.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_4.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -212,6 +221,7 @@ CREATE TABLE primary_ds_4.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_4.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_4.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_4.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_4.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_4.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_4.t_order_2 (order_id);
@@ -223,6 +233,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_4.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_4.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_4.t_order_9 (order_id);
+CREATE TABLE primary_ds_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_5.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_5.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_5.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -244,6 +255,7 @@ CREATE TABLE primary_ds_5.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_5.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_5.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_5.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_5.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_5.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_5.t_order_2 (order_id);
@@ -255,6 +267,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_5.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_5.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_5.t_order_9 (order_id);
+CREATE TABLE primary_ds_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_6.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_6.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_6.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -276,6 +289,7 @@ CREATE TABLE primary_ds_6.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_6.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_6.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_6.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_6.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_6.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_6.t_order_2 (order_id);
@@ -287,6 +301,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_6.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_6.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_6.t_order_9 (order_id);
+CREATE TABLE primary_ds_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_7.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_7.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_7.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -308,6 +323,7 @@ CREATE TABLE primary_ds_7.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_7.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_7.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_7.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_7.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_7.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_7.t_order_2 (order_id);
@@ -319,6 +335,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_7.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_7.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_7.t_order_9 (order_id);
+CREATE TABLE primary_ds_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_8.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_8.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_8.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -340,6 +357,7 @@ CREATE TABLE primary_ds_8.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_8.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_8.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_8.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_8.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_8.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_8.t_order_2 (order_id);
@@ -351,6 +369,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_8.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_8.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_8.t_order_9 (order_id);
+CREATE TABLE primary_ds_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_9.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_9.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_9.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -372,6 +391,7 @@ CREATE TABLE primary_ds_9.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_9.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_9.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_9.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_9.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_9.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_9.t_order_2 (order_id);
@@ -383,6 +403,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_9.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_9.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_9.t_order_9 (order_id);
+CREATE TABLE replica_ds_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_0.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_0.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_0.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -404,6 +425,7 @@ CREATE TABLE replica_ds_0.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_0.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_0.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_0.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_0.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_0.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_0.t_order_2 (order_id);
@@ -415,6 +437,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_0.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_0.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_0.t_order_9 (order_id);
+CREATE TABLE replica_ds_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_1.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_1.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_1.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -436,6 +459,7 @@ CREATE TABLE replica_ds_1.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_1.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_1.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_1.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_1.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_1.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_1.t_order_2 (order_id);
@@ -447,6 +471,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_1.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_1.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_1.t_order_9 (order_id);
+CREATE TABLE replica_ds_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_2.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_2.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_2.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -468,6 +493,7 @@ CREATE TABLE replica_ds_2.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_2.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_2.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_2.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_2.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_2.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_2.t_order_2 (order_id);
@@ -479,6 +505,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_2.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_2.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_2.t_order_9 (order_id);
+CREATE TABLE replica_ds_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_3.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_3.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_3.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -500,6 +527,7 @@ CREATE TABLE replica_ds_3.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_3.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_3.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_3.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_3.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_3.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_3.t_order_2 (order_id);
@@ -511,6 +539,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_3.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_3.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_3.t_order_9 (order_id);
+CREATE TABLE replica_ds_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_4.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_4.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_4.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -532,6 +561,7 @@ CREATE TABLE replica_ds_4.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_4.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_4.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_4.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_4.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_4.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_4.t_order_2 (order_id);
@@ -543,6 +573,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_4.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_4.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_4.t_order_9 (order_id);
+CREATE TABLE replica_ds_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_5.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_5.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_5.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -564,6 +595,7 @@ CREATE TABLE replica_ds_5.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_5.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_5.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_5.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_5.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_5.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_5.t_order_2 (order_id);
@@ -575,6 +607,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_5.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_5.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_5.t_order_9 (order_id);
+CREATE TABLE replica_ds_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_6.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_6.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_6.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -596,6 +629,7 @@ CREATE TABLE replica_ds_6.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_6.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_6.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_6.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_6.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_6.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_6.t_order_2 (order_id);
@@ -607,6 +641,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_6.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_6.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_6.t_order_9 (order_id);
+CREATE TABLE replica_ds_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_7.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_7.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_7.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -628,6 +663,7 @@ CREATE TABLE replica_ds_7.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_7.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_7.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_7.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_7.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_7.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_7.t_order_2 (order_id);
@@ -639,6 +675,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_7.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_7.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_7.t_order_9 (order_id);
+CREATE TABLE replica_ds_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_8.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_8.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_8.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -660,6 +697,7 @@ CREATE TABLE replica_ds_8.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_8.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_8.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_8.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_8.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_8.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_8.t_order_2 (order_id);
@@ -671,6 +709,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_8.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_8.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_8.t_order_9 (order_id);
+CREATE TABLE replica_ds_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_9.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_9.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_9.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -692,6 +731,7 @@ CREATE TABLE replica_ds_9.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_9.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_9.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_9.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_9.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_9.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_9.t_order_2 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/oracle/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/oracle/init.sql
index 6f3917a..a114bf4 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/oracle/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/oracle/init.sql
@@ -60,6 +60,7 @@ CREATE SCHEMA replica_ds_7;
CREATE SCHEMA replica_ds_8;
CREATE SCHEMA replica_ds_9;
+CREATE TABLE primary_ds_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_0.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_0.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_0.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -81,6 +82,7 @@ CREATE TABLE primary_ds_0.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_0.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_0.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_0.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_0.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_0.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_0.t_order_2 (order_id);
@@ -92,6 +94,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_0.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_0.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_0.t_order_9 (order_id);
+CREATE TABLE primary_ds_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_1.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_1.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_1.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -113,6 +116,7 @@ CREATE TABLE primary_ds_1.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_1.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_1.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_1.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_1.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_1.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_1.t_order_2 (order_id);
@@ -124,6 +128,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_1.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_1.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_1.t_order_9 (order_id);
+CREATE TABLE primary_ds_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_2.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_2.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_2.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -145,6 +150,7 @@ CREATE TABLE primary_ds_2.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_2.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_2.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_2.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_2.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_2.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_2.t_order_2 (order_id);
@@ -156,6 +162,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_2.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_2.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_2.t_order_9 (order_id);
+CREATE TABLE primary_ds_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_3.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_3.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_3.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -177,6 +184,7 @@ CREATE TABLE primary_ds_3.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_3.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_3.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_3.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_3.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_3.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_3.t_order_2 (order_id);
@@ -188,6 +196,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_3.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_3.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_3.t_order_9 (order_id);
+CREATE TABLE primary_ds_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_4.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_4.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_4.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -209,6 +218,7 @@ CREATE TABLE primary_ds_4.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_4.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_4.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_4.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_4.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_4.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_4.t_order_2 (order_id);
@@ -220,6 +230,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_4.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_4.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_4.t_order_9 (order_id);
+CREATE TABLE primary_ds_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_5.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_5.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_5.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -241,6 +252,7 @@ CREATE TABLE primary_ds_5.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_5.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_5.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_5.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_5.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_5.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_5.t_order_2 (order_id);
@@ -252,6 +264,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_5.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_5.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_5.t_order_9 (order_id);
+CREATE TABLE primary_ds_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_6.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_6.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_6.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -273,6 +286,7 @@ CREATE TABLE primary_ds_6.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_6.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_6.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_6.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_6.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_6.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_6.t_order_2 (order_id);
@@ -284,6 +298,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_6.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_6.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_6.t_order_9 (order_id);
+CREATE TABLE primary_ds_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_7.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_7.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_7.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -305,6 +320,7 @@ CREATE TABLE primary_ds_7.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_7.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_7.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_7.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_7.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_7.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_7.t_order_2 (order_id);
@@ -316,6 +332,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_7.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_7.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_7.t_order_9 (order_id);
+CREATE TABLE primary_ds_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_8.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_8.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_8.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -337,6 +354,7 @@ CREATE TABLE primary_ds_8.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_8.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_8.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_8.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_8.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_8.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_8.t_order_2 (order_id);
@@ -348,6 +366,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_8.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_8.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_8.t_order_9 (order_id);
+CREATE TABLE primary_ds_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_9.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_9.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_9.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -369,6 +388,7 @@ CREATE TABLE primary_ds_9.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_9.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_9.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_9.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_9.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_9.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_9.t_order_2 (order_id);
@@ -380,6 +400,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_9.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_9.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_9.t_order_9 (order_id);
+CREATE TABLE replica_ds_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_0.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_0.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_0.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -401,6 +422,7 @@ CREATE TABLE replica_ds_0.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_0.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_0.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_0.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_0.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_0.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_0.t_order_2 (order_id);
@@ -412,6 +434,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_0.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_0.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_0.t_order_9 (order_id);
+CREATE TABLE replica_ds_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_1.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_1.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_1.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -433,6 +456,7 @@ CREATE TABLE replica_ds_1.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_1.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_1.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_1.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_1.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_1.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_1.t_order_2 (order_id);
@@ -444,6 +468,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_1.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_1.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_1.t_order_9 (order_id);
+CREATE TABLE replica_ds_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_2.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_2.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_2.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -465,6 +490,7 @@ CREATE TABLE replica_ds_2.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_2.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_2.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_2.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_2.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_2.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_2.t_order_2 (order_id);
@@ -476,6 +502,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_2.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_2.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_2.t_order_9 (order_id);
+CREATE TABLE replica_ds_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_3.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_3.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_3.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -497,6 +524,7 @@ CREATE TABLE replica_ds_3.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_3.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_3.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_3.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_3.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_3.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_3.t_order_2 (order_id);
@@ -508,6 +536,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_3.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_3.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_3.t_order_9 (order_id);
+CREATE TABLE replica_ds_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_4.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_4.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_4.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -529,6 +558,7 @@ CREATE TABLE replica_ds_4.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_4.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_4.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_4.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_4.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_4.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_4.t_order_2 (order_id);
@@ -540,6 +570,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_4.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_4.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_4.t_order_9 (order_id);
+CREATE TABLE replica_ds_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_5.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_5.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_5.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -561,6 +592,7 @@ CREATE TABLE replica_ds_5.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_5.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_5.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_5.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_5.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_5.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_5.t_order_2 (order_id);
@@ -572,6 +604,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_5.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_5.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_5.t_order_9 (order_id);
+CREATE TABLE replica_ds_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_6.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_6.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_6.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -593,6 +626,7 @@ CREATE TABLE replica_ds_6.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_6.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_6.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_6.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_6.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_6.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_6.t_order_2 (order_id);
@@ -604,6 +638,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_6.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_6.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_6.t_order_9 (order_id);
+CREATE TABLE replica_ds_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_7.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_7.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_7.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -625,6 +660,7 @@ CREATE TABLE replica_ds_7.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_7.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_7.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_7.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_7.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_7.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_7.t_order_2 (order_id);
@@ -636,6 +672,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_7.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_7.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_7.t_order_9 (order_id);
+CREATE TABLE replica_ds_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_8.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_8.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_8.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -657,6 +694,7 @@ CREATE TABLE replica_ds_8.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_8.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_8.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_8.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_8.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_8.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_8.t_order_2 (order_id);
@@ -668,6 +706,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_8.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_8.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_8.t_order_9 (order_id);
+CREATE TABLE replica_ds_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_9.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_9.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_9.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -689,6 +728,7 @@ CREATE TABLE replica_ds_9.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_9.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_9.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_9.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_9.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_9.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_9.t_order_2 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/postgresql/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/postgresql/init.sql
index 2a1fa7a..19be962 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/postgresql/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/postgresql/init.sql
@@ -15,6 +15,7 @@
-- limitations under the License.
--
+CREATE TABLE t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -36,6 +37,7 @@ CREATE TABLE t_order_item_8 (item_id INT NOT NULL, order_id INT NOT NULL, user_i
CREATE TABLE t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON t_user (user_id);
CREATE INDEX order_index_t_order_0 ON t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON t_order_2 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/sqlserver/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/sqlserver/init.sql
index 48e2dd0..dac05a7 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/sqlserver/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init-sql/sqlserver/init.sql
@@ -60,6 +60,7 @@ CREATE DATABASE replica_ds_7;
CREATE DATABASE replica_ds_8;
CREATE DATABASE replica_ds_9;
+CREATE TABLE primary_ds_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_0.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_0.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_0.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -81,6 +82,7 @@ CREATE TABLE primary_ds_0.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_0.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_0.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_0.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_0.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_0.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_0.t_order_2 (order_id);
@@ -92,6 +94,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_0.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_0.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_0.t_order_9 (order_id);
+CREATE TABLE primary_ds_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_1.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_1.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_1.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -113,6 +116,7 @@ CREATE TABLE primary_ds_1.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_1.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_1.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_1.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_1.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_1.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_1.t_order_2 (order_id);
@@ -124,6 +128,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_1.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_1.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_1.t_order_9 (order_id);
+CREATE TABLE primary_ds_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_2.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_2.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_2.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -145,6 +150,7 @@ CREATE TABLE primary_ds_2.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_2.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_2.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_2.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_2.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_2.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_2.t_order_2 (order_id);
@@ -156,6 +162,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_2.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_2.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_2.t_order_9 (order_id);
+CREATE TABLE primary_ds_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_3.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_3.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_3.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -177,6 +184,7 @@ CREATE TABLE primary_ds_3.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_3.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_3.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_3.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_3.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_3.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_3.t_order_2 (order_id);
@@ -188,6 +196,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_3.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_3.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_3.t_order_9 (order_id);
+CREATE TABLE primary_ds_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_4.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_4.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_4.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -209,6 +218,7 @@ CREATE TABLE primary_ds_4.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_4.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_4.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_4.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_4.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_4.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_4.t_order_2 (order_id);
@@ -220,6 +230,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_4.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_4.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_4.t_order_9 (order_id);
+CREATE TABLE primary_ds_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_5.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_5.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_5.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -241,6 +252,7 @@ CREATE TABLE primary_ds_5.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_5.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_5.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_5.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_5.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_5.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_5.t_order_2 (order_id);
@@ -252,6 +264,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_5.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_5.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_5.t_order_9 (order_id);
+CREATE TABLE primary_ds_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_6.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_6.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_6.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -273,6 +286,7 @@ CREATE TABLE primary_ds_6.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_6.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_6.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_6.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_6.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_6.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_6.t_order_2 (order_id);
@@ -284,6 +298,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_6.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_6.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_6.t_order_9 (order_id);
+CREATE TABLE primary_ds_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_7.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_7.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_7.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -305,6 +320,7 @@ CREATE TABLE primary_ds_7.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_7.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_7.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_7.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_7.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_7.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_7.t_order_2 (order_id);
@@ -316,6 +332,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_7.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_7.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_7.t_order_9 (order_id);
+CREATE TABLE primary_ds_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_8.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_8.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_8.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -337,6 +354,7 @@ CREATE TABLE primary_ds_8.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_8.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_8.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_8.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_8.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_8.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_8.t_order_2 (order_id);
@@ -348,6 +366,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_8.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_8.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_8.t_order_9 (order_id);
+CREATE TABLE primary_ds_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds_9.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_9.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_9.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -369,6 +388,7 @@ CREATE TABLE primary_ds_9.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE primary_ds_9.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds_9.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds_9.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON primary_ds_9.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON primary_ds_9.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON primary_ds_9.t_order_2 (order_id);
@@ -380,6 +400,7 @@ CREATE INDEX order_index_t_order_7 ON primary_ds_9.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON primary_ds_9.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON primary_ds_9.t_order_9 (order_id);
+CREATE TABLE replica_ds_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_0.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_0.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_0.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -401,6 +422,7 @@ CREATE TABLE replica_ds_0.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_0.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_0.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_0.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_0.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_0.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_0.t_order_2 (order_id);
@@ -412,6 +434,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_0.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_0.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_0.t_order_9 (order_id);
+CREATE TABLE replica_ds_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_1.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_1.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_1.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -433,6 +456,7 @@ CREATE TABLE replica_ds_1.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_1.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_1.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_1.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_1.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_1.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_1.t_order_2 (order_id);
@@ -444,6 +468,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_1.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_1.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_1.t_order_9 (order_id);
+CREATE TABLE replica_ds_2.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_2.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_2.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_2.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -465,6 +490,7 @@ CREATE TABLE replica_ds_2.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_2.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_2.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_2.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_2.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_2.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_2.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_2.t_order_2 (order_id);
@@ -476,6 +502,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_2.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_2.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_2.t_order_9 (order_id);
+CREATE TABLE replica_ds_3.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_3.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_3.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_3.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -497,6 +524,7 @@ CREATE TABLE replica_ds_3.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_3.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_3.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_3.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_3.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_3.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_3.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_3.t_order_2 (order_id);
@@ -508,6 +536,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_3.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_3.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_3.t_order_9 (order_id);
+CREATE TABLE replica_ds_4.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_4.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_4.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_4.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -529,6 +558,7 @@ CREATE TABLE replica_ds_4.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_4.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_4.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_4.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_4.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_4.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_4.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_4.t_order_2 (order_id);
@@ -540,6 +570,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_4.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_4.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_4.t_order_9 (order_id);
+CREATE TABLE replica_ds_5.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_5.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_5.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_5.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -561,6 +592,7 @@ CREATE TABLE replica_ds_5.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_5.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_5.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_5.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_5.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_5.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_5.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_5.t_order_2 (order_id);
@@ -572,6 +604,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_5.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_5.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_5.t_order_9 (order_id);
+CREATE TABLE replica_ds_6.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_6.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_6.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_6.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -593,6 +626,7 @@ CREATE TABLE replica_ds_6.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_6.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_6.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_6.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_6.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_6.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_6.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_6.t_order_2 (order_id);
@@ -604,6 +638,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_6.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_6.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_6.t_order_9 (order_id);
+CREATE TABLE replica_ds_7.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_7.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_7.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_7.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -625,6 +660,7 @@ CREATE TABLE replica_ds_7.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_7.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_7.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_7.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_7.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_7.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_7.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_7.t_order_2 (order_id);
@@ -636,6 +672,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_7.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_7.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_7.t_order_9 (order_id);
+CREATE TABLE replica_ds_8.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_8.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_8.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_8.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -657,6 +694,7 @@ CREATE TABLE replica_ds_8.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_8.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_8.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_8.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_8.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_8.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_8.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_8.t_order_2 (order_id);
@@ -668,6 +706,7 @@ CREATE INDEX order_index_t_order_7 ON replica_ds_8.t_order_7 (order_id);
CREATE INDEX order_index_t_order_8 ON replica_ds_8.t_order_8 (order_id);
CREATE INDEX order_index_t_order_9 ON replica_ds_8.t_order_9 (order_id);
+CREATE TABLE replica_ds_9.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_ds_9.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_9.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_9.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
@@ -689,6 +728,7 @@ CREATE TABLE replica_ds_9.t_order_item_8 (item_id INT NOT NULL, order_id INT NOT
CREATE TABLE replica_ds_9.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_ds_9.t_order_item_9 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_ds_9.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_ds_9.t_user (user_id);
CREATE INDEX order_index_t_order_0 ON replica_ds_9.t_order_0 (order_id);
CREATE INDEX order_index_t_order_1 ON replica_ds_9.t_order_1 (order_id);
CREATE INDEX order_index_t_order_2 ON replica_ds_9.t_order_2 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/rules.yaml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/rules.yaml
index 5aad1da..2f94cfb 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/rules.yaml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/rules.yaml
@@ -56,6 +56,7 @@ rules:
bindingTables:
- t_order,t_order_item,t_order_details
broadcastTables:
+ - t_user
- t_broadcast_table
- t_broadcast_table_for_ddl
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/dataset.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/dataset.xml
index 109a0da..4d4634c 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/dataset.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/dataset.xml
@@ -32,6 +32,22 @@
<column name="id" type="numeric" />
<column name="status" type="varchar" />
</metadata>
+ <metadata data-nodes="primary_ds.t_user,replica_${0..1}.t_user">
+ <column name="user_id" type="numeric" />
+ <column name="pwd" type="varchar" />
+ </metadata>
+ <row data-node="primary_ds.t_user" values="10, abc" />
+ <row data-node="primary_ds.t_user" values="11, def" />
+ <row data-node="primary_ds.t_user" values="12, hig" />
+ <row data-node="primary_ds.t_user" values="13, kli" />
+ <row data-node="replica_0.t_user" values="10, abc" />
+ <row data-node="replica_0.t_user" values="11, def" />
+ <row data-node="replica_0.t_user" values="12, hig" />
+ <row data-node="replica_0.t_user" values="13, kli" />
+ <row data-node="replica_1.t_user" values="10, abc" />
+ <row data-node="replica_1.t_user" values="11, def" />
+ <row data-node="replica_1.t_user" values="12, hig" />
+ <row data-node="replica_1.t_user" values="13, kli" />
<row data-node="primary_ds.t_order" values="1000, 10, init" />
<row data-node="primary_ds.t_order" values="1001, 10, init" />
<row data-node="primary_ds.t_order" values="1100, 11, init" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/h2/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/h2/init.sql
index 0fd19c9..52df056 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/h2/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/h2/init.sql
@@ -18,8 +18,11 @@
DROP TABLE IF EXISTS t_order;
DROP TABLE IF EXISTS t_order_item;
DROP TABLE IF EXISTS t_broadcast_table;
+DROP TABLE IF EXISTS t_user;
+CREATE TABLE t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON t_user (user_id);
CREATE INDEX order_index_t_order ON t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/mysql/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/mysql/init.sql
index 596490e..eb254a7 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/mysql/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/mysql/init.sql
@@ -29,17 +29,23 @@ CREATE DATABASE primary_ds;
CREATE DATABASE replica_0;
CREATE DATABASE replica_1;
+CREATE TABLE primary_ds.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds.t_user (user_id);
CREATE INDEX order_index_t_order ON primary_ds.t_order (order_id);
+CREATE TABLE replica_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_0.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_0.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_0.t_user (user_id);
CREATE INDEX order_index_t_order ON replica_0.t_order (order_id);
+CREATE TABLE replica_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_1.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_1.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_1.t_user (user_id);
CREATE INDEX order_index_t_order ON replica_1.t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/oracle/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/oracle/init.sql
index 2f678eb..1345015 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/oracle/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/oracle/init.sql
@@ -26,17 +26,23 @@ CREATE SCHEMA primary_ds;
CREATE SCHEMA replica_0;
CREATE SCHEMA replica_1;
+CREATE TABLE primary_ds.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds.t_user (user_id);
CREATE INDEX order_index_t_order ON primary_ds.t_order (order_id);
+CREATE TABLE replica_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_0.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_0.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_0.t_user (user_id);
CREATE INDEX order_index_t_order ON replica_0.t_order (order_id);
+CREATE TABLE replica_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_1.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_1.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_1.t_user (user_id);
CREATE INDEX order_index_t_order ON replica_1.t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/postgresql/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/postgresql/init.sql
index d639b18..9d0b608 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/postgresql/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/postgresql/init.sql
@@ -15,7 +15,9 @@
-- limitations under the License.
--
+CREATE TABLE t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON t_user (user_id);
CREATE INDEX order_index_t_order ON t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/sqlserver/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/sqlserver/init.sql
index 6179dc6..9f20d76 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/sqlserver/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init-sql/sqlserver/init.sql
@@ -26,17 +26,23 @@ CREATE DATABASE primary_ds;
CREATE DATABASE replica_0;
CREATE DATABASE replica_1;
+CREATE TABLE primary_ds.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE primary_ds.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE primary_ds.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE primary_ds.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON primary_ds.t_user (user_id);
CREATE INDEX order_index_t_order ON primary_ds.t_order (order_id);
+CREATE TABLE replica_0.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_0.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_0.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_0.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_0.t_user (user_id);
CREATE INDEX order_index_t_order ON replica_0.t_order (order_id);
+CREATE TABLE replica_1.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
CREATE TABLE replica_1.t_order (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE replica_1.t_order_item (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE TABLE replica_1.t_broadcast_table (id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (id));
+CREATE INDEX user_index_t_user ON replica_1.t_user (user_id);
CREATE INDEX order_index_t_order ON replica_1.t_order (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/rules.yaml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/rules.yaml
index f29bb1f..258d53c 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/rules.yaml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/rules.yaml
@@ -39,6 +39,7 @@ rules:
bindingTables:
- t_order,t_order_item,t_order_details
broadcastTables:
+ - t_user
- t_broadcast_table
- t_broadcast_table_for_ddl
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/dataset.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/dataset.xml
index 071981c..09c5665 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/dataset.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/dataset.xml
@@ -32,6 +32,14 @@
<column name="id" type="numeric" />
<column name="status" type="varchar" />
</metadata>
+ <metadata data-nodes="tbl.t_user">
+ <column name="user_id" type="numeric" />
+ <column name="pwd" type="varchar" />
+ </metadata>
+ <row data-node="tbl.t_user" values="10, abc" />
+ <row data-node="tbl.t_user" values="11, def" />
+ <row data-node="tbl.t_user" values="12, hig" />
+ <row data-node="tbl.t_user" values="13, kli" />
<row data-node="tbl.t_order_0" values="1000, 10, init" />
<row data-node="tbl.t_order_1" values="1001, 10, init" />
<row data-node="tbl.t_order_2" values="1002, 10, init" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/h2/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/h2/init.sql
index 195c6a1..9e33980 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/h2/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/h2/init.sql
@@ -36,6 +36,10 @@ DROP TABLE IF EXISTS t_order_item_8;
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_user;
+
+CREATE TABLE t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
+CREATE INDEX user_index_t_user ON t_user (user_id);
CREATE TABLE t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/mysql/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/mysql/init.sql
index 86c04c8..d67bce3 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/mysql/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/mysql/init.sql
@@ -25,6 +25,9 @@ DROP DATABASE IF EXISTS tbl;
CREATE DATABASE tbl;
+CREATE TABLE tbl.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
+CREATE INDEX user_index_t_user ON tbl.t_user (user_id);
+
CREATE TABLE tbl.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE INDEX order_index_t_order_0 ON tbl.t_order_0 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/oracle/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/oracle/init.sql
index 2382bb1..b95d962 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/oracle/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/oracle/init.sql
@@ -22,6 +22,9 @@ DROP SCHEMA tbl;
CREATE SCHEMA tbl;
+CREATE TABLE tbl.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
+CREATE INDEX user_index_t_user ON tbl.t_user (user_id);
+
CREATE TABLE tbl.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE INDEX order_index_t_order_0 ON tbl.t_order_0 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/postgresql/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/postgresql/init.sql
index 7b5dee1..71bcd0b 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/postgresql/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/postgresql/init.sql
@@ -15,6 +15,9 @@
-- limitations under the License.
--
+CREATE TABLE t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
+CREATE INDEX user_index_t_user ON t_user (user_id);
+
CREATE TABLE t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE INDEX order_index_t_order_0 ON t_order_0 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/sqlserver/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/sqlserver/init.sql
index 9b5397d..8557106 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/sqlserver/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init-sql/sqlserver/init.sql
@@ -22,6 +22,9 @@ DROP DATABASE IF EXISTS tbl;
CREATE DATABASE tbl;
+CREATE TABLE tbl.t_user (user_id INT NOT NULL, pwd VARCHAR(45) NULL, PRIMARY KEY (user_id));
+CREATE INDEX user_index_t_user ON tbl.t_user (user_id);
+
CREATE TABLE tbl.t_order_0 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_0 (item_id INT NOT NULL, order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, creation_date DATE, PRIMARY KEY (item_id));
CREATE INDEX order_index_t_order_0 ON tbl.t_order_0 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/rules.yaml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/rules.yaml
index 86336d2..eff7ef7 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/rules.yaml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/rules.yaml
@@ -42,6 +42,7 @@ rules:
bindingTables:
- t_order,t_order_item,t_order_details
broadcastTables:
+ - t_user
- t_broadcast_table
- t_broadcast_table_for_ddl