diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/mysql/MySQLSelectParser.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/mysql/MySQLSelectParser.java index 4d1eec1b9a486d2e06df0e9bcb3f7092fec7fa79..4eb08a17dd8cc28fbb09641e9cfe1327219c51b3 100755 --- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/mysql/MySQLSelectParser.java +++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/mysql/MySQLSelectParser.java @@ -40,8 +40,7 @@ public class MySQLSelectParser extends AbstractSelectParser { @Override public void query() { - if (getSqlParser().equalAny(DefaultKeyword.SELECT)) { - getSqlParser().getLexer().nextToken(); + if (getSqlParser().skipIfEqual(DefaultKeyword.SELECT)) { parseDistinct(); getSqlParser().skipAll(MySQLKeyword.HIGH_PRIORITY, DefaultKeyword.STRAIGHT_JOIN, MySQLKeyword.SQL_SMALL_RESULT, MySQLKeyword.SQL_BIG_RESULT, MySQLKeyword.SQL_BUFFER_RESULT, MySQLKeyword.SQL_CACHE, MySQLKeyword.SQL_NO_CACHE, MySQLKeyword.SQL_CALC_FOUND_ROWS); diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/oracle/OracleSelectParser.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/oracle/OracleSelectParser.java index f2212046ba020e05196f2c75f877f462dd353412..052aec4e08f652b07522eb1bfab1d08dda6d3b1a 100755 --- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/oracle/OracleSelectParser.java +++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/oracle/OracleSelectParser.java @@ -34,8 +34,7 @@ public class OracleSelectParser extends AbstractSelectParser { @Override public void query() { - if (getSqlParser().equalAny(DefaultKeyword.SELECT)) { - getSqlParser().getLexer().nextToken(); + if (getSqlParser().skipIfEqual(DefaultKeyword.SELECT)) { parseDistinct(); parseSelectList(); }