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 d6ddc1f80e3 Fix for code format (#37187)
d6ddc1f80e3 is described below
commit d6ddc1f80e3403506832c99c6a85d8afb7638b37
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Nov 26 22:53:19 2025 +0800
Fix for code format (#37187)
---
.../authentication/OpenGaussMacCalculator.java | 2 +-
.../dml/expression/type/ColumnSegmentBinder.java | 2 +-
.../postgresql/PostgreSQLStatisticsCollector.java | 6 +--
.../ShardingSphereStatisticsCollector.java | 6 +--
...tgreSQLPgClassTableStatisticsCollectorTest.java | 5 +--
...SQLPgNamespaceTableStatisticsCollectorTest.java | 3 +-
.../DataConsistencyCheckUtils.java | 2 +-
.../AbstractRecordTableInventoryCalculator.java | 2 +-
.../progress/JobItemIncrementalTasksProgress.java | 2 +-
.../core/datasource/PipelineDataSourceTest.java | 4 +-
.../importer/sink/PipelineCDCSocketSinkTest.java | 3 +-
.../scenario/migration/api/MigrationJobAPI.java | 2 +-
.../handler/distsql/rul/PreviewExecutor.java | 3 +-
.../CreateDatabaseProxyBackendHandlerTest.java | 6 +--
.../type/DropDatabaseProxyBackendHandlerTest.java | 7 ++-
.../ImportDatabaseConfigurationExecutorTest.java | 13 +++---
.../imports/ImportMetaDataExecutorTest.java | 3 +-
.../variable/SetDistVariableExecutorTest.java | 8 ++--
.../command/FirebirdCommandExecuteEngine.java | 2 +-
.../FirebirdCommandExecutorFactoryTest.java | 50 +++++++++++-----------
.../FirebirdCancelBlobCommandExecutorTest.java | 3 +-
.../blob/FirebirdCloseBlobCommandExecutorTest.java | 3 +-
.../FirebirdCreateBlobCommandExecutorTest.java | 3 +-
.../FirebirdGetBlobSegmentCommandExecutorTest.java | 3 +-
.../blob/FirebirdOpenBlobCommandExecutorTest.java | 3 +-
.../FirebirdPutBlobSegmentCommandExecutorTest.java | 3 +-
.../blob/FirebirdSeekBlobCommandExecutorTest.java | 3 +-
...rebirdAllocateStatementCommandExecutorTest.java | 3 +-
.../FirebirdFreeStatementCommandExecutorTest.java | 7 ++-
...irebirdStartTransactionCommandExecutorTest.java | 3 +-
.../flush/PostgreSQLComFlushExecutorTest.java | 3 +-
.../BaseTCLStatementTransactionTestCase.java | 2 +-
.../RecordTableInventoryCheckCalculatorTest.java | 2 +-
33 files changed, 72 insertions(+), 100 deletions(-)
diff --git
a/database/protocol/dialect/opengauss/src/main/java/org/apache/shardingsphere/database/protocol/opengauss/packet/authentication/OpenGaussMacCalculator.java
b/database/protocol/dialect/opengauss/src/main/java/org/apache/shardingsphere/database/protocol/opengauss/packet/authentication/OpenGaussMacCalculator.java
index 56730a2726d..a82df90cdcb 100644
---
a/database/protocol/dialect/opengauss/src/main/java/org/apache/shardingsphere/database/protocol/opengauss/packet/authentication/OpenGaussMacCalculator.java
+++
b/database/protocol/dialect/opengauss/src/main/java/org/apache/shardingsphere/database/protocol/opengauss/packet/authentication/OpenGaussMacCalculator.java
@@ -137,7 +137,7 @@ public final class OpenGaussMacCalculator {
}
@RequiredArgsConstructor
- enum MacType {
+ private enum MacType {
SERVER("Server Key"),
CLIENT("Client Key");
diff --git
a/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/engine/segment/dml/expression/type/ColumnSegmentBinder.java
b/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/engine/segment/dml/expression/type/ColumnSegmentBinder.java
index 040f24fbd21..ae9e637d571 100644
---
a/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/engine/segment/dml/expression/type/ColumnSegmentBinder.java
+++
b/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/engine/segment/dml/expression/type/ColumnSegmentBinder.java
@@ -306,7 +306,7 @@ public final class ColumnSegmentBinder {
@RequiredArgsConstructor
@Getter
- static class ColumnSegmentInfo {
+ private static class ColumnSegmentInfo {
private final ColumnSegment inputColumnSegment;
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/PostgreSQLStatisticsCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/PostgreSQLStatisticsCollector.java
index 4b846c44750..5ac01381891 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/PostgreSQLStatisticsCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/PostgreSQLStatisticsCollector.java
@@ -24,7 +24,6 @@ import
org.apache.shardingsphere.infra.metadata.statistics.collector.DialectData
import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Map;
import java.util.Optional;
@@ -46,10 +45,9 @@ public final class PostgreSQLStatisticsCollector implements
DialectDatabaseStati
}
@Override
- public Optional<Collection<Map<String, Object>>>
collectRowColumnValues(final String databaseName, final String schemaName,
final String tableName,
-
final ShardingSphereMetaData metaData) throws SQLException {
+ public Optional<Collection<Map<String, Object>>>
collectRowColumnValues(final String databaseName, final String schemaName,
final String tableName, final ShardingSphereMetaData metaData) {
Optional<PostgreSQLTableStatisticsCollector> tableStatisticsCollector
= TypedSPILoader.findService(PostgreSQLTableStatisticsCollector.class,
String.format("%s.%s", schemaName, tableName));
- return tableStatisticsCollector.isPresent() ?
Optional.of(tableStatisticsCollector.get().collect(databaseName, schemaName,
tableName, metaData)) : Optional.empty();
+ return tableStatisticsCollector.map(postgreSQLTableStatisticsCollector
-> postgreSQLTableStatisticsCollector.collect(databaseName, schemaName,
tableName, metaData));
}
@Override
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/shardingsphere/ShardingSphereStatisticsCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/shardingsphere/ShardingSphereStatisticsCollector.java
index 49b5b689b70..97b9d4eb589 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/shardingsphere/ShardingSphereStatisticsCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/shardingsphere/ShardingSphereStatisticsCollector.java
@@ -24,7 +24,6 @@ import
org.apache.shardingsphere.infra.metadata.statistics.collector.DialectData
import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Map;
import java.util.Optional;
@@ -46,11 +45,10 @@ public final class ShardingSphereStatisticsCollector
implements DialectDatabaseS
}
@Override
- public Optional<Collection<Map<String, Object>>>
collectRowColumnValues(final String databaseName, final String schemaName,
final String tableName,
-
final ShardingSphereMetaData metaData) throws SQLException {
+ public Optional<Collection<Map<String, Object>>>
collectRowColumnValues(final String databaseName, final String schemaName,
final String tableName, final ShardingSphereMetaData metaData) {
Optional<ShardingSphereTableStatisticsCollector>
tableStatisticsCollector = TypedSPILoader.findService(
ShardingSphereTableStatisticsCollector.class,
String.format("%s.%s", schemaName, tableName));
- return tableStatisticsCollector.isPresent() ?
Optional.of(tableStatisticsCollector.get().collect(databaseName, schemaName,
tableName, metaData)) : Optional.empty();
+ return tableStatisticsCollector.map(optional ->
optional.collect(databaseName, schemaName, tableName, metaData));
}
@Override
diff --git
a/infra/common/src/test/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgClassTableStatisticsCollectorTest.java
b/infra/common/src/test/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgClassTableStatisticsCollectorTest.java
index c0e62d59134..ce2576728d0 100644
---
a/infra/common/src/test/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgClassTableStatisticsCollectorTest.java
+++
b/infra/common/src/test/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgClassTableStatisticsCollectorTest.java
@@ -27,7 +27,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
@@ -47,7 +46,7 @@ class PostgreSQLPgClassTableStatisticsCollectorTest {
private ShardingSphereMetaData metaData;
@Test
- void assertCollectWithPublicSchemaExists() throws SQLException {
+ void assertCollectWithPublicSchemaExists() {
ShardingSphereTable table = mock(ShardingSphereTable.class);
when(table.getName()).thenReturn("foo_tbl");
when(metaData.getDatabase("foo_db").getSchema("public").getAllTables()).thenReturn(Collections.singleton(table));
@@ -61,7 +60,7 @@ class PostgreSQLPgClassTableStatisticsCollectorTest {
}
@Test
- void assertCollectWithPublicSchemaNotExists() throws SQLException {
+ void assertCollectWithPublicSchemaNotExists() {
when(metaData.getDatabase("foo_db").getSchema("public")).thenReturn(null);
Collection<Map<String, Object>> actual = collector.collect("foo_db",
"pg_catalog", "pg_class", metaData);
assertTrue(actual.isEmpty());
diff --git
a/infra/common/src/test/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgNamespaceTableStatisticsCollectorTest.java
b/infra/common/src/test/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgNamespaceTableStatisticsCollectorTest.java
index c5a6ea88a56..dedbf5027ed 100644
---
a/infra/common/src/test/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgNamespaceTableStatisticsCollectorTest.java
+++
b/infra/common/src/test/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgNamespaceTableStatisticsCollectorTest.java
@@ -27,7 +27,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Arrays;
import java.util.Collection;
import java.util.Map;
@@ -46,7 +45,7 @@ class PostgreSQLPgNamespaceTableStatisticsCollectorTest {
@SuppressWarnings("unchecked")
@Test
- void assertCollectWithMultipleSchemas() throws SQLException {
+ void assertCollectWithMultipleSchemas() {
when(metaData.getDatabase("foo_db").getAllSchemas())
.thenReturn(Arrays.asList(new ShardingSphereSchema("public"),
new ShardingSphereSchema("foo_schema"), new
ShardingSphereSchema("bar_schema")));
Collection<Map<String, Object>> actual = collector.collect("foo_db",
"pg_catalog", "pg_namespace", metaData);
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/DataConsistencyCheckUtils.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/DataConsistencyCheckUtils.java
index 608dc579001..9fd5c4d7c32 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/DataConsistencyCheckUtils.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/DataConsistencyCheckUtils.java
@@ -151,7 +151,7 @@ public final class DataConsistencyCheckUtils {
/**
* Check two BigDecimal whether equals or not.
*
- * <p>Scale will be ignored, so <code>332.2</code> is equals to
<code>332.20</code>.</p>
+ * <p>Scale will be ignored, so ${@code 332.2} is equals to {@code
332.20}.</p>
*
* @param one first BigDecimal
* @param another second BigDecimal
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/calculator/AbstractRecordTableInventoryCalculator.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/calculator/AbstractRecordTableInventoryCalculator.java
index f27622728e6..87147b1c43f 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/calculator/AbstractRecordTableInventoryCalculator.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/calculator/AbstractRecordTableInventoryCalculator.java
@@ -64,7 +64,7 @@ public abstract class
AbstractRecordTableInventoryCalculator<S, C> extends Abstr
private final StreamingRangeType streamingRangeType;
- public AbstractRecordTableInventoryCalculator(final int chunkSize, final
StreamingRangeType streamingRangeType) {
+ protected AbstractRecordTableInventoryCalculator(final int chunkSize,
final StreamingRangeType streamingRangeType) {
this(chunkSize, DEFAULT_STREAMING_CHUNK_COUNT, streamingRangeType);
}
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/JobItemIncrementalTasksProgress.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/JobItemIncrementalTasksProgress.java
index 366f27ac658..49ed5fb02e1 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/JobItemIncrementalTasksProgress.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/progress/JobItemIncrementalTasksProgress.java
@@ -45,7 +45,7 @@ public final class JobItemIncrementalTasksProgress {
/**
* Get incremental latest active time milliseconds.
*
- * @return latest active time, <code>0</code> means there is no activity
+ * @return latest active time, ${@code 0} means there is no activity
*/
public long getIncrementalLatestActiveTimeMillis() {
return null == incrementalTaskProgress ? 0L :
incrementalTaskProgress.getIncrementalTaskDelay().getLatestActiveTimeMillis();
diff --git
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSourceTest.java
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSourceTest.java
index 962a3a2c3f0..c6e5a69ef4a 100644
---
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSourceTest.java
+++
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSourceTest.java
@@ -106,7 +106,7 @@ class PipelineDataSourceTest {
}
@Test
- void assertCloseTwice() throws SQLException {
+ void assertCloseTwice() {
assertFalse(pipelineDataSource.isClosed());
pipelineDataSource.close();
assertTrue(pipelineDataSource.isClosed());
@@ -115,7 +115,7 @@ class PipelineDataSourceTest {
}
@Test
- void assertCloseWithNotAutoCloseableDataSource() throws SQLException {
+ void assertCloseWithNotAutoCloseableDataSource() {
PipelineDataSource pipelineDataSource = new
PipelineDataSource(mock(DataSource.class),
TypedSPILoader.getService(DatabaseType.class, "FIXTURE"));
assertFalse(pipelineDataSource.isClosed());
pipelineDataSource.close();
diff --git
a/kernel/data-pipeline/scenario/cdc/core/src/test/java/org/apache/shardingsphere/data/pipeline/cdc/core/importer/sink/PipelineCDCSocketSinkTest.java
b/kernel/data-pipeline/scenario/cdc/core/src/test/java/org/apache/shardingsphere/data/pipeline/cdc/core/importer/sink/PipelineCDCSocketSinkTest.java
index 414c2adfa8e..d8e1db42d2d 100644
---
a/kernel/data-pipeline/scenario/cdc/core/src/test/java/org/apache/shardingsphere/data/pipeline/cdc/core/importer/sink/PipelineCDCSocketSinkTest.java
+++
b/kernel/data-pipeline/scenario/cdc/core/src/test/java/org/apache/shardingsphere/data/pipeline/cdc/core/importer/sink/PipelineCDCSocketSinkTest.java
@@ -26,7 +26,6 @@ import
org.apache.shardingsphere.data.pipeline.core.job.progress.listener.Pipeli
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.junit.jupiter.api.Test;
-import java.io.IOException;
import java.util.Collections;
import static org.hamcrest.CoreMatchers.is;
@@ -37,7 +36,7 @@ import static org.mockito.Mockito.when;
class PipelineCDCSocketSinkTest {
@Test
- void assertWrite() throws IOException {
+ void assertWrite() {
Channel mockChannel = mock(Channel.class);
when(mockChannel.isWritable()).thenReturn(false, true);
when(mockChannel.isActive()).thenReturn(true);
diff --git
a/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
index f08ab2bdf62..6fe56fd19d6 100644
---
a/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
+++
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
@@ -97,7 +97,7 @@ public final class MigrationJobAPI implements
TransmissionJobAPI {
private final PipelineDataSourcePersistService dataSourcePersistService;
public MigrationJobAPI() {
- PipelineJobType jobType = new MigrationJobType();
+ MigrationJobType jobType = new MigrationJobType();
jobManager = new PipelineJobManager(jobType);
jobConfigManager = new
PipelineJobConfigurationManager(jobType.getOption());
dataSourcePersistService = new PipelineDataSourcePersistService();
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rul/PreviewExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rul/PreviewExecutor.java
index d4fe058c9ac..9494b847af3 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rul/PreviewExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rul/PreviewExecutor.java
@@ -110,8 +110,7 @@ public final class PreviewExecutor implements
DistSQLQueryExecutor<PreviewStatem
return
sqlStatementContext.getTablesContext().getSchemaName().orElse(defaultSchemaName);
}
- private Collection<ExecutionUnit> getExecutionUnits(final ContextManager
contextManager, final String schemaName, final ShardingSphereMetaData metaData,
- final QueryContext
queryContext) throws SQLException {
+ private Collection<ExecutionUnit> getExecutionUnits(final ContextManager
contextManager, final String schemaName, final ShardingSphereMetaData metaData,
final QueryContext queryContext) {
JDBCExecutor jdbcExecutor = new
JDBCExecutor(BackendExecutorContext.getInstance().getExecutorEngine(),
connectionContext.getQueryContext().getConnectionContext());
SQLFederationEngine federationEngine = new
SQLFederationEngine(database.getName(), schemaName, metaData,
contextManager.getMetaDataContexts().getStatistics(), jdbcExecutor);
if (federationEngine.decide(queryContext,
metaData.getGlobalRuleMetaData())) {
diff --git
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/database/type/CreateDatabaseProxyBackendHandlerTest.java
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/database/type/CreateDatabaseProxyBackendHandlerTest.java
index 450c3b8be92..59706183f29 100644
---
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/database/type/CreateDatabaseProxyBackendHandlerTest.java
+++
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/database/type/CreateDatabaseProxyBackendHandlerTest.java
@@ -27,8 +27,6 @@ import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
-
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.isA;
import static org.junit.jupiter.api.Assertions.assertThrows;
@@ -43,7 +41,7 @@ class CreateDatabaseProxyBackendHandlerTest {
private CreateDatabaseStatement statement;
@Test
- void assertExecuteCreateNewDatabase() throws SQLException {
+ void assertExecuteCreateNewDatabase() {
when(statement.getDatabaseName()).thenReturn("bar_db");
assertThat(new CreateDatabaseProxyBackendHandler(statement,
mock(ContextManager.class, RETURNS_DEEP_STUBS)).execute(),
isA(UpdateResponseHeader.class));
}
@@ -59,7 +57,7 @@ class CreateDatabaseProxyBackendHandlerTest {
}
@Test
- void assertExecuteCreateExistDatabaseWithIfNotExists() throws SQLException
{
+ void assertExecuteCreateExistDatabaseWithIfNotExists() {
when(statement.getDatabaseName()).thenReturn("foo_db");
when(statement.isIfNotExists()).thenReturn(true);
assertThat(new CreateDatabaseProxyBackendHandler(statement,
mock(ContextManager.class, RETURNS_DEEP_STUBS)).execute(),
isA(UpdateResponseHeader.class));
diff --git
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandlerTest.java
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandlerTest.java
index 662b8cb7735..4e8b4fd8f8c 100644
---
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandlerTest.java
+++
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandlerTest.java
@@ -38,7 +38,6 @@ import org.mockito.junit.jupiter.MockitoExtension;
import org.mockito.junit.jupiter.MockitoSettings;
import org.mockito.quality.Strictness;
-import java.sql.SQLException;
import java.util.Arrays;
import java.util.Collections;
@@ -103,7 +102,7 @@ class DropDatabaseProxyBackendHandlerTest {
}
@Test
- void assertExecuteDropWithoutCurrentDatabase() throws SQLException {
+ void assertExecuteDropWithoutCurrentDatabase() {
when(sqlStatement.getDatabaseName()).thenReturn("foo_db");
ResponseHeader responseHeader = handler.execute();
assertThat(responseHeader, isA(UpdateResponseHeader.class));
@@ -111,7 +110,7 @@ class DropDatabaseProxyBackendHandlerTest {
}
@Test
- void assertExecuteDropCurrentDatabaseWithMySQL() throws SQLException {
+ void assertExecuteDropCurrentDatabaseWithMySQL() {
when(connectionSession.getUsedDatabaseName()).thenReturn("foo_db");
when(connectionSession.getProtocolType()).thenReturn(TypedSPILoader.getService(DatabaseType.class,
"MySQL"));
when(sqlStatement.getDatabaseName()).thenReturn("foo_db");
@@ -129,7 +128,7 @@ class DropDatabaseProxyBackendHandlerTest {
}
@Test
- void assertExecuteDropOtherDatabase() throws SQLException {
+ void assertExecuteDropOtherDatabase() {
when(connectionSession.getUsedDatabaseName()).thenReturn("foo_db");
when(sqlStatement.getDatabaseName()).thenReturn("bar_db");
ResponseHeader responseHeader = handler.execute();
diff --git
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportDatabaseConfigurationExecutorTest.java
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportDatabaseConfigurationExecutorTest.java
index c06f749ea4d..31bddadc2d3 100644
---
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportDatabaseConfigurationExecutorTest.java
+++
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportDatabaseConfigurationExecutorTest.java
@@ -38,7 +38,6 @@ import org.junit.jupiter.api.Test;
import javax.sql.DataSource;
import java.net.URL;
-import java.sql.SQLException;
import java.util.Collections;
import java.util.HashMap;
import java.util.LinkedList;
@@ -52,31 +51,31 @@ import static org.mockito.Mockito.when;
class ImportDatabaseConfigurationExecutorTest {
@Test
- void assertImportDatabaseExecutorForSharding() throws SQLException {
+ void assertImportDatabaseExecutorForSharding() {
ContextManager contextManager = mockContextManager("sharding_db");
assertExecute(contextManager, "/conf/import/database-sharding.yaml");
}
@Test
- void assertImportDatabaseExecutorForReadwriteSplitting() throws
SQLException {
+ void assertImportDatabaseExecutorForReadwriteSplitting() {
ContextManager contextManager =
mockContextManager("readwrite_splitting_db");
assertExecute(contextManager,
"/conf/import/database-readwrite-splitting.yaml");
}
@Test
- void assertImportDatabaseExecutorForEncrypt() throws SQLException {
+ void assertImportDatabaseExecutorForEncrypt() {
ContextManager contextManager = mockContextManager("encrypt_db");
assertExecute(contextManager, "/conf/import/database-encrypt.yaml");
}
@Test
- void assertImportDatabaseExecutorForShadow() throws SQLException {
+ void assertImportDatabaseExecutorForShadow() {
ContextManager contextManager = mockContextManager("shadow_db");
assertExecute(contextManager, "/conf/import/database-shadow.yaml");
}
@Test
- void assertImportDatabaseExecutorForMask() throws SQLException {
+ void assertImportDatabaseExecutorForMask() {
ContextManager contextManager = mockContextManager("mask_db");
assertExecute(contextManager, "/conf/import/database-mask.yaml");
}
@@ -106,7 +105,7 @@ class ImportDatabaseConfigurationExecutorTest {
assertThrows(ServiceProviderNotFoundException.class, () ->
assertExecute(contextManager, "/conf/import/database-invalid-algorithm.yaml"));
}
- private void assertExecute(final ContextManager contextManager, final
String filePath) throws SQLException {
+ private void assertExecute(final ContextManager contextManager, final
String filePath) {
ImportDatabaseConfigurationExecutor executor = new
ImportDatabaseConfigurationExecutor();
URL url =
ImportDatabaseConfigurationExecutorTest.class.getResource(filePath);
assertNotNull(url);
diff --git
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportMetaDataExecutorTest.java
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportMetaDataExecutorTest.java
index a775c4c55f2..ff910fe0b84 100644
---
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportMetaDataExecutorTest.java
+++
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportMetaDataExecutorTest.java
@@ -53,7 +53,6 @@ import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import javax.sql.DataSource;
-import java.sql.SQLException;
import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
@@ -98,7 +97,7 @@ class ImportMetaDataExecutorTest {
}
@Test
- void assertImportMetaDataFromJsonValue() throws SQLException {
+ void assertImportMetaDataFromJsonValue() {
ContextManager contextManager = mock(ContextManager.class,
RETURNS_DEEP_STUBS);
ImportMetaDataExecutor executor = new ImportMetaDataExecutor();
executor.executeUpdate(new
ImportMetaDataStatement(Base64.encodeBase64String(METADATA_VALUE.getBytes()),
null), contextManager);
diff --git
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/variable/SetDistVariableExecutorTest.java
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/variable/SetDistVariableExecutorTest.java
index e87b346ea34..52cc934acfa 100644
---
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/variable/SetDistVariableExecutorTest.java
+++
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/variable/SetDistVariableExecutorTest.java
@@ -37,8 +37,6 @@ import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
-
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.mockito.Mockito.RETURNS_DEEP_STUBS;
@@ -51,7 +49,7 @@ class SetDistVariableExecutorTest {
private final SetDistVariableExecutor executor = new
SetDistVariableExecutor();
@Test
- void assertExecuteWithConfigurationKey() throws SQLException {
+ void assertExecuteWithConfigurationKey() {
SetDistVariableStatement statement = new
SetDistVariableStatement("proxy_frontend_flush_threshold", "1024");
ContextManager contextManager = mockContextManager();
executor.executeUpdate(statement, contextManager);
@@ -59,7 +57,7 @@ class SetDistVariableExecutorTest {
}
@Test
- void assertExecuteWithTemporaryConfigurationKey() throws SQLException {
+ void assertExecuteWithTemporaryConfigurationKey() {
SetDistVariableStatement statement = new
SetDistVariableStatement("proxy_meta_data_collector_enabled", "false");
ContextManager contextManager = mockContextManager();
executor.executeUpdate(statement, contextManager);
@@ -67,7 +65,7 @@ class SetDistVariableExecutorTest {
}
@Test
- void assertExecuteWithTypedSPI() throws SQLException {
+ void assertExecuteWithTypedSPI() {
SetDistVariableStatement statement = new
SetDistVariableStatement("proxy_frontend_database_protocol_type", "Fixture");
ContextManager contextManager = mockContextManager();
executor.executeUpdate(statement, contextManager);
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecuteEngine.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecuteEngine.java
index 2a9ffd9076b..528293bba8c 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecuteEngine.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecuteEngine.java
@@ -58,7 +58,7 @@ public final class FirebirdCommandExecuteEngine implements
CommandExecuteEngine
}
@Override
- public CommandExecutor getCommandExecutor(final CommandPacketType type,
final CommandPacket packet, final ConnectionSession connectionSession) throws
SQLException {
+ public CommandExecutor getCommandExecutor(final CommandPacketType type,
final CommandPacket packet, final ConnectionSession connectionSession) {
return
FirebirdCommandExecutorFactory.newInstance((FirebirdCommandPacketType) type,
packet, connectionSession);
}
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecutorFactoryTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecutorFactoryTest.java
index a183954dd19..fe3345b34a9 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecutorFactoryTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecutorFactoryTest.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.proxy.frontend.firebird.command;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.FirebirdCommandPacketType;
-import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.info.FirebirdInfoPacket;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdCancelBlobCommandPacket;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdCloseBlobCommandPacket;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdCreateBlobCommandPacket;
@@ -26,6 +25,7 @@ import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdOpenBlobCommandPacket;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdPutBlobSegmentCommandPacket;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdSeekBlobCommandPacket;
+import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.info.FirebirdInfoPacket;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.statement.FirebirdAllocateStatementPacket;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.statement.FirebirdFetchStatementPacket;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.statement.FirebirdFreeStatementPacket;
@@ -37,8 +37,6 @@ import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query
import
org.apache.shardingsphere.database.protocol.packet.command.CommandPacket;
import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.admin.FirebirdUnsupportedCommandExecutor;
-import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.info.FirebirdDatabaseInfoExecutor;
-import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.info.FirebirdSQLInfoExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.blob.FirebirdCancelBlobCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.blob.FirebirdCloseBlobCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.blob.FirebirdCreateBlobCommandExecutor;
@@ -46,10 +44,12 @@ import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.blob.Fire
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.blob.FirebirdOpenBlobCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.blob.FirebirdPutBlobSegmentCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.blob.FirebirdSeekBlobCommandExecutor;
+import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.info.FirebirdDatabaseInfoExecutor;
+import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.info.FirebirdSQLInfoExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.allocate.FirebirdAllocateStatementCommandExecutor;
+import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.execute.FirebirdExecuteStatementCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.fetch.FirebirdFetchStatementCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.free.FirebirdFreeStatementCommandExecutor;
-import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.execute.FirebirdExecuteStatementCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.prepare.FirebirdPrepareStatementCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.transaction.FirebirdCommitTransactionCommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.transaction.FirebirdRollbackTransactionCommandExecutor;
@@ -60,8 +60,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
-
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.isA;
import static org.mockito.Mockito.mock;
@@ -73,119 +71,119 @@ class FirebirdCommandExecutorFactoryTest {
private ConnectionSession connectionSession;
@Test
- void assertNewInstanceWithInfoDatabase() throws SQLException {
+ void assertNewInstanceWithInfoDatabase() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.INFO_DATABASE,
mock(FirebirdInfoPacket.class), connectionSession),
isA(FirebirdDatabaseInfoExecutor.class));
}
@Test
- void assertNewInstanceWithTransaction() throws SQLException {
+ void assertNewInstanceWithTransaction() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.TRANSACTION,
mock(FirebirdStartTransactionPacket.class), connectionSession),
isA(FirebirdStartTransactionCommandExecutor.class));
}
@Test
- void assertNewInstanceWithCreateBlob() throws SQLException {
+ void assertNewInstanceWithCreateBlob() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.CREATE_BLOB,
mock(FirebirdCreateBlobCommandPacket.class), connectionSession),
isA(FirebirdCreateBlobCommandExecutor.class));
}
@Test
- void assertNewInstanceWithCreateBlob2() throws SQLException {
+ void assertNewInstanceWithCreateBlob2() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.CREATE_BLOB2,
mock(FirebirdCreateBlobCommandPacket.class), connectionSession),
isA(FirebirdCreateBlobCommandExecutor.class));
}
@Test
- void assertNewInstanceWithOpenBlob() throws SQLException {
+ void assertNewInstanceWithOpenBlob() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.OPEN_BLOB,
mock(FirebirdOpenBlobCommandPacket.class), connectionSession),
isA(FirebirdOpenBlobCommandExecutor.class));
}
@Test
- void assertNewInstanceWithOpenBlob2() throws SQLException {
+ void assertNewInstanceWithOpenBlob2() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.OPEN_BLOB2,
mock(FirebirdOpenBlobCommandPacket.class), connectionSession),
isA(FirebirdOpenBlobCommandExecutor.class));
}
@Test
- void assertNewInstanceWithGetBlobSegment() throws SQLException {
+ void assertNewInstanceWithGetBlobSegment() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.GET_SEGMENT,
mock(FirebirdGetBlobSegmentCommandPacket.class), connectionSession),
isA(FirebirdGetBlobSegmentCommandExecutor.class));
}
@Test
- void assertNewInstanceWithPutBlobSegment() throws SQLException {
+ void assertNewInstanceWithPutBlobSegment() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.PUT_SEGMENT,
mock(FirebirdPutBlobSegmentCommandPacket.class), connectionSession),
isA(FirebirdPutBlobSegmentCommandExecutor.class));
}
@Test
- void assertNewInstanceWithCancelBlob() throws SQLException {
+ void assertNewInstanceWithCancelBlob() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.CANCEL_BLOB,
mock(FirebirdCancelBlobCommandPacket.class), connectionSession),
isA(FirebirdCancelBlobCommandExecutor.class));
}
@Test
- void assertNewInstanceWithCloseBlob() throws SQLException {
+ void assertNewInstanceWithCloseBlob() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.CLOSE_BLOB,
mock(FirebirdCloseBlobCommandPacket.class), connectionSession),
isA(FirebirdCloseBlobCommandExecutor.class));
}
@Test
- void assertNewInstanceWithSeekBlob() throws SQLException {
+ void assertNewInstanceWithSeekBlob() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.SEEK_BLOB,
mock(FirebirdSeekBlobCommandPacket.class), connectionSession),
isA(FirebirdSeekBlobCommandExecutor.class));
}
@Test
- void assertNewInstanceWithAllocateStatement() throws SQLException {
+ void assertNewInstanceWithAllocateStatement() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.ALLOCATE_STATEMENT,
mock(FirebirdAllocateStatementPacket.class), connectionSession),
isA(FirebirdAllocateStatementCommandExecutor.class));
}
@Test
- void assertNewInstanceWithPrepareStatement() throws SQLException {
+ void assertNewInstanceWithPrepareStatement() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.PREPARE_STATEMENT,
mock(FirebirdPrepareStatementPacket.class), connectionSession),
isA(FirebirdPrepareStatementCommandExecutor.class));
}
@Test
- void assertNewInstanceWithExecuteStatement() throws SQLException {
+ void assertNewInstanceWithExecuteStatement() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.EXECUTE,
mock(FirebirdExecuteStatementPacket.class), connectionSession),
isA(FirebirdExecuteStatementCommandExecutor.class));
}
@Test
- void assertNewInstanceWithFetch() throws SQLException {
+ void assertNewInstanceWithFetch() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.FETCH,
mock(FirebirdFetchStatementPacket.class), connectionSession),
isA(FirebirdFetchStatementCommandExecutor.class));
}
@Test
- void assertNewInstanceWithInfoSQL() throws SQLException {
+ void assertNewInstanceWithInfoSQL() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.INFO_SQL,
mock(FirebirdInfoPacket.class), connectionSession),
isA(FirebirdSQLInfoExecutor.class));
}
@Test
- void assertNewInstanceWithCommit() throws SQLException {
+ void assertNewInstanceWithCommit() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.COMMIT,
mock(FirebirdCommitTransactionPacket.class), connectionSession),
isA(FirebirdCommitTransactionCommandExecutor.class));
}
@Test
- void assertNewInstanceWithRollback() throws SQLException {
+ void assertNewInstanceWithRollback() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.ROLLBACK,
mock(FirebirdRollbackTransactionPacket.class), connectionSession),
isA(FirebirdRollbackTransactionCommandExecutor.class));
}
@Test
- void assertNewInstanceWithFreeStatement() throws SQLException {
+ void assertNewInstanceWithFreeStatement() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.FREE_STATEMENT,
mock(FirebirdFreeStatementPacket.class), connectionSession),
isA(FirebirdFreeStatementCommandExecutor.class));
}
@Test
- void assertNewInstanceWithUnsupportedCommand() throws SQLException {
+ void assertNewInstanceWithUnsupportedCommand() {
assertThat(FirebirdCommandExecutorFactory.newInstance(FirebirdCommandPacketType.VOID,
mock(CommandPacket.class), connectionSession),
isA(FirebirdUnsupportedCommandExecutor.class));
}
}
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCancelBlobCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCancelBlobCommandExecutorTest.java
index bbcd09f043a..4527f02f287 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCancelBlobCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCancelBlobCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -61,7 +60,7 @@ class FirebirdCancelBlobCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
FirebirdCancelBlobCommandExecutor executor = new
FirebirdCancelBlobCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
assertThat(actual.size(), is(1));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCloseBlobCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCloseBlobCommandExecutorTest.java
index 42e5b4367ff..14de1de0d14 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCloseBlobCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCloseBlobCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -61,7 +60,7 @@ class FirebirdCloseBlobCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
FirebirdCloseBlobCommandExecutor executor = new
FirebirdCloseBlobCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
assertThat(actual.size(), is(1));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCreateBlobCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCreateBlobCommandExecutorTest.java
index e9bd9751020..4a69ff1780b 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCreateBlobCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCreateBlobCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -61,7 +60,7 @@ class FirebirdCreateBlobCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
FirebirdCreateBlobCommandExecutor executor = new
FirebirdCreateBlobCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
assertThat(actual.size(), is(1));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdGetBlobSegmentCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdGetBlobSegmentCommandExecutorTest.java
index e9416543649..518f1df5134 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdGetBlobSegmentCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdGetBlobSegmentCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -61,7 +60,7 @@ class FirebirdGetBlobSegmentCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
FirebirdGetBlobSegmentCommandExecutor executor = new
FirebirdGetBlobSegmentCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
assertThat(actual.size(), is(1));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdOpenBlobCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdOpenBlobCommandExecutorTest.java
index a2eac0f12b3..ac17e026007 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdOpenBlobCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdOpenBlobCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -61,7 +60,7 @@ class FirebirdOpenBlobCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
FirebirdOpenBlobCommandExecutor executor = new
FirebirdOpenBlobCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
assertThat(actual.size(), is(1));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdPutBlobSegmentCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdPutBlobSegmentCommandExecutorTest.java
index 5fd3cfbe43e..7309dc8e353 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdPutBlobSegmentCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdPutBlobSegmentCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -61,7 +60,7 @@ class FirebirdPutBlobSegmentCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
FirebirdPutBlobSegmentCommandExecutor executor = new
FirebirdPutBlobSegmentCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
assertThat(actual.size(), is(1));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdSeekBlobCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdSeekBlobCommandExecutorTest.java
index daa79938da7..2fb6ecc5e72 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdSeekBlobCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdSeekBlobCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -61,7 +60,7 @@ class FirebirdSeekBlobCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
FirebirdSeekBlobCommandExecutor executor = new
FirebirdSeekBlobCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
assertThat(actual.size(), is(1));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/allocate/FirebirdAllocateStatementCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/allocate/FirebirdAllocateStatementCommandExecutorTest.java
index 36bea2138c2..7a463f6393a 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/allocate/FirebirdAllocateStatementCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/allocate/FirebirdAllocateStatementCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -61,7 +60,7 @@ class FirebirdAllocateStatementCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
FirebirdAllocateStatementCommandExecutor executor = new
FirebirdAllocateStatementCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
assertThat(actual.size(), is(1));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/free/FirebirdFreeStatementCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/free/FirebirdFreeStatementCommandExecutorTest.java
index 5ae99fcdb86..e664c931b05 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/free/FirebirdFreeStatementCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/free/FirebirdFreeStatementCommandExecutorTest.java
@@ -36,7 +36,6 @@ import org.mockito.junit.jupiter.MockitoExtension;
import org.mockito.junit.jupiter.MockitoSettings;
import org.mockito.quality.Strictness;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.MatcherAssert.assertThat;
@@ -86,7 +85,7 @@ class FirebirdFreeStatementCommandExecutorTest {
}
@Test
- void assertExecuteWithDrop() throws SQLException {
+ void assertExecuteWithDrop() {
when(packet.getOption()).thenReturn(FirebirdFreeStatementPacket.DROP);
FirebirdFreeStatementCommandExecutor executor = new
FirebirdFreeStatementCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
@@ -95,7 +94,7 @@ class FirebirdFreeStatementCommandExecutorTest {
}
@Test
- void assertExecuteWithUnprepare() throws SQLException {
+ void assertExecuteWithUnprepare() {
when(packet.getOption()).thenReturn(FirebirdFreeStatementPacket.UNPREPARE);
FirebirdFreeStatementCommandExecutor executor = new
FirebirdFreeStatementCommandExecutor(packet, connectionSession);
Collection<DatabasePacket> actual = executor.execute();
@@ -104,7 +103,7 @@ class FirebirdFreeStatementCommandExecutorTest {
}
@Test
- void assertExecuteWithClose() throws SQLException {
+ void assertExecuteWithClose() {
when(packet.getOption()).thenReturn(FirebirdFreeStatementPacket.CLOSE);
FirebirdFreeStatementCommandExecutor executor = new
FirebirdFreeStatementCommandExecutor(packet, connectionSession);
executor.execute();
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutorTest.java
index ad1f6271a38..8bf8e4efcab 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutorTest.java
@@ -30,7 +30,6 @@ import org.mockito.Answers;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
-import java.sql.SQLException;
import java.util.Collection;
import static org.hamcrest.CoreMatchers.is;
@@ -62,7 +61,7 @@ class FirebirdStartTransactionCommandExecutorTest {
}
@Test
- void assertExecute() throws SQLException {
+ void assertExecute() {
when(packet.getAutocommit()).thenReturn(true);
when(packet.getReadOnly()).thenReturn(true);
when(packet.getIsolationLevel()).thenReturn(TransactionIsolationLevel.SERIALIZABLE);
diff --git
a/proxy/frontend/dialect/postgresql/src/test/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/extended/flush/PostgreSQLComFlushExecutorTest.java
b/proxy/frontend/dialect/postgresql/src/test/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/extended/flush/PostgreSQLComFlushExecutorTest.java
index f9becfa2101..bde5a42d9ec 100644
---
a/proxy/frontend/dialect/postgresql/src/test/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/extended/flush/PostgreSQLComFlushExecutorTest.java
+++
b/proxy/frontend/dialect/postgresql/src/test/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/extended/flush/PostgreSQLComFlushExecutorTest.java
@@ -19,7 +19,6 @@ package
org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extend
import org.junit.jupiter.api.Test;
-import java.sql.SQLException;
import java.util.Collections;
import static org.hamcrest.CoreMatchers.is;
@@ -28,7 +27,7 @@ import static org.hamcrest.MatcherAssert.assertThat;
class PostgreSQLComFlushExecutorTest {
@Test
- void assertNewInstance() throws SQLException {
+ void assertNewInstance() {
PostgreSQLComFlushExecutor actual = new PostgreSQLComFlushExecutor();
assertThat(actual.execute(), is(Collections.emptyList()));
}
diff --git
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/operation/transaction/cases/statement/BaseTCLStatementTransactionTestCase.java
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/operation/transaction/cases/statement/BaseTCLStatementTransactionTestCase.java
index 7c2a8bf0f16..e96674dbc86 100644
---
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/operation/transaction/cases/statement/BaseTCLStatementTransactionTestCase.java
+++
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/operation/transaction/cases/statement/BaseTCLStatementTransactionTestCase.java
@@ -27,7 +27,7 @@ import java.sql.SQLException;
*/
public abstract class BaseTCLStatementTransactionTestCase extends
BaseTransactionTestCase {
- public BaseTCLStatementTransactionTestCase(final
TransactionTestCaseParameter testCaseParam) {
+ protected BaseTCLStatementTransactionTestCase(final
TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/calculator/RecordTableInventoryCheckCalculatorTest.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/calculator/RecordTableInventoryCheckCalculatorTest.java
index d39bf3d4b8c..27b689b53d2 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/calculator/RecordTableInventoryCheckCalculatorTest.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/calculator/RecordTableInventoryCheckCalculatorTest.java
@@ -63,7 +63,7 @@ class RecordTableInventoryCheckCalculatorTest {
}
@AfterAll
- static void tearDown() throws Exception {
+ static void tearDown() {
dataSource.close();
}
