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/23 03:25:31 UTC

[shardingsphere] branch master updated: add cases of dml and fix some assert (#9468)

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 ecc8414  add cases of dml and fix some assert (#9468)
ecc8414 is described below

commit ecc8414910f715a4b9f4f4bcba74a53be989672c
Author: Jieker <ji...@163.com>
AuthorDate: Tue Feb 23 11:24:45 2021 +0800

    add cases of dml and fix some assert (#9468)
    
    * add cases of dml and fix some assert
    
    * Update batch_insert_into_user_table.xml
    
    * prefect format
---
 .../dataset/db/batch_insert_into_user_table.xml    | 83 ++++++++++++++++++++++
 .../cases/dml/dataset/db/delete_user_table.xml     | 53 ++++++++++++++
 .../cases/dml/dataset/db/update_user_table.xml     | 63 ++++++++++++++++
 .../batch_insert_into_user_table.xml               | 83 ++++++++++++++++++++++
 .../dbtbl_with_replica_query/delete_user_table.xml | 53 ++++++++++++++
 .../dbtbl_with_replica_query/update_user_table.xml | 63 ++++++++++++++++
 .../encrypt/batch_insert_into_user_table.xml       | 30 ++++++++
 .../dml/dataset/encrypt/delete_user_table.xml      | 27 +++++++
 .../dataset/encrypt/delete_with_sharding_value.xml |  1 -
 .../encrypt/delete_without_sharding_value.xml      | 40 -----------
 .../insert_multiple_values_for_order_1_2.xml       |  4 +-
 .../dataset/encrypt/insert_with_now_function.xml   |  4 +-
 .../encrypt/insert_without_generate_key_column.xml |  3 +-
 .../resources/cases/dml/dataset/encrypt/update.xml |  2 +-
 .../dml/dataset/encrypt/update_user_table.xml      | 28 ++++++++
 .../dataset/encrypt/update_without_condition.xml   |  2 +-
 .../replica_query/batch_insert_into_user_table.xml | 37 ++++++++++
 .../dataset/replica_query/delete_user_table.xml    | 34 +++++++++
 .../insert_multiple_values_for_order_1_2.xml       |  4 +-
 .../insert_without_generate_key_column.xml         |  3 +-
 .../dataset/replica_query/update_user_table.xml    | 35 +++++++++
 .../replica_query/update_without_condition.xml     | 82 ++++++++++-----------
 .../dataset/tbl/batch_insert_into_user_table.xml   | 29 ++++++++
 .../cases/dml/dataset/tbl/delete_user_table.xml    | 26 +++++++
 .../cases/dml/dataset/tbl/update_user_table.xml    | 27 +++++++
 .../cases/dml/dml-integration-test-cases.xml       | 16 ++++-
 26 files changed, 736 insertions(+), 96 deletions(-)

diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/batch_insert_into_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/batch_insert_into_user_table.xml
new file mode 100644
index 0000000..319825e
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/batch_insert_into_user_table.xml
@@ -0,0 +1,83 @@
+<!--
+  ~ 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" broadcast="true">
+    <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_0.t_user" values="14, mno" />
+    <row data-node="db_0.t_user" values="15, pqr" />
+    <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_1.t_user" values="14, mno" />
+    <row data-node="db_1.t_user" values="15, pqr" />
+    <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_2.t_user" values="14, mno" />
+    <row data-node="db_2.t_user" values="15, pqr" />
+    <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_3.t_user" values="14, mno" />
+    <row data-node="db_3.t_user" values="15, pqr" />
+    <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_4.t_user" values="14, mno" />
+    <row data-node="db_4.t_user" values="15, pqr" />
+    <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_5.t_user" values="14, mno" />
+    <row data-node="db_5.t_user" values="15, pqr" />
+    <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_6.t_user" values="14, mno" />
+    <row data-node="db_6.t_user" values="15, pqr" />
+    <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_7.t_user" values="14, mno" />
+    <row data-node="db_7.t_user" values="15, pqr" />
+    <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_8.t_user" values="14, mno" />
+    <row data-node="db_8.t_user" values="15, pqr" />
+    <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_9.t_user" values="14, mno" />
+    <row data-node="db_9.t_user" values="15, pqr" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/delete_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/delete_user_table.xml
new file mode 100644
index 0000000..609e846
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/delete_user_table.xml
@@ -0,0 +1,53 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <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="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="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="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="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="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="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="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="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="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="11, def" />
+    <row data-node="db_9.t_user" values="12, hig" />
+    <row data-node="db_9.t_user" values="13, kli" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/update_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/update_user_table.xml
new file mode 100644
index 0000000..ab14a1b
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/db/update_user_table.xml
@@ -0,0 +1,63 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/batch_insert_into_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/batch_insert_into_user_table.xml
new file mode 100644
index 0000000..9c178c8
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/batch_insert_into_user_table.xml
@@ -0,0 +1,83 @@
+<!--
+  ~ 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" broadcast="true">
+    <metadata data-nodes="primary_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_0.t_user" values="14, mno" />
+    <row data-node="primary_ds_0.t_user" values="15, pqr" />
+    <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_1.t_user" values="14, mno" />
+    <row data-node="primary_ds_1.t_user" values="15, pqr" />
+    <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_2.t_user" values="14, mno" />
+    <row data-node="primary_ds_2.t_user" values="15, pqr" />
+    <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_3.t_user" values="14, mno" />
+    <row data-node="primary_ds_3.t_user" values="15, pqr" />
+    <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_4.t_user" values="14, mno" />
+    <row data-node="primary_ds_4.t_user" values="15, pqr" />
+    <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_5.t_user" values="14, mno" />
+    <row data-node="primary_ds_5.t_user" values="15, pqr" />
+    <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_6.t_user" values="14, mno" />
+    <row data-node="primary_ds_6.t_user" values="15, pqr" />
+    <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_7.t_user" values="14, mno" />
+    <row data-node="primary_ds_7.t_user" values="15, pqr" />
+    <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_8.t_user" values="14, mno" />
+    <row data-node="primary_ds_8.t_user" values="15, pqr" />
+    <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="primary_ds_9.t_user" values="14, mno" />
+    <row data-node="primary_ds_9.t_user" values="15, pqr" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/delete_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/delete_user_table.xml
new file mode 100644
index 0000000..d4e121c
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/delete_user_table.xml
@@ -0,0 +1,53 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <metadata data-nodes="primary_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="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="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="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="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="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="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="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="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="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="11, def" />
+    <row data-node="primary_ds_9.t_user" values="12, hig" />
+    <row data-node="primary_ds_9.t_user" values="13, kli" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/update_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/update_user_table.xml
new file mode 100644
index 0000000..649b761
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/dbtbl_with_replica_query/update_user_table.xml
@@ -0,0 +1,63 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <metadata data-nodes="primary_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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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, stu" />
+    <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" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/batch_insert_into_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/batch_insert_into_user_table.xml
new file mode 100644
index 0000000..7a16f2a
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/batch_insert_into_user_table.xml
@@ -0,0 +1,30 @@
+<!--
+  ~ 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_user">
+        <column name="user_id" type="numeric"/>
+        <column name="pwd" type="varchar"/>
+        <column name="pwd_cipher" type="varchar"/>
+    </metadata>
+    <row data-node="encrypt.t_user" values="10, null, xdpUjIyP5dJQfX+2tOVbYg==" />
+    <row data-node="encrypt.t_user" values="11, null, ad3U0KgdvmyMjHGHM1TnQA==" />
+    <row data-node="encrypt.t_user" values="12, null, yiGGBrwHiDXsZPtZUhPd9A==" />
+    <row data-node="encrypt.t_user" values="13, null, UizTwGQDouZaeZA+NYZrKA==" />
+    <row data-node="encrypt.t_user" values="14, mno, k27eGvR2XKv7E0c4w7a7PQ==" />
+    <row data-node="encrypt.t_user" values="15, pqr, 8XoLq+Q3ES8NCUWb2u83NQ==" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_user_table.xml
new file mode 100644
index 0000000..70cade9
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_user_table.xml
@@ -0,0 +1,27 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <metadata data-nodes="encrypt.t_user">
+        <column name="user_id" type="numeric"/>
+        <column name="pwd" type="varchar"/>
+        <column name="pwd_cipher" type="varchar"/>
+    </metadata>
+    <row data-node="encrypt.t_user" values="11, null, ad3U0KgdvmyMjHGHM1TnQA==" />
+    <row data-node="encrypt.t_user" values="12, null, yiGGBrwHiDXsZPtZUhPd9A==" />
+    <row data-node="encrypt.t_user" values="13, null, UizTwGQDouZaeZA+NYZrKA==" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_with_sharding_value.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_with_sharding_value.xml
index 7044c74..db5e432 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_with_sharding_value.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_with_sharding_value.xml
@@ -21,7 +21,6 @@
         <column name="user_id" type="numeric" />
         <column name="status" type="varchar" />
     </metadata>
-    <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" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_without_sharding_value.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_without_sharding_value.xml
index d320908..7be32b6 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_without_sharding_value.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/delete_without_sharding_value.xml
@@ -21,44 +21,4 @@
         <column name="user_id" type="numeric" />
         <column name="status" type="varchar" />
     </metadata>
-    <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/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
index 6130f9d..9a72806 100644
--- 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
@@ -21,8 +21,8 @@
         <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="1, 1, insert" />
+    <row data-node="encrypt.t_order" values="2, 2, insert2" />
     <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" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_with_now_function.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_with_now_function.xml
index 126540b..65101c7 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_with_now_function.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_with_now_function.xml
@@ -16,14 +16,14 @@
   -->
 
 <dataset update-count="1">
-    <metadata data-nodes="primary_ds.t_order_item,replica_${0..1}.t_order_item">
+    <metadata data-nodes="encrypt.t_order_item">
         <column name="item_id" type="numeric" />
         <column name="order_id" type="numeric" />
         <column name="user_id" type="numeric" />
         <column name="status" type="varchar" />
         <column name="creation_date" type="datetime" />
     </metadata>
-    <row data-node="primary_ds.t_order_item" values="1, 1, 1, insert, NOT_VERIFY" />
+    <row data-node="encrypt.t_order_item" values="1, 1, 1, insert, NOT_VERIFY" />
     <row data-node="encrypt.t_order_item" values="100001, 1000, 10, init, NOT_VERIFY" />
     <row data-node="encrypt.t_order_item" values="100002, 1000, 10, init, NOT_VERIFY" />
     <row data-node="encrypt.t_order_item" values="100101, 1001, 10, init, NOT_VERIFY" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_without_generate_key_column.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_without_generate_key_column.xml
index 87953bf..f6fb673 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_without_generate_key_column.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/insert_without_generate_key_column.xml
@@ -15,7 +15,7 @@
   ~ limitations under the License.
   -->
 
-<dataset update-count="1">
+<dataset update-count="0">
     <metadata data-nodes="encrypt.t_order_item">
         <column name="item_id" type="numeric" />
         <column name="order_id" type="numeric" />
@@ -23,7 +23,6 @@
         <column name="status" type="varchar" />
         <column name="creation_date" type="datetime" />
     </metadata>
-    <row data-node="encrypt.t_order_item" values="0, 1, 1, insert, 2017-08-08" />
     <row data-node="encrypt.t_order_item" values="100001, 1000, 10, init, 2017-08-08" />
     <row data-node="encrypt.t_order_item" values="100002, 1000, 10, init, 2017-08-08" />
     <row data-node="encrypt.t_order_item" values="100101, 1001, 10, init, 2017-08-08" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update.xml
index 7044c74..c2c04d5 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update.xml
@@ -21,7 +21,7 @@
         <column name="user_id" type="numeric" />
         <column name="status" type="varchar" />
     </metadata>
-    <row data-node="encrypt.t_order" values="1000, 10, init" />
+    <row data-node="encrypt.t_order" values="1000, 10, update" />
     <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" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update_user_table.xml
new file mode 100644
index 0000000..9a52ae1
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update_user_table.xml
@@ -0,0 +1,28 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <metadata data-nodes="encrypt.t_user">
+        <column name="user_id" type="numeric"/>
+        <column name="pwd" type="varchar"/>
+        <column name="pwd_cipher" type="varchar"/>
+    </metadata>
+    <row data-node="encrypt.t_user" values="10, stu, 0DoehJtbanWbtn2fWI5Y+A==" />
+    <row data-node="encrypt.t_user" values="11, null, ad3U0KgdvmyMjHGHM1TnQA==" />
+    <row data-node="encrypt.t_user" values="12, null, yiGGBrwHiDXsZPtZUhPd9A==" />
+    <row data-node="encrypt.t_user" values="13, null, UizTwGQDouZaeZA+NYZrKA==" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update_without_condition.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update_without_condition.xml
index 4973349..8206380 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update_without_condition.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/encrypt/update_without_condition.xml
@@ -15,7 +15,7 @@
   ~ limitations under the License.
   -->
 
-<dataset update-count="100">
+<dataset update-count="40">
     <metadata data-nodes="encrypt.t_order">
         <column name="order_id" type="numeric" />
         <column name="user_id" type="numeric" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/batch_insert_into_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/batch_insert_into_user_table.xml
new file mode 100644
index 0000000..ca4649f
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/batch_insert_into_user_table.xml
@@ -0,0 +1,37 @@
+<!--
+  ~ 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" broadcast="true">
+    <metadata data-nodes="primary_ds.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="primary_ds.t_user" values="14, mno" />
+    <row data-node="primary_ds.t_user" values="15, pqr" />
+    <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" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/delete_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/delete_user_table.xml
new file mode 100644
index 0000000..6b08f35
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/delete_user_table.xml
@@ -0,0 +1,34 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <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="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" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/insert_multiple_values_for_order_1_2.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/insert_multiple_values_for_order_1_2.xml
index b305503..5421149 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/insert_multiple_values_for_order_1_2.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/insert_multiple_values_for_order_1_2.xml
@@ -21,8 +21,8 @@
         <column name="user_id" type="numeric" />
         <column name="status" type="varchar" />
     </metadata>
-    <row data-node="primary_ds.t_order" values="1, 1, init" />
-    <row data-node="primary_ds.t_order" values="2, 2, init" />
+    <row data-node="primary_ds.t_order" values="1, 1, insert" />
+    <row data-node="primary_ds.t_order" values="2, 2, insert2" />
     <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/cases/dml/dataset/replica_query/insert_without_generate_key_column.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/insert_without_generate_key_column.xml
index 9f547fd..5b59eed 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/insert_without_generate_key_column.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/insert_without_generate_key_column.xml
@@ -15,7 +15,7 @@
   ~ limitations under the License.
   -->
 
-<dataset update-count="1">
+<dataset update-count="0">
     <metadata data-nodes="primary_ds.t_order_item,replica_${0..1}.t_order_item">
         <column name="item_id" type="numeric" />
         <column name="order_id" type="numeric" />
@@ -23,7 +23,6 @@
         <column name="status" type="varchar" />
         <column name="creation_date" type="datetime" />
     </metadata>
-    <row data-node="primary_ds.t_order_item" values="0, 1, 1, insert, 2017-08-08" />
     <row data-node="primary_ds.t_order_item" values="100001, 1000, 10, init, 2017-08-08" />
     <row data-node="primary_ds.t_order_item" values="100002, 1000, 10, init, 2017-08-08" />
     <row data-node="primary_ds.t_order_item" values="100101, 1001, 10, init, 2017-08-08" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/update_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/update_user_table.xml
new file mode 100644
index 0000000..972e540
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/update_user_table.xml
@@ -0,0 +1,35 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <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, stu" />
+    <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" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/update_without_condition.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/update_without_condition.xml
index 16c2af3..8993676 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/update_without_condition.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/replica_query/update_without_condition.xml
@@ -15,52 +15,52 @@
   ~ limitations under the License.
   -->
 
-<dataset update-count="100">
+<dataset update-count="40">
     <metadata data-nodes="primary_ds.t_order,replica_ds_${0..1}.t_order">
         <column name="order_id" type="numeric" />
         <column name="user_id" type="numeric" />
         <column name="status" type="varchar" />
     </metadata>
-    <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" />
-    <row data-node="primary_ds.t_order" values="1101, 11, init" />
-    <row data-node="primary_ds.t_order" values="1200, 12, init" />
-    <row data-node="primary_ds.t_order" values="1201, 12, init" />
-    <row data-node="primary_ds.t_order" values="1300, 13, init" />
-    <row data-node="primary_ds.t_order" values="1301, 13, init" />
-    <row data-node="primary_ds.t_order" values="1400, 14, init" />
-    <row data-node="primary_ds.t_order" values="1401, 14, init" />
-    <row data-node="primary_ds.t_order" values="1500, 15, init" />
-    <row data-node="primary_ds.t_order" values="1501, 15, init" />
-    <row data-node="primary_ds.t_order" values="1600, 16, init" />
-    <row data-node="primary_ds.t_order" values="1601, 16, init" />
-    <row data-node="primary_ds.t_order" values="1700, 17, init" />
-    <row data-node="primary_ds.t_order" values="1701, 17, init" />
-    <row data-node="primary_ds.t_order" values="1800, 18, init" />
-    <row data-node="primary_ds.t_order" values="1801, 18, init" />
-    <row data-node="primary_ds.t_order" values="1900, 19, init" />
-    <row data-node="primary_ds.t_order" values="1901, 19, init" />
-    <row data-node="primary_ds.t_order" values="2000, 20, init" />
-    <row data-node="primary_ds.t_order" values="2001, 20, init" />
-    <row data-node="primary_ds.t_order" values="2100, 21, init" />
-    <row data-node="primary_ds.t_order" values="2101, 21, init" />
-    <row data-node="primary_ds.t_order" values="2200, 22, init" />
-    <row data-node="primary_ds.t_order" values="2201, 22, init" />
-    <row data-node="primary_ds.t_order" values="2300, 23, init" />
-    <row data-node="primary_ds.t_order" values="2301, 23, init" />
-    <row data-node="primary_ds.t_order" values="2400, 24, init" />
-    <row data-node="primary_ds.t_order" values="2401, 24, init" />
-    <row data-node="primary_ds.t_order" values="2500, 25, init" />
-    <row data-node="primary_ds.t_order" values="2501, 25, init" />
-    <row data-node="primary_ds.t_order" values="2600, 26, init" />
-    <row data-node="primary_ds.t_order" values="2601, 26, init" />
-    <row data-node="primary_ds.t_order" values="2700, 27, init" />
-    <row data-node="primary_ds.t_order" values="2701, 27, init" />
-    <row data-node="primary_ds.t_order" values="2800, 28, init" />
-    <row data-node="primary_ds.t_order" values="2801, 28, init" />
-    <row data-node="primary_ds.t_order" values="2900, 29, init" />
-    <row data-node="primary_ds.t_order" values="2901, 29, init" />
+    <row data-node="primary_ds.t_order" values="1000, 10, finished" />
+    <row data-node="primary_ds.t_order" values="1001, 10, finished" />
+    <row data-node="primary_ds.t_order" values="1100, 11, finished" />
+    <row data-node="primary_ds.t_order" values="1101, 11, finished" />
+    <row data-node="primary_ds.t_order" values="1200, 12, finished" />
+    <row data-node="primary_ds.t_order" values="1201, 12, finished" />
+    <row data-node="primary_ds.t_order" values="1300, 13, finished" />
+    <row data-node="primary_ds.t_order" values="1301, 13, finished" />
+    <row data-node="primary_ds.t_order" values="1400, 14, finished" />
+    <row data-node="primary_ds.t_order" values="1401, 14, finished" />
+    <row data-node="primary_ds.t_order" values="1500, 15, finished" />
+    <row data-node="primary_ds.t_order" values="1501, 15, finished" />
+    <row data-node="primary_ds.t_order" values="1600, 16, finished" />
+    <row data-node="primary_ds.t_order" values="1601, 16, finished" />
+    <row data-node="primary_ds.t_order" values="1700, 17, finished" />
+    <row data-node="primary_ds.t_order" values="1701, 17, finished" />
+    <row data-node="primary_ds.t_order" values="1800, 18, finished" />
+    <row data-node="primary_ds.t_order" values="1801, 18, finished" />
+    <row data-node="primary_ds.t_order" values="1900, 19, finished" />
+    <row data-node="primary_ds.t_order" values="1901, 19, finished" />
+    <row data-node="primary_ds.t_order" values="2000, 20, finished" />
+    <row data-node="primary_ds.t_order" values="2001, 20, finished" />
+    <row data-node="primary_ds.t_order" values="2100, 21, finished" />
+    <row data-node="primary_ds.t_order" values="2101, 21, finished" />
+    <row data-node="primary_ds.t_order" values="2200, 22, finished" />
+    <row data-node="primary_ds.t_order" values="2201, 22, finished" />
+    <row data-node="primary_ds.t_order" values="2300, 23, finished" />
+    <row data-node="primary_ds.t_order" values="2301, 23, finished" />
+    <row data-node="primary_ds.t_order" values="2400, 24, finished" />
+    <row data-node="primary_ds.t_order" values="2401, 24, finished" />
+    <row data-node="primary_ds.t_order" values="2500, 25, finished" />
+    <row data-node="primary_ds.t_order" values="2501, 25, finished" />
+    <row data-node="primary_ds.t_order" values="2600, 26, finished" />
+    <row data-node="primary_ds.t_order" values="2601, 26, finished" />
+    <row data-node="primary_ds.t_order" values="2700, 27, finished" />
+    <row data-node="primary_ds.t_order" values="2701, 27, finished" />
+    <row data-node="primary_ds.t_order" values="2800, 28, finished" />
+    <row data-node="primary_ds.t_order" values="2801, 28, finished" />
+    <row data-node="primary_ds.t_order" values="2900, 29, finished" />
+    <row data-node="primary_ds.t_order" values="2901, 29, finished" />
     <row data-node="replica_0.t_order" values="1000, 10, init_replica" />
     <row data-node="replica_0.t_order" values="1001, 10, init_replica" />
     <row data-node="replica_0.t_order" values="1100, 11, init_replica" />
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/batch_insert_into_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/batch_insert_into_user_table.xml
new file mode 100644
index 0000000..d99e967
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/batch_insert_into_user_table.xml
@@ -0,0 +1,29 @@
+<!--
+  ~ Licensed to the Apache Software Foundation (ASF) under one or more
+  ~ contributor license agreements.  See the NOTICE file distributed with
+  ~ this work for additional information regarding copyright ownership.
+  ~ The ASF licenses this file to You under the Apache License, Version 2.0
+  ~ (the "License"); you may not use this file except in compliance with
+  ~ the License.  You may obtain a copy of the License at
+  ~
+  ~     http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~ Unless required by applicable law or agreed to in writing, software
+  ~ distributed under the License is distributed on an "AS IS" BASIS,
+  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~ See the License for the specific language governing permissions and
+  ~ limitations under the License.
+  -->
+
+<dataset update-count="2" broadcast="true">
+    <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_user" values="14, mno" />
+    <row data-node="tbl.t_user" values="15, pqr" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/delete_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/delete_user_table.xml
new file mode 100644
index 0000000..db0d952
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/delete_user_table.xml
@@ -0,0 +1,26 @@
+<!--
+  ~ Licensed to the Apache Software Foundation (ASF) under one or more
+  ~ contributor license agreements.  See the NOTICE file distributed with
+  ~ this work for additional information regarding copyright ownership.
+  ~ The ASF licenses this file to You under the Apache License, Version 2.0
+  ~ (the "License"); you may not use this file except in compliance with
+  ~ the License.  You may obtain a copy of the License at
+  ~
+  ~     http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~ Unless required by applicable law or agreed to in writing, software
+  ~ distributed under the License is distributed on an "AS IS" BASIS,
+  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~ See the License for the specific language governing permissions and
+  ~ limitations under the License.
+  -->
+
+<dataset update-count="1" broadcast="true">
+    <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="11, def" />
+    <row data-node="tbl.t_user" values="12, hig" />
+    <row data-node="tbl.t_user" values="13, kli" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/update_user_table.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/update_user_table.xml
new file mode 100644
index 0000000..41dc5dd
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dataset/tbl/update_user_table.xml
@@ -0,0 +1,27 @@
+<!--
+  ~ 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="1" broadcast="true">
+    <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, stu" />
+    <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" />
+</dataset>
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dml-integration-test-cases.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dml-integration-test-cases.xml
index b0885ba..18b244e 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dml-integration-test-cases.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-suite/src/test/resources/cases/dml/dml-integration-test-cases.xml
@@ -111,6 +111,10 @@
     <test-case sql="INSERT INTO t_broadcast_table(id, status) values (?, 'insert'),(?, 'insert')">
         <assertion parameters="2:int, 3:int" expected-data-file="batch_insert_into_broadcast_table.xml" />
     </test-case>
+
+    <test-case sql="INSERT INTO t_user(user_id, pwd) values (?, 'mno'),(?, 'pqr')">
+        <assertion parameters="14:int, 15:int" expected-data-file="batch_insert_into_user_table.xml" />
+    </test-case>
     
     <test-case sql="UPDATE t_order SET status = ? WHERE order_id = ? AND user_id = ?">
         <assertion parameters="update:String, 1000:int, 10:int" expected-data-file="update.xml" />
@@ -144,14 +148,22 @@
     <test-case sql="UPDATE t_broadcast_table b SET b.status = 'finished'" db-types="H2,MySQL">
         <assertion expected-data-file="update_broadcast_table.xml" />
     </test-case>
+
+    <test-case sql="UPDATE t_user u SET u.pwd = 'stu' WHERE user_id = 10" db-types="H2,MySQL">
+        <assertion expected-data-file="update_user_table.xml" />
+    </test-case>
     
-    <test-case sql="DELETE FROM t_order WHERE order_id = ? AND user_id = ? AND status=?">
+    <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>
     
-    <test-case sql="DELETE FROM t_order WHERE status=?">
+    <test-case sql="DELETE FROM t_order WHERE status= ?">
         <assertion parameters="init:String" expected-data-file="delete_without_sharding_value.xml" />
     </test-case>
+
+    <test-case sql="DELETE FROM t_user WHERE user_id = 10" db-types="H2,MySQL">
+        <assertion expected-data-file="delete_user_table.xml" />
+    </test-case>
     
     <test-case sql="DELETE /*+ index(status) */ ONLY t_order WHERE status=1 RETURN * LOG ERRORS INTO TABLE_LOG" db-types="Oracle">
         <assertion expected-data-file="delete_with_special_comments_return_without_sharding_value.xml" />