| 限定符和类型 | 方法和说明 |
|---|---|
Class<ShardingRule> |
ShardingResultMergerEngine.getTypeClass() |
| 限定符和类型 | 方法和说明 |
|---|---|
ResultMerger |
ShardingResultMergerEngine.newInstance(String schemaName,
org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
ShardingRule shardingRule,
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties props,
SQLStatementContext sqlStatementContext) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected List<MemoryQueryResultRow> |
ShowTableStatusMergedResult.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) |
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) |
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) |
| 构造器和说明 |
|---|
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) |
ShowTableStatusMergedResult(ShardingRule shardingRule,
SQLStatementContext sqlStatementContext,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema,
List<org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult> queryResults) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
Class<ShardingRule> |
ShardingTableMetaDataBuilder.getTypeClass() |
| 限定符和类型 | 方法和说明 |
|---|---|
org.apache.shardingsphere.infra.metadata.schema.model.TableMetaData |
ShardingTableMetaDataBuilder.decorate(String tableName,
org.apache.shardingsphere.infra.metadata.schema.model.TableMetaData tableMetaData,
ShardingRule shardingRule) |
Map<String,org.apache.shardingsphere.infra.metadata.schema.model.TableMetaData> |
ShardingTableMetaDataBuilder.load(Collection<String> tableNames,
ShardingRule rule,
org.apache.shardingsphere.infra.metadata.schema.builder.SchemaBuilderMaterials materials) |
| 限定符和类型 | 方法和说明 |
|---|---|
Class<ShardingRule> |
ShardingSQLRewriteContextDecorator.getTypeClass() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
ShardingSQLRewriteContextDecorator.decorate(ShardingRule shardingRule,
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties props,
SQLRewriteContext sqlRewriteContext,
RouteContext routeContext) |
| 构造器和说明 |
|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
Class<ShardingRule> |
ShardingSQLRouter.getTypeClass() |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 构造器和说明 |
|---|
ShardingConditions(List<ShardingCondition> conditions,
SQLStatementContext<?> sqlStatementContext,
ShardingRule rule) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ShardingConditionEngine<?> |
ShardingConditionEngineFactory.createShardingConditionEngine(LogicSQL logicSQL,
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData metaData,
ShardingRule rule)
Create new instance of sharding condition engine.
|
| 限定符和类型 | 方法和说明 |
|---|---|
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.
|
RouteContext |
ShardingRouteEngine.route(ShardingRule shardingRule)
Route.
|
| 限定符和类型 | 方法和说明 |
|---|---|
RouteContext |
ShardingTableBroadcastRoutingEngine.route(ShardingRule shardingRule) |
RouteContext |
ShardingDatabaseBroadcastRoutingEngine.route(ShardingRule shardingRule) |
RouteContext |
ShardingDataSourceGroupBroadcastRoutingEngine.route(ShardingRule shardingRule) |
RouteContext |
ShardingInstanceBroadcastRoutingEngine.route(ShardingRule shardingRule) |
| 限定符和类型 | 方法和说明 |
|---|---|
RouteContext |
ShardingCartesianRoutingEngine.route(ShardingRule shardingRule) |
RouteContext |
ShardingComplexRoutingEngine.route(ShardingRule shardingRule) |
| 限定符和类型 | 方法和说明 |
|---|---|
RouteContext |
ShardingFederatedRoutingEngine.route(ShardingRule shardingRule) |
| 限定符和类型 | 方法和说明 |
|---|---|
RouteContext |
ShardingIgnoreRoutingEngine.route(ShardingRule shardingRule) |
| 限定符和类型 | 方法和说明 |
|---|---|
RouteContext |
ShardingStandardRoutingEngine.route(ShardingRule shardingRule) |
| 限定符和类型 | 方法和说明 |
|---|---|
RouteContext |
ShardingUnicastRoutingEngine.route(ShardingRule shardingRule) |
| 限定符和类型 | 方法和说明 |
|---|---|
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.
|
| 限定符和类型 | 方法和说明 |
|---|---|
protected boolean |
ShardingDDLStatementValidator.isRouteUnitDataNodeDifferentSize(ShardingRule shardingRule,
RouteContext routeContext,
String tableName)
Judge whether route unit and data node are different size or not.
|
| 限定符和类型 | 方法和说明 |
|---|---|
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.common.statement.ddl.PrepareStatement> 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.common.statement.ddl.PrepareStatement> sqlStatementContext,
List<Object> parameters,
org.apache.shardingsphere.infra.metadata.schema.ShardingSphereSchema schema) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
ShardingDMLStatementValidator.validateMultipleTable(ShardingRule shardingRule,
SQLStatementContext<T> sqlStatementContext)
Validate multiple table.
|
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
ShardingRuleAware.setShardingRule(ShardingRule shardingRule)
Set sharding rule.
|
| 限定符和类型 | 方法和说明 |
|---|---|
ShardingRule |
AlgorithmProvidedShardingRuleBuilder.build(org.apache.shardingsphere.infra.rule.builder.schema.SchemaRulesBuilderMaterials materials,
AlgorithmProvidedShardingRuleConfiguration config,
Collection<org.apache.shardingsphere.infra.rule.ShardingSphereRule> builtRules) |
ShardingRule |
ShardingRuleBuilder.build(org.apache.shardingsphere.infra.rule.builder.schema.SchemaRulesBuilderMaterials materials,
ShardingRuleConfiguration config,
Collection<org.apache.shardingsphere.infra.rule.ShardingSphereRule> builtRules) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.