This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new d7b5bf6064a Fix sonar issues on Replace this lambda with method
reference (#25726)
d7b5bf6064a is described below
commit d7b5bf6064a1de136186db8f7f0be507cdef67c3
Author: Liang Zhang <[email protected]>
AuthorDate: Wed May 17 14:19:12 2023 +0800
Fix sonar issues on Replace this lambda with method reference (#25726)
---
.../shadow/distsql/parser/core/ShadowDistSQLStatementVisitor.java | 8 ++++----
.../org/apache/shardingsphere/sharding/rule/ShardingRule.java | 2 +-
.../sharding/yaml/swapper/ShardingRuleConfigurationConverter.java | 2 +-
.../handler/checker/ShardingTableRuleStatementChecker.java | 4 ++--
.../handler/update/CreateBroadcastTableRuleStatementUpdater.java | 2 +-
.../select/subquery/engine/SubqueryTableContextEngine.java | 2 +-
.../infra/binder/statement/dml/SelectStatementContext.java | 2 +-
.../java/org/apache/shardingsphere/infra/datanode/DataNodes.java | 2 +-
.../metadata/data/collector/tables/PgClassTableCollector.java | 2 +-
.../metadata/database/schema/builder/GenericSchemaBuilder.java | 4 ++--
.../driver/jdbc/core/datasource/ShardingSphereDataSource.java | 2 +-
.../core/datasource/metadata/ShardingSphereDatabaseMetaData.java | 2 +-
.../jdbc/core/statement/ShardingSpherePreparedStatement.java | 2 +-
.../driver/jdbc/core/statement/ShardingSphereStatement.java | 8 ++++----
.../pipeline/cdc/core/connector/SocketSinkImporterConnector.java | 2 +-
.../data/pipeline/core/importer/DataSourceImporter.java | 2 +-
.../handler/update/RegisterMigrationSourceStorageUnitUpdater.java | 2 +-
.../persist/service/config/global/GlobalRulePersistService.java | 4 ++--
.../java/org/apache/shardingsphere/single/rule/SingleRule.java | 2 +-
.../sqlfederation/executor/FilterableTableScanExecutor.java | 2 +-
.../sqlfederation/executor/TranslatableTableScanExecutor.java | 2 +-
.../org/apache/shardingsphere/mode/manager/ContextManager.java | 4 ++--
.../proxy/backend/config/ProxyConfigurationLoader.java | 2 +-
.../proxy/backend/hbase/util/HBaseHeterogeneousUtils.java | 2 +-
.../executor/information/SelectInformationSchemataExecutor.java | 2 +-
.../command/query/binary/prepare/MySQLComStmtPrepareExecutor.java | 2 +-
.../opengauss/command/OpenGaussCommandExecutorFactory.java | 2 +-
.../rdl/alter/impl/AlterShardingTableRuleStatementAssert.java | 4 ++--
.../rdl/create/impl/CreateShardingTableRuleStatementAssert.java | 4 ++--
29 files changed, 41 insertions(+), 41 deletions(-)
diff --git
a/features/shadow/distsql/parser/src/main/java/org/apache/shardingsphere/shadow/distsql/parser/core/ShadowDistSQLStatementVisitor.java
b/features/shadow/distsql/parser/src/main/java/org/apache/shardingsphere/shadow/distsql/parser/core/ShadowDistSQLStatementVisitor.java
index 17a4daf50b8..136d437926b 100644
---
a/features/shadow/distsql/parser/src/main/java/org/apache/shardingsphere/shadow/distsql/parser/core/ShadowDistSQLStatementVisitor.java
+++
b/features/shadow/distsql/parser/src/main/java/org/apache/shardingsphere/shadow/distsql/parser/core/ShadowDistSQLStatementVisitor.java
@@ -73,7 +73,7 @@ public final class ShadowDistSQLStatementVisitor extends
ShadowDistSQLStatementB
@Override
public ASTNode visitCreateShadowRule(final CreateShadowRuleContext ctx) {
- List<ShadowRuleSegment> shadowRuleSegments =
ctx.shadowRuleDefinition().stream().map(this::visit).map(each ->
(ShadowRuleSegment) each).collect(Collectors.toList());
+ List<ShadowRuleSegment> shadowRuleSegments =
ctx.shadowRuleDefinition().stream().map(this::visit).map(ShadowRuleSegment.class::cast).collect(Collectors.toList());
return new CreateShadowRuleStatement(null != ctx.ifNotExists(),
autoCreateAlgorithmName(shadowRuleSegments));
}
@@ -123,7 +123,7 @@ public final class ShadowDistSQLStatementVisitor extends
ShadowDistSQLStatementB
@Override
public ASTNode visitAlterShadowRule(final AlterShadowRuleContext ctx) {
- List<ShadowRuleSegment> shadowRuleSegments =
ctx.shadowRuleDefinition().stream().map(this::visit).map(each ->
(ShadowRuleSegment) each).collect(Collectors.toList());
+ List<ShadowRuleSegment> shadowRuleSegments =
ctx.shadowRuleDefinition().stream().map(this::visit).map(ShadowRuleSegment.class::cast).collect(Collectors.toList());
return new
AlterShadowRuleStatement(autoCreateAlgorithmName(shadowRuleSegments));
}
@@ -160,8 +160,8 @@ public final class ShadowDistSQLStatementVisitor extends
ShadowDistSQLStatementB
return null == ctx || ctx.isEmpty() ? null : new
IdentifierValue(ctx.getText()).getValue();
}
- private Collection<ShadowAlgorithmSegment> visitShadowAlgorithms(final
List<AlgorithmDefinitionContext> ctxs) {
- return ctxs.stream().map(this::visit).map(each ->
(ShadowAlgorithmSegment) each).collect(Collectors.toList());
+ private Collection<ShadowAlgorithmSegment> visitShadowAlgorithms(final
List<AlgorithmDefinitionContext> contexts) {
+ return
contexts.stream().map(this::visit).map(ShadowAlgorithmSegment.class::cast).collect(Collectors.toList());
}
@Override
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rule/ShardingRule.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rule/ShardingRule.java
index ab72fb951cd..f31dbea8cc8 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rule/ShardingRule.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rule/ShardingRule.java
@@ -138,7 +138,7 @@ public final class ShardingRule implements DatabaseRule,
DataNodeContainedRule,
ShardingSpherePreconditions.checkState(isValidBindingTableConfiguration(tableRules,
new BindingTableCheckedConfiguration(this.dataSourceNames, shardingAlgorithms,
ruleConfig.getBindingTableGroups(), broadcastTables,
defaultDatabaseShardingStrategyConfig, defaultTableShardingStrategyConfig,
defaultShardingColumn)),
InvalidBindingTablesException::new);
- keyGenerators.values().stream().filter(each -> each instanceof
InstanceContextAware).forEach(each -> ((InstanceContextAware)
each).setInstanceContext(instanceContext));
+
keyGenerators.values().stream().filter(InstanceContextAware.class::isInstance).forEach(each
-> ((InstanceContextAware) each).setInstanceContext(instanceContext));
if (defaultKeyGenerateAlgorithm instanceof InstanceContextAware && -1
== instanceContext.getWorkerId()) {
((InstanceContextAware)
defaultKeyGenerateAlgorithm).setInstanceContext(instanceContext);
}
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/yaml/swapper/ShardingRuleConfigurationConverter.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/yaml/swapper/ShardingRuleConfigurationConverter.java
index caa807f60d4..f869417b033 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/yaml/swapper/ShardingRuleConfigurationConverter.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/yaml/swapper/ShardingRuleConfigurationConverter.java
@@ -52,6 +52,6 @@ public final class ShardingRuleConfigurationConverter {
* @throws IllegalStateException if there is no available sharding rule
*/
public static Optional<YamlShardingRuleConfiguration>
findYamlShardingRuleConfiguration(final Collection<YamlRuleConfiguration>
yamlRuleConfigs) {
- return yamlRuleConfigs.stream().filter(each -> each instanceof
YamlShardingRuleConfiguration).findFirst().map(each ->
(YamlShardingRuleConfiguration) each);
+ return
yamlRuleConfigs.stream().filter(YamlShardingRuleConfiguration.class::isInstance).findFirst().map(YamlShardingRuleConfiguration.class::cast);
}
}
diff --git
a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/checker/ShardingTableRuleStatementChecker.java
b/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/checker/ShardingTableRuleStatementChecker.java
index c717e031ea6..349ed97f36e 100644
---
a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/checker/ShardingTableRuleStatementChecker.java
+++
b/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/checker/ShardingTableRuleStatementChecker.java
@@ -419,7 +419,7 @@ public final class ShardingTableRuleStatementChecker {
}
private static void checkAutoTableRule(final
Collection<AbstractTableRuleSegment> rules) {
- Collection<AutoTableRuleSegment> autoTableRules =
rules.stream().map(each -> (AutoTableRuleSegment)
each).collect(Collectors.toList());
+ Collection<AutoTableRuleSegment> autoTableRules =
rules.stream().map(AutoTableRuleSegment.class::cast).collect(Collectors.toList());
Optional<AlgorithmSegment> anyAutoTableRule =
autoTableRules.stream().map(AutoTableRuleSegment::getShardingAlgorithmSegment).filter(Objects::nonNull).findAny();
if (anyAutoTableRule.isPresent()) {
checkAutoTableShardingAlgorithms(autoTableRules);
@@ -438,7 +438,7 @@ public final class ShardingTableRuleStatementChecker {
}
private static void checkTableRule(final String databaseName, final
Collection<AbstractTableRuleSegment> rules) {
- Collection<TableRuleSegment> tableRules = rules.stream().map(each ->
(TableRuleSegment) each).collect(Collectors.toList());
+ Collection<TableRuleSegment> tableRules =
rules.stream().map(TableRuleSegment.class::cast).collect(Collectors.toList());
Optional<ShardingStrategySegment> anyTableRule =
tableRules.stream().map(each ->
Arrays.asList(each.getDatabaseStrategySegment(),
each.getTableStrategySegment()))
.flatMap(Collection::stream).filter(Objects::nonNull).findAny();
if (anyTableRule.isPresent()) {
diff --git
a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/update/CreateBroadcastTableRuleStatementUpdater.java
b/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/update/CreateBroadcastTableRuleStatementUpdater.java
index 3d145a5e8b9..3e8f643d040 100644
---
a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/update/CreateBroadcastTableRuleStatementUpdater.java
+++
b/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/update/CreateBroadcastTableRuleStatementUpdater.java
@@ -45,7 +45,7 @@ public final class CreateBroadcastTableRuleStatementUpdater
implements RuleDefin
Collection<String> tables = sqlStatement.getTables();
if (sqlStatement.isIfNotExists()) {
Collection<String> duplicatedRuleNames =
getDuplicatedRuleNames(sqlStatement, currentRuleConfig);
- tables.removeIf(each -> duplicatedRuleNames.contains(each));
+ tables.removeIf(duplicatedRuleNames::contains);
}
result.setBroadcastTables(tables);
return result;
diff --git
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/segment/select/subquery/engine/SubqueryTableContextEngine.java
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/segment/select/subquery/engine/SubqueryTableContextEngine.java
index 1a3f243e82f..1651d4f8378 100644
---
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/segment/select/subquery/engine/SubqueryTableContextEngine.java
+++
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/segment/select/subquery/engine/SubqueryTableContextEngine.java
@@ -41,7 +41,7 @@ public final class SubqueryTableContextEngine {
public Collection<SubqueryTableContext> createSubqueryTableContexts(final
SelectStatementContext subqueryContext, final String alias) {
Collection<SubqueryTableContext> result = new LinkedList<>();
List<String> columnNames =
subqueryContext.getProjectionsContext().getExpandProjections().stream()
- .filter(each -> each instanceof ColumnProjection).map(each ->
((ColumnProjection) each).getName()).collect(Collectors.toList());
+ .filter(ColumnProjection.class::isInstance).map(each ->
((ColumnProjection) each).getName()).collect(Collectors.toList());
for (String each : subqueryContext.getTablesContext().getTableNames())
{
result.add(new SubqueryTableContext(each, alias, columnNames));
}
diff --git
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/statement/dml/SelectStatementContext.java
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/statement/dml/SelectStatementContext.java
index 3455c29ebc7..f596bc2a86d 100644
---
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/statement/dml/SelectStatementContext.java
+++
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/statement/dml/SelectStatementContext.java
@@ -209,7 +209,7 @@ public final class SelectStatementContext extends
CommonSQLStatementContext impl
* @return whether contains partial distinct aggregation
*/
public boolean isContainsPartialDistinctAggregation() {
- Collection<Projection> aggregationProjections =
projectionsContext.getProjections().stream().filter(each -> each instanceof
AggregationProjection).collect(Collectors.toList());
+ Collection<Projection> aggregationProjections =
projectionsContext.getProjections().stream().filter(AggregationProjection.class::isInstance).collect(Collectors.toList());
Collection<AggregationDistinctProjection>
aggregationDistinctProjections =
projectionsContext.getAggregationDistinctProjections();
return aggregationProjections.size() > 1 &&
!aggregationDistinctProjections.isEmpty() && aggregationProjections.size() !=
aggregationDistinctProjections.size();
}
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/datanode/DataNodes.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/datanode/DataNodes.java
index 8bb8c28058a..b197ed51f4a 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/datanode/DataNodes.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/datanode/DataNodes.java
@@ -65,7 +65,7 @@ public final class DataNodes {
}
private Optional<DataNodeContainedRule> findDataNodeContainedRule(final
String tableName) {
- return rules.stream().filter(each ->
isDataNodeContainedRuleContainsTable(each, tableName)).findFirst().map(optional
-> (DataNodeContainedRule) optional);
+ return rules.stream().filter(each ->
isDataNodeContainedRuleContainsTable(each,
tableName)).findFirst().map(DataNodeContainedRule.class::cast);
}
private boolean isDataNodeContainedRuleContainsTable(final
ShardingSphereRule each, final String tableName) {
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/data/collector/tables/PgClassTableCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/data/collector/tables/PgClassTableCollector.java
index 1927e26b7e9..43ba54d1142 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/data/collector/tables/PgClassTableCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/data/collector/tables/PgClassTableCollector.java
@@ -60,7 +60,7 @@ public final class PgClassTableCollector implements
ShardingSphereDataCollector
}
private Collection<ShardingSphereRowData> decorateTableName(final
Collection<ShardingSphereRowData> rows, final ShardingSphereTable table, final
Collection<ShardingSphereRule> rules) {
- Optional<DataNodeContainedRule> dataNodeContainedRule =
rules.stream().filter(rule -> rule instanceof DataNodeContainedRule).map(rule
-> (DataNodeContainedRule) rule).findFirst();
+ Optional<DataNodeContainedRule> dataNodeContainedRule =
rules.stream().filter(DataNodeContainedRule.class::isInstance).map(DataNodeContainedRule.class::cast).findFirst();
if (!dataNodeContainedRule.isPresent()) {
return rows;
}
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/builder/GenericSchemaBuilder.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/builder/GenericSchemaBuilder.java
index 9e86483bc61..8e12f1e9994 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/builder/GenericSchemaBuilder.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/builder/GenericSchemaBuilder.java
@@ -93,7 +93,7 @@ public final class GenericSchemaBuilder {
}
private static Collection<String> getAllTableNames(final
Collection<ShardingSphereRule> rules) {
- return rules.stream().filter(each -> each instanceof
TableContainedRule).flatMap(each -> ((TableContainedRule)
each).getTables().stream()).collect(Collectors.toSet());
+ return
rules.stream().filter(TableContainedRule.class::isInstance).flatMap(each ->
((TableContainedRule) each).getTables().stream()).collect(Collectors.toSet());
}
private static Map<String, SchemaMetaData> loadSchemas(final
Collection<String> tableNames, final GenericSchemaBuilderMaterial material)
throws SQLException {
@@ -119,7 +119,7 @@ public final class GenericSchemaBuilder {
private static Map<String, ShardingSphereSchema> revise(final Map<String,
SchemaMetaData> schemaMetaDataMap, final GenericSchemaBuilderMaterial material)
{
Map<String, SchemaMetaData> result = new
LinkedHashMap<>(schemaMetaDataMap);
- result.putAll(new
MetaDataReviseEngine(material.getRules().stream().filter(each -> each
instanceof TableContainedRule).collect(Collectors.toList())).revise(result,
material));
+ result.putAll(new
MetaDataReviseEngine(material.getRules().stream().filter(TableContainedRule.class::isInstance).collect(Collectors.toList())).revise(result,
material));
return convertToSchemaMap(result, material);
}
diff --git
a/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/ShardingSphereDataSource.java
b/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/ShardingSphereDataSource.java
index 99ea67399df..02682df4f55 100644
---
a/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/ShardingSphereDataSource.java
+++
b/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/ShardingSphereDataSource.java
@@ -74,7 +74,7 @@ public final class ShardingSphereDataSource extends
AbstractDataSourceAdapter im
private ContextManager createContextManager(final String databaseName,
final ModeConfiguration modeConfig, final Map<String, DataSource> dataSourceMap,
final
Collection<RuleConfiguration> ruleConfigs, final Properties props) throws
SQLException {
InstanceMetaData instanceMetaData =
TypedSPILoader.getService(InstanceMetaDataBuilder.class, "JDBC").build(-1);
- Collection<RuleConfiguration> globalRuleConfigs =
ruleConfigs.stream().filter(each -> each instanceof
GlobalRuleConfiguration).collect(Collectors.toList());
+ Collection<RuleConfiguration> globalRuleConfigs =
ruleConfigs.stream().filter(GlobalRuleConfiguration.class::isInstance).collect(Collectors.toList());
Collection<RuleConfiguration> databaseRuleConfigs = new
LinkedList<>(ruleConfigs);
databaseRuleConfigs.removeAll(globalRuleConfigs);
ContextManagerBuilderParameter param = new
ContextManagerBuilderParameter(modeConfig,
Collections.singletonMap(databaseName,
diff --git
a/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaData.java
b/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaData.java
index c6e61a76bb3..10d05ab4c05 100644
---
a/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaData.java
+++
b/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaData.java
@@ -214,7 +214,7 @@ public final class ShardingSphereDatabaseMetaData extends
AdaptedDatabaseMetaDat
}
private Optional<DataNodeContainedRule> findDataNodeContainedRule() {
- return rules.stream().filter(each -> each instanceof
DataNodeContainedRule).findFirst().map(each -> (DataNodeContainedRule) each);
+ return
rules.stream().filter(DataNodeContainedRule.class::isInstance).findFirst().map(DataNodeContainedRule.class::cast);
}
private ResultSet createDatabaseMetaDataResultSet(final ResultSet
resultSet) throws SQLException {
diff --git
a/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSpherePreparedStatement.java
b/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSpherePreparedStatement.java
index 2e55859c1d5..493b34088fc 100644
---
a/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSpherePreparedStatement.java
+++
b/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSpherePreparedStatement.java
@@ -325,7 +325,7 @@ public final class ShardingSpherePreparedStatement extends
AbstractPreparedState
private List<QueryResult> executeQuery0() throws SQLException {
if (hasRawExecutionRule()) {
return
executor.getRawExecutor().execute(createRawExecutionGroupContext(),
- executionContext.getQueryContext(), new
RawSQLExecutorCallback()).stream().map(each -> (QueryResult)
each).collect(Collectors.toList());
+ executionContext.getQueryContext(), new
RawSQLExecutorCallback()).stream().map(QueryResult.class::cast).collect(Collectors.toList());
}
ExecutionGroupContext<JDBCExecutionUnit> executionGroupContext =
createExecutionGroupContext();
cacheStatements(executionGroupContext.getInputGroups());
diff --git
a/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
b/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
index deadab4117d..2232ebf3b52 100644
---
a/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
+++
b/jdbc/core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
@@ -220,9 +220,9 @@ public final class ShardingSphereStatement extends
AbstractStatementAdapter {
}
private List<QueryResult> executeQuery0() throws SQLException {
- if
(metaDataContexts.getMetaData().getDatabase(connection.getDatabaseName()).getRuleMetaData().getRules().stream().anyMatch(each
-> each instanceof RawExecutionRule)) {
+ if
(metaDataContexts.getMetaData().getDatabase(connection.getDatabaseName()).getRuleMetaData().getRules().stream().anyMatch(RawExecutionRule.class::isInstance))
{
return executor.getRawExecutor().execute(
- createRawExecutionContext(),
executionContext.getQueryContext(), new
RawSQLExecutorCallback()).stream().map(each -> (QueryResult)
each).collect(Collectors.toList());
+ createRawExecutionContext(),
executionContext.getQueryContext(), new
RawSQLExecutorCallback()).stream().map(QueryResult.class::cast).collect(Collectors.toList());
}
ExecutionGroupContext<JDBCExecutionUnit> executionGroupContext =
createExecutionGroupContext();
cacheStatements(executionGroupContext.getInputGroups());
@@ -348,7 +348,7 @@ public final class ShardingSphereStatement extends
AbstractStatementAdapter {
return executor.getTrafficExecutor().execute(executionUnit,
trafficCallback);
}
executionContext = createExecutionContext(queryContext);
- if
(metaDataContexts.getMetaData().getDatabase(connection.getDatabaseName()).getRuleMetaData().getRules().stream().anyMatch(each
-> each instanceof RawExecutionRule)) {
+ if
(metaDataContexts.getMetaData().getDatabase(connection.getDatabaseName()).getRuleMetaData().getRules().stream().anyMatch(RawExecutionRule.class::isInstance))
{
return
accumulate(executor.getRawExecutor().execute(createRawExecutionContext(),
executionContext.getQueryContext(), new RawSQLExecutorCallback()));
}
return executeUpdate(updateCallback,
executionContext.getSqlStatementContext());
@@ -471,7 +471,7 @@ public final class ShardingSphereStatement extends
AbstractStatementAdapter {
return null != resultSet;
}
executionContext = createExecutionContext(queryContext);
- if
(metaDataContexts.getMetaData().getDatabase(connection.getDatabaseName()).getRuleMetaData().getRules().stream().anyMatch(each
-> each instanceof RawExecutionRule)) {
+ if
(metaDataContexts.getMetaData().getDatabase(connection.getDatabaseName()).getRuleMetaData().getRules().stream().anyMatch(RawExecutionRule.class::isInstance))
{
Collection<ExecuteResult> results =
executor.getRawExecutor().execute(createRawExecutionContext(),
executionContext.getQueryContext(), new RawSQLExecutorCallback());
return results.iterator().next() instanceof QueryResult;
}
diff --git
a/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java
b/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java
index 5e74102ad42..b326565741e 100644
---
a/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java
+++
b/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java
@@ -113,7 +113,7 @@ public final class SocketSinkImporterConnector implements
ImporterConnector, Aut
return;
}
if (ImporterType.INVENTORY == importerType || null ==
dataRecordComparator) {
- int dataRecordCount = (int) recordList.stream().filter(each ->
each instanceof DataRecord).count();
+ int dataRecordCount = (int)
recordList.stream().filter(DataRecord.class::isInstance).count();
Record lastRecord = recordList.get(recordList.size() - 1);
if (lastRecord instanceof FinishedRecord && 0 == dataRecordCount) {
socketSinkImporter.ackWithLastDataRecord(new
CDCAckPosition(lastRecord, 0));
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/DataSourceImporter.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/DataSourceImporter.java
index d318dfefd7a..65fd0ebace0 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/DataSourceImporter.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/DataSourceImporter.java
@@ -111,7 +111,7 @@ public final class DataSourceImporter extends
AbstractLifecycleExecutor implemen
}
private PipelineJobProgressUpdatedParameter flush(final DataSource
dataSource, final List<Record> buffer) {
- List<DataRecord> dataRecords = buffer.stream().filter(each -> each
instanceof DataRecord).map(each -> (DataRecord)
each).collect(Collectors.toList());
+ List<DataRecord> dataRecords =
buffer.stream().filter(DataRecord.class::isInstance).map(DataRecord.class::cast).collect(Collectors.toList());
if (dataRecords.isEmpty()) {
return new PipelineJobProgressUpdatedParameter(0);
}
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
index 19207f135da..3c128e07779 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
@@ -48,7 +48,7 @@ public final class RegisterMigrationSourceStorageUnitUpdater
implements RALUpdat
@Override
public void executeUpdate(final String databaseName, final
RegisterMigrationSourceStorageUnitStatement sqlStatement) {
List<DataSourceSegment> dataSources = new
ArrayList<>(sqlStatement.getDataSources());
-
ShardingSpherePreconditions.checkState(dataSources.stream().noneMatch(each ->
each instanceof HostnameAndPortBasedDataSourceSegment),
+
ShardingSpherePreconditions.checkState(dataSources.stream().noneMatch(HostnameAndPortBasedDataSourceSegment.class::isInstance),
() -> new UnsupportedSQLOperationException("Not currently
support add hostname and port, please use url"));
URLBasedDataSourceSegment urlBasedDataSourceSegment =
(URLBasedDataSourceSegment) dataSources.get(0);
DatabaseType databaseType =
DatabaseTypeEngine.getDatabaseType(urlBasedDataSourceSegment.getUrl());
diff --git
a/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/global/GlobalRulePersistService.java
b/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/global/GlobalRulePersistService.java
index 4bfdcaa3392..dad99460712 100644
---
a/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/global/GlobalRulePersistService.java
+++
b/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/global/GlobalRulePersistService.java
@@ -60,8 +60,8 @@ public final class GlobalRulePersistService implements
GlobalPersistService<Coll
*/
@Override
public Collection<ShardingSphereUser> loadUsers() {
- Optional<AuthorityRuleConfiguration> authorityRuleConfig =
load().stream().filter(each -> each instanceof AuthorityRuleConfiguration)
- .map(each -> (AuthorityRuleConfiguration) each).findFirst();
+ Optional<AuthorityRuleConfiguration> authorityRuleConfig =
load().stream()
+
.filter(AuthorityRuleConfiguration.class::isInstance).map(AuthorityRuleConfiguration.class::cast).findFirst();
return authorityRuleConfig.isPresent() ?
authorityRuleConfig.get().getUsers() : Collections.emptyList();
}
}
diff --git
a/kernel/single/core/src/main/java/org/apache/shardingsphere/single/rule/SingleRule.java
b/kernel/single/core/src/main/java/org/apache/shardingsphere/single/rule/SingleRule.java
index 2307d7500ec..c124ed025e1 100644
---
a/kernel/single/core/src/main/java/org/apache/shardingsphere/single/rule/SingleRule.java
+++
b/kernel/single/core/src/main/java/org/apache/shardingsphere/single/rule/SingleRule.java
@@ -103,7 +103,7 @@ public final class SingleRule implements DatabaseRule,
DataNodeContainedRule, Ta
}
private Collection<String> getLoadedTables(final
Collection<ShardingSphereRule> builtRules) {
- return builtRules.stream().filter(each -> each instanceof
DataNodeContainedRule)
+ return
builtRules.stream().filter(DataNodeContainedRule.class::isInstance)
.flatMap(each -> ((DataNodeContainedRule)
each).getAllTables().stream()).collect(Collectors.toCollection(() -> new
TreeSet<>(String.CASE_INSENSITIVE_ORDER)));
}
diff --git
a/kernel/sql-federation/executor/core/src/main/java/org/apache/shardingsphere/sqlfederation/executor/FilterableTableScanExecutor.java
b/kernel/sql-federation/executor/core/src/main/java/org/apache/shardingsphere/sqlfederation/executor/FilterableTableScanExecutor.java
index 4813cbb4a25..96d471fa90e 100644
---
a/kernel/sql-federation/executor/core/src/main/java/org/apache/shardingsphere/sqlfederation/executor/FilterableTableScanExecutor.java
+++
b/kernel/sql-federation/executor/core/src/main/java/org/apache/shardingsphere/sqlfederation/executor/FilterableTableScanExecutor.java
@@ -170,7 +170,7 @@ public final class FilterableTableScanExecutor implements
TableScanExecutor {
}
private List<QueryResult> execute(final
ExecutionGroupContext<JDBCExecutionUnit> executionGroupContext, final
DatabaseType databaseType) throws SQLException {
- Collection<QueryResult> queryResults =
jdbcExecutor.execute(executionGroupContext, callback).stream().map(each ->
(QueryResult) each).collect(Collectors.toList());
+ Collection<QueryResult> queryResults =
jdbcExecutor.execute(executionGroupContext,
callback).stream().map(QueryResult.class::cast).collect(Collectors.toList());
List<QueryResult> result = new LinkedList<>();
for (QueryResult each : queryResults) {
QueryResult queryResult = each instanceof JDBCStreamQueryResult
diff --git
a/kernel/sql-federation/executor/core/src/main/java/org/apache/shardingsphere/sqlfederation/executor/TranslatableTableScanExecutor.java
b/kernel/sql-federation/executor/core/src/main/java/org/apache/shardingsphere/sqlfederation/executor/TranslatableTableScanExecutor.java
index e12ecb844e1..eb7b0482747 100644
---
a/kernel/sql-federation/executor/core/src/main/java/org/apache/shardingsphere/sqlfederation/executor/TranslatableTableScanExecutor.java
+++
b/kernel/sql-federation/executor/core/src/main/java/org/apache/shardingsphere/sqlfederation/executor/TranslatableTableScanExecutor.java
@@ -254,7 +254,7 @@ public final class TranslatableTableScanExecutor implements
TableScanExecutor {
}
private List<QueryResult> execute(final
ExecutionGroupContext<JDBCExecutionUnit> executionGroupContext, final
DatabaseType databaseType) throws SQLException {
- Collection<QueryResult> queryResults =
jdbcExecutor.execute(executionGroupContext, callback).stream().map(each ->
(QueryResult) each).collect(Collectors.toList());
+ Collection<QueryResult> queryResults =
jdbcExecutor.execute(executionGroupContext,
callback).stream().map(QueryResult.class::cast).collect(Collectors.toList());
List<QueryResult> result = new LinkedList<>();
for (QueryResult each : queryResults) {
QueryResult queryResult = each instanceof JDBCStreamQueryResult
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
index b0709d8df31..74ffdb2aa32 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
@@ -204,13 +204,13 @@ public final class ContextManager implements
AutoCloseable {
private synchronized void dropTable(final String databaseName, final
String schemaName, final String toBeDeletedTableName) {
metaDataContexts.get().getMetaData().getDatabase(databaseName).getSchema(schemaName).removeTable(toBeDeletedTableName);
-
metaDataContexts.get().getMetaData().getDatabase(databaseName).getRuleMetaData().getRules().stream().filter(each
-> each instanceof MutableDataNodeRule).findFirst()
+
metaDataContexts.get().getMetaData().getDatabase(databaseName).getRuleMetaData().getRules().stream().filter(MutableDataNodeRule.class::isInstance).findFirst()
.ifPresent(optional -> ((MutableDataNodeRule)
optional).remove(schemaName, toBeDeletedTableName));
}
private synchronized void dropView(final String databaseName, final String
schemaName, final String toBeDeletedViewName) {
metaDataContexts.get().getMetaData().getDatabase(databaseName).getSchema(schemaName).removeView(toBeDeletedViewName);
-
metaDataContexts.get().getMetaData().getDatabase(databaseName).getRuleMetaData().getRules().stream().filter(each
-> each instanceof MutableDataNodeRule).findFirst()
+
metaDataContexts.get().getMetaData().getDatabase(databaseName).getRuleMetaData().getRules().stream().filter(MutableDataNodeRule.class::isInstance).findFirst()
.ifPresent(optional -> ((MutableDataNodeRule)
optional).remove(schemaName, toBeDeletedViewName));
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/config/ProxyConfigurationLoader.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/config/ProxyConfigurationLoader.java
index 51eaf638129..c4376ba43f4 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/config/ProxyConfigurationLoader.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/config/ProxyConfigurationLoader.java
@@ -81,7 +81,7 @@ public final class ProxyConfigurationLoader {
}
private static YamlProxyServerConfiguration
rebuildGlobalRuleConfiguration(final YamlProxyServerConfiguration
serverConfiguration) {
- serverConfiguration.getRules().removeIf(each -> each instanceof
YamlGlobalRuleConfiguration);
+
serverConfiguration.getRules().removeIf(YamlGlobalRuleConfiguration.class::isInstance);
if (null != serverConfiguration.getAuthority()) {
serverConfiguration.getRules().add(serverConfiguration.getAuthority());
}
diff --git
a/proxy/backend/type/hbase/src/main/java/org/apache/shardingsphere/proxy/backend/hbase/util/HBaseHeterogeneousUtils.java
b/proxy/backend/type/hbase/src/main/java/org/apache/shardingsphere/proxy/backend/hbase/util/HBaseHeterogeneousUtils.java
index 20954e8fee7..f4926049ecd 100644
---
a/proxy/backend/type/hbase/src/main/java/org/apache/shardingsphere/proxy/backend/hbase/util/HBaseHeterogeneousUtils.java
+++
b/proxy/backend/type/hbase/src/main/java/org/apache/shardingsphere/proxy/backend/hbase/util/HBaseHeterogeneousUtils.java
@@ -79,6 +79,6 @@ public final class HBaseHeterogeneousUtils {
* @return is use shorthand projection
*/
public static boolean isUseShorthandProjection(final
SelectStatementContext statementContext) {
- return
statementContext.getProjectionsContext().getProjections().stream().anyMatch(each
-> each instanceof ShorthandProjection);
+ return
statementContext.getProjectionsContext().getProjections().stream().anyMatch(ShorthandProjection.class::isInstance);
}
}
diff --git
a/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/information/SelectInformationSchemataExecutor.java
b/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/information/SelectInformationSchemataExecutor.java
index 4e09f860f79..f5567a703bb 100644
---
a/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/information/SelectInformationSchemataExecutor.java
+++
b/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/information/SelectInformationSchemataExecutor.java
@@ -122,7 +122,7 @@ public final class SelectInformationSchemataExecutor
extends DefaultDatabaseMeta
private Map<String, String> getTheDefaultRowData() {
Map<String, String> result;
Collection<ProjectionSegment> projections =
sqlStatement.getProjections().getProjections();
- if (projections.stream().anyMatch(each -> each instanceof
ShorthandProjectionSegment)) {
+ if
(projections.stream().anyMatch(ShorthandProjectionSegment.class::isInstance)) {
result = Stream.of(CATALOG_NAME, SCHEMA_NAME,
DEFAULT_CHARACTER_SET_NAME, DEFAULT_COLLATION_NAME, SQL_PATH,
DEFAULT_ENCRYPTION).collect(Collectors.toMap(each -> each, each -> ""));
} else {
result = projections.stream().map(each ->
((ColumnProjectionSegment) each).getColumn().getIdentifier())
diff --git
a/proxy/frontend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutor.java
b/proxy/frontend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutor.java
index a01d086e815..89be752b0cc 100644
---
a/proxy/frontend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutor.java
+++
b/proxy/frontend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutor.java
@@ -143,7 +143,7 @@ public final class MySQLComStmtPrepareExecutor implements
CommandExecutor {
Collection<Projection> projections =
selectStatementContext.getProjectionsContext().getExpandProjections();
ShardingSphereSchema schema = getSchema(selectStatementContext);
Map<String, String> columnToTableMap =
selectStatementContext.getTablesContext()
-
.findTableNamesByColumnProjection(projections.stream().filter(each -> each
instanceof ColumnProjection).map(each -> (ColumnProjection)
each).collect(Collectors.toList()), schema);
+
.findTableNamesByColumnProjection(projections.stream().filter(ColumnProjection.class::isInstance).map(ColumnProjection.class::cast).collect(Collectors.toList()),
schema);
Collection<DatabasePacket<?>> result = new
ArrayList<>(projections.size());
for (Projection each : projections) {
// TODO Calculate column definition flag for other projection types
diff --git
a/proxy/frontend/type/opengauss/src/main/java/org/apache/shardingsphere/proxy/frontend/opengauss/command/OpenGaussCommandExecutorFactory.java
b/proxy/frontend/type/opengauss/src/main/java/org/apache/shardingsphere/proxy/frontend/opengauss/command/OpenGaussCommandExecutorFactory.java
index e5b9115c405..1d5d1410c53 100644
---
a/proxy/frontend/type/opengauss/src/main/java/org/apache/shardingsphere/proxy/frontend/opengauss/command/OpenGaussCommandExecutorFactory.java
+++
b/proxy/frontend/type/opengauss/src/main/java/org/apache/shardingsphere/proxy/frontend/opengauss/command/OpenGaussCommandExecutorFactory.java
@@ -77,7 +77,7 @@ public final class OpenGaussCommandExecutorFactory {
return getCommandExecutor(commandPacketType, commandPacket,
connectionSession, portalContext);
}
PostgreSQLAggregatedCommandPacket aggregatedCommandPacket =
(PostgreSQLAggregatedCommandPacket) commandPacket;
- if (aggregatedCommandPacket.isContainsBatchedStatements() &&
aggregatedCommandPacket.getPackets().stream().noneMatch(each -> each instanceof
OpenGaussComBatchBindPacket)) {
+ if (aggregatedCommandPacket.isContainsBatchedStatements() &&
aggregatedCommandPacket.getPackets().stream().noneMatch(OpenGaussComBatchBindPacket.class::isInstance))
{
return new
PostgreSQLAggregatedCommandExecutor(getExecutorsOfAggregatedBatchedStatements(aggregatedCommandPacket,
connectionSession, portalContext));
}
List<CommandExecutor> result = new
ArrayList<>(aggregatedCommandPacket.getPackets().size());
diff --git
a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/impl/AlterShardingTableRuleStatementAssert.java
b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/impl/AlterShardingTableRuleStatementAssert.java
index 1b442c98c3d..73ca4ca45f7 100644
---
a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/impl/AlterShardingTableRuleStatementAssert.java
+++
b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/impl/AlterShardingTableRuleStatementAssert.java
@@ -56,11 +56,11 @@ public final class AlterShardingTableRuleStatementAssert {
if (ExistingAssert.assertIs(assertContext, actual, expected)) {
if (expected instanceof
AlterShardingAutoTableRuleStatementTestCase) {
AlterShardingAutoTableRuleStatementTestCase
autoTableRuleStatementTestCase = (AlterShardingAutoTableRuleStatementTestCase)
expected;
- Collection<AutoTableRuleSegment> actualAutoTableRules =
actual.getRules().stream().map(each -> (AutoTableRuleSegment)
each).collect(Collectors.toList());
+ Collection<AutoTableRuleSegment> actualAutoTableRules =
actual.getRules().stream().map(AutoTableRuleSegment.class::cast).collect(Collectors.toList());
assertShardingAutoTableRules(assertContext,
actualAutoTableRules, autoTableRuleStatementTestCase.getRules());
} else {
AlterShardingTableRuleStatementTestCase
tableRuleStatementTestCase = (AlterShardingTableRuleStatementTestCase) expected;
- Collection<TableRuleSegment> actualTableRules =
actual.getRules().stream().map(each -> (TableRuleSegment)
each).collect(Collectors.toList());
+ Collection<TableRuleSegment> actualTableRules =
actual.getRules().stream().map(TableRuleSegment.class::cast).collect(Collectors.toList());
assertShardingTableRules(assertContext, actualTableRules,
tableRuleStatementTestCase.getRules());
}
}
diff --git
a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/impl/CreateShardingTableRuleStatementAssert.java
b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/impl/CreateShardingTableRuleStatementAssert.java
index 6dd6879e0e6..0a8a403e4a3 100644
---
a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/impl/CreateShardingTableRuleStatementAssert.java
+++
b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/impl/CreateShardingTableRuleStatementAssert.java
@@ -59,12 +59,12 @@ public final class CreateShardingTableRuleStatementAssert {
if (expected instanceof
CreateShardingAutoTableRuleStatementTestCase) {
CreateShardingAutoTableRuleStatementTestCase
autoTableRuleStatementTestCase = (CreateShardingAutoTableRuleStatementTestCase)
expected;
assertThat(assertContext.getText("if not exists segment
assertion error: "), actual.isIfNotExists(),
is(autoTableRuleStatementTestCase.isIfNotExists()));
- Collection<AutoTableRuleSegment> actualAutoTableRules =
actual.getRules().stream().map(each -> (AutoTableRuleSegment)
each).collect(Collectors.toList());
+ Collection<AutoTableRuleSegment> actualAutoTableRules =
actual.getRules().stream().map(AutoTableRuleSegment.class::cast).collect(Collectors.toList());
assertShardingAutoTableRules(assertContext,
actualAutoTableRules, autoTableRuleStatementTestCase.getRules());
} else {
CreateShardingTableRuleStatementTestCase
tableRuleStatementTestCase = (CreateShardingTableRuleStatementTestCase)
expected;
assertThat(assertContext.getText("if not exists segment
assertion error: "), actual.isIfNotExists(),
is(tableRuleStatementTestCase.isIfNotExists()));
- Collection<TableRuleSegment> actualTableRules =
actual.getRules().stream().map(each -> (TableRuleSegment)
each).collect(Collectors.toList());
+ Collection<TableRuleSegment> actualTableRules =
actual.getRules().stream().map(TableRuleSegment.class::cast).collect(Collectors.toList());
assertShardingTableRules(assertContext, actualTableRules,
tableRuleStatementTestCase.getRules());
}
}
