语法解析器，根据不同类型的语句有不同的语法解析器去解析成成SQLStatement，SQL解析器的类图我用脑图画出来如下:
SQLParser.png
可以看到，不同的sql有不同的处理解析器去解析，解析完成之后，会将SQL解析成SQLStatement,看一下SQLParser的定义:
public interface SQLParser {
SQLStatement parse();
}
| 方法名 | 说明 |
|---|---|
| SQLType getType() | 获取SQL类型，有DDL，DML，DQL，DAL，TCL |
| Tables getTables(); | 获取表集合 |
| Conditions getConditions(); | 获取条件 |
| List<SQLToken> getSqlTokens(); | 获取所有的SQLToken |
| int getParametersIndex() | 获取参数位置 |
| void setParametersIndex(int parametersIndex) | 重置参数位置 |
| int increaseParametersIndex() | 增加参数位置 |
除了语法解析器SQLParser,还有SQL从句解析器SQLClauseParser,SQL别名解析器AliasExpressionParser，表达式解析器BasicExpressionParser。
如下图：
SQLClauseParser.png
SQLStatement对象是个超类，具体实现类有很多。按照不同的语句，返回不同的SQLStatement。
SQLStatement.png
api如下：
| 方法名 | 说明 |
|---|---|
| SQLType getType() | 获取SQL类型，有DDL，DML，DQL，DAL，TCL |
| Tables getTables(); | 获取表集合 |
| Conditions getConditions(); | 获取条件 |
| List<SQLToken> getSqlTokens(); | 获取所有的SQLToken |
| int getParametersIndex() | 获取参数位置 |
| void setParametersIndex(int parametersIndex) | 重置参数位置 |
| int increaseParametersIndex() | 增加参数位置 |
不同的语句，ddl，dml，tcl等，有不同的语法解析器SQLParser去解析，Sharding-sphere如何根据不同的SQL去选择不同的SQLParser？
这里和词法分析器一样，同样是使用工厂模式，按照不同类型的SQL选择不同的语法解析器。根据数据库类型，DB类型分词解析器获取语法解析器。
public final class SQLParserFactory {
public static SQLParser newInstance(final DatabaseType dbType, final TokenType tokenType, final ShardingRule shardingRule, final LexerEngine lexerEngine, final ShardingMetaData shardingMetaData) {
//如果是DQL语句 select语句
if (isDQL(tokenType)) {
return getDQLParser(dbType, shardingRule, lexerEngine, shardingMetaData);
}
//DML语句 insert，update，delete语句
if (isDML(tokenType)) {
return getDMLParser(dbType, tokenType, shardingRule, lexerEngine, shardingMetaData);
}
//DDL语句 create，alter，drop，TRUNCATE语句
if (isDDL(tokenType)) {
return getDDLParser(dbType, tokenType, shardingRule, lexerEngine);
}
//TCL语句 set,commit,rollBack,savePoint,begin语句
if (isTCL(tokenType)) {
return getTCLParser(dbType, shardingRule, lexerEngine);
}
//DAL语句，use，desc，describe，show语句
if (isDAL(tokenType)) {
return getDALParser(dbType, (Keyword) tokenType, shardingRule, lexerEngine);
}
throw new SQLParsingUnsupportedException(tokenType);
}
}
这里以insert语句为例，看一下如何通过数据库类型选择不同的SQLParser
private static SQLParser getDMLParser(
final DatabaseType dbType, final TokenType tokenType, final ShardingRule shardingRule, final LexerEngine lexerEngine, final ShardingMetaData shardingMetaData) {
switch ((DefaultKeyword) tokenType) {
case INSERT:
//如果Insert语句
return InsertParserFactory.newInstance(dbType, shardingRule, lexerEngine, shardingMetaData);
case UPDATE:
return UpdateParserFactory.newInstance(dbType, shardingRule, lexerEngine);
case DELETE:
return DeleteParserFactory.newInstance(dbType, shardingRule, lexerEngine);
default:
throw new SQLParsingUnsupportedException(tokenType);
}
}
public final class InsertParserFactory {
public static AbstractInsertParser newInstance(final DatabaseType dbType, final ShardingRule shardingRule, final LexerEngine lexerEngine, final ShardingMetaData shardingMetaData) {
switch (dbType) {
case H2:
case MySQL:
return new MySQLInsertParser(shardingRule, lexerEngine, shardingMetaData);
case Oracle:
return new OracleInsertParser(shardingRule, lexerEngine, shardingMetaData);
case SQLServer:
return new SQLServerInsertParser(shardingRule, lexerEngine, shardingMetaData);
case PostgreSQL:
return new PostgreSQLInsertParser(shardingRule, lexerEngine, shardingMetaData);
default:
throw new UnsupportedOperationException(String.format("Cannot support database [%s].", dbType));
}
}
}
能够看到,通过多个Factory,根据SQL语句类型(DML，DDL)等路由到不同的方法，根据具体类型(Insert，update)等找到对应的工厂模式，按照不同的数据库类型返回具体的语法解析器SQLParser。
一条sql在执行的时候，如何知道是什么类型的语句？？
词法分析器Lexer在解析Sql的时候，第一个分词就是SQL的具体类型(select,update)，所以在执行sql的时候，首先调用词法分析器解析第一个分词，获取语句类型，然后选择具体的语法解析器解析。和分词器引擎一样，SQL语句解析器也有自己的解析引擎SQLParsingEngine
public final class SQLParsingEngine {
//数据库类型
private final DatabaseType dbType;
//sql
private final String sql;
//分片规则
private final ShardingRule shardingRule;
private final ShardingMetaData shardingMetaData;
public SQLStatement parse(final boolean useCache) {
//是否从缓存中获取
Optional<SQLStatement> cachedSQLStatement = getSQLStatementFromCache(useCache);
if (cachedSQLStatement.isPresent()) {
return cachedSQLStatement.get();
}
//词法解析器，根据不同的sql，获取不同的词法解析引擎
LexerEngine lexerEngine = LexerEngineFactory.newInstance(dbType, sql);
//解析第一个分词，第一个分词能区分sql类型
lexerEngine.nextToken();
//不同的sql解析器去做解析，完成解析工作，返回SQLStatement
SQLStatement result = SQLParserFactory.newInstance(dbType, lexerEngine.getCurrentToken().getType(), shardingRule, lexerEngine, shardingMetaData).parse();
if (useCache) {
ParsingResultCache.getInstance().put(sql, result);
}
return result;
}
}
所以sql语句解析的过程如下图：
语法解析器.png
终于把sql语法解析器的流程梳理清楚了。
下一篇，分析insert语句的流程。
