diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/SetAssignmentsExtractor.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/SetAssignmentsExtractor.java
index a7e6ff7730655..1603ee1476230 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/SetAssignmentsExtractor.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/SetAssignmentsExtractor.java
@@ -24,8 +24,6 @@
 import org.apache.shardingsphere.core.parse.antlr.extractor.util.RuleName;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.assignment.AssignmentSegment;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.assignment.SetAssignmentsSegment;
-import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.ColumnSegment;
-import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.expr.CommonExpressionSegment;
 
 import java.util.Collection;
 import java.util.HashMap;
@@ -47,17 +45,15 @@ public Optional<SetAssignmentsSegment> extract(final ParserRuleContext ancestorN
         if (!setAssignmentsClauseNode.isPresent()) {
             return Optional.absent();
         }
-        Collection<ColumnSegment> columnSegments = new LinkedList<>();
-        Collection<CommonExpressionSegment> valueSegments = new LinkedList<>();
+        Collection<AssignmentSegment> assignmentSegments = new LinkedList<>();
         assignmentExtractor = new AssignmentExtractor(getPlaceholderIndexes(ancestorNode));
         for (ParserRuleContext each : ExtractorUtils.getAllDescendantNodes(ancestorNode, RuleName.ASSIGNMENT)) {
             Optional<AssignmentSegment> assignmentSegment = assignmentExtractor.extract(each);
             if (assignmentSegment.isPresent()) {
-                columnSegments.add(assignmentSegment.get().getColumn());
-                valueSegments.add(assignmentSegment.get().getValue());
+                assignmentSegments.add(assignmentSegment.get());
             }
         }
-        return Optional.of(new SetAssignmentsSegment(setAssignmentsClauseNode.get().getStart().getStartIndex(), columnSegments, valueSegments));
+        return Optional.of(new SetAssignmentsSegment(setAssignmentsClauseNode.get().getStart().getStartIndex(), assignmentSegments));
     }
     
     private Map<ParserRuleContext, Integer> getPlaceholderIndexes(final ParserRuleContext rootNode) {
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/insert/InsertDuplicateKeyColumnsExtractor.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/insert/OnDuplicateKeyColumnsExtractor.java
similarity index 82%
rename from sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/insert/InsertDuplicateKeyColumnsExtractor.java
rename to sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/insert/OnDuplicateKeyColumnsExtractor.java
index 74b3d811c7b3a..6060f3cf08a40 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/insert/InsertDuplicateKeyColumnsExtractor.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/impl/dml/insert/OnDuplicateKeyColumnsExtractor.java
@@ -24,27 +24,27 @@
 import org.apache.shardingsphere.core.parse.antlr.extractor.util.ExtractorUtils;
 import org.apache.shardingsphere.core.parse.antlr.extractor.util.RuleName;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.ColumnSegment;
-import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.InsertDuplicateKeyColumnsSegment;
+import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.OnDuplicateKeyColumnsSegment;
 
 import java.util.Collection;
 import java.util.LinkedList;
 
 /**
- * Insert duplicate key columns extractor.
+ * On duplicate key columns extractor.
  *
  * @author zhangliang
  */
-public final class InsertDuplicateKeyColumnsExtractor implements OptionalSQLSegmentExtractor {
+public final class OnDuplicateKeyColumnsExtractor implements OptionalSQLSegmentExtractor {
     
     private final ColumnExtractor columnExtractor = new ColumnExtractor();
     
     @Override
-    public Optional<InsertDuplicateKeyColumnsSegment> extract(final ParserRuleContext ancestorNode) {
-        Optional<ParserRuleContext> onDuplicateKeyClauseNode = ExtractorUtils.findFirstChildNode(ancestorNode, RuleName.INSERT_ON_DUPLICATE_KEY_CLAUSE);
+    public Optional<OnDuplicateKeyColumnsSegment> extract(final ParserRuleContext ancestorNode) {
+        Optional<ParserRuleContext> onDuplicateKeyClauseNode = ExtractorUtils.findFirstChildNode(ancestorNode, RuleName.ON_DUPLICATE_KEY_CLAUSE);
         if (!onDuplicateKeyClauseNode.isPresent()) {
             return Optional.absent();
         }
-        return Optional.of(new InsertDuplicateKeyColumnsSegment(extractColumnSegments(onDuplicateKeyClauseNode.get())));
+        return Optional.of(new OnDuplicateKeyColumnsSegment(extractColumnSegments(onDuplicateKeyClauseNode.get())));
     }
     
     private Collection<ColumnSegment> extractColumnSegments(final ParserRuleContext onDuplicateKeyClauseNode) {
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/util/RuleName.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/util/RuleName.java
index 862506ceaa798..22ac32fd82e65 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/util/RuleName.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/extractor/util/RuleName.java
@@ -75,7 +75,7 @@ public enum RuleName {
     
     INSERT_VALUES_CLAUSE("InsertValuesClause"),
     
-    INSERT_ON_DUPLICATE_KEY_CLAUSE("InsertOnDuplicateKeyClause"),
+    ON_DUPLICATE_KEY_CLAUSE("OnDuplicateKeyClause"),
     
     SET_ASSIGNMENTS_CLAUSE("SetAssignmentsClause"),
     
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/encrypt/dml/EncryptOrConditionFiller.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/encrypt/dml/EncryptOrConditionFiller.java
index db302039f6d2a..530bc05c6331e 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/encrypt/dml/EncryptOrConditionFiller.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/encrypt/dml/EncryptOrConditionFiller.java
@@ -36,7 +36,9 @@
 
 import java.util.Collection;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.Map;
+import java.util.Set;
 
 /**
  * Encrypt or condition filler.
@@ -76,11 +78,17 @@ private void fillColumnTableMap(final SQLStatement sqlStatement, final ShardingT
     
     private OrCondition filterCondition(final ShardingTableMetaData shardingTableMetaData, final SQLStatement sqlStatement, final OrConditionSegment orCondition, final EncryptRule encryptRule) {
         OrCondition result = new OrCondition();
+        Set<Integer> filledConditionStopIndexes = new HashSet<>();
         for (AndConditionSegment each : orCondition.getAndConditions()) {
             for (ConditionSegment condition : each.getConditions()) {
                 if (null == condition.getColumn()) {
                     continue;
                 }
+                if(filledConditionStopIndexes.contains(condition.getStopIndex())) {
+                    continue;
+                }else {
+                    filledConditionStopIndexes.add(condition.getStopIndex());
+                }
                 Column column = new Column(condition.getColumn().getName(), getTableName(shardingTableMetaData, sqlStatement, condition));
                 fillEncryptCondition(column, condition, encryptRule, sqlStatement);
             }
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/encrypt/dml/EncryptSetAssignmentsFiller.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/encrypt/dml/EncryptSetAssignmentsFiller.java
index 1d8bd92c49f36..819e697d5ee88 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/encrypt/dml/EncryptSetAssignmentsFiller.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/encrypt/dml/EncryptSetAssignmentsFiller.java
@@ -21,9 +21,9 @@
 import org.apache.shardingsphere.core.metadata.table.ShardingTableMetaData;
 import org.apache.shardingsphere.core.parse.antlr.constant.QuoteCharacter;
 import org.apache.shardingsphere.core.parse.antlr.filler.SQLSegmentFiller;
+import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.assignment.AssignmentSegment;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.assignment.SetAssignmentsSegment;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.ColumnSegment;
-import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.expr.CommonExpressionSegment;
 import org.apache.shardingsphere.core.parse.antlr.sql.statement.SQLStatement;
 import org.apache.shardingsphere.core.parse.antlr.sql.statement.dml.InsertStatement;
 import org.apache.shardingsphere.core.parse.lexer.token.DefaultKeyword;
@@ -49,8 +49,8 @@ public final class EncryptSetAssignmentsFiller implements SQLSegmentFiller<SetAs
     public void fill(final SetAssignmentsSegment sqlSegment, final SQLStatement sqlStatement, final EncryptRule encryptRule, final ShardingTableMetaData shardingTableMetaData) {
         InsertStatement insertStatement = (InsertStatement) sqlStatement;
         String tableName = insertStatement.getTables().getSingleTableName();
-        for (ColumnSegment each : sqlSegment.getColumns()) {
-            fillColumn(each, insertStatement, tableName);
+        for (AssignmentSegment each : sqlSegment.getAssignments()) {
+            fillColumn(each.getColumn(), insertStatement, tableName);
         }
         InsertValue insertValue = getInsertValue(sqlSegment, sqlStatement.getLogicSQL());
         insertStatement.getInsertValues().getValues().add(insertValue);
@@ -68,8 +68,8 @@ private void fillColumn(final ColumnSegment sqlSegment, final InsertStatement in
     private InsertValue getInsertValue(final SetAssignmentsSegment sqlSegment, final String sql) {
         int parametersCount = 0;
         List<SQLExpression> columnValues = new LinkedList<>();
-        for (CommonExpressionSegment each : sqlSegment.getValues()) {
-            Optional<SQLExpression> sqlExpression = each.convertToSQLExpression(sql);
+        for (AssignmentSegment each : sqlSegment.getAssignments()) {
+            Optional<SQLExpression> sqlExpression = each.getValue().convertToSQLExpression(sql);
             if (sqlExpression.isPresent()) {
                 columnValues.add(sqlExpression.get());
                 if (sqlExpression.get() instanceof SQLPlaceholderExpression) {
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/OrConditionFiller.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/OrConditionFiller.java
index 35a6aa8122d6f..ed2c9577d42e7 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/OrConditionFiller.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/OrConditionFiller.java
@@ -17,7 +17,14 @@
 
 package org.apache.shardingsphere.core.parse.antlr.filler.sharding.dml;
 
-import com.google.common.base.Optional;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
 import org.apache.shardingsphere.core.constant.ShardingOperator;
 import org.apache.shardingsphere.core.metadata.table.ShardingTableMetaData;
 import org.apache.shardingsphere.core.metadata.table.TableMetaData;
@@ -39,11 +46,7 @@
 import org.apache.shardingsphere.core.parse.parser.token.TableToken;
 import org.apache.shardingsphere.core.rule.ShardingRule;
 
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
+import com.google.common.base.Optional;
 
 /**
  * Or condition filler.
@@ -122,6 +125,7 @@ private OrCondition filterCondition(final ShardingTableMetaData shardingTableMet
                 break;
             }
         }
+        Set<Integer> filledConditionStopIndexes = new HashSet<>();
         for (AndConditionSegment each : orCondition.getAndConditions()) {
             for (ConditionSegment condition : each.getConditions()) {
                 if (null == condition.getColumn()) {
@@ -130,6 +134,11 @@ private OrCondition filterCondition(final ShardingTableMetaData shardingTableMet
                 if (condition.getExpression() instanceof ColumnSegment) {
                     continue;
                 }
+                if(filledConditionStopIndexes.contains(condition.getStopIndex())) {
+                    continue;
+                }else {
+                    filledConditionStopIndexes.add(condition.getStopIndex());
+                }
                 Column column = new Column(condition.getColumn().getName(), getTableName(shardingTableMetaData, shardingRule, sqlStatement, condition));
                 fillEncryptCondition(column, condition, shardingRule, sqlStatement);
             }
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/SetAssignmentsFiller.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/SetAssignmentsFiller.java
index 1d7275fa49d54..17e3b2a79f0b3 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/SetAssignmentsFiller.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/SetAssignmentsFiller.java
@@ -22,6 +22,7 @@
 import org.apache.shardingsphere.core.metadata.table.ShardingTableMetaData;
 import org.apache.shardingsphere.core.parse.antlr.constant.QuoteCharacter;
 import org.apache.shardingsphere.core.parse.antlr.filler.SQLSegmentFiller;
+import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.assignment.AssignmentSegment;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.assignment.SetAssignmentsSegment;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.ColumnSegment;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.expr.CommonExpressionSegment;
@@ -55,19 +56,19 @@ public final class SetAssignmentsFiller implements SQLSegmentFiller<SetAssignmen
     public void fill(final SetAssignmentsSegment sqlSegment, final SQLStatement sqlStatement, final ShardingRule shardingRule, final ShardingTableMetaData shardingTableMetaData) {
         InsertStatement insertStatement = (InsertStatement) sqlStatement;
         String tableName = insertStatement.getTables().getSingleTableName();
-        for (ColumnSegment each : sqlSegment.getColumns()) {
-            fillColumn(each, insertStatement, tableName);
+        for (AssignmentSegment each : sqlSegment.getAssignments()) {
+            fillColumn(each.getColumn(), insertStatement, tableName);
         }
         int columnCount = getColumnCountExcludeAssistedQueryColumns(insertStatement, shardingRule, shardingTableMetaData);
-        if (sqlSegment.getValues().size() != columnCount) {
+        if (sqlSegment.getAssignments().size() != columnCount) {
             throw new SQLParsingException("INSERT INTO column size mismatch value size.");
         }
         AndCondition andCondition = new AndCondition();
         Iterator<Column> columns = insertStatement.getColumns().iterator();
         int parametersCount = 0;
         List<SQLExpression> columnValues = new LinkedList<>();
-        for (CommonExpressionSegment each : sqlSegment.getValues()) {
-            SQLExpression columnValue = getColumnValue(insertStatement, shardingRule, andCondition, columns.next(), each);
+        for (AssignmentSegment each : sqlSegment.getAssignments()) {
+            SQLExpression columnValue = getColumnValue(insertStatement, shardingRule, andCondition, columns.next(), each.getValue());
             columnValues.add(columnValue);
             if (columnValue instanceof SQLPlaceholderExpression) {
                 parametersCount++;
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/insert/InsertDuplicateKeyColumnsFiller.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/insert/OnDuplicateKeyColumnsFiller.java
similarity index 88%
rename from sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/insert/InsertDuplicateKeyColumnsFiller.java
rename to sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/insert/OnDuplicateKeyColumnsFiller.java
index c070e876c73b2..37ef7dc74f564 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/insert/InsertDuplicateKeyColumnsFiller.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/insert/OnDuplicateKeyColumnsFiller.java
@@ -20,21 +20,21 @@
 import org.apache.shardingsphere.core.metadata.table.ShardingTableMetaData;
 import org.apache.shardingsphere.core.parse.antlr.filler.SQLSegmentFiller;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.ColumnSegment;
-import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.InsertDuplicateKeyColumnsSegment;
+import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.OnDuplicateKeyColumnsSegment;
 import org.apache.shardingsphere.core.parse.antlr.sql.statement.SQLStatement;
 import org.apache.shardingsphere.core.parse.lexer.token.Literals;
 import org.apache.shardingsphere.core.parse.parser.exception.SQLParsingException;
 import org.apache.shardingsphere.core.rule.ShardingRule;
 
 /**
- * Insert duplicate key columns filler.
+ * On duplicate key columns filler.
  *
  * @author zhangliang
  */
-public final class InsertDuplicateKeyColumnsFiller implements SQLSegmentFiller<InsertDuplicateKeyColumnsSegment, ShardingRule> {
+public final class OnDuplicateKeyColumnsFiller implements SQLSegmentFiller<OnDuplicateKeyColumnsSegment, ShardingRule> {
     
     @Override
-    public void fill(final InsertDuplicateKeyColumnsSegment sqlSegment, 
+    public void fill(final OnDuplicateKeyColumnsSegment sqlSegment, 
                      final SQLStatement sqlStatement, final ShardingRule shardingRule, final ShardingTableMetaData shardingTableMetaData) {
         String tableName = sqlStatement.getTables().getSingleTableName();
         for (ColumnSegment each : sqlSegment.getColumns()) {
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/assignment/SetAssignmentsSegment.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/assignment/SetAssignmentsSegment.java
index c050a0b5c7454..c1c68717bbe7a 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/assignment/SetAssignmentsSegment.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/assignment/SetAssignmentsSegment.java
@@ -20,8 +20,6 @@
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import org.apache.shardingsphere.core.parse.antlr.sql.segment.SQLSegment;
-import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.ColumnSegment;
-import org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.expr.CommonExpressionSegment;
 
 import java.util.Collection;
 
@@ -36,7 +34,5 @@ public final class SetAssignmentsSegment implements SQLSegment {
     
     private final int startIndex;
     
-    private final Collection<ColumnSegment> columns;
-    
-    private final Collection<CommonExpressionSegment> values;
+    private final Collection<AssignmentSegment> assignments;
 }
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/column/InsertDuplicateKeyColumnsSegment.java b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/column/OnDuplicateKeyColumnsSegment.java
similarity index 90%
rename from sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/column/InsertDuplicateKeyColumnsSegment.java
rename to sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/column/OnDuplicateKeyColumnsSegment.java
index 6f887dc32b50e..0106680b41670 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/column/InsertDuplicateKeyColumnsSegment.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/sql/segment/dml/column/OnDuplicateKeyColumnsSegment.java
@@ -24,13 +24,13 @@
 import java.util.Collection;
 
 /**
- * Insert duplicate key columns segment.
+ * On duplicate key columns segment.
  *
  * @author zhangliang
  */
 @RequiredArgsConstructor
 @Getter
-public final class InsertDuplicateKeyColumnsSegment implements SQLSegment {
+public final class OnDuplicateKeyColumnsSegment implements SQLSegment {
     
     private final Collection<ColumnSegment> columns;
 }
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/resources/META-INF/parsing-rule-definition/common/extractor-rule-definition.xml b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/resources/META-INF/parsing-rule-definition/common/extractor-rule-definition.xml
index 3b5dffe2ed103..04c6be0050bc8 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/resources/META-INF/parsing-rule-definition/common/extractor-rule-definition.xml
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/resources/META-INF/parsing-rule-definition/common/extractor-rule-definition.xml
@@ -29,7 +29,7 @@
     <extractor-rule id="insertColumns" extractor-class="org.apache.shardingsphere.core.parse.antlr.extractor.impl.dml.insert.InsertColumnsExtractor" />
     <extractor-rule id="insertValues" extractor-class="org.apache.shardingsphere.core.parse.antlr.extractor.impl.dml.insert.InsertValuesExtractor" />
     <extractor-rule id="setAssignments" extractor-class="org.apache.shardingsphere.core.parse.antlr.extractor.impl.dml.SetAssignmentsExtractor" />
-    <extractor-rule id="insertDuplicateKeyColumns" extractor-class="org.apache.shardingsphere.core.parse.antlr.extractor.impl.dml.insert.InsertDuplicateKeyColumnsExtractor" />
+    <extractor-rule id="onDuplicateKeyColumns" extractor-class="org.apache.shardingsphere.core.parse.antlr.extractor.impl.dml.insert.OnDuplicateKeyColumnsExtractor" />
     <extractor-rule id="selectClause" extractor-class="org.apache.shardingsphere.core.parse.antlr.extractor.impl.dml.select.SelectClauseExtractor" />
     <extractor-rule id="fromWhere" extractor-class="org.apache.shardingsphere.core.parse.antlr.extractor.impl.dml.select.FromWhereExtractor" />
     <extractor-rule id="updateSetWhere" extractor-class="org.apache.shardingsphere.core.parse.antlr.extractor.impl.dml.update.UpdateSetWhereExtractor" />
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/resources/META-INF/parsing-rule-definition/sharding/common/filler-rule-definition.xml b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/resources/META-INF/parsing-rule-definition/sharding/common/filler-rule-definition.xml
index d71abba4d4bb6..cfc915840349f 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/resources/META-INF/parsing-rule-definition/sharding/common/filler-rule-definition.xml
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/resources/META-INF/parsing-rule-definition/sharding/common/filler-rule-definition.xml
@@ -20,7 +20,7 @@
     <filler-rule sql-segment-class="org.apache.shardingsphere.core.parse.antlr.sql.segment.common.TableSegment" filler-class="org.apache.shardingsphere.core.parse.antlr.filler.sharding.dml.TableFiller" />
     <filler-rule sql-segment-class="org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.InsertValuesSegment" filler-class="org.apache.shardingsphere.core.parse.antlr.filler.sharding.dml.insert.InsertValuesFiller" />
     <filler-rule sql-segment-class="org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.assignment.SetAssignmentsSegment" filler-class="org.apache.shardingsphere.core.parse.antlr.filler.sharding.dml.SetAssignmentsFiller" />
-    <filler-rule sql-segment-class="org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.InsertDuplicateKeyColumnsSegment" filler-class="org.apache.shardingsphere.core.parse.antlr.filler.sharding.dml.insert.InsertDuplicateKeyColumnsFiller" />
+    <filler-rule sql-segment-class="org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.column.OnDuplicateKeyColumnsSegment" filler-class="org.apache.shardingsphere.core.parse.antlr.filler.sharding.dml.insert.OnDuplicateKeyColumnsFiller" />
     <filler-rule sql-segment-class="org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.FromWhereSegment" filler-class="org.apache.shardingsphere.core.parse.antlr.filler.sharding.dml.FromWhereFiller" />
     <filler-rule sql-segment-class="org.apache.shardingsphere.core.parse.antlr.sql.segment.dml.condition.SubqueryConditionSegment" filler-class="org.apache.shardingsphere.core.parse.antlr.filler.sharding.dml.select.SubqueryConditionFiller" />
 </filler-rule-definition>
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/antlr4/imports/mysql/DMLStatement.g4 b/sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/antlr4/imports/mysql/DMLStatement.g4
index 37ef9d2ee1b39..0e25e2224d3f9 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/antlr4/imports/mysql/DMLStatement.g4
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/antlr4/imports/mysql/DMLStatement.g4
@@ -20,7 +20,7 @@ grammar DMLStatement;
 import Symbol, Keyword, Literals, BaseRule;
 
 insert
-    : INSERT insertSpecification_ INTO? tableName partitionNames_? (insertValuesClause | setAssignmentsClause | insertSelectClause) insertOnDuplicateKeyClause?
+    : INSERT insertSpecification_ INTO? tableName partitionNames_? (insertValuesClause | setAssignmentsClause | insertSelectClause) onDuplicateKeyClause?
     ;
 
 insertSpecification_
@@ -39,7 +39,7 @@ insertSelectClause
     : columnNames? select
     ;
 
-insertOnDuplicateKeyClause
+onDuplicateKeyClause
     : ON DUPLICATE KEY UPDATE assignment (COMMA_ assignment)*
     ;
 
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/resources/META-INF/parsing-rule-definition/sharding/mysql/sql-statement-rule-definition.xml b/sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/resources/META-INF/parsing-rule-definition/sharding/mysql/sql-statement-rule-definition.xml
index 15b801cfe90ef..7204a87a28348 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/resources/META-INF/parsing-rule-definition/sharding/mysql/sql-statement-rule-definition.xml
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/resources/META-INF/parsing-rule-definition/sharding/mysql/sql-statement-rule-definition.xml
@@ -26,7 +26,7 @@
     <sql-statement-rule context="createIndex" sql-statement-class="org.apache.shardingsphere.core.parse.antlr.sql.statement.ddl.DDLStatement" extractor-rule-refs="tableName, indexName" />
     <sql-statement-rule context="dropIndex" sql-statement-class="org.apache.shardingsphere.core.parse.antlr.sql.statement.ddl.DDLStatement" extractor-rule-refs="tableName, indexName" />
     
-    <sql-statement-rule context="insert" sql-statement-class="org.apache.shardingsphere.core.parse.antlr.sql.statement.dml.InsertStatement" extractor-rule-refs="tableNames, insertColumns, insertValues, setAssignments, insertDuplicateKeyColumns"/>
+    <sql-statement-rule context="insert" sql-statement-class="org.apache.shardingsphere.core.parse.antlr.sql.statement.dml.InsertStatement" extractor-rule-refs="tableNames, insertColumns, insertValues, setAssignments, onDuplicateKeyColumns"/>
     <sql-statement-rule context="update" sql-statement-class="org.apache.shardingsphere.core.parse.antlr.sql.statement.dml.DMLStatement" extractor-rule-refs="tableNames, updateWhere"/>
     <sql-statement-rule context="delete" sql-statement-class="org.apache.shardingsphere.core.parse.antlr.sql.statement.dml.DMLStatement" extractor-rule-refs="tableNames, deleteFromWhere"/>
     <sql-statement-rule context="select" sql-statement-class="org.apache.shardingsphere.core.parse.antlr.sql.statement.dml.SelectStatement"
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/AntlrIntegrateParsingTest.java b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/AntlrIntegrateParsingTest.java
index 771aa6e865a70..e3b33e3f2fece 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/AntlrIntegrateParsingTest.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/AntlrIntegrateParsingTest.java
@@ -91,7 +91,7 @@ public void assertSupportedSQL() {
                 execDatabaseType = DatabaseType.MySQL;
             }
             new SQLStatementAssert(new AntlrParsingEngine(execDatabaseType, sql, AbstractBaseIntegrateSQLParsingTest.getShardingRule(), 
-                    AbstractBaseIntegrateSQLParsingTest.getShardingTableMetaData()).parse(), sqlCaseId, sqlCaseType, sqlCasesLoader, parserResultSetLoader).assertSQLStatement();
+                    AbstractBaseIntegrateSQLParsingTest.getShardingTableMetaData()).parse(), sqlCaseId, sqlCaseType, sqlCasesLoader, parserResultSetLoader, execDatabaseType).assertSQLStatement();
         }
     }
 }
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/ddl/IntegrateDDLParsingCompatibleTest.java b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/ddl/IntegrateDDLParsingCompatibleTest.java
index 8685cb398b22e..32fe528b0a6f1 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/ddl/IntegrateDDLParsingCompatibleTest.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/ddl/IntegrateDDLParsingCompatibleTest.java
@@ -85,6 +85,6 @@ public void assertSupportedSQL() {
         }
         new SQLStatementAssert(new AntlrParsingEngine(
                 execDatabaseType, sql, AbstractBaseIntegrateSQLParsingTest.getShardingRule(), 
-                AbstractBaseIntegrateSQLParsingTest.getShardingTableMetaData()).parse(), sqlCaseId, sqlCaseType, sqlCasesLoader, parserResultSetLoader).assertSQLStatement();
+                AbstractBaseIntegrateSQLParsingTest.getShardingTableMetaData()).parse(), sqlCaseId, sqlCaseType, sqlCasesLoader, parserResultSetLoader, execDatabaseType).assertSQLStatement();
     }
 }
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/SQLStatementAssert.java b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/SQLStatementAssert.java
index 59d8bef33e616..61dca58184d8a 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/SQLStatementAssert.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/SQLStatementAssert.java
@@ -17,6 +17,10 @@
 
 package org.apache.shardingsphere.core.parse.integrate.asserts;
 
+import static org.hamcrest.CoreMatchers.is;
+import static org.junit.Assert.assertThat;
+
+import org.apache.shardingsphere.core.constant.DatabaseType;
 import org.apache.shardingsphere.core.parse.antlr.sql.statement.SQLStatement;
 import org.apache.shardingsphere.core.parse.antlr.sql.statement.ddl.AlterTableStatement;
 import org.apache.shardingsphere.core.parse.antlr.sql.statement.ddl.CreateTableStatement;
@@ -36,9 +40,6 @@
 import org.apache.shardingsphere.test.sql.SQLCaseType;
 import org.apache.shardingsphere.test.sql.SQLCasesLoader;
 
-import static org.hamcrest.CoreMatchers.is;
-import static org.junit.Assert.assertThat;
-
 /**
  * SQL statement assert.
  *
@@ -70,17 +71,19 @@ public final class SQLStatementAssert {
     
     private final AlterTableAssert alterTableAssert;
     
-    public SQLStatementAssert(final SQLStatement actual, final String sqlCaseId, final SQLCaseType sqlCaseType) {
-        this(actual, sqlCaseId, sqlCaseType, SQLCasesLoader.getInstance(), ParserResultSetLoader.getInstance());
+    private final DatabaseType databaseType;
+    
+    public SQLStatementAssert(final SQLStatement actual, final String sqlCaseId, final SQLCaseType sqlCaseType, final DatabaseType databaseType) {
+        this(actual, sqlCaseId, sqlCaseType, SQLCasesLoader.getInstance(), ParserResultSetLoader.getInstance(), databaseType);
     }
     
-    public SQLStatementAssert(final SQLStatement actual, final String sqlCaseId, final SQLCaseType sqlCaseType, final SQLCasesLoader sqlLoader, final ParserResultSetLoader parserResultSetLoader) {
+    public SQLStatementAssert(final SQLStatement actual, final String sqlCaseId, final SQLCaseType sqlCaseType, final SQLCasesLoader sqlLoader, final ParserResultSetLoader parserResultSetLoader, final DatabaseType databaseType) {
         SQLStatementAssertMessage assertMessage = new SQLStatementAssertMessage(sqlLoader, parserResultSetLoader, sqlCaseId, sqlCaseType);
         this.actual = actual;
         expected = parserResultSetLoader.getParserResult(sqlCaseId);
         tableAssert = new TableAssert(assertMessage);
         conditionAssert = new ConditionAssert(assertMessage);
-        tokenAssert = new TokenAssert(sqlCaseType, assertMessage);
+        tokenAssert = new TokenAssert(sqlCaseType, assertMessage, databaseType);
         indexAssert = new IndexAssert(sqlCaseType, assertMessage);
         itemAssert = new ItemAssert(assertMessage);
         groupByAssert = new GroupByAssert(assertMessage);
@@ -88,6 +91,7 @@ public SQLStatementAssert(final SQLStatement actual, final String sqlCaseId, fin
         limitAssert = new LimitAssert(sqlCaseType, assertMessage);
         metaAssert = new TableMetaDataAssert(assertMessage);
         alterTableAssert = new AlterTableAssert(assertMessage);
+        this.databaseType = databaseType;
     }
     
     /**
@@ -96,7 +100,9 @@ public SQLStatementAssert(final SQLStatement actual, final String sqlCaseId, fin
     public void assertSQLStatement() {
         tableAssert.assertTables(actual.getTables(), expected.getTables());
         conditionAssert.assertOrCondition(actual.getRouteConditions().getOrCondition(), expected.getOrCondition());
-        //conditionAssert.assertOrCondition(actual.getEncryptConditions().getOrCondition(), expected.getEncryptCondition());
+        if(DatabaseType.MySQL == databaseType) {
+            conditionAssert.assertOrCondition(actual.getEncryptConditions().getOrCondition(), expected.getEncryptCondition());
+        }
         tokenAssert.assertTokens(actual.getSQLTokens(), expected.getTokens());
         indexAssert.assertParametersIndex(actual.getParametersIndex(), expected.getParameters().size());
         if (actual instanceof SelectStatement) {
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/token/EncryptColumnTokenAssert.java b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/token/EncryptColumnTokenAssert.java
index f208e3bea7296..5129f79a09e18 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/token/EncryptColumnTokenAssert.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/token/EncryptColumnTokenAssert.java
@@ -31,14 +31,17 @@
 import org.apache.shardingsphere.core.parse.integrate.jaxb.token.ExpectedTokens;
 import org.apache.shardingsphere.core.parse.parser.token.EncryptColumnToken;
 import org.apache.shardingsphere.core.parse.parser.token.SQLToken;
+import org.apache.shardingsphere.test.sql.SQLCaseType;
 
 import lombok.RequiredArgsConstructor;
 @RequiredArgsConstructor
 public final class EncryptColumnTokenAssert {
     
+    private final SQLCaseType sqlCaseType;
+    
     private final SQLStatementAssertMessage assertMessage;
     
-    void assertIndexToken(final Collection<SQLToken> actual, final ExpectedTokens expected) {
+    void assertEncryptColumnsToken(final Collection<SQLToken> actual, final ExpectedTokens expected) {
         List<EncryptColumnToken> encryptColumnTokens = getEncryptColumnTokens(actual);
         assertThat(assertMessage.getFullAssertMessage("Encrypt column tokens size error: "), encryptColumnTokens.size(), is(expected.getEncryptColumnTokens().size()));
         int count = 0;
@@ -49,8 +52,13 @@ void assertIndexToken(final Collection<SQLToken> actual, final ExpectedTokens ex
     }
     
     private void assertEncryptColumnToken(final EncryptColumnToken actual, final ExpectedEncryptColumnToken expected) {
-        assertThat(assertMessage.getFullAssertMessage("Encrypt column start index assertion error: "), actual.getStartIndex(), is(expected.getStartIndex()));
-        assertThat(assertMessage.getFullAssertMessage("Encrypt column stop index assertion error: "), actual.getStopIndex(), is(expected.getStopIndex()));
+        if(SQLCaseType.Placeholder == sqlCaseType){
+            assertThat(assertMessage.getFullAssertMessage("Encrypt column start index for placeholder assertion error: "), actual.getStartIndex(), is(expected.getStartIndexForPlaceholder()));
+            assertThat(assertMessage.getFullAssertMessage("Encrypt column stop index for placeholder assertion error: "), actual.getStopIndex(), is(expected.getStopIndexForPlaceholder()));
+        }else {
+            assertThat(assertMessage.getFullAssertMessage("Encrypt column start index for literal assertion error: "), actual.getStartIndex(), is(expected.getStartIndexForLiteral()));
+            assertThat(assertMessage.getFullAssertMessage("Encrypt column stop index for literal assertion error: "), actual.getStopIndex(), is(expected.getStopIndexForLiteral()));
+        }
         assertNotNull(assertMessage.getFullAssertMessage("Encrypt column does not exist assertion error: "), expected.getColumn());
         assertTrue(assertMessage.getFullAssertMessage("Missing encrypt column assertion error: "), actual.getColumn() != null);
         assertThat(assertMessage.getFullAssertMessage("Encrypt column name assertion error: "), actual.getColumn().getName(), is(expected.getColumn().getName()));
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/token/TokenAssert.java b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/token/TokenAssert.java
index c9651596e8053..afd21e5ffaf31 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/token/TokenAssert.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/asserts/token/TokenAssert.java
@@ -17,6 +17,7 @@
 
 package org.apache.shardingsphere.core.parse.integrate.asserts.token;
 
+import org.apache.shardingsphere.core.constant.DatabaseType;
 import org.apache.shardingsphere.core.parse.integrate.asserts.SQLStatementAssertMessage;
 import org.apache.shardingsphere.core.parse.integrate.jaxb.token.ExpectedTokens;
 import org.apache.shardingsphere.core.parse.parser.token.SQLToken;
@@ -51,7 +52,11 @@ public final class TokenAssert {
     
     private final AggregationDistinctTokenAssert aggregationDistinctTokenAssert;
     
-    public TokenAssert(final SQLCaseType sqlCaseType, final SQLStatementAssertMessage assertMessage) {
+    private final EncryptColumnTokenAssert encryptColumnTokenAssert;
+    
+    private final DatabaseType databaseType;
+    
+    public TokenAssert(final SQLCaseType sqlCaseType, final SQLStatementAssertMessage assertMessage, final DatabaseType databaseType) {
         tableTokenAssert = new TableTokenAssert(assertMessage);
         schemaTokenAssert = new SchemaTokenAssert(assertMessage);
         indexTokenAssert = new IndexTokenAssert(assertMessage);
@@ -62,6 +67,8 @@ public TokenAssert(final SQLCaseType sqlCaseType, final SQLStatementAssertMessag
         offsetTokenAssert = new OffsetTokenAssert(sqlCaseType, assertMessage);
         rowCountTokenAssert = new RowCountTokenAssert(sqlCaseType, assertMessage);
         aggregationDistinctTokenAssert = new AggregationDistinctTokenAssert(assertMessage);
+        encryptColumnTokenAssert = new EncryptColumnTokenAssert(sqlCaseType, assertMessage);
+        this.databaseType = databaseType;
     }
     
     /**
@@ -81,5 +88,8 @@ public void assertTokens(final Collection<SQLToken> actual, final ExpectedTokens
         offsetTokenAssert.assertOffsetToken(actual, expected);
         rowCountTokenAssert.assertRowCountToken(actual, expected);
         aggregationDistinctTokenAssert.assertAggregationDistinctTokens(actual, expected);
+        if(DatabaseType.MySQL == databaseType) {
+            encryptColumnTokenAssert.assertEncryptColumnsToken(actual, expected);
+        }
     }
 }
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/engine/IntegrateSupportedSQLParsingTest.java b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/engine/IntegrateSupportedSQLParsingTest.java
index 28b25aaa44d2c..0d5bb4ddaae90 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/engine/IntegrateSupportedSQLParsingTest.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/engine/IntegrateSupportedSQLParsingTest.java
@@ -63,6 +63,6 @@ public void assertSupportedSQL() {
             return;
         }
         new SQLStatementAssert(new SQLParsingEngine(
-                databaseType, sql, getShardingRule(), getShardingTableMetaData(), new ParsingResultCache()).parse(false), sqlCaseId, sqlCaseType).assertSQLStatement();
+                databaseType, sql, getShardingRule(), getShardingTableMetaData(), new ParsingResultCache()).parse(false), sqlCaseId, sqlCaseType, databaseType).assertSQLStatement();
     }
 }
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/jaxb/token/ExpectedEncryptColumnToken.java b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/jaxb/token/ExpectedEncryptColumnToken.java
index 887ebad9ca842..41cdcf4836034 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/jaxb/token/ExpectedEncryptColumnToken.java
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/java/org/apache/shardingsphere/core/parse/integrate/jaxb/token/ExpectedEncryptColumnToken.java
@@ -29,11 +29,18 @@
 @XmlAccessorType(XmlAccessType.FIELD)
 public final class ExpectedEncryptColumnToken {
     
-    @XmlAttribute(name = "start-index")
-    private int startIndex;
+    @XmlAttribute(name = "start-index-for-placeholder")
+    private int startIndexForPlaceholder;
     
-    @XmlAttribute(name = "stop-index")
-    private int stopIndex;
+    @XmlAttribute(name = "stop-index-for-placeholder")
+    private int stopIndexForPlaceholder;
+    
+    
+    @XmlAttribute(name = "start-index-for-literal")
+    private int startIndexForLiteral;
+    
+    @XmlAttribute(name = "stop-index-for-literal")
+    private int stopIndexForLiteral;
     
     private ExpectedColumn column;
     
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/delete.xml b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/delete.xml
index 33d8c40edc5ae..28eb5dcc13c0c 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/delete.xml
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/delete.xml
@@ -23,6 +23,9 @@
         </tables>
         <tokens>
             <table-token start-index="12" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="59" stop-index-for-placeholder="66" start-index-for-literal="65" stop-index-for-literal="77" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -34,6 +37,13 @@
                 </condition>
             </and-condition>
         </or-condition>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="2" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="delete_without_sharding_value" parameters="'init'">
@@ -42,7 +52,17 @@
         </tables>
         <tokens>
             <table-token start-index="12" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="26" stop-index-for-placeholder="33" start-index-for-literal="26" stop-index-for-literal="38" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
 
     <parser-result sql-case-id="delete_with_special_character_without_sharding_value">
@@ -51,7 +71,17 @@
         </tables>
         <tokens>
             <table-token start-index="12" table-name="t_order" left-delimiter="`" right-delimiter="`" length="9" />
+            <encrypt-column-token start-index-for-placeholder="28" stop-index-for-placeholder="42" start-index-for-literal="28" stop-index-for-literal="42" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
 
     <parser-result sql-case-id="delete_with_special_comments_return_without_sharding_value">
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select.xml b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select.xml
index c48810a4d735d..075c37a1f6fc2 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select.xml
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select.xml
@@ -318,6 +318,9 @@
         <tokens>
             <table-token start-index="16" table-name="t_order" length="7" />
             <table-token start-index="31" table-name="t_order_item" length="12" />
+            <encrypt-column-token start-index-for-placeholder="208" stop-index-for-placeholder="219" start-index-for-literal="209" stop-index-for-literal="225" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -334,6 +337,13 @@
         <order-by-columns>
             <order-by-column owner="i" name="item_id" order-direction="ASC" />
         </order-by-columns>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="4" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_keyword_table_name_with_back_quotes" parameters="1, 2, 9, 10, 'init'">
@@ -344,6 +354,9 @@
         <tokens>
             <table-token start-index="16" table-name="t_order" length="7" />
             <table-token start-index="31" table-name="t_order_item" length="12" />
+            <encrypt-column-token start-index-for-placeholder="199" stop-index-for-placeholder="210" start-index-for-literal="200" stop-index-for-literal="216" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -360,6 +373,13 @@
         <order-by-columns>
             <order-by-column owner="i" name="item_id" order-direction="ASC" />
         </order-by-columns>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="4" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_keyword_table_name_with_double_quotes" parameters="1, 2, 9, 10, 'init'">
@@ -747,7 +767,17 @@
         </tables>
         <tokens>
             <table-token start-index="14" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="28" stop-index-for-placeholder="38" start-index-for-literal="28" stop-index-for-literal="38" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="\'" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_escape_with_double_quota" >
@@ -756,7 +786,17 @@
         </tables>
         <tokens>
             <table-token start-index="14" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="28" stop-index-for-placeholder="38" start-index-for-literal="28" stop-index-for-literal="38" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="\&quot;" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_with_block_comment" >
@@ -765,7 +805,17 @@
         </tables>
         <tokens>
             <table-token start-index="83" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="97" stop-index-for-placeholder="106" start-index-for-literal="97" stop-index-for-literal="106" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="1" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_with_single_comment" >
@@ -774,7 +824,17 @@
         </tables>
         <tokens>
             <table-token start-index="77" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="91" stop-index-for-placeholder="100" start-index-for-literal="91" stop-index-for-literal="100" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="1" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_alias_as_single_quote_string">
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select_or.xml b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select_or.xml
index 333dd21d22d9b..ed2640a05d373 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select_or.xml
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select_or.xml
@@ -65,7 +65,17 @@
         </tables>
         <tokens>
             <table-token start-index="14" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="44" stop-index-for-placeholder="53" start-index-for-literal="44" stop-index-for-literal="58" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="1" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_or_mix_and_for_simple_pattern" parameters="1, 'init', 3">
@@ -74,6 +84,9 @@
         </tables>
         <tokens>
             <table-token start-index="14" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="45" stop-index-for-placeholder="54" start-index-for-literal="45" stop-index-for-literal="59" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -90,6 +103,13 @@
                 </condition>
             </and-condition>
         </or-condition>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="1" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_or_mix_and_for_complex_pattern" parameters="'init', 1, 2, 3, 4">
@@ -98,6 +118,9 @@
         </tables>
         <tokens>
             <table-token start-index="14" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="30" stop-index-for-placeholder="39" start-index-for-literal="30" stop-index-for-literal="44" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -133,6 +156,13 @@
                 </condition>
             </and-condition>
         </or-condition>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_or_mix_and_with_binding_tables" parameters="1, 2, 3">
@@ -172,6 +202,9 @@
         <tokens>
             <table-token start-index="16" table-name="t_order" length="7" />
             <table-token start-index="31" table-name="t_order_item" length="12" />
+            <encrypt-column-token start-index-for-placeholder="210" stop-index-for-placeholder="221" start-index-for-literal="210" stop-index-for-literal="226" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -191,5 +224,12 @@
                 </condition>
             </and-condition>
         </or-condition>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="3" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
 </parser-result-sets>
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select_order_by.xml b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select_order_by.xml
index 6a0a3de65c50b..dfaafa5e0702e 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select_order_by.xml
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/select_order_by.xml
@@ -43,11 +43,21 @@
                     <item>o.order_id AS ORDER_BY_DERIVED_0 </item>
                 </items>
             </items-token>
+            <encrypt-column-token start-index-for-placeholder="76" stop-index-for-placeholder="92" start-index-for-literal="76" stop-index-for-literal="92" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <order-by-columns>
             <order-by-column owner="o" name="order_id" alias="ORDER_BY_DERIVED_0" order-direction="DESC" />
             <order-by-column index="1" order-direction="ASC" />
         </order-by-columns>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <parser-result sql-case-id="select_order_by_with_ordered_column">
@@ -75,12 +85,22 @@
                     <item>o.order_id AS ORDER_BY_DERIVED_0 </item>
                 </items>
             </items-token>
+            <encrypt-column-token start-index-for-placeholder="76" stop-index-for-placeholder="92" start-index-for-literal="76" stop-index-for-literal="92" is-in-where="true">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <order-by-columns>
             <order-by-column owner="i" name="creation_date" order-direction="DESC" />
             <order-by-column owner="o" name="order_id" alias="ORDER_BY_DERIVED_0" order-direction="DESC" />
             <order-by-column owner="i" name="item_id" order-direction="ASC" />
         </order-by-columns>
+        <encrypt-condition>
+            <and-condition>
+                <condition column-name="status" table-name="t_order" operator="EQUAL">
+                    <value index="0" literal="init" type="varchar" />
+                </condition>
+            </and-condition>
+        </encrypt-condition>
     </parser-result>
     
     <!-- //TODO add order-by-null-type -->
diff --git a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/update.xml b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/update.xml
index 473153d9904c6..cea6d59099ee7 100644
--- a/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/update.xml
+++ b/sharding-core/sharding-core-parse/sharding-core-parse-test/src/test/resources/parser/update.xml
@@ -23,6 +23,9 @@
         </tables>
         <tokens>
             <table-token start-index="7" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="19" stop-index-for-placeholder="28" start-index-for-literal="19" stop-index-for-literal="35" is-in-where="false">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -42,6 +45,9 @@
         </tables>
         <tokens>
             <table-token start-index="7" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="24" stop-index-for-placeholder="35" start-index-for-literal="24" stop-index-for-literal="42" is-in-where="false">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -80,6 +86,9 @@
         </tables>
         <tokens>
             <table-token start-index="7" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="21" stop-index-for-placeholder="41" start-index-for-literal="21" stop-index-for-literal="41" is-in-where="false">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
     </parser-result>
 
@@ -89,6 +98,9 @@
         </tables>
         <tokens>
             <table-token start-index="27" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="39" stop-index-for-placeholder="48" start-index-for-literal="39" stop-index-for-literal="55" is-in-where="false">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -108,6 +120,9 @@
         </tables>
         <tokens>
             <table-token start-index="7" table-name="t_order" left-delimiter="`" right-delimiter="`" length="9" />
+            <encrypt-column-token start-index-for-placeholder="21" stop-index-for-placeholder="32" start-index-for-literal="21" stop-index-for-literal="39" is-in-where="false">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -146,6 +161,9 @@
         </tables>
         <tokens>
             <table-token start-index="7" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="19" stop-index-for-placeholder="35" start-index-for-literal="19" stop-index-for-literal="35" is-in-where="false">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
@@ -165,6 +183,9 @@
         </tables>
         <tokens>
             <table-token start-index="7" table-name="t_order" length="7" />
+            <encrypt-column-token start-index-for-placeholder="19" stop-index-for-placeholder="35" start-index-for-literal="19" stop-index-for-literal="35" is-in-where="false">
+               <column table-name="t_order" name="status"/>
+            </encrypt-column-token>
         </tokens>
         <or-condition>
             <and-condition>
diff --git a/sharding-sql-test/src/main/resources/sql/dql/select.xml b/sharding-sql-test/src/main/resources/sql/dql/select.xml
index dcd6b834556fe..4f9ff5008c9bb 100644
--- a/sharding-sql-test/src/main/resources/sql/dql/select.xml
+++ b/sharding-sql-test/src/main/resources/sql/dql/select.xml
@@ -58,8 +58,8 @@
     <sql-case id="select_with_schema" value="SELECT * FROM db1.t_order" />
     <sql-case id="select_escape_with_single_quota" value="SELECT * FROM t_order where status='\''" db-types="MySQL" />
     <sql-case id="select_escape_with_double_quota" value="SELECT * FROM t_order where status=&quot;\&quot;&quot;" db-types="MySQL" />
-    <sql-case id="select_with_block_comment" value="SELECT * /* this is &#x000D;&#x000A; block comment */ FROM /* this is another &#x000A; block comment */ t_order where status=1" db-types="MySQL" />
-    <sql-case id="select_with_single_comment" value="SELECT * -- this is an line comment &#x000D;&#x000A; FROM --this is another line comment &#x000A; t_order where status=1" db-types="MySQL" />
+    <sql-case id="select_with_block_comment" value="SELECT * /* this is &#x000D;&#x000A; block comment */ FROM /* this is another &#x000A; block comment */ t_order where status='1'" db-types="MySQL" />
+    <sql-case id="select_with_single_comment" value="SELECT * -- this is an line comment &#x000D;&#x000A; FROM --this is another line comment &#x000A; t_order where status='1'" db-types="MySQL" />
     <sql-case id="select_alias_as_single_quote_string" value="SELECT status as 'status' FROM t_order" />
     <sql-case id="select_alias_as_string_double_quote" value="SELECT status as &quot;status&quot; FROM t_order" />
 </sql-cases>