| Modifier and Type | Method and Description |
|---|---|
Class<ShardingRule> |
ShardingResultMergerEngine.getTypeClass() |
| Modifier and Type | Method and Description |
|---|---|
ResultMerger |
ShardingResultMergerEngine.newInstance(org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
ShardingRule shardingRule,
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties props,
SQLStatementContext sqlStatementContext) |
| Modifier and Type | Method and Description |
|---|---|
protected List<MemoryQueryResultRow> |
LogicTablesMergedResult.init(ShardingRule shardingRule,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema,
SQLStatementContext sqlStatementContext,
List<org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult> queryResults,
MergedResult mergedResult) |
protected List<MemoryQueryResultRow> |
ShowIndexMergedResult.init(ShardingRule shardingRule,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema,
SQLStatementContext sqlStatementContext,
List<org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult> queryResults,
MergedResult mergedResult) |
| Constructor and Description |
|---|
LogicTablesMergedResult(ShardingRule shardingRule,
SQLStatementContext sqlStatementContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema,
List<org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult> queryResults) |
ShowCreateTableMergedResult(ShardingRule shardingRule,
SQLStatementContext sqlStatementContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema,
List<org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult> queryResults) |
ShowIndexMergedResult(ShardingRule shardingRule,
SQLStatementContext sqlStatementContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema,
List<org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult> queryResults) |
| Modifier and Type | Method and Description |
|---|---|
protected List<MemoryQueryResultRow> |
GroupByMemoryMergedResult.init(ShardingRule shardingRule,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema,
SQLStatementContext sqlStatementContext,
List<org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult> queryResults,
MergedResult mergedResult) |
| Modifier and Type | Method and Description |
|---|---|
protected List<MemoryQueryResultRow> |
HavingDecoratorMergedResult.init(ShardingRule rule,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema,
SQLStatementContext sqlStatementContext,
List<org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult> queryResults,
MergedResult mergedResult) |
| Modifier and Type | Method and Description |
|---|---|
Class<ShardingRule> |
ShardingTableMetaDataBuilder.getTypeClass() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.shardingsphere.infra.metadata.schema.model.TableMetaData |
ShardingTableMetaDataBuilder.decorate(String tableName,
org.apache.shardingsphere.infra.metadata.schema.model.TableMetaData tableMetaData,
ShardingRule shardingRule) |
Optional<org.apache.shardingsphere.infra.metadata.schema.model.TableMetaData> |
ShardingTableMetaDataBuilder.load(String tableName,
org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
Map<String,DataSource> dataSourceMap,
org.apache.shardingsphere.infra.datanode.DataNodes dataNodes,
ShardingRule rule,
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties props) |
| Modifier and Type | Method and Description |
|---|---|
Class<ShardingRule> |
ShardingSQLRewriteContextDecorator.getTypeClass() |
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingSQLRewriteContextDecorator.decorate(ShardingRule shardingRule,
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties props,
SQLRewriteContext sqlRewriteContext,
RouteContext routeContext) |
| Constructor and Description |
|---|
ConstraintToken(int startIndex,
int stopIndex,
org.apache.shardingsphere.sql.parser.sql.common.value.identifier.IdentifierValue identifier,
SQLStatementContext sqlStatementContext,
ShardingRule shardingRule) |
IndexToken(int startIndex,
int stopIndex,
org.apache.shardingsphere.sql.parser.sql.common.value.identifier.IdentifierValue identifier,
SQLStatementContext sqlStatementContext,
ShardingRule shardingRule,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
TableToken(int startIndex,
int stopIndex,
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.table.SimpleTableSegment tableSegment,
SQLStatementContext sqlStatementContext,
ShardingRule shardingRule) |
| Modifier and Type | Method and Description |
|---|---|
Class<ShardingRule> |
ShardingSQLRouter.getTypeClass() |
| Modifier and Type | Method and Description |
|---|---|
RouteContext |
ShardingSQLRouter.createRouteContext(LogicSQL logicSQL,
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData metaData,
ShardingRule rule,
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties props) |
void |
ShardingSQLRouter.decorateRouteContext(RouteContext routeContext,
LogicSQL logicSQL,
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData metaData,
ShardingRule rule,
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties props) |
| Modifier and Type | Method and Description |
|---|---|
static ShardingConditionEngine<?> |
ShardingConditionEngineFactory.createShardingConditionEngine(LogicSQL logicSQL,
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData metaData,
ShardingRule rule)
Create new instance of sharding condition engine.
|
| Modifier and Type | Method and Description |
|---|---|
static ShardingRouteEngine |
ShardingRouteEngineFactory.newInstance(ShardingRule shardingRule,
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData metaData,
SQLStatementContext<?> sqlStatementContext,
ShardingConditions shardingConditions,
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties props)
Create new instance of routing engine.
|
void |
ShardingRouteEngine.route(RouteContext routeContext,
ShardingRule shardingRule)
Route.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingTableBroadcastRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
void |
ShardingDatabaseBroadcastRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
void |
ShardingDataSourceGroupBroadcastRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
void |
ShardingInstanceBroadcastRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingCartesianRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
void |
ShardingComplexRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingFederatedRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingIgnoreRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
| Modifier and Type | Method and Description |
|---|---|
void |
SingleTablesRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingStandardRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingUnicastRoutingEngine.route(RouteContext routeContext,
ShardingRule shardingRule) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<T> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema)
Validate whether sharding operation is supported after route.
|
void |
ShardingStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<T> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema)
Validate whether sharding operation is supported before route.
|
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
ShardingDDLStatementValidator.isRouteUnitDataNodeDifferentSize(ShardingRule shardingRule,
RouteContext routeContext,
String tableName)
Judge whether route unit and data node are different size or not.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingAlterIndexStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterIndexStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingAlterTableStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterTableStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingAlterViewStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterViewStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateFunctionStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateFunctionStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateIndexStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateIndexStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateProcedureStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateProcedureStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateTableStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateTableStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateViewStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateViewStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingDropIndexStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.DropIndexStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingDropTableStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.DropTableStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingPrepareStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLPrepareStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingAlterIndexStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterIndexStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingAlterTableStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterTableStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingAlterViewStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterViewStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateFunctionStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateFunctionStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateIndexStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateIndexStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateProcedureStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateProcedureStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateTableStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateTableStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingCreateViewStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateViewStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingDropIndexStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.DropIndexStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingDropTableStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.DropTableStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingPrepareStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLPrepareStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
ShardingDMLStatementValidator.checkSubqueryShardingValues(ShardingRule shardingRule,
SQLStatementContext sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
protected boolean |
ShardingDMLStatementValidator.isNeedMergeShardingValues(SQLStatementContext<?> sqlStatementContext,
ShardingRule rule) |
protected void |
ShardingDMLStatementValidator.validateShardingMultipleTable(ShardingRule shardingRule,
SQLStatementContext<T> sqlStatementContext)
Validate sharding multiple table.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingDeleteStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.dml.DeleteStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingInsertStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.dml.InsertStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingSelectStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.dml.SelectStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingUpdateStatementValidator.postValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.dml.UpdateStatement> sqlStatementContext,
RouteContext routeContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingDeleteStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.dml.DeleteStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingInsertStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.dml.InsertStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingSelectStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.dml.SelectStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
void |
ShardingUpdateStatementValidator.preValidate(ShardingRule shardingRule,
SQLStatementContext<org.apache.shardingsphere.sql.parser.sql.common.statement.dml.UpdateStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShardingRuleAware.setShardingRule(ShardingRule shardingRule)
Set sharding rule.
|
| Modifier and Type | Method and Description |
|---|---|
ShardingRule |
AlgorithmProvidedShardingRuleBuilder.build(String schemaName,
Map<String,DataSource> dataSourceMap,
org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
AlgorithmProvidedShardingRuleConfiguration config) |
ShardingRule |
ShardingRuleBuilder.build(String schemaName,
Map<String,DataSource> dataSourceMap,
org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
ShardingRuleConfiguration config) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.