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/01/11 02:38:23 UTC
[shardingsphere] branch master updated: Skip SQL init if using
docker (#8968)
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 af82b01 Skip SQL init if using docker (#8968)
af82b01 is described below
commit af82b01e532958df00be62d2981b9a0bb4ef3cb3
Author: Liang Zhang <te...@163.com>
AuthorDate: Mon Jan 11 10:38:04 2021 +0800
Skip SQL init if using docker (#8968)
* Avoid create env if using docker
* Add isEnvironmentPrepared
* Add index to init.sql
* Fix it.yaml's port
* Fix init sql
---
.github/workflows/it.yml | 14 +-
.../shardingsphere-integration-test-suite/pom.xml | 3 +
.../integration/env/IntegrateTestEnvironment.java | 3 +
.../env/schema/SchemaEnvironmentManager.java | 12 ++
.../cases/dml/dml-integrate-test-cases.xml | 6 +-
.../src/test/resources/env/db/init.sql | 10 ++
.../env/dbtbl_with_replica_query/init.sql | 200 +++++++++++++++++++++
.../src/test/resources/env/env.properties | 2 +
.../src/test/resources/env/replica_query/init.sql | 3 +
.../src/test/resources/env/tbl/init.sql | 10 ++
10 files changed, 253 insertions(+), 10 deletions(-)
diff --git a/.github/workflows/it.yml b/.github/workflows/it.yml
index 44a89cd..46c2e9c 100644
--- a/.github/workflows/it.yml
+++ b/.github/workflows/it.yml
@@ -64,7 +64,7 @@ jobs:
- name: Build Project
run: ./mvnw -B clean install -Dmaven.javadoc.skip=true -Drat.skip=true -Djacoco.skip=true -DskipITs
- name: Run Integration Test
- run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=proxy -Dit.scenarios=tbl -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33060
+ run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=proxy -Dit.scenarios=tbl -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33160
mysql-proxy-repilca-query:
name: MySQL-Proxy with REPLICA-QUERY
@@ -85,7 +85,7 @@ jobs:
- name: Build Project
run: ./mvnw -B clean install -Dmaven.javadoc.skip=true -Drat.skip=true -Djacoco.skip=true -DskipITs
- name: Run Integration Test
- run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=proxy -Dit.scenarios=repilca_query -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33060
+ run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=proxy -Dit.scenarios=repilca_query -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33260
mysql-proxy-dbtbl-with-proxy-repilca-query:
name: MySQL-Proxy with DBTBL-WITH-REPLICA-QUERY
@@ -106,7 +106,7 @@ jobs:
- name: Build Project
run: ./mvnw -B clean install -Dmaven.javadoc.skip=true -Drat.skip=true -Djacoco.skip=true -DskipITs
- name: Run Integration Test
- run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=proxy -Dit.scenarios=dbtbl_with_repilca_query -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33060
+ run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=proxy -Dit.scenarios=dbtbl_with_repilca_query -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33360
mysql-jdbc-db:
name: MySQL-JDBC with DB
@@ -127,7 +127,7 @@ jobs:
- name: Build Project
run: ./mvnw -B clean install -Dmaven.javadoc.skip=true -Drat.skip=true -Djacoco.skip=true -DskipITs
- name: Run Integration Test
- run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=jdbc -Dit.scenarios=db -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=3306
+ run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=jdbc -Dit.scenarios=db -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33060
mysql-jdbc-tbl:
name: MySQL-JDBC with TBL
@@ -148,7 +148,7 @@ jobs:
- name: Build Project
run: ./mvnw -B clean install -Dmaven.javadoc.skip=true -Drat.skip=true -Djacoco.skip=true -DskipITs
- name: Run Integration Test
- run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=jdbc -Dit.scenarios=tbl -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=3306
+ run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=jdbc -Dit.scenarios=tbl -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33160
mysql-jdbc-repilca-query:
name: MySQL-JDBC with REPLICA-QUERY
@@ -169,7 +169,7 @@ jobs:
- name: Build Project
run: ./mvnw -B clean install -Dmaven.javadoc.skip=true -Drat.skip=true -Djacoco.skip=true -DskipITs
- name: Run Integration Test
- run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=jdbc -Dit.scenarios=repilca_query -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=3306
+ run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=jdbc -Dit.scenarios=repilca_query -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33260
mysql-jdbc-dbtbl-with-proxy-repilca-query:
name: MySQL-JDBC with DBTBL-WITH-REPLICA-QUERY
@@ -190,4 +190,4 @@ jobs:
- name: Build Project
run: ./mvnw -B clean install -Dmaven.javadoc.skip=true -Drat.skip=true -Djacoco.skip=true -DskipITs
- name: Run Integration Test
- run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=jdbc -Dit.scenarios=dbtbl_with_repilca_query -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=3306
+ run: ./mvnw -B clean install -f shardingsphere-test/shardingsphere-integration-test/pom.xml -Pit.env.docker -Dit.adapters=jdbc -Dit.scenarios=dbtbl_with_repilca_query -Dit.mysql.host=127.0.0.1 -Dit.mysql.port=33360
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/pom.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/pom.xml
index 55edb9e..0ddf89d 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/pom.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/pom.xml
@@ -80,6 +80,9 @@
<profiles>
<profile>
<id>it.env.docker</id>
+ <properties>
+ <it.env>docker</it.env>
+ </properties>
<build>
<plugins>
<plugin>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/java/org/apache/shardingsphere/test/integration/env/IntegrateTestEnvironment.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/java/org/apache/shardingsphere/test/integration/env/IntegrateTestEnvironment.java
index f1f434d..89ed39c 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/java/org/apache/shardingsphere/test/integration/env/IntegrateTestEnvironment.java
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/java/org/apache/shardingsphere/test/integration/env/IntegrateTestEnvironment.java
@@ -44,6 +44,8 @@ import java.util.stream.Collectors;
public final class IntegrateTestEnvironment {
private static final IntegrateTestEnvironment INSTANCE = new IntegrateTestEnvironment();
+
+ private final boolean isEnvironmentPrepared;
private final Collection<String> adapters;
@@ -57,6 +59,7 @@ public final class IntegrateTestEnvironment {
private IntegrateTestEnvironment() {
Properties envProps = loadProperties();
+ isEnvironmentPrepared = "docker".equals(envProps.getProperty("it.env.type"));
adapters = Splitter.on(",").trimResults().splitToList(envProps.getProperty("it.adapters"));
runAdditionalTestCases = Boolean.parseBoolean(envProps.getProperty("it.run.additional.cases"));
scenarios = Splitter.on(",").trimResults().splitToList(envProps.getProperty("it.scenarios"));
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/java/org/apache/shardingsphere/test/integration/env/schema/SchemaEnvironmentManager.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/java/org/apache/shardingsphere/test/integration/env/schema/SchemaEnvironmentManager.java
index 14abcbb..654bd4d 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/java/org/apache/shardingsphere/test/integration/env/schema/SchemaEnvironmentManager.java
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/java/org/apache/shardingsphere/test/integration/env/schema/SchemaEnvironmentManager.java
@@ -69,6 +69,9 @@ public final class SchemaEnvironmentManager {
* @throws JAXBException JAXB exception
*/
public static void createDatabases() throws IOException, JAXBException {
+ if (IntegrateTestEnvironment.getInstance().isEnvironmentPrepared()) {
+ return;
+ }
for (String each : IntegrateTestEnvironment.getInstance().getScenarios()) {
dropDatabases(each);
createDatabases(each);
@@ -102,6 +105,9 @@ public final class SchemaEnvironmentManager {
* @throws JAXBException JAXB exception
*/
public static void dropDatabases() throws IOException, JAXBException {
+ if (IntegrateTestEnvironment.getInstance().isEnvironmentPrepared()) {
+ return;
+ }
for (String each : IntegrateTestEnvironment.getInstance().getScenarios()) {
dropDatabases(each);
}
@@ -143,6 +149,9 @@ public final class SchemaEnvironmentManager {
* @throws IOException IO exception
*/
public static void createTables() throws JAXBException, IOException {
+ if (IntegrateTestEnvironment.getInstance().isEnvironmentPrepared()) {
+ return;
+ }
for (String each : IntegrateTestEnvironment.getInstance().getScenarios()) {
createTables(each);
}
@@ -170,6 +179,9 @@ public final class SchemaEnvironmentManager {
* @throws IOException IO exception
*/
public static void dropTables() throws JAXBException, IOException {
+ if (IntegrateTestEnvironment.getInstance().isEnvironmentPrepared()) {
+ return;
+ }
for (String each : IntegrateTestEnvironment.getInstance().getScenarios()) {
dropTables(each);
}
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dml-integrate-test-cases.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dml-integrate-test-cases.xml
index 8145c10..999986c 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dml-integrate-test-cases.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dml-integrate-test-cases.xml
@@ -127,15 +127,15 @@
<test-case sql="UPDATE t_order SET status = 'update' WHERE order_id = 1000 AND user_id = 10">
<assertion expected-data-file="update.xml" />
</test-case>
-
+
<test-case sql="UPDATE t_order SET status = 'update' WHERE (order_id = ? OR order_id = ?) AND user_id = ?">
<assertion parameters="1000:int, 0:int, 10:int" expected-data-file="update.xml" />
</test-case>
-
+
<test-case sql="update t_order set status = status where user_id = user_id AND order_id = 1000">
<assertion expected-data-file="update_with_column_equal_column.xml" />
</test-case>
-
+
<test-case sql="DELETE FROM t_order WHERE order_id = ? AND user_id = ? AND status=?">
<assertion parameters="1000:int, 10:int, init:String" expected-data-file="delete_with_sharding_value.xml" />
</test-case>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init.sql
index ff342ea..850215b 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/db/init.sql
@@ -32,39 +32,49 @@ CREATE DATABASE db_9;
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 order_index_t_order ON db_0.t_order (order_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 order_index_t_order ON db_1.t_order (order_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 order_index_t_order ON db_2.t_order (order_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 order_index_t_order ON db_3.t_order (order_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 order_index_t_order ON db_4.t_order (order_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 order_index_t_order ON db_5.t_order (order_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 order_index_t_order ON db_6.t_order (order_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 order_index_t_order ON db_7.t_order (order_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 order_index_t_order ON db_8.t_order (order_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 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/dbtbl_with_replica_query/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init.sql
index 26a1806..80ae5c6 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/dbtbl_with_replica_query/init.sql
@@ -59,6 +59,16 @@ CREATE TABLE primary_ds_0.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_0.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_0.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_0.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_0.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_0.t_order_6 (order_id);
+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_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));
@@ -80,6 +90,16 @@ CREATE TABLE primary_ds_1.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_1.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_1.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_1.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_1.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_1.t_order_6 (order_id);
+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_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));
@@ -101,6 +121,16 @@ CREATE TABLE primary_ds_2.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_2.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_2.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_2.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_2.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_2.t_order_6 (order_id);
+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_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));
@@ -122,6 +152,16 @@ CREATE TABLE primary_ds_3.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_3.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_3.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_3.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_3.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_3.t_order_6 (order_id);
+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_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));
@@ -143,6 +183,16 @@ CREATE TABLE primary_ds_4.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_4.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_4.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_4.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_4.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_4.t_order_6 (order_id);
+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_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));
@@ -164,6 +214,16 @@ CREATE TABLE primary_ds_5.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_5.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_5.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_5.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_5.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_5.t_order_6 (order_id);
+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_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));
@@ -185,6 +245,16 @@ CREATE TABLE primary_ds_6.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_6.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_6.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_6.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_6.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_6.t_order_6 (order_id);
+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_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));
@@ -206,6 +276,16 @@ CREATE TABLE primary_ds_7.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_7.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_7.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_7.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_7.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_7.t_order_6 (order_id);
+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_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));
@@ -227,6 +307,16 @@ CREATE TABLE primary_ds_8.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_8.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_8.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_8.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_8.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_8.t_order_6 (order_id);
+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_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));
@@ -248,6 +338,16 @@ CREATE TABLE primary_ds_9.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE primary_ds_9.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON primary_ds_9.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON primary_ds_9.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON primary_ds_9.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON primary_ds_9.t_order_6 (order_id);
+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_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));
@@ -269,6 +369,16 @@ CREATE TABLE replica_ds_0.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_0.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_0.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_0.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_0.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_0.t_order_6 (order_id);
+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_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));
@@ -290,6 +400,16 @@ CREATE TABLE replica_ds_1.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_1.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_1.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_1.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_1.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_1.t_order_6 (order_id);
+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_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));
@@ -311,6 +431,16 @@ CREATE TABLE replica_ds_2.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_2.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_2.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_2.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_2.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_2.t_order_6 (order_id);
+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_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));
@@ -332,6 +462,16 @@ CREATE TABLE replica_ds_3.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_3.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_3.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_3.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_3.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_3.t_order_6 (order_id);
+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_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));
@@ -353,6 +493,16 @@ CREATE TABLE replica_ds_4.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_4.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_4.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_4.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_4.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_4.t_order_6 (order_id);
+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_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));
@@ -374,6 +524,16 @@ CREATE TABLE replica_ds_5.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_5.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_5.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_5.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_5.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_5.t_order_6 (order_id);
+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_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));
@@ -395,6 +555,16 @@ CREATE TABLE replica_ds_6.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_6.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_6.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_6.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_6.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_6.t_order_6 (order_id);
+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_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));
@@ -416,6 +586,16 @@ CREATE TABLE replica_ds_7.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_7.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_7.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_7.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_7.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_7.t_order_6 (order_id);
+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_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));
@@ -437,6 +617,16 @@ CREATE TABLE replica_ds_8.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_8.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_8.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_8.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_8.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_8.t_order_6 (order_id);
+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_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));
@@ -458,3 +648,13 @@ CREATE TABLE replica_ds_9.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL
CREATE TABLE replica_ds_9.t_order_item_8 (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_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 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);
+CREATE INDEX order_index_t_order_3 ON replica_ds_9.t_order_3 (order_id);
+CREATE INDEX order_index_t_order_4 ON replica_ds_9.t_order_4 (order_id);
+CREATE INDEX order_index_t_order_5 ON replica_ds_9.t_order_5 (order_id);
+CREATE INDEX order_index_t_order_6 ON replica_ds_9.t_order_6 (order_id);
+CREATE INDEX order_index_t_order_7 ON replica_ds_9.t_order_7 (order_id);
+CREATE INDEX order_index_t_order_8 ON replica_ds_9.t_order_8 (order_id);
+CREATE INDEX order_index_t_order_9 ON replica_ds_9.t_order_9 (order_id);
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/env.properties b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/env.properties
index 2969482..ea85a33 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/env.properties
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/env.properties
@@ -15,6 +15,8 @@
# limitations under the License.
#
+it.env.type=${it.env}
+
it.adapters=jdbc
it.run.additional.cases=false
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init.sql
index fcf6962..c23f312 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/replica_query/init.sql
@@ -24,9 +24,12 @@ CREATE DATABASE replica_1;
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 INDEX order_index_t_order ON primary_ds.t_order (order_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 INDEX order_index_t_order ON replica_0.t_order (order_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 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/tbl/init.sql b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init.sql
index 0aaf2e1..dd8a30f 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init.sql
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/env/tbl/init.sql
@@ -22,30 +22,40 @@ CREATE DATABASE tbl;
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);
CREATE TABLE tbl.t_order_1 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_1 (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_1 ON tbl.t_order_1 (order_id);
CREATE TABLE tbl.t_order_2 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_2 (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_2 ON tbl.t_order_2 (order_id);
CREATE TABLE tbl.t_order_3 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_3 (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_3 ON tbl.t_order_3 (order_id);
CREATE TABLE tbl.t_order_4 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_4 (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_4 ON tbl.t_order_4 (order_id);
CREATE TABLE tbl.t_order_5 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_5 (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_5 ON tbl.t_order_5 (order_id);
CREATE TABLE tbl.t_order_6 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_6 (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_6 ON tbl.t_order_6 (order_id);
CREATE TABLE tbl.t_order_7 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_7 (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_7 ON tbl.t_order_7 (order_id);
CREATE TABLE tbl.t_order_8 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.t_order_item_8 (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_8 ON tbl.t_order_8 (order_id);
CREATE TABLE tbl.t_order_9 (order_id INT NOT NULL, user_id INT NOT NULL, status VARCHAR(45) NULL, PRIMARY KEY (order_id));
CREATE TABLE tbl.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 INDEX order_index_t_order_9 ON tbl.t_order_9 (order_id);