View Javadoc
1   /*
2    * Licensed to the Apache Software Foundation (ASF) under one or more
3    * contributor license agreements.  See the NOTICE file distributed with
4    * this work for additional information regarding copyright ownership.
5    * The ASF licenses this file to You under the Apache License, Version 2.0
6    * (the "License"); you may not use this file except in compliance with
7    * the License.  You may obtain a copy of the License at
8    *
9    *     http://www.apache.org/licenses/LICENSE-2.0
10   *
11   * Unless required by applicable law or agreed to in writing, software
12   * distributed under the License is distributed on an "AS IS" BASIS,
13   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14   * See the License for the specific language governing permissions and
15   * limitations under the License.
16   */
17  
18  package org.apache.shardingsphere.globalclock.distsql.parser.core;
19  
20  import org.antlr.v4.runtime.tree.ParseTree;
21  import org.apache.shardingsphere.distsql.parser.autogen.GlobalClockDistSQLStatementBaseVisitor;
22  import org.apache.shardingsphere.distsql.parser.autogen.GlobalClockDistSQLStatementParser.AlterGlobalClockRuleContext;
23  import org.apache.shardingsphere.distsql.parser.autogen.GlobalClockDistSQLStatementParser.GlobalClockRuleDefinitionContext;
24  import org.apache.shardingsphere.distsql.parser.autogen.GlobalClockDistSQLStatementParser.PropertiesDefinitionContext;
25  import org.apache.shardingsphere.distsql.parser.autogen.GlobalClockDistSQLStatementParser.PropertyContext;
26  import org.apache.shardingsphere.distsql.parser.autogen.GlobalClockDistSQLStatementParser.ShowGlobalClockRuleContext;
27  import org.apache.shardingsphere.globalclock.distsql.statement.queryable.ShowGlobalClockRuleStatement;
28  import org.apache.shardingsphere.globalclock.distsql.statement.updatable.AlterGlobalClockRuleStatement;
29  import org.apache.shardingsphere.sql.parser.api.ASTNode;
30  import org.apache.shardingsphere.sql.parser.api.visitor.SQLVisitor;
31  import org.apache.shardingsphere.sql.parser.sql.common.value.identifier.IdentifierValue;
32  
33  import java.util.Properties;
34  
35  /**
36   * SQL statement visitor for global clock DistSQL.
37   */
38  public final class GlobalClockDistSQLStatementVisitor extends GlobalClockDistSQLStatementBaseVisitor<ASTNode> implements SQLVisitor<ASTNode> {
39      
40      @Override
41      public ASTNode visitShowGlobalClockRule(final ShowGlobalClockRuleContext ctx) {
42          return new ShowGlobalClockRuleStatement();
43      }
44      
45      @Override
46      public ASTNode visitAlterGlobalClockRule(final AlterGlobalClockRuleContext ctx) {
47          GlobalClockRuleDefinitionContext ruleDefinitionContext = ctx.globalClockRuleDefinition();
48          return new AlterGlobalClockRuleStatement(getIdentifierValue(ruleDefinitionContext.typeDefinition().typeName()), getIdentifierValue(ruleDefinitionContext.providerDefinition().providerName()),
49                  Boolean.parseBoolean(getIdentifierValue(ruleDefinitionContext.enabledDefinition().enabled())), getProperties(ruleDefinitionContext.propertiesDefinition()));
50      }
51      
52      private String getIdentifierValue(final ParseTree context) {
53          return null == context ? null : new IdentifierValue(context.getText()).getValue();
54      }
55      
56      private Properties getProperties(final PropertiesDefinitionContext ctx) {
57          Properties result = new Properties();
58          if (null == ctx || null == ctx.properties()) {
59              return result;
60          }
61          for (PropertyContext each : ctx.properties().property()) {
62              result.setProperty(IdentifierValue.getQuotedContent(each.key.getText()), IdentifierValue.getQuotedContent(each.value.getText()));
63          }
64          return result;
65      }
66  }