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 a7f0051f2f4 Refactor methods to remove SQLException declarations for
cleaner code (#37170)
a7f0051f2f4 is described below
commit a7f0051f2f4b8cd36217205cc340bca5e5904be2
Author: Liang Zhang <[email protected]>
AuthorDate: Sun Nov 23 18:52:34 2025 +0800
Refactor methods to remove SQLException declarations for cleaner code
(#37170)
---
.../collector/DialectTableStatisticsCollector.java | 4 +---
.../table/PostgreSQLPgClassTableStatisticsCollector.java | 3 +--
.../PostgreSQLPgNamespaceTableStatisticsCollector.java | 3 +--
.../rdl/rule/engine/database/DatabaseRuleOperator.java | 5 +----
.../engine/global/GlobalRuleDefinitionExecuteEngine.java | 6 +-----
.../engine/raw/callback/RawSQLExecutorCallback.java | 3 +--
.../query/type/memory/AbstractMemoryQueryResult.java | 3 +--
.../sql/prepare/raw/RawExecutionPrepareEngine.java | 3 +--
.../jdbc/core/statement/ShardingSphereStatement.java | 2 +-
.../state/circuit/statement/CircuitBreakerStatement.java | 3 +--
.../pipeline/core/datasource/PipelineDataSource.java | 2 +-
.../core/datasource/PipelineDataSourceManager.java | 7 +------
.../core/execute/AbstractPipelineLifecycleRunnable.java | 5 ++---
.../core/ingest/dumper/inventory/InventoryDumper.java | 2 +-
.../data/pipeline/core/job/api/TransmissionJobAPI.java | 2 +-
.../data/pipeline/core/util/PipelineLazyInitializer.java | 2 +-
.../shardingsphere/data/pipeline/cdc/api/CDCJobAPI.java | 4 ++--
.../cdc/core/importer/sink/PipelineCDCSocketSink.java | 3 +--
.../distsql/handler/update/DropStreamingExecutor.java | 4 +---
.../handler/update/CheckMigrationJobExecutor.java | 10 ++++------
.../shardingsphere/transaction/spi/TransactionHook.java | 9 +++------
.../schema/AlterSchemaPushDownMetaDataRefresher.java | 3 +--
.../type/table/RenameTablePushDownMetaDataRefresher.java | 3 +--
.../backend/connector/AdvancedProxySQLExecutor.java | 4 +---
.../database/type/CreateDatabaseProxyBackendHandler.java | 4 +---
.../database/type/DropDatabaseProxyBackendHandler.java | 4 +---
.../imports/ImportDatabaseConfigurationExecutor.java | 3 +--
.../ral/updatable/imports/ImportMetaDataExecutor.java | 3 +--
.../ral/updatable/label/LabelComputeNodeExecutor.java | 3 +--
.../refresh/RefreshDatabaseMetaDataExecutor.java | 3 +--
.../updatable/refresh/RefreshTableMetaDataExecutor.java | 3 +--
.../ral/updatable/variable/SetDistVariableExecutor.java | 3 +--
.../backend/handler/distsql/rul/PreviewExecutor.java | 3 +--
.../jdbc/fixture/QueryHeaderBuilderFixture.java | 3 +--
.../firebird/command/FirebirdCommandExecutorFactory.java | 16 ++++++----------
.../query/blob/FirebirdCancelBlobCommandExecutor.java | 3 +--
.../query/blob/FirebirdCloseBlobCommandExecutor.java | 3 +--
.../query/blob/FirebirdCreateBlobCommandExecutor.java | 3 +--
.../blob/FirebirdGetBlobSegmentCommandExecutor.java | 3 +--
.../query/blob/FirebirdOpenBlobCommandExecutor.java | 3 +--
.../blob/FirebirdPutBlobSegmentCommandExecutor.java | 3 +--
.../query/blob/FirebirdSeekBlobCommandExecutor.java | 3 +--
.../FirebirdAllocateStatementCommandExecutor.java | 3 +--
.../free/FirebirdFreeStatementCommandExecutor.java | 3 +--
.../prepare/FirebirdPrepareStatementCommandExecutor.java | 3 +--
.../FirebirdStartTransactionCommandExecutor.java | 3 +--
.../query/extended/flush/PostgreSQLComFlushExecutor.java | 3 +--
.../alterresource/SwitchingTransactionRuleTestCase.java | 2 +-
.../test/e2e/sql/it/sql/dml/BaseDMLE2EIT.java | 3 +--
.../test/e2e/sql/it/sql/dql/BaseDQLE2EIT.java | 2 +-
50 files changed, 62 insertions(+), 124 deletions(-)
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/DialectTableStatisticsCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/DialectTableStatisticsCollector.java
index 9ee108987ee..c16f2842dbb 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/DialectTableStatisticsCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/DialectTableStatisticsCollector.java
@@ -20,7 +20,6 @@ package
org.apache.shardingsphere.infra.metadata.statistics.collector;
import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPI;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Map;
@@ -51,7 +50,6 @@ public interface DialectTableStatisticsCollector extends
TypedSPI {
* @param tableName table name
* @param metaData shardingsphere meta data
* @return row columns data
- * @throws SQLException SQL exception
*/
- Collection<Map<String, Object>> collect(String databaseName, String
schemaName, String tableName, ShardingSphereMetaData metaData) throws
SQLException;
+ Collection<Map<String, Object>> collect(String databaseName, String
schemaName, String tableName, ShardingSphereMetaData metaData);
}
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgClassTableStatisticsCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgClassTableStatisticsCollector.java
index 74320109095..3d090e5a27f 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgClassTableStatisticsCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgClassTableStatisticsCollector.java
@@ -23,7 +23,6 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import
org.apache.shardingsphere.infra.metadata.statistics.collector.postgresql.PostgreSQLTableStatisticsCollector;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.LinkedList;
import java.util.Map;
@@ -36,7 +35,7 @@ public final class PostgreSQLPgClassTableStatisticsCollector
implements PostgreS
private static final String PUBLIC_SCHEMA = "public";
@Override
- public Collection<Map<String, Object>> collect(final String databaseName,
final String schemaName, final String tableName, final ShardingSphereMetaData
metaData) throws SQLException {
+ public Collection<Map<String, Object>> collect(final String databaseName,
final String schemaName, final String tableName, final ShardingSphereMetaData
metaData) {
Collection<Map<String, Object>> result = new LinkedList<>();
ShardingSphereSchema publicSchema =
metaData.getDatabase(databaseName).getSchema(PUBLIC_SCHEMA);
if (null != publicSchema) {
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgNamespaceTableStatisticsCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgNamespaceTableStatisticsCollector.java
index cdf348f7f1f..5820f70eeda 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgNamespaceTableStatisticsCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/postgresql/table/PostgreSQLPgNamespaceTableStatisticsCollector.java
@@ -22,7 +22,6 @@ import
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereSchema;
import
org.apache.shardingsphere.infra.metadata.statistics.collector.postgresql.PostgreSQLTableStatisticsCollector;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.LinkedList;
import java.util.Map;
@@ -37,7 +36,7 @@ public final class
PostgreSQLPgNamespaceTableStatisticsCollector implements Post
private static final Long PUBLIC_SCHEMA_OID = 0L;
@Override
- public Collection<Map<String, Object>> collect(final String databaseName,
final String schemaName, final String tableName, final ShardingSphereMetaData
metaData) throws SQLException {
+ public Collection<Map<String, Object>> collect(final String databaseName,
final String schemaName, final String tableName, final ShardingSphereMetaData
metaData) {
Collection<Map<String, Object>> result = new LinkedList<>();
long oid = 1L;
for (ShardingSphereSchema each :
metaData.getDatabase(databaseName).getAllSchemas()) {
diff --git
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/database/DatabaseRuleOperator.java
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/database/DatabaseRuleOperator.java
index febd3ad6088..78b186085c2 100644
---
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/database/DatabaseRuleOperator.java
+++
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/database/DatabaseRuleOperator.java
@@ -21,8 +21,6 @@ import
org.apache.shardingsphere.distsql.statement.type.rdl.rule.database.Databa
import org.apache.shardingsphere.infra.config.rule.RuleConfiguration;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
-import java.sql.SQLException;
-
/**
* Database rule operator.
*/
@@ -34,7 +32,6 @@ public interface DatabaseRuleOperator {
* @param sqlStatement SQL statement
* @param database database
* @param currentRuleConfig current rule configuration
- * @throws SQLException SQL Exception
*/
- void operate(DatabaseRuleDefinitionStatement sqlStatement,
ShardingSphereDatabase database, RuleConfiguration currentRuleConfig) throws
SQLException;
+ void operate(DatabaseRuleDefinitionStatement sqlStatement,
ShardingSphereDatabase database, RuleConfiguration currentRuleConfig);
}
diff --git
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/global/GlobalRuleDefinitionExecuteEngine.java
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/global/GlobalRuleDefinitionExecuteEngine.java
index b115613b0a5..6eaa9200345 100644
---
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/global/GlobalRuleDefinitionExecuteEngine.java
+++
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/global/GlobalRuleDefinitionExecuteEngine.java
@@ -22,8 +22,6 @@ import
org.apache.shardingsphere.distsql.handler.engine.update.rdl.rule.spi.glob
import
org.apache.shardingsphere.distsql.statement.type.rdl.rule.global.GlobalRuleDefinitionStatement;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import java.sql.SQLException;
-
/**
* Global rule definition execute engine.
*/
@@ -39,11 +37,9 @@ public final class GlobalRuleDefinitionExecuteEngine {
/**
* Execute update.
- *
- * @throws SQLException SQL exception
*/
@SuppressWarnings("unchecked")
- public void executeUpdate() throws SQLException {
+ public void executeUpdate() {
executor.checkBeforeUpdate(sqlStatement);
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService().alterGlobalRuleConfiguration(executor.buildToBeAlteredRuleConfiguration(sqlStatement));
}
diff --git
a/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/engine/raw/callback/RawSQLExecutorCallback.java
b/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/engine/raw/callback/RawSQLExecutorCallback.java
index 00d3f9f384d..7d062f90732 100644
---
a/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/engine/raw/callback/RawSQLExecutorCallback.java
+++
b/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/engine/raw/callback/RawSQLExecutorCallback.java
@@ -24,7 +24,6 @@ import
org.apache.shardingsphere.infra.executor.sql.execute.result.ExecuteResult
import org.apache.shardingsphere.infra.executor.sql.process.ProcessEngine;
import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
-import java.sql.SQLException;
import java.util.Collection;
/**
@@ -44,7 +43,7 @@ public final class RawSQLExecutorCallback implements
ExecutorCallback<RawSQLExec
@SuppressWarnings("unchecked")
@Override
- public Collection<ExecuteResult> execute(final
Collection<RawSQLExecutionUnit> inputs, final boolean isTrunkThread, final
String processId) throws SQLException {
+ public Collection<ExecuteResult> execute(final
Collection<RawSQLExecutionUnit> inputs, final boolean isTrunkThread, final
String processId) {
Collection<ExecuteResult> result =
callbacks.iterator().next().execute(inputs, isTrunkThread);
for (RawSQLExecutionUnit each : inputs) {
processEngine.completeSQLUnitExecution(each, processId);
diff --git
a/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/type/memory/AbstractMemoryQueryResult.java
b/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/type/memory/AbstractMemoryQueryResult.java
index 526f9a22998..1954514cda5 100644
---
a/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/type/memory/AbstractMemoryQueryResult.java
+++
b/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/type/memory/AbstractMemoryQueryResult.java
@@ -31,7 +31,6 @@ import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.io.Reader;
-import java.sql.SQLException;
import java.util.Calendar;
import java.util.Collection;
import java.util.Iterator;
@@ -103,7 +102,7 @@ public abstract class AbstractMemoryQueryResult implements
QueryResult {
}
@Override
- public Reader getCharacterStream(final int columnIndex) throws
SQLException {
+ public Reader getCharacterStream(final int columnIndex) {
// TODO Support connection property character encoding
return new BufferedReader(new
InputStreamReader(getInputStream(columnIndex)));
}
diff --git
a/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/prepare/raw/RawExecutionPrepareEngine.java
b/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/prepare/raw/RawExecutionPrepareEngine.java
index b1572ef52da..dcf5a486ff3 100644
---
a/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/prepare/raw/RawExecutionPrepareEngine.java
+++
b/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/prepare/raw/RawExecutionPrepareEngine.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.infra.executor.sql.execute.engine.raw.RawSQLExe
import
org.apache.shardingsphere.infra.executor.sql.prepare.AbstractExecutionPrepareEngine;
import org.apache.shardingsphere.infra.rule.ShardingSphereRule;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.List;
import java.util.stream.Collectors;
@@ -42,7 +41,7 @@ public final class RawExecutionPrepareEngine extends
AbstractExecutionPrepareEng
@Override
protected List<ExecutionGroup<RawSQLExecutionUnit>> group(final String
databaseName, final String dataSourceName, final int connectionOffset, final
List<List<ExecutionUnit>> executionUnitGroups,
- final
ConnectionMode connectionMode) throws SQLException {
+ final
ConnectionMode connectionMode) {
return executionUnitGroups.stream().map(each ->
createExecutionGroup(each, connectionMode)).collect(Collectors.toList());
}
diff --git
a/jdbc/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
b/jdbc/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
index f44cd8db5be..510ef7e4405 100644
---
a/jdbc/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
+++
b/jdbc/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
@@ -284,7 +284,7 @@ public final class ShardingSphereStatement extends
AbstractStatementAdapter {
}
@Override
- public void addBatch(final String sql) throws SQLException {
+ public void addBatch(final String sql) {
batchStatementExecutor.addBatch(sql);
}
diff --git
a/jdbc/src/main/java/org/apache/shardingsphere/driver/state/circuit/statement/CircuitBreakerStatement.java
b/jdbc/src/main/java/org/apache/shardingsphere/driver/state/circuit/statement/CircuitBreakerStatement.java
index 57ea193a6af..64d79a04312 100644
---
a/jdbc/src/main/java/org/apache/shardingsphere/driver/state/circuit/statement/CircuitBreakerStatement.java
+++
b/jdbc/src/main/java/org/apache/shardingsphere/driver/state/circuit/statement/CircuitBreakerStatement.java
@@ -22,7 +22,6 @@ import
org.apache.shardingsphere.driver.state.circuit.connection.CircuitBreakerC
import java.sql.Connection;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.SQLWarning;
import java.sql.Statement;
@@ -130,7 +129,7 @@ public final class CircuitBreakerStatement extends
WrapperAdapter implements Sta
}
@Override
- public int[] executeBatch() throws SQLException {
+ public int[] executeBatch() {
return new int[0];
}
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSource.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSource.java
index 1be03c1476a..20408f7fea3 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSource.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSource.java
@@ -110,7 +110,7 @@ public final class PipelineDataSource implements
DataSource, AutoCloseable {
}
@Override
- public void close() throws SQLException {
+ public void close() {
if (closed.get()) {
return;
}
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSourceManager.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSourceManager.java
index d02dc6c3013..4c31368f564 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSourceManager.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineDataSourceManager.java
@@ -20,7 +20,6 @@ package
org.apache.shardingsphere.data.pipeline.core.datasource;
import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.api.PipelineDataSourceConfiguration;
-import java.sql.SQLException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
@@ -63,11 +62,7 @@ public final class PipelineDataSourceManager implements
AutoCloseable {
if (each.isClosed()) {
continue;
}
- try {
- each.close();
- } catch (final SQLException ex) {
- log.error("An exception occurred while closing the data
source.", ex);
- }
+ each.close();
}
cachedDataSources.clear();
}
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/AbstractPipelineLifecycleRunnable.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/AbstractPipelineLifecycleRunnable.java
index 7985848e5da..bc4c8130bfd 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/AbstractPipelineLifecycleRunnable.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/AbstractPipelineLifecycleRunnable.java
@@ -20,7 +20,6 @@ package org.apache.shardingsphere.data.pipeline.core.execute;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.infra.util.datetime.DateTimeFormatterFactory;
-import java.sql.SQLException;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
@@ -67,14 +66,14 @@ public abstract class AbstractPipelineLifecycleRunnable
implements PipelineLifec
try {
doStop();
// CHECKSTYLE:OFF
- } catch (final SQLException | RuntimeException ex) {
+ } catch (final RuntimeException ex) {
// CHECKSTYLE:ON
log.warn("doStop failed", ex);
}
this.running.set(false);
}
- protected abstract void doStop() throws SQLException;
+ protected abstract void doStop();
@Override
public final void run() {
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
index 085a14dec27..c06585e4ef7 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
@@ -116,7 +116,7 @@ public final class InventoryDumper extends
AbstractPipelineLifecycleRunnable imp
}
}
- private void dumpByCalculator() throws SQLException {
+ private void dumpByCalculator() {
String schemaName =
dumperContext.getCommonContext().getTableAndSchemaNameMapper().getSchemaName(dumperContext.getLogicTableName());
QualifiedTable table = new QualifiedTable(schemaName,
dumperContext.getActualTableName());
IngestPosition initialPosition =
dumperContext.getCommonContext().getPosition();
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/api/TransmissionJobAPI.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/api/TransmissionJobAPI.java
index 61738c1160e..fc981773697 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/api/TransmissionJobAPI.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/api/TransmissionJobAPI.java
@@ -32,7 +32,7 @@ public interface TransmissionJobAPI extends TypedSPI {
* Commit pipeline job.
*
* @param jobId job ID
- * @throws SQLException sql exception
+ * @throws SQLException SQL exception
*/
void commit(String jobId) throws SQLException;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/PipelineLazyInitializer.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/PipelineLazyInitializer.java
index 0d7d116ea24..8f5fcb58b6a 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/PipelineLazyInitializer.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/PipelineLazyInitializer.java
@@ -43,5 +43,5 @@ public abstract class PipelineLazyInitializer<T> extends
LazyInitializer<T> {
return initialized.get();
}
- protected abstract T doInitialize() throws ConcurrentException;
+ protected abstract T doInitialize();
}
diff --git
a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/CDCJobAPI.java
b/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/CDCJobAPI.java
index 72b54107780..2980c6cfbae 100644
---
a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/CDCJobAPI.java
+++
b/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/CDCJobAPI.java
@@ -316,11 +316,11 @@ public final class CDCJobAPI implements
TransmissionJobAPI {
}
@Override
- public void commit(final String jobId) throws SQLException {
+ public void commit(final String jobId) {
}
@Override
- public void rollback(final String jobId) throws SQLException {
+ public void rollback(final String jobId) {
}
@Override
diff --git
a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/importer/sink/PipelineCDCSocketSink.java
b/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/importer/sink/PipelineCDCSocketSink.java
index 0d1c8a5c28d..d6d11c7914b 100644
---
a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/importer/sink/PipelineCDCSocketSink.java
+++
b/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/importer/sink/PipelineCDCSocketSink.java
@@ -31,7 +31,6 @@ import
org.apache.shardingsphere.data.pipeline.core.job.progress.listener.Pipeli
import
org.apache.shardingsphere.infra.exception.external.sql.sqlstate.XOpenSQLState;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
-import java.io.IOException;
import java.util.Collection;
import java.util.HashMap;
import java.util.LinkedList;
@@ -114,7 +113,7 @@ public final class PipelineCDCSocketSink implements
PipelineSink {
}
@Override
- public void close() throws IOException {
+ public void close() {
channel.writeAndFlush(CDCResponseUtils.failed("",
XOpenSQLState.GENERAL_ERROR.getValue(), "The socket channel is closed."));
}
}
diff --git
a/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/update/DropStreamingExecutor.java
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/update/DropStreamingExecutor.java
index 651b5989963..b1898b13a74 100644
---
a/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/update/DropStreamingExecutor.java
+++
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/update/DropStreamingExecutor.java
@@ -24,8 +24,6 @@ import
org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExec
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import java.sql.SQLException;
-
/**
* Drop streaming executor.
*/
@@ -34,7 +32,7 @@ public final class DropStreamingExecutor implements
DistSQLUpdateExecutor<DropSt
private final CDCJobAPI jobAPI = (CDCJobAPI)
TypedSPILoader.getService(TransmissionJobAPI.class, "STREAMING");
@Override
- public void executeUpdate(final DropStreamingStatement sqlStatement, final
ContextManager contextManager) throws SQLException {
+ public void executeUpdate(final DropStreamingStatement sqlStatement, final
ContextManager contextManager) {
jobAPI.drop(sqlStatement.getJobId());
}
diff --git
a/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/distsql/handler/update/CheckMigrationJobExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/distsql/handler/update/CheckMigrationJobExecutor.java
index 26575f31a8e..0df13deb2e2 100644
---
a/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/distsql/handler/update/CheckMigrationJobExecutor.java
+++
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/distsql/handler/update/CheckMigrationJobExecutor.java
@@ -21,7 +21,6 @@ import
org.apache.shardingsphere.data.pipeline.core.exception.param.PipelineInva
import
org.apache.shardingsphere.data.pipeline.core.job.progress.PipelineJobProgressDetector;
import
org.apache.shardingsphere.data.pipeline.core.job.service.PipelineJobConfigurationManager;
import
org.apache.shardingsphere.data.pipeline.core.job.service.TransmissionJobManager;
-import org.apache.shardingsphere.data.pipeline.core.job.type.PipelineJobType;
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobType;
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.ConsistencyCheckJobAPI;
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.CreateConsistencyCheckJobParameter;
@@ -33,7 +32,6 @@ import
org.apache.shardingsphere.distsql.segment.AlgorithmSegment;
import org.apache.shardingsphere.infra.exception.ShardingSpherePreconditions;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import java.sql.SQLException;
import java.util.Properties;
/**
@@ -43,21 +41,21 @@ public final class CheckMigrationJobExecutor implements
DistSQLUpdateExecutor<Ch
private final ConsistencyCheckJobAPI checkJobAPI = new
ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
- private final PipelineJobType migrationJobType = new MigrationJobType();
+ private final MigrationJobType jobType = new MigrationJobType();
@Override
- public void executeUpdate(final CheckMigrationStatement sqlStatement,
final ContextManager contextManager) throws SQLException {
+ public void executeUpdate(final CheckMigrationStatement sqlStatement,
final ContextManager contextManager) {
AlgorithmSegment typeStrategy = sqlStatement.getTypeStrategy();
String algorithmTypeName = null == typeStrategy ? null :
typeStrategy.getName();
Properties algorithmProps = null == typeStrategy ? null :
typeStrategy.getProps();
String jobId = sqlStatement.getJobId();
- MigrationJobConfiguration jobConfig = new
PipelineJobConfigurationManager(migrationJobType.getOption()).getJobConfiguration(jobId);
+ MigrationJobConfiguration jobConfig = new
PipelineJobConfigurationManager(jobType.getOption()).getJobConfiguration(jobId);
verifyInventoryFinished(jobConfig);
checkJobAPI.start(new CreateConsistencyCheckJobParameter(jobId,
algorithmTypeName, algorithmProps, jobConfig.getSourceDatabaseType(),
jobConfig.getTargetDatabaseType()));
}
private void verifyInventoryFinished(final MigrationJobConfiguration
jobConfig) {
- TransmissionJobManager transmissionJobManager = new
TransmissionJobManager(migrationJobType);
+ TransmissionJobManager transmissionJobManager = new
TransmissionJobManager(jobType);
ShardingSpherePreconditions.checkState(PipelineJobProgressDetector.isInventoryFinished(jobConfig.getJobShardingCount(),
transmissionJobManager.getJobProgress(jobConfig).values()),
() -> new PipelineInvalidParameterException("Inventory is not
finished."));
}
diff --git
a/kernel/transaction/api/src/main/java/org/apache/shardingsphere/transaction/spi/TransactionHook.java
b/kernel/transaction/api/src/main/java/org/apache/shardingsphere/transaction/spi/TransactionHook.java
index 67de9cf15be..6299eb4a775 100644
---
a/kernel/transaction/api/src/main/java/org/apache/shardingsphere/transaction/spi/TransactionHook.java
+++
b/kernel/transaction/api/src/main/java/org/apache/shardingsphere/transaction/spi/TransactionHook.java
@@ -96,9 +96,8 @@ public interface TransactionHook<T extends
ShardingSphereRule> extends OrderedSP
* @param databaseType database type
* @param connections connections
* @param transactionContext transaction context
- * @throws SQLException SQL exception
*/
- void afterCommit(T rule, DatabaseType databaseType, Collection<Connection>
connections, TransactionConnectionContext transactionContext) throws
SQLException;
+ void afterCommit(T rule, DatabaseType databaseType, Collection<Connection>
connections, TransactionConnectionContext transactionContext);
/**
* Whether to need lock when transaction committed.
@@ -115,9 +114,8 @@ public interface TransactionHook<T extends
ShardingSphereRule> extends OrderedSP
* @param databaseType database type
* @param connections connections
* @param transactionContext transaction context
- * @throws SQLException SQL exception
*/
- void beforeRollback(T rule, DatabaseType databaseType,
Collection<Connection> connections, TransactionConnectionContext
transactionContext) throws SQLException;
+ void beforeRollback(T rule, DatabaseType databaseType,
Collection<Connection> connections, TransactionConnectionContext
transactionContext);
/**
* Process after rolling back the transaction.
@@ -126,7 +124,6 @@ public interface TransactionHook<T extends
ShardingSphereRule> extends OrderedSP
* @param databaseType database type
* @param connections connections
* @param transactionContext transaction context
- * @throws SQLException SQL exception
*/
- void afterRollback(T rule, DatabaseType databaseType,
Collection<Connection> connections, TransactionConnectionContext
transactionContext) throws SQLException;
+ void afterRollback(T rule, DatabaseType databaseType,
Collection<Connection> connections, TransactionConnectionContext
transactionContext);
}
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/pushdown/type/schema/AlterSchemaPushDownMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/pushdown/type/schema/AlterSchemaPushDownMetaDataRefresher.java
index cae70578d43..d0d3739693a 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/pushdown/type/schema/AlterSchemaPushDownMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/pushdown/type/schema/AlterSchemaPushDownMetaDataRefresher.java
@@ -24,7 +24,6 @@ import
org.apache.shardingsphere.mode.metadata.refresher.pushdown.PushDownMetaDa
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.schema.AlterSchemaStatement;
-import java.sql.SQLException;
import java.util.Optional;
/**
@@ -34,7 +33,7 @@ public final class AlterSchemaPushDownMetaDataRefresher
implements PushDownMetaD
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
String logicDataSourceName,
- final String schemaName, final DatabaseType
databaseType, final AlterSchemaStatement sqlStatement, final
ConfigurationProperties props) throws SQLException {
+ final String schemaName, final DatabaseType
databaseType, final AlterSchemaStatement sqlStatement, final
ConfigurationProperties props) {
Optional<String> renameSchemaName =
sqlStatement.getRenameSchema().map(optional ->
optional.getValue().toLowerCase());
if (!renameSchemaName.isPresent()) {
return;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/pushdown/type/table/RenameTablePushDownMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/pushdown/type/table/RenameTablePushDownMetaDataRefresher.java
index 88cbe395cbb..549fa449518 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/pushdown/type/table/RenameTablePushDownMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/pushdown/type/table/RenameTablePushDownMetaDataRefresher.java
@@ -26,7 +26,6 @@ import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistServ
import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.RenameTableDefinitionSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.table.RenameTableStatement;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.LinkedList;
@@ -37,7 +36,7 @@ public final class RenameTablePushDownMetaDataRefresher
implements PushDownMetaD
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
String logicDataSourceName,
- final String schemaName, final DatabaseType
databaseType, final RenameTableStatement sqlStatement, final
ConfigurationProperties props) throws SQLException {
+ final String schemaName, final DatabaseType
databaseType, final RenameTableStatement sqlStatement, final
ConfigurationProperties props) {
Collection<ShardingSphereTable> alteredTables = new LinkedList<>();
Collection<String> droppedTables = new LinkedList<>();
for (RenameTableDefinitionSegment each :
sqlStatement.getRenameTables()) {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/AdvancedProxySQLExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/AdvancedProxySQLExecutor.java
index c02f47e1729..4c2421c7cb7 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/AdvancedProxySQLExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/AdvancedProxySQLExecutor.java
@@ -24,7 +24,6 @@ import org.apache.shardingsphere.infra.spi.ShardingSphereSPI;
import org.apache.shardingsphere.infra.spi.annotation.SingletonSPI;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import java.sql.SQLException;
import java.util.List;
/**
@@ -41,7 +40,6 @@ public interface AdvancedProxySQLExecutor extends
ShardingSphereSPI {
* @param database database
* @param databaseProxyConnector database proxy connector
* @return execute result
- * @throws SQLException SQL exception
*/
- List<ExecuteResult> execute(ExecutionContext executionContext,
ContextManager contextManager, ShardingSphereDatabase database,
DatabaseProxyConnector databaseProxyConnector) throws SQLException;
+ List<ExecuteResult> execute(ExecutionContext executionContext,
ContextManager contextManager, ShardingSphereDatabase database,
DatabaseProxyConnector databaseProxyConnector);
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/CreateDatabaseProxyBackendHandler.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/CreateDatabaseProxyBackendHandler.java
index c5e44ca82a6..cdcc0ae5978 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/CreateDatabaseProxyBackendHandler.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/CreateDatabaseProxyBackendHandler.java
@@ -26,8 +26,6 @@ import
org.apache.shardingsphere.proxy.backend.response.header.ResponseHeader;
import
org.apache.shardingsphere.proxy.backend.response.header.update.UpdateResponseHeader;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.database.CreateDatabaseStatement;
-import java.sql.SQLException;
-
/**
* Create database proxy backend handler.
*/
@@ -39,7 +37,7 @@ public final class CreateDatabaseProxyBackendHandler
implements ProxyBackendHand
private final ContextManager contextManager;
@Override
- public ResponseHeader execute() throws SQLException {
+ public ResponseHeader execute() {
ShardingSpherePreconditions.checkState(sqlStatement.isIfNotExists() ||
!contextManager.getMetaDataContexts().getMetaData().containsDatabase(sqlStatement.getDatabaseName()),
() -> new
DatabaseCreateExistsException(sqlStatement.getDatabaseName()));
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService().createDatabase(sqlStatement.getDatabaseName());
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandler.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandler.java
index 42624707a73..df0337a4419 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandler.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandler.java
@@ -36,8 +36,6 @@ import
org.apache.shardingsphere.proxy.backend.response.header.update.UpdateResp
import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.database.DropDatabaseStatement;
-import java.sql.SQLException;
-
/**
* Drop database proxy backend handler.
*/
@@ -51,7 +49,7 @@ public final class DropDatabaseProxyBackendHandler implements
ProxyBackendHandle
private final ConnectionSession connectionSession;
@Override
- public ResponseHeader execute() throws SQLException {
+ public ResponseHeader execute() {
ShardingSphereMetaData metaData =
contextManager.getMetaDataContexts().getMetaData();
check(sqlStatement, metaData,
connectionSession.getConnectionContext().getGrantee());
if (isDropCurrentDatabase(sqlStatement.getDatabaseName())) {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportDatabaseConfigurationExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportDatabaseConfigurationExecutor.java
index b5e1c3fde70..0c63928a01c 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportDatabaseConfigurationExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportDatabaseConfigurationExecutor.java
@@ -27,7 +27,6 @@ import
org.apache.shardingsphere.proxy.backend.util.MetaDataImportExecutor;
import java.io.File;
import java.io.IOException;
-import java.sql.SQLException;
import java.util.Collections;
/**
@@ -36,7 +35,7 @@ import java.util.Collections;
public final class ImportDatabaseConfigurationExecutor implements
DistSQLUpdateExecutor<ImportDatabaseConfigurationStatement> {
@Override
- public void executeUpdate(final ImportDatabaseConfigurationStatement
sqlStatement, final ContextManager contextManager) throws SQLException {
+ public void executeUpdate(final ImportDatabaseConfigurationStatement
sqlStatement, final ContextManager contextManager) {
YamlProxyDatabaseConfiguration yamlConfig =
getYamlProxyDatabaseConfiguration(sqlStatement);
new
MetaDataImportExecutor(contextManager).importDatabaseConfigurations(Collections.singletonList(yamlConfig));
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportMetaDataExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportMetaDataExecutor.java
index 5227297c5d0..f1988b3d38b 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportMetaDataExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/imports/ImportMetaDataExecutor.java
@@ -31,7 +31,6 @@ import
org.apache.shardingsphere.proxy.backend.util.MetaDataImportExecutor;
import java.io.File;
import java.io.IOException;
import java.nio.charset.Charset;
-import java.sql.SQLException;
/**
* Import meta data executor.
@@ -39,7 +38,7 @@ import java.sql.SQLException;
public final class ImportMetaDataExecutor implements
DistSQLUpdateExecutor<ImportMetaDataStatement> {
@Override
- public void executeUpdate(final ImportMetaDataStatement sqlStatement,
final ContextManager contextManager) throws SQLException {
+ public void executeUpdate(final ImportMetaDataStatement sqlStatement,
final ContextManager contextManager) {
String jsonMetaDataConfig = sqlStatement.getFilePath().isPresent() ?
getMetaDataFromFile(sqlStatement) : getMetaDataFromConsole(sqlStatement);
ExportedClusterInfo exportedClusterInfo =
JsonUtils.fromJsonString(jsonMetaDataConfig, ExportedClusterInfo.class);
ExportedMetaData exportedMetaData = exportedClusterInfo.getMetaData();
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/label/LabelComputeNodeExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/label/LabelComputeNodeExecutor.java
index e1c068feb73..6895025a2c5 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/label/LabelComputeNodeExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/label/LabelComputeNodeExecutor.java
@@ -24,7 +24,6 @@ import
org.apache.shardingsphere.infra.instance.ComputeNodeInstance;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.persist.facade.ClusterPersistServiceFacade;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.LinkedHashSet;
import java.util.LinkedList;
@@ -37,7 +36,7 @@ import java.util.Optional;
public final class LabelComputeNodeExecutor implements
DistSQLUpdateExecutor<LabelComputeNodeStatement> {
@Override
- public void executeUpdate(final LabelComputeNodeStatement sqlStatement,
final ContextManager contextManager) throws SQLException {
+ public void executeUpdate(final LabelComputeNodeStatement sqlStatement,
final ContextManager contextManager) {
String instanceId = sqlStatement.getInstanceId();
Optional<ComputeNodeInstance> computeNodeInstance =
contextManager.getComputeNodeInstanceContext().getClusterInstanceRegistry().find(instanceId);
if (computeNodeInstance.isPresent()) {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/refresh/RefreshDatabaseMetaDataExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/refresh/RefreshDatabaseMetaDataExecutor.java
index 88ae74ca116..85b48767f02 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/refresh/RefreshDatabaseMetaDataExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/refresh/RefreshDatabaseMetaDataExecutor.java
@@ -23,7 +23,6 @@ import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.metadata.database.schema.util.SystemSchemaUtils;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -33,7 +32,7 @@ import java.util.Collections;
public final class RefreshDatabaseMetaDataExecutor implements
DistSQLUpdateExecutor<RefreshDatabaseMetaDataStatement> {
@Override
- public void executeUpdate(final RefreshDatabaseMetaDataStatement
sqlStatement, final ContextManager contextManager) throws SQLException {
+ public void executeUpdate(final RefreshDatabaseMetaDataStatement
sqlStatement, final ContextManager contextManager) {
Collection<ShardingSphereDatabase> databases =
sqlStatement.getDatabaseName().map(optional ->
(Collection<ShardingSphereDatabase>)
Collections.singleton(contextManager.getDatabase(optional)))
.orElseGet(() ->
contextManager.getMetaDataContexts().getMetaData().getAllDatabases());
for (ShardingSphereDatabase each : databases) {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/refresh/RefreshTableMetaDataExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/refresh/RefreshTableMetaDataExecutor.java
index 706d848f770..c6aa70961f4 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/refresh/RefreshTableMetaDataExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/refresh/RefreshTableMetaDataExecutor.java
@@ -31,7 +31,6 @@ import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.metadata.database.resource.unit.StorageUnit;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import java.sql.SQLException;
import java.util.Collections;
import java.util.Map;
@@ -44,7 +43,7 @@ public final class RefreshTableMetaDataExecutor implements
DistSQLUpdateExecutor
private ShardingSphereDatabase database;
@Override
- public void executeUpdate(final RefreshTableMetaDataStatement
sqlStatement, final ContextManager contextManager) throws SQLException {
+ public void executeUpdate(final RefreshTableMetaDataStatement
sqlStatement, final ContextManager contextManager) {
String schemaName = getSchemaName(sqlStatement);
checkBeforeUpdate(sqlStatement, schemaName);
if (sqlStatement.getStorageUnitName().isPresent()) {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/variable/SetDistVariableExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/variable/SetDistVariableExecutor.java
index bac0c347241..c275ec479d9 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/variable/SetDistVariableExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/variable/SetDistVariableExecutor.java
@@ -33,7 +33,6 @@ import org.apache.shardingsphere.mode.manager.ContextManager;
import org.apache.shardingsphere.mode.metadata.MetaDataContexts;
import org.quartz.CronExpression;
-import java.sql.SQLException;
import java.util.Properties;
/**
@@ -42,7 +41,7 @@ import java.util.Properties;
public final class SetDistVariableExecutor implements
DistSQLUpdateExecutor<SetDistVariableStatement> {
@Override
- public void executeUpdate(final SetDistVariableStatement sqlStatement,
final ContextManager contextManager) throws SQLException {
+ public void executeUpdate(final SetDistVariableStatement sqlStatement,
final ContextManager contextManager) {
ShardingSpherePreconditions.checkState(getEnumType(sqlStatement.getName())
instanceof TypedPropertyKey, () -> new
UnsupportedVariableException(sqlStatement.getName()));
handleConfigurationProperty(contextManager, (TypedPropertyKey)
getEnumType(sqlStatement.getName()), sqlStatement.getValue());
}
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 0e6a364797c..d4fe058c9ac 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
@@ -131,8 +131,7 @@ public final class PreviewExecutor implements
DistSQLQueryExecutor<PreviewStatem
toBePreviewedStatementContext.setCursorStatementContext(cursorStatementContext);
}
- private Collection<ExecutionUnit> getFederationExecutionUnits(final
QueryContext queryContext, final ShardingSphereMetaData metaData,
- final
SQLFederationEngine federationEngine) throws SQLException {
+ private Collection<ExecutionUnit> getFederationExecutionUnits(final
QueryContext queryContext, final ShardingSphereMetaData metaData, final
SQLFederationEngine federationEngine) {
SQLStatement sqlStatement =
queryContext.getSqlStatementContext().getSqlStatement();
DriverExecutionPrepareEngine<JDBCExecutionUnit, Connection>
prepareEngine = createDriverExecutionPrepareEngine(metaData);
SQLFederationContext context = new SQLFederationContext(true,
queryContext, metaData,
diff --git
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/fixture/QueryHeaderBuilderFixture.java
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/fixture/QueryHeaderBuilderFixture.java
index acb275b111b..a6174c06922 100644
---
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/fixture/QueryHeaderBuilderFixture.java
+++
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/fixture/QueryHeaderBuilderFixture.java
@@ -22,14 +22,13 @@ import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.proxy.backend.response.header.query.QueryHeader;
import
org.apache.shardingsphere.proxy.backend.response.header.query.QueryHeaderBuilder;
-import java.sql.SQLException;
import java.sql.Types;
public final class QueryHeaderBuilderFixture implements QueryHeaderBuilder {
@Override
public QueryHeader build(final QueryResultMetaData queryResultMetaData,
- final ShardingSphereDatabase database, final
String columnName, final String columnLabel, final int columnIndex) throws
SQLException {
+ final ShardingSphereDatabase database, final
String columnName, final String columnLabel, final int columnIndex) {
return new QueryHeader(null, null, null, null, Types.INTEGER, null, 0,
0, false, false, false, false);
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecutorFactory.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecutorFactory.java
index d35c18ce7e5..d8895025a78 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecutorFactory.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/FirebirdCommandExecutorFactory.java
@@ -20,13 +20,13 @@ package
org.apache.shardingsphere.proxy.frontend.firebird.command;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.FirebirdCommandPacketType;
+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;
import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdGetBlobSegmentCommandPacket;
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.blob.FirebirdCreateBlobCommandPacket;
-import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdCloseBlobCommandPacket;
-import
org.apache.shardingsphere.database.protocol.firebird.packet.command.query.blob.FirebirdCancelBlobCommandPacket;
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;
@@ -39,6 +39,7 @@ 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.command.executor.CommandExecutor;
+import
org.apache.shardingsphere.proxy.frontend.firebird.command.admin.FirebirdUnsupportedCommandExecutor;
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,20 +47,17 @@ 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.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.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;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.transaction.FirebirdStartTransactionCommandExecutor;
-import java.sql.SQLException;
-
/**
* Command executor factory for Firebird.
*/
@@ -73,10 +71,8 @@ public final class FirebirdCommandExecutorFactory {
* @param commandPacket command packet for Firebird
* @param connectionSession connection session
* @return created instance
- * @throws SQLException SQL exception
*/
- public static CommandExecutor newInstance(final FirebirdCommandPacketType
commandPacketType, final CommandPacket commandPacket,
- final ConnectionSession
connectionSession) throws SQLException {
+ public static CommandExecutor newInstance(final FirebirdCommandPacketType
commandPacketType, final CommandPacket commandPacket, final ConnectionSession
connectionSession) {
switch (commandPacketType) {
case INFO_DATABASE:
return new FirebirdDatabaseInfoExecutor((FirebirdInfoPacket)
commandPacket, connectionSession);
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCancelBlobCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCancelBlobCommandExecutor.java
index 58d585efd7e..d3734ce7bbf 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCancelBlobCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCancelBlobCommandExecutor.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.FirebirdStatementIdGenerator;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -40,7 +39,7 @@ public final class FirebirdCancelBlobCommandExecutor
implements CommandExecutor
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
int statementId =
FirebirdStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());
return Collections.singleton(new
FirebirdGenericResponsePacket().setHandle(statementId));
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCloseBlobCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCloseBlobCommandExecutor.java
index 22adb74cb1a..c5978f30321 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCloseBlobCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCloseBlobCommandExecutor.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.FirebirdStatementIdGenerator;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -40,7 +39,7 @@ public final class FirebirdCloseBlobCommandExecutor
implements CommandExecutor {
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
int statementId =
FirebirdStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());
return Collections.singleton(new
FirebirdGenericResponsePacket().setHandle(statementId));
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCreateBlobCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCreateBlobCommandExecutor.java
index 3e1797111de..8cd71076835 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCreateBlobCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdCreateBlobCommandExecutor.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.FirebirdStatementIdGenerator;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -40,7 +39,7 @@ public final class FirebirdCreateBlobCommandExecutor
implements CommandExecutor
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
int statementId =
FirebirdStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());
return Collections.singleton(new
FirebirdGenericResponsePacket().setHandle(statementId));
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdGetBlobSegmentCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdGetBlobSegmentCommandExecutor.java
index 452f3cd2141..815bae0ec99 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdGetBlobSegmentCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdGetBlobSegmentCommandExecutor.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.FirebirdStatementIdGenerator;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -40,7 +39,7 @@ public final class FirebirdGetBlobSegmentCommandExecutor
implements CommandExecu
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
int statementId =
FirebirdStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());
return Collections.singleton(new
FirebirdGenericResponsePacket().setHandle(statementId));
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdOpenBlobCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdOpenBlobCommandExecutor.java
index 6a7ebe87cf1..6febfbd5185 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdOpenBlobCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdOpenBlobCommandExecutor.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.FirebirdStatementIdGenerator;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -40,7 +39,7 @@ public final class FirebirdOpenBlobCommandExecutor implements
CommandExecutor {
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
int statementId =
FirebirdStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());
return Collections.singleton(new
FirebirdGenericResponsePacket().setHandle(statementId));
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdPutBlobSegmentCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdPutBlobSegmentCommandExecutor.java
index 0dd6703524d..475e15b943a 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdPutBlobSegmentCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdPutBlobSegmentCommandExecutor.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.FirebirdStatementIdGenerator;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -40,7 +39,7 @@ public final class FirebirdPutBlobSegmentCommandExecutor
implements CommandExecu
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
int statementId =
FirebirdStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());
return Collections.singleton(new
FirebirdGenericResponsePacket().setHandle(statementId));
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdSeekBlobCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdSeekBlobCommandExecutor.java
index 4c2ac075573..469b37eaf41 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdSeekBlobCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/blob/FirebirdSeekBlobCommandExecutor.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.FirebirdStatementIdGenerator;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -40,7 +39,7 @@ public final class FirebirdSeekBlobCommandExecutor implements
CommandExecutor {
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
int statementId =
FirebirdStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());
return Collections.singleton(new
FirebirdGenericResponsePacket().setHandle(statementId));
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/allocate/FirebirdAllocateStatementCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/allocate/FirebirdAllocateStatementCommandExecutor.java
index 3b7cf234a92..545e9d975d8 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/allocate/FirebirdAllocateStatementCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/allocate/FirebirdAllocateStatementCommandExecutor.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.FirebirdStatementIdGenerator;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -40,7 +39,7 @@ public final class FirebirdAllocateStatementCommandExecutor
implements CommandEx
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
int statementId =
FirebirdStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());
return Collections.singleton(new
FirebirdGenericResponsePacket().setHandle(statementId));
}
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/free/FirebirdFreeStatementCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/free/FirebirdFreeStatementCommandExecutor.java
index da786481834..3d050685603 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/free/FirebirdFreeStatementCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/free/FirebirdFreeStatementCommandExecutor.java
@@ -27,7 +27,6 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
import
org.apache.shardingsphere.proxy.frontend.firebird.command.query.statement.fetch.FirebirdFetchStatementCache;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -42,7 +41,7 @@ public final class FirebirdFreeStatementCommandExecutor
implements CommandExecut
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
switch (packet.getOption()) {
case FirebirdFreeStatementPacket.DROP:
case FirebirdFreeStatementPacket.UNPREPARE:
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/prepare/FirebirdPrepareStatementCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/prepare/FirebirdPrepareStatementCommandExecutor.java
index 1377cbd8100..eed2b5347aa 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/prepare/FirebirdPrepareStatementCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/statement/prepare/FirebirdPrepareStatementCommandExecutor.java
@@ -83,7 +83,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.type.tcl.Ro
import
org.apache.shardingsphere.sql.parser.statement.core.statement.type.tcl.SavepointStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import java.sql.SQLException;
import java.sql.Types;
import java.util.Collection;
import java.util.Collections;
@@ -104,7 +103,7 @@ public final class FirebirdPrepareStatementCommandExecutor
implements CommandExe
private ReturningSegment returningSegment;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
MetaDataContexts metaDataContexts =
ProxyContext.getInstance().getContextManager().getMetaDataContexts();
SQLParserRule sqlParserRule =
metaDataContexts.getMetaData().getGlobalRuleMetaData().getSingleRule(SQLParserRule.class);
DatabaseType databaseType =
TypedSPILoader.getService(DatabaseType.class, "Firebird");
diff --git
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutor.java
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutor.java
index cddbcd38e50..676050d8960 100644
---
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutor.java
+++
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutor.java
@@ -24,7 +24,6 @@ import
org.apache.shardingsphere.database.protocol.packet.DatabasePacket;
import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -39,7 +38,7 @@ public final class FirebirdStartTransactionCommandExecutor
implements CommandExe
private final ConnectionSession connectionSession;
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
connectionSession.setAutoCommit(packet.getAutocommit());
connectionSession.setReadOnly(packet.getReadOnly());
connectionSession.setIsolationLevel(packet.getIsolationLevel());
diff --git
a/proxy/frontend/dialect/postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/extended/flush/PostgreSQLComFlushExecutor.java
b/proxy/frontend/dialect/postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/extended/flush/PostgreSQLComFlushExecutor.java
index e49536ae883..ad6d25a22d4 100644
---
a/proxy/frontend/dialect/postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/extended/flush/PostgreSQLComFlushExecutor.java
+++
b/proxy/frontend/dialect/postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/extended/flush/PostgreSQLComFlushExecutor.java
@@ -20,7 +20,6 @@ package
org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extend
import org.apache.shardingsphere.database.protocol.packet.DatabasePacket;
import
org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
-import java.sql.SQLException;
import java.util.Collection;
import java.util.Collections;
@@ -30,7 +29,7 @@ import java.util.Collections;
public final class PostgreSQLComFlushExecutor implements CommandExecutor {
@Override
- public Collection<DatabasePacket> execute() throws SQLException {
+ public Collection<DatabasePacket> execute() {
return Collections.emptyList();
}
}
diff --git
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/operation/transaction/cases/alterresource/SwitchingTransactionRuleTestCase.java
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/operation/transaction/cases/alterresource/SwitchingTransactionRuleTestCase.java
index b13e3ac37af..f5237f0bcb3 100644
---
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/operation/transaction/cases/alterresource/SwitchingTransactionRuleTestCase.java
+++
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/operation/transaction/cases/alterresource/SwitchingTransactionRuleTestCase.java
@@ -71,7 +71,7 @@ public final class SwitchingTransactionRuleTestCase extends
BaseTransactionTestC
}
@Override
- protected void executeTest(final TransactionContainerComposer
containerComposer) throws SQLException {
+ protected void executeTest(final TransactionContainerComposer
containerComposer) {
innerRun(containerComposer);
}
diff --git
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dml/BaseDMLE2EIT.java
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dml/BaseDMLE2EIT.java
index ea1cba2d4a8..960bbeba3d7 100644
---
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dml/BaseDMLE2EIT.java
+++
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dml/BaseDMLE2EIT.java
@@ -91,11 +91,10 @@ public abstract class BaseDMLE2EIT implements SQLE2EIT {
* Init.
*
* @param testParam test parameter
- * @throws SQLException SQL exception
* @throws IOException IO exception
* @throws JAXBException JAXB exception
*/
- protected void init(final E2ETestParameter testParam) throws SQLException,
IOException, JAXBException {
+ protected void init(final E2ETestParameter testParam) throws IOException,
JAXBException {
dataSetEnvironmentManager = new DataSetEnvironmentManager(
new ScenarioDataPath(testParam.getScenario(),
Type.ACTUAL).getDataSetFile(), getEnvironmentEngine().getActualDataSourceMap(),
testParam.getDatabaseType());
dataSetEnvironmentManager.fillData();
diff --git
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dql/BaseDQLE2EIT.java
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dql/BaseDQLE2EIT.java
index 1bd3c48cd9b..cefa1b52520 100644
---
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dql/BaseDQLE2EIT.java
+++
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dql/BaseDQLE2EIT.java
@@ -70,7 +70,7 @@ public abstract class BaseDQLE2EIT implements SQLE2EIT {
@Setter
private SQLE2EEnvironmentEngine environmentEngine;
- protected final void init(final AssertionTestParameter testParam, final
SQLE2EITContext context) throws SQLException, IOException, JAXBException {
+ protected final void init(final AssertionTestParameter testParam, final
SQLE2EITContext context) throws IOException, JAXBException {
fillDataOnlyOnce(testParam);
expectedDataSource = null ==
context.getAssertion().getExpectedDataSourceName() || 1 ==
getEnvironmentEngine().getExpectedDataSourceMap().size()
?
getFirstExpectedDataSource(getEnvironmentEngine().getExpectedDataSourceMap().values())
