Skip to content

Commit

Permalink
Merge fe25dfc into 46f60b9
Browse files Browse the repository at this point in the history
  • Loading branch information
nancyzrh committed Jan 19, 2020
2 parents 46f60b9 + fe25dfc commit 68de985
Show file tree
Hide file tree
Showing 65 changed files with 93 additions and 60 deletions.
2 changes: 1 addition & 1 deletion .../shardingsphere/encrypt/rewrite/token/generator/impl/EncryptProjectionTokenGenerator.java
View file
Expand Up @@ -27,7 +27,7 @@
import org.apache.shardingsphere.sql.parser.sql.segment.dml.item.ColumnProjectionSegment;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.item.ProjectionSegment;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.item.ProjectionsSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.rewrite.sql.token.generator.CollectionSQLTokenGenerator;
import org.apache.shardingsphere.underlying.rewrite.sql.token.pojo.generic.SubstitutableColumnNameToken;

Expand Down
2 changes: 1 addition & 1 deletion .../org/apache/shardingsphere/masterslave/route/engine/impl/MasterSlaveDataSourceRouter.java
View file
Expand Up @@ -21,7 +21,7 @@
import org.apache.shardingsphere.api.hint.HintManager;
import org.apache.shardingsphere.core.rule.MasterSlaveRule;
import org.apache.shardingsphere.sql.parser.sql.statement.SQLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;

import java.util.ArrayList;

Expand Down
2 changes: 1 addition & 1 deletion ...ava/org/apache/shardingsphere/masterslave/route/engine/MasterSlaveRouteDecoratorTest.java
View file
Expand Up @@ -26,7 +26,7 @@
import org.apache.shardingsphere.sql.parser.sql.segment.dml.predicate.LockSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.SQLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.InsertStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.route.context.RouteContext;
import org.apache.shardingsphere.underlying.route.context.RouteResult;
import org.apache.shardingsphere.underlying.route.context.RouteUnit;
Expand Down
2 changes: 1 addition & 1 deletion ...c/test/java/org/apache/shardingsphere/masterslave/route/engine/MasterSlaveRouterTest.java
View file
Expand Up @@ -25,7 +25,7 @@
import org.apache.shardingsphere.sql.parser.SQLParseEngine;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.predicate.LockSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.InsertStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.route.context.RouteContext;
import org.junit.After;
import org.junit.Before;
Expand Down
2 changes: 1 addition & 1 deletion ...va/org/apache/shardingsphere/shadow/rewrite/judgement/impl/SimpleJudgementEngineTest.java
View file
Expand Up @@ -33,7 +33,7 @@
import org.apache.shardingsphere.sql.parser.sql.segment.dml.predicate.WhereSegment;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.predicate.value.PredicateCompareRightValue;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.InsertStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
Expand Down
2 changes: 1 addition & 1 deletion ...rc/test/java/org/apache/shardingsphere/sharding/merge/ShardingResultMergerEngineTest.java
View file
Expand Up @@ -33,7 +33,7 @@
import org.apache.shardingsphere.sql.parser.sql.segment.generic.TableSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dal.DALStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.InsertStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.common.constant.properties.ShardingSphereProperties;
import org.apache.shardingsphere.underlying.common.database.type.DatabaseTypes;
import org.apache.shardingsphere.underlying.merge.engine.merger.impl.TransparentResultMerger;
Expand Down
2 changes: 1 addition & 1 deletion ...c/test/java/org/apache/shardingsphere/sharding/merge/dql/ShardingDQLResultMergerTest.java
View file
Expand Up @@ -38,7 +38,7 @@
import org.apache.shardingsphere.sql.parser.sql.segment.dml.order.item.IndexOrderByItemSegment;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.pagination.limit.NumberLiteralLimitValueSegment;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.pagination.rownum.NumberLiteralRowNumberValueSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.executor.QueryResult;
import org.apache.shardingsphere.underlying.merge.result.MergedResult;
import org.junit.Test;
Expand Down
2 changes: 1 addition & 1 deletion ...a/org/apache/shardingsphere/sharding/merge/dql/groupby/GroupByMemoryMergedResultTest.java
View file
Expand Up @@ -30,7 +30,7 @@
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.impl.AggregationProjection;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.order.item.IndexOrderByItemSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.executor.QueryResult;
import org.apache.shardingsphere.underlying.merge.result.MergedResult;
import org.junit.Test;
Expand Down
2 changes: 1 addition & 1 deletion ...t/java/org/apache/shardingsphere/sharding/merge/dql/groupby/GroupByRowComparatorTest.java
View file
Expand Up @@ -29,7 +29,7 @@
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.ProjectionsContext;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.order.item.IndexOrderByItemSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.junit.Test;

import java.sql.ResultSet;
Expand Down
2 changes: 1 addition & 1 deletion ...a/org/apache/shardingsphere/sharding/merge/dql/groupby/GroupByStreamMergedResultTest.java
View file
Expand Up @@ -30,7 +30,7 @@
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.impl.AggregationProjection;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.order.item.IndexOrderByItemSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.executor.QueryResult;
import org.apache.shardingsphere.underlying.merge.result.MergedResult;
import org.junit.Test;
Expand Down
2 changes: 1 addition & 1 deletion ...org/apache/shardingsphere/sharding/merge/dql/iterator/IteratorStreamMergedResultTest.java
View file
Expand Up @@ -26,7 +26,7 @@
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.Projection;
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.ProjectionsContext;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.executor.QueryResult;
import org.apache.shardingsphere.underlying.merge.result.MergedResult;
import org.junit.Before;
Expand Down
2 changes: 1 addition & 1 deletion ...a/org/apache/shardingsphere/sharding/merge/dql/orderby/OrderByStreamMergedResultTest.java
View file
Expand Up @@ -28,7 +28,7 @@
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.ProjectionsContext;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.order.item.IndexOrderByItemSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.executor.QueryResult;
import org.apache.shardingsphere.underlying.merge.result.MergedResult;
import org.junit.Before;
Expand Down
2 changes: 1 addition & 1 deletion ...g/apache/shardingsphere/sharding/merge/dql/pagination/LimitDecoratorMergedResultTest.java
View file
Expand Up @@ -27,7 +27,7 @@
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.ProjectionsContext;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.pagination.limit.NumberLiteralLimitValueSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.executor.QueryResult;
import org.apache.shardingsphere.underlying.merge.result.MergedResult;
import org.junit.Test;
Expand Down
2 changes: 1 addition & 1 deletion ...ache/shardingsphere/sharding/merge/dql/pagination/RowNumberDecoratorMergedResultTest.java
View file
Expand Up @@ -27,7 +27,7 @@
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.ProjectionsContext;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.pagination.rownum.NumberLiteralRowNumberValueSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.executor.QueryResult;
import org.apache.shardingsphere.underlying.merge.result.MergedResult;
import org.junit.Test;
Expand Down
2 changes: 1 addition & 1 deletion ...hardingsphere/sharding/merge/dql/pagination/TopAndRowNumberDecoratorMergedResultTest.java
View file
Expand Up @@ -28,7 +28,7 @@
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.pagination.limit.NumberLiteralLimitValueSegment;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.pagination.rownum.NumberLiteralRowNumberValueSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.executor.QueryResult;
import org.apache.shardingsphere.underlying.merge.result.MergedResult;
import org.junit.Test;
Expand Down
2 changes: 1 addition & 1 deletion .../org/apache/shardingsphere/sharding/rewrite/token/generator/impl/TableTokenGenerator.java
View file
Expand Up @@ -30,7 +30,7 @@
import org.apache.shardingsphere.sql.parser.sql.segment.generic.TableAvailable;
import org.apache.shardingsphere.sql.parser.sql.segment.generic.TableSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.SQLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.rewrite.sql.token.generator.CollectionSQLTokenGenerator;
import org.apache.shardingsphere.core.rule.aware.ShardingRuleAware;
import org.apache.shardingsphere.sharding.rewrite.token.pojo.impl.TableToken;
Expand Down
6 changes: 4 additions & 2 deletions ...e-route/src/main/java/org/apache/shardingsphere/sharding/route/engine/ShardingRouter.java
View file
Expand Up @@ -23,6 +23,7 @@
import org.apache.shardingsphere.api.hint.HintManager;
import org.apache.shardingsphere.sharding.route.engine.context.ShardingRouteContext;
import org.apache.shardingsphere.sharding.route.engine.type.ShardingRouteEngineFactory;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.DQLStatement;
import org.apache.shardingsphere.underlying.route.DateNodeRouter;
import org.apache.shardingsphere.sharding.route.engine.condition.ShardingCondition;
import org.apache.shardingsphere.sharding.route.engine.condition.ShardingConditions;
Expand Down Expand Up @@ -83,7 +84,8 @@ public ShardingRouteContext route(final String sql, final List<Object> parameter
? GeneratedKey.getGenerateKey(shardingRule, metaData.getTables(), parameters, (InsertStatement) sqlStatement) : Optional.<GeneratedKey>absent();
ShardingConditions shardingConditions = getShardingConditions(parameters, sqlStatementContext, generatedKey.orNull(), metaData.getRelationMetas());
boolean needMergeShardingValues = isNeedMergeShardingValues(sqlStatementContext);
if (sqlStatementContext.getSqlStatement() instanceof DMLStatement && needMergeShardingValues) {
if ((sqlStatementContext.getSqlStatement() instanceof DMLStatement || sqlStatementContext.getSqlStatement() instanceof DQLStatement)
&& needMergeShardingValues) {
checkSubqueryShardingValues(sqlStatementContext, shardingConditions);
mergeShardingConditions(shardingConditions);
}
Expand All @@ -107,7 +109,7 @@ private SQLStatement parse(final String sql, final boolean useCache) {
}

private ShardingConditions getShardingConditions(final List<Object> parameters, final SQLStatementContext sqlStatementContext, final GeneratedKey generatedKey, final RelationMetas relationMetas) {
if (sqlStatementContext.getSqlStatement() instanceof DMLStatement) {
if (sqlStatementContext.getSqlStatement() instanceof DMLStatement || sqlStatementContext.getSqlStatement() instanceof DQLStatement) {
if (sqlStatementContext instanceof InsertSQLStatementContext) {
InsertSQLStatementContext shardingInsertStatement = (InsertSQLStatementContext) sqlStatementContext;
return new ShardingConditions(new InsertClauseShardingConditionEngine(shardingRule).createShardingConditions(shardingInsertStatement, generatedKey, parameters));
Expand Down
9 changes: 6 additions & 3 deletions ...java/org/apache/shardingsphere/sharding/route/engine/type/ShardingRouteEngineFactory.java
View file
Expand Up @@ -40,7 +40,8 @@
import org.apache.shardingsphere.sql.parser.sql.statement.dcl.DCLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.ddl.DDLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.DMLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.DQLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.tcl.TCLStatement;
import org.apache.shardingsphere.underlying.common.metadata.ShardingSphereMetaData;

Expand Down Expand Up @@ -85,10 +86,12 @@ public static ShardingRouteEngine newInstance(final ShardingRule shardingRule,
if (shardingRule.isAllBroadcastTables(tableNames)) {
return sqlStatement instanceof SelectStatement ? new ShardingUnicastRoutingEngine(tableNames) : new ShardingDatabaseBroadcastRoutingEngine();
}
if (sqlStatementContext.getSqlStatement() instanceof DMLStatement && tableNames.isEmpty() && shardingRule.hasDefaultDataSourceName()) {
if ((sqlStatementContext.getSqlStatement() instanceof DMLStatement || sqlStatementContext.getSqlStatement() instanceof DQLStatement)
&& tableNames.isEmpty() && shardingRule.hasDefaultDataSourceName()) {
return new ShardingDefaultDatabaseRoutingEngine(tableNames);
}
if (sqlStatementContext.getSqlStatement() instanceof DMLStatement && shardingConditions.isAlwaysFalse() || tableNames.isEmpty() || !shardingRule.tableRuleExists(tableNames)) {
if ((sqlStatementContext.getSqlStatement() instanceof DMLStatement || sqlStatementContext.getSqlStatement() instanceof DQLStatement)
&& shardingConditions.isAlwaysFalse() || tableNames.isEmpty() || !shardingRule.tableRuleExists(tableNames)) {
return new ShardingUnicastRoutingEngine(tableNames);
}
return getShardingRoutingEngine(shardingRule, sqlStatementContext, shardingConditions, tableNames);
Expand Down
2 changes: 1 addition & 1 deletion .../org/apache/shardingsphere/sharding/route/engine/type/ShardingRouteEngineFactoryTest.java
View file
Expand Up @@ -38,7 +38,7 @@
import org.apache.shardingsphere.sql.parser.sql.statement.dcl.DCLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.ddl.DDLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.InsertStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.tcl.TCLStatement;
import org.apache.shardingsphere.underlying.common.metadata.ShardingSphereMetaData;
import org.junit.Before;
Expand Down
2 changes: 1 addition & 1 deletion ...e/shardingsphere/sharding/route/engine/type/complex/ShardingComplexRoutingEngineTest.java
View file
Expand Up @@ -26,7 +26,7 @@
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.Projection;
import org.apache.shardingsphere.sql.parser.relation.segment.select.projection.ProjectionsContext;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.common.exception.ShardingSphereException;
import org.apache.shardingsphere.underlying.route.context.RouteResult;
import org.apache.shardingsphere.underlying.route.context.RouteUnit;
Expand Down
2 changes: 1 addition & 1 deletion ...shardingsphere/sharding/route/engine/type/standard/ShardingStandardRoutingEngineTest.java
View file
Expand Up @@ -32,7 +32,7 @@
import org.apache.shardingsphere.sql.parser.relation.statement.SQLStatementContext;
import org.apache.shardingsphere.sql.parser.relation.statement.impl.SelectSQLStatementContext;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.InsertStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.underlying.common.exception.ShardingSphereException;
import org.apache.shardingsphere.underlying.route.context.RouteResult;
import org.apache.shardingsphere.underlying.route.context.RouteUnit;
Expand Down
2 changes: 1 addition & 1 deletion ...est/sharding-jdbc-test/src/test/java/org/apache/shardingsphere/dbtest/engine/SQLType.java
View file
Expand Up @@ -24,7 +24,7 @@
import org.apache.shardingsphere.sql.parser.sql.statement.dcl.DCLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.ddl.DDLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.DMLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.tcl.TCLStatement;

/**
Expand Down
2 changes: 1 addition & 1 deletion ...rc/main/java/org/apache/shardingsphere/sql/parser/core/filler/impl/dml/GroupByFiller.java
View file
Expand Up @@ -20,7 +20,7 @@
import org.apache.shardingsphere.sql.parser.core.filler.SQLSegmentFiller;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.order.GroupBySegment;
import org.apache.shardingsphere.sql.parser.sql.statement.SQLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;

/**
* Group by filler.
Expand Down
2 changes: 1 addition & 1 deletion ...e/src/main/java/org/apache/shardingsphere/sql/parser/core/filler/impl/dml/LockFiller.java
View file
Expand Up @@ -20,7 +20,7 @@
import org.apache.shardingsphere.sql.parser.core.filler.SQLSegmentFiller;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.predicate.LockSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.SQLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;

/**
* lock filler.
Expand Down
2 changes: 1 addition & 1 deletion ...rc/main/java/org/apache/shardingsphere/sql/parser/core/filler/impl/dml/OrderByFiller.java
View file
Expand Up @@ -20,7 +20,7 @@
import org.apache.shardingsphere.sql.parser.core.filler.SQLSegmentFiller;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.order.OrderBySegment;
import org.apache.shardingsphere.sql.parser.sql.statement.SQLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;

/**
* Order by filler.
Expand Down
2 changes: 1 addition & 1 deletion ...ain/java/org/apache/shardingsphere/sql/parser/core/filler/impl/dml/ProjectionsFiller.java
View file
Expand Up @@ -20,7 +20,7 @@
import org.apache.shardingsphere.sql.parser.core.filler.SQLSegmentFiller;
import org.apache.shardingsphere.sql.parser.sql.segment.dml.item.ProjectionsSegment;
import org.apache.shardingsphere.sql.parser.sql.statement.SQLStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dml.SelectStatement;
import org.apache.shardingsphere.sql.parser.sql.statement.dql.SelectStatement;

/**
* projections filler.
Expand Down
28 changes: 28 additions & 0 deletions ...ne/src/main/java/org/apache/shardingsphere/sql/parser/sql/statement/dql/DQLStatement.java
View file
@@ -0,0 +1,28 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package org.apache.shardingsphere.sql.parser.sql.statement.dql;

import org.apache.shardingsphere.sql.parser.sql.statement.generic.AbstractSQLStatement;

/**
* DML statement.
*
* @author zhangliang
*/
public abstract class DQLStatement extends AbstractSQLStatement {
}

0 comments on commit 68de985

Please sign in to comment.