1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.parser.rule;
19
20 import lombok.Getter;
21 import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
22 import org.apache.shardingsphere.infra.parser.SQLParserEngine;
23 import org.apache.shardingsphere.infra.parser.ShardingSphereSQLParserEngine;
24 import org.apache.shardingsphere.infra.parser.SimpleSQLParserEngine;
25 import org.apache.shardingsphere.infra.rule.attribute.RuleAttributes;
26 import org.apache.shardingsphere.infra.rule.scope.GlobalRule;
27 import org.apache.shardingsphere.parser.config.SQLParserRuleConfiguration;
28 import org.apache.shardingsphere.sql.parser.api.CacheOption;
29
30
31
32
33 @Getter
34 public final class SQLParserRule implements GlobalRule {
35
36 private final SQLParserRuleConfiguration configuration;
37
38 private final CacheOption sqlStatementCache;
39
40 private final CacheOption parseTreeCache;
41
42 private final String engineType;
43
44 public SQLParserRule(final SQLParserRuleConfiguration ruleConfig) {
45 configuration = ruleConfig;
46 sqlStatementCache = ruleConfig.getSqlStatementCache();
47 parseTreeCache = ruleConfig.getParseTreeCache();
48 engineType = "Standard";
49 }
50
51
52
53
54
55
56
57 public SQLParserEngine getSQLParserEngine(final DatabaseType databaseType) {
58 return "Standard".equals(engineType)
59 ? new ShardingSphereSQLParserEngine(databaseType, sqlStatementCache, parseTreeCache)
60 : new SimpleSQLParserEngine();
61 }
62
63 @Override
64 public RuleAttributes getAttributes() {
65 return new RuleAttributes();
66 }
67 }