This is an automated email from the ASF dual-hosted git repository.
panjuan 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 9a3530a733a Change the visibility of constructor to protected for
abstract class (#25572)
9a3530a733a is described below
commit 9a3530a733aa505dd8e00ed03dec13b5ef8da4aa
Author: Liang Zhang <[email protected]>
AuthorDate: Thu May 11 19:12:00 2023 +0800
Change the visibility of constructor to protected for abstract class
(#25572)
---
.../shardingsphere/dialect/exception/SQLDialectException.java | 5 +++--
.../dialect/exception/protocol/DatabaseProtocolException.java | 2 +-
.../distsql/handler/exception/DistSQLException.java | 2 +-
.../algorithm/AlgorithmDefinitionViolationException.java | 2 +-
.../datasource/DataSourceDefinitionViolationException.java | 2 +-
.../handler/exception/rule/RuleDefinitionViolationException.java | 2 +-
.../storageunit/StorageUnitDefinitionViolationException.java | 2 +-
.../shardingsphere/encrypt/exception/EncryptSQLException.java | 2 +-
.../apache/shardingsphere/mask/exception/MaskSQLException.java | 2 +-
.../exception/ReadwriteSplittingSQLException.java | 2 +-
.../shardingsphere/shadow/exception/ShadowSQLException.java | 2 +-
.../shardingsphere/sharding/exception/ShardingSQLException.java | 2 +-
.../infra/datasource/props/synonym/PropertySynonyms.java | 2 +-
.../shardingsphere/infra/exception/ConnectionSQLException.java | 2 +-
.../apache/shardingsphere/infra/exception/DataSQLException.java | 2 +-
.../shardingsphere/infra/exception/MetaDataSQLException.java | 2 +-
.../shardingsphere/infra/exception/SyntaxSQLException.java | 2 +-
.../util/exception/external/ShardingSphereExternalException.java | 4 ++--
.../exception/external/server/ShardingSphereServerException.java | 4 ++--
.../util/exception/external/sql/ShardingSphereSQLException.java | 6 +++---
.../exception/external/sql/type/feature/FeatureSQLException.java | 2 +-
.../exception/external/sql/type/generic/GenericSQLException.java | 4 ++--
.../exception/external/sql/type/kernel/KernelSQLException.java | 4 ++--
.../util/exception/internal/ShardingSphereInternalException.java | 9 +++++----
.../shardingsphere/data/pipeline/api/ingest/record/Record.java | 3 ++-
.../data/pipeline/api/job/type/AbstractJobType.java | 2 +-
.../AbstractStreamingDataConsistencyCalculateAlgorithm.java | 1 -
.../core/context/AbstractInventoryIncrementalProcessContext.java | 2 +-
.../data/pipeline/core/exception/PipelineSQLException.java | 4 ++--
.../data/pipeline/core/job/AbstractPipelineJobId.java | 8 +++-----
.../postgresql/ddlgenerator/AbstractPostgreSQLDDLAdapter.java | 9 +++------
.../globalclock/core/exception/GlobalClockSQLException.java | 2 +-
.../sqltranslator/exception/SQLTranslationException.java | 2 +-
.../shardingsphere/traffic/exception/TrafficException.java | 2 +-
.../transaction/exception/TransactionSQLException.java | 2 +-
.../registry/workerid/exception/ClusterSQLException.java | 2 +-
.../distsql/parser/statement/rdl/create/CreateRuleStatement.java | 2 +-
.../distsql/parser/statement/rdl/drop/DropRuleStatement.java | 2 +-
.../parser/sql/common/statement/ddl/AlterDatabaseStatement.java | 4 ----
.../jdbc/executor/callback/ProxyJDBCExecutorCallback.java | 6 +++---
.../rdl/storage/unit/StorageUnitDefinitionBackendHandler.java | 2 +-
.../test/e2e/env/container/atomic/DockerITContainer.java | 2 +-
.../e2e/env/container/atomic/governance/GovernanceContainer.java | 2 +-
.../e2e/env/container/atomic/storage/DockerStorageContainer.java | 2 +-
.../env/container/atomic/storage/EmbeddedStorageContainer.java | 2 +-
.../data/pipeline/cases/migration/AbstractMigrationE2EIT.java | 2 +-
.../framework/container/compose/BaseContainerComposer.java | 2 +-
.../test/e2e/transaction/cases/readonly/SetReadOnlyTestCase.java | 2 +-
.../e2e/transaction/cases/savepoint/BaseSavePointTestCase.java | 2 +-
.../test/e2e/transaction/engine/base/AutoDataSource.java | 2 +-
.../test/e2e/transaction/engine/base/TransactionBaseE2EIT.java | 2 +-
.../framework/container/compose/BaseContainerComposer.java | 2 +-
.../test/e2e/engine/composer/E2EContainerComposer.java | 2 +-
53 files changed, 71 insertions(+), 78 deletions(-)
diff --git
a/dialect-exception/core/src/main/java/org/apache/shardingsphere/dialect/exception/SQLDialectException.java
b/dialect-exception/core/src/main/java/org/apache/shardingsphere/dialect/exception/SQLDialectException.java
index 2e5f203fe05..579afe23a08 100644
---
a/dialect-exception/core/src/main/java/org/apache/shardingsphere/dialect/exception/SQLDialectException.java
+++
b/dialect-exception/core/src/main/java/org/apache/shardingsphere/dialect/exception/SQLDialectException.java
@@ -17,18 +17,19 @@
package org.apache.shardingsphere.dialect.exception;
+import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.infra.util.exception.external.ShardingSphereExternalException;
/**
* SQL dialect exception.
*/
-@NoArgsConstructor
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
public abstract class SQLDialectException extends
ShardingSphereExternalException {
private static final long serialVersionUID = -5090068160364259336L;
- public SQLDialectException(final String reason) {
+ protected SQLDialectException(final String reason) {
super(reason);
}
}
diff --git
a/dialect-exception/core/src/main/java/org/apache/shardingsphere/dialect/exception/protocol/DatabaseProtocolException.java
b/dialect-exception/core/src/main/java/org/apache/shardingsphere/dialect/exception/protocol/DatabaseProtocolException.java
index 34a8a32b7af..f950ad9fca6 100644
---
a/dialect-exception/core/src/main/java/org/apache/shardingsphere/dialect/exception/protocol/DatabaseProtocolException.java
+++
b/dialect-exception/core/src/main/java/org/apache/shardingsphere/dialect/exception/protocol/DatabaseProtocolException.java
@@ -26,7 +26,7 @@ public abstract class DatabaseProtocolException extends
SQLDialectException {
private static final long serialVersionUID = -6035033415978907492L;
- public DatabaseProtocolException(final String reason) {
+ protected DatabaseProtocolException(final String reason) {
super(reason);
}
}
diff --git
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/DistSQLException.java
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/DistSQLException.java
index fb3fb03b949..565075712d6 100644
---
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/DistSQLException.java
+++
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/DistSQLException.java
@@ -29,7 +29,7 @@ public abstract class DistSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 9;
- public DistSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected DistSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
super(sqlState, KERNEL_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/algorithm/AlgorithmDefinitionViolationException.java
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/algorithm/AlgorithmDefinitionViolationException.java
index 930d9372b30..d43c8f10932 100644
---
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/algorithm/AlgorithmDefinitionViolationException.java
+++
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/algorithm/AlgorithmDefinitionViolationException.java
@@ -27,7 +27,7 @@ public abstract class AlgorithmDefinitionViolationException
extends DistSQLExcep
private static final long serialVersionUID = -727466071244178933L;
- public AlgorithmDefinitionViolationException(final SQLState sqlState,
final int errorCode, final String reason, final Object... messageArgs) {
+ protected AlgorithmDefinitionViolationException(final SQLState sqlState,
final int errorCode, final String reason, final Object... messageArgs) {
super(sqlState, errorCode, reason, messageArgs);
}
}
diff --git
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/datasource/DataSourceDefinitionViolationException.java
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/datasource/DataSourceDefinitionViolationException.java
index e25f961429a..57bc4cebacf 100644
---
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/datasource/DataSourceDefinitionViolationException.java
+++
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/datasource/DataSourceDefinitionViolationException.java
@@ -27,7 +27,7 @@ public abstract class DataSourceDefinitionViolationException
extends DistSQLExce
private static final long serialVersionUID = -3318829232811230364L;
- public DataSourceDefinitionViolationException(final SQLState sqlState,
final int errorCode, final String reason, final Object... messageArgs) {
+ protected DataSourceDefinitionViolationException(final SQLState sqlState,
final int errorCode, final String reason, final Object... messageArgs) {
super(sqlState, errorCode, reason, messageArgs);
}
}
diff --git
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/rule/RuleDefinitionViolationException.java
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/rule/RuleDefinitionViolationException.java
index 10aee1dba56..d4b29f1c6e6 100644
---
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/rule/RuleDefinitionViolationException.java
+++
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/rule/RuleDefinitionViolationException.java
@@ -27,7 +27,7 @@ public abstract class RuleDefinitionViolationException
extends DistSQLException
private static final long serialVersionUID = 1090914641996552474L;
- public RuleDefinitionViolationException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
+ protected RuleDefinitionViolationException(final SQLState sqlState, final
int errorCode, final String reason, final Object... messageArgs) {
super(sqlState, errorCode, reason, messageArgs);
}
}
diff --git
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/storageunit/StorageUnitDefinitionViolationException.java
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/storageunit/StorageUnitDefinitionViolationException.java
index c273cd3f122..6454455d3ea 100644
---
a/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/storageunit/StorageUnitDefinitionViolationException.java
+++
b/distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/exception/storageunit/StorageUnitDefinitionViolationException.java
@@ -27,7 +27,7 @@ public abstract class StorageUnitDefinitionViolationException
extends DistSQLExc
private static final long serialVersionUID = -2686784350802985974L;
- public StorageUnitDefinitionViolationException(final SQLState sqlState,
final int errorCode, final String reason, final Object... messageArgs) {
+ protected StorageUnitDefinitionViolationException(final SQLState sqlState,
final int errorCode, final String reason, final Object... messageArgs) {
super(sqlState, errorCode, reason, messageArgs);
}
}
diff --git
a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/exception/EncryptSQLException.java
b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/exception/EncryptSQLException.java
index b2110515e34..8c46b45441a 100644
---
a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/exception/EncryptSQLException.java
+++
b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/exception/EncryptSQLException.java
@@ -29,7 +29,7 @@ public abstract class EncryptSQLException extends
FeatureSQLException {
private static final int FEATURE_CODE = 7;
- public EncryptSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected EncryptSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, FEATURE_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/exception/MaskSQLException.java
b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/exception/MaskSQLException.java
index 6fd76cf9da5..69fc474142e 100644
---
a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/exception/MaskSQLException.java
+++
b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/exception/MaskSQLException.java
@@ -29,7 +29,7 @@ public abstract class MaskSQLException extends
FeatureSQLException {
private static final int FEATURE_CODE = 9;
- public MaskSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected MaskSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
super(sqlState, FEATURE_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/exception/ReadwriteSplittingSQLException.java
b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/exception/ReadwriteSplittingSQLException.java
index ca4fe712df1..2e71dda565b 100644
---
a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/exception/ReadwriteSplittingSQLException.java
+++
b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/exception/ReadwriteSplittingSQLException.java
@@ -29,7 +29,7 @@ public abstract class ReadwriteSplittingSQLException extends
FeatureSQLException
private static final int FEATURE_CODE = 2;
- public ReadwriteSplittingSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
+ protected ReadwriteSplittingSQLException(final SQLState sqlState, final
int errorCode, final String reason, final Object... messageArgs) {
super(sqlState, FEATURE_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/exception/ShadowSQLException.java
b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/exception/ShadowSQLException.java
index a7c90749848..6a3c1e4591e 100644
---
a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/exception/ShadowSQLException.java
+++
b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/exception/ShadowSQLException.java
@@ -29,7 +29,7 @@ public abstract class ShadowSQLException extends
FeatureSQLException {
private static final int FEATURE_CODE = 8;
- public ShadowSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected ShadowSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
super(sqlState, FEATURE_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/exception/ShardingSQLException.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/exception/ShardingSQLException.java
index ebb3b6d4672..818feaef875 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/exception/ShardingSQLException.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/exception/ShardingSQLException.java
@@ -29,7 +29,7 @@ public abstract class ShardingSQLException extends
FeatureSQLException {
private static final int FEATURE_CODE = 0;
- public ShardingSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected ShardingSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, FEATURE_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/datasource/props/synonym/PropertySynonyms.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/datasource/props/synonym/PropertySynonyms.java
index 5147d19fae3..c8a0953da77 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/datasource/props/synonym/PropertySynonyms.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/datasource/props/synonym/PropertySynonyms.java
@@ -38,7 +38,7 @@ public abstract class PropertySynonyms {
private final Map<String, Object> localProperties;
- public PropertySynonyms(final Map<String, Object> props, final
Collection<String> standardPropertyKeys, final Map<String, String>
propertySynonyms) {
+ protected PropertySynonyms(final Map<String, Object> props, final
Collection<String> standardPropertyKeys, final Map<String, String>
propertySynonyms) {
this.standardPropertyKeys = standardPropertyKeys;
standardProperties = buildStandardProperties(props,
standardPropertyKeys, propertySynonyms);
localProperties = buildLocalProperties(props, standardPropertyKeys,
propertySynonyms);
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/ConnectionSQLException.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/ConnectionSQLException.java
index f2a487cc60c..ef3a75a2288 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/ConnectionSQLException.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/ConnectionSQLException.java
@@ -29,7 +29,7 @@ public abstract class ConnectionSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 3;
- public ConnectionSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
+ protected ConnectionSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, KERNEL_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/DataSQLException.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/DataSQLException.java
index 6a1f26bad3d..50bea6ef49b 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/DataSQLException.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/DataSQLException.java
@@ -29,7 +29,7 @@ public abstract class DataSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 1;
- public DataSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected DataSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
super(sqlState, KERNEL_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/MetaDataSQLException.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/MetaDataSQLException.java
index 7069c52e39f..53c5f2ae819 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/MetaDataSQLException.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/MetaDataSQLException.java
@@ -29,7 +29,7 @@ public abstract class MetaDataSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 0;
- public MetaDataSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected MetaDataSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, KERNEL_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/SyntaxSQLException.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/SyntaxSQLException.java
index 63d62bf36ef..00d69713ff7 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/SyntaxSQLException.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/exception/SyntaxSQLException.java
@@ -29,7 +29,7 @@ public abstract class SyntaxSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 2;
- public SyntaxSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected SyntaxSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
super(sqlState, KERNEL_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/ShardingSphereExternalException.java
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/ShardingSphereExternalException.java
index 6bfae37a562..c8f0e88d8bf 100644
---
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/ShardingSphereExternalException.java
+++
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/ShardingSphereExternalException.java
@@ -27,11 +27,11 @@ public abstract class ShardingSphereExternalException
extends RuntimeException {
private static final long serialVersionUID = 1629786588176694067L;
- public ShardingSphereExternalException(final String reason) {
+ protected ShardingSphereExternalException(final String reason) {
super(reason);
}
- public ShardingSphereExternalException(final String reason, final
Exception cause) {
+ protected ShardingSphereExternalException(final String reason, final
Exception cause) {
super(reason, cause);
}
}
diff --git
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/server/ShardingSphereServerException.java
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/server/ShardingSphereServerException.java
index e78a4a7f58c..dfba1484fdc 100644
---
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/server/ShardingSphereServerException.java
+++
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/server/ShardingSphereServerException.java
@@ -26,11 +26,11 @@ public abstract class ShardingSphereServerException extends
ShardingSphereExtern
private static final long serialVersionUID = 1547233217081261239L;
- public ShardingSphereServerException(final String errorCategory, final int
errorCode, final String message) {
+ protected ShardingSphereServerException(final String errorCategory, final
int errorCode, final String message) {
super(String.format("%s-%05d: %s", errorCategory, errorCode, message));
}
- public ShardingSphereServerException(final String errorCategory, final int
errorCode, final String message, final Exception cause) {
+ protected ShardingSphereServerException(final String errorCategory, final
int errorCode, final String message, final Exception cause) {
super(String.format("%s-%05d: %s", errorCategory, errorCode, message),
cause);
}
}
diff --git
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/ShardingSphereSQLException.java
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/ShardingSphereSQLException.java
index a41d57fe05a..6eafc4c7ce7 100644
---
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/ShardingSphereSQLException.java
+++
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/ShardingSphereSQLException.java
@@ -37,15 +37,15 @@ public abstract class ShardingSphereSQLException extends
ShardingSphereExternalE
private final Exception cause;
- public ShardingSphereSQLException(final SQLState sqlState, final int
typeOffset, final int errorCode, final String reason, final Object...
messageArgs) {
+ protected ShardingSphereSQLException(final SQLState sqlState, final int
typeOffset, final int errorCode, final String reason, final Object...
messageArgs) {
this(sqlState.getValue(), typeOffset, errorCode, reason, messageArgs);
}
- public ShardingSphereSQLException(final String sqlState, final int
typeOffset, final int errorCode, final String reason, final Object...
messageArgs) {
+ protected ShardingSphereSQLException(final String sqlState, final int
typeOffset, final int errorCode, final String reason, final Object...
messageArgs) {
this(sqlState, typeOffset, errorCode, null == reason ? null :
String.format(reason, messageArgs), (Exception) null);
}
- public ShardingSphereSQLException(final String sqlState, final int
typeOffset, final int errorCode, final String reason, final Exception cause) {
+ protected ShardingSphereSQLException(final String sqlState, final int
typeOffset, final int errorCode, final String reason, final Exception cause) {
super(reason, cause);
this.sqlState = sqlState;
vendorCode = typeOffset * 10000 + errorCode;
diff --git
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/feature/FeatureSQLException.java
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/feature/FeatureSQLException.java
index 45b7ade6b46..d5248e214d6 100644
---
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/feature/FeatureSQLException.java
+++
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/feature/FeatureSQLException.java
@@ -29,7 +29,7 @@ public abstract class FeatureSQLException extends
ShardingSphereSQLException {
private static final int TYPE_OFFSET = 2;
- public FeatureSQLException(final SQLState sqlState, final int featureCode,
final int errorCode, final String reason, final Object... messageArgs) {
+ protected FeatureSQLException(final SQLState sqlState, final int
featureCode, final int errorCode, final String reason, final Object...
messageArgs) {
super(sqlState, TYPE_OFFSET, featureCode * 100 + errorCode, reason,
messageArgs);
}
}
diff --git
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/generic/GenericSQLException.java
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/generic/GenericSQLException.java
index e1a9ac7e48a..76272f59d79 100644
---
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/generic/GenericSQLException.java
+++
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/generic/GenericSQLException.java
@@ -29,11 +29,11 @@ public abstract class GenericSQLException extends
ShardingSphereSQLException {
private static final int TYPE_OFFSET = 3;
- public GenericSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected GenericSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, TYPE_OFFSET, errorCode, reason, messageArgs);
}
- public GenericSQLException(final String reason, final Exception cause,
final SQLState sqlState, final int errorCode) {
+ protected GenericSQLException(final String reason, final Exception cause,
final SQLState sqlState, final int errorCode) {
super(sqlState.getValue(), TYPE_OFFSET, errorCode, reason, cause);
}
}
diff --git
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/kernel/KernelSQLException.java
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/kernel/KernelSQLException.java
index 8c8ffc79cbb..e95c1849378 100644
---
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/kernel/KernelSQLException.java
+++
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/external/sql/type/kernel/KernelSQLException.java
@@ -29,11 +29,11 @@ public abstract class KernelSQLException extends
ShardingSphereSQLException {
private static final int TYPE_OFFSET = 1;
- public KernelSQLException(final SQLState sqlState, final int kernelCode,
final int errorCode, final String reason, final Object... messageArgs) {
+ protected KernelSQLException(final SQLState sqlState, final int
kernelCode, final int errorCode, final String reason, final Object...
messageArgs) {
super(sqlState, TYPE_OFFSET, kernelCode * 1000 + errorCode, reason,
messageArgs);
}
- public KernelSQLException(final SQLState sqlState, final int kernelCode,
final int errorCode, final String reason, final Exception cause) {
+ protected KernelSQLException(final SQLState sqlState, final int
kernelCode, final int errorCode, final String reason, final Exception cause) {
super(sqlState.getValue(), TYPE_OFFSET, kernelCode * 1000 + errorCode,
reason, cause);
}
}
diff --git
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/internal/ShardingSphereInternalException.java
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/internal/ShardingSphereInternalException.java
index 3f7979abe26..ebeba09476c 100644
---
a/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/internal/ShardingSphereInternalException.java
+++
b/infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/internal/ShardingSphereInternalException.java
@@ -17,25 +17,26 @@
package org.apache.shardingsphere.infra.util.exception.internal;
+import lombok.AccessLevel;
import lombok.NoArgsConstructor;
/**
* ShardingSphere internal exception.
*/
-@NoArgsConstructor
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
public abstract class ShardingSphereInternalException extends Exception {
private static final long serialVersionUID = -8238061892944243621L;
- public ShardingSphereInternalException(final String errorMessage, final
Object... args) {
+ protected ShardingSphereInternalException(final String errorMessage, final
Object... args) {
super(String.format(errorMessage, args));
}
- public ShardingSphereInternalException(final Exception cause) {
+ protected ShardingSphereInternalException(final Exception cause) {
super(cause);
}
- public ShardingSphereInternalException(final String message, final
Exception cause) {
+ protected ShardingSphereInternalException(final String message, final
Exception cause) {
super(message, cause);
}
}
diff --git
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/record/Record.java
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/record/Record.java
index 9f4ea3357ea..403548a0515 100644
---
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/record/Record.java
+++
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/record/Record.java
@@ -17,6 +17,7 @@
package org.apache.shardingsphere.data.pipeline.api.ingest.record;
+import lombok.AccessLevel;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.Setter;
@@ -26,7 +27,7 @@ import
org.apache.shardingsphere.data.pipeline.api.ingest.position.IngestPositio
/**
* Record interface.
*/
-@RequiredArgsConstructor
+@RequiredArgsConstructor(access = AccessLevel.PROTECTED)
@Getter
@Setter
@ToString
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/api/job/type/AbstractJobType.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/api/job/type/AbstractJobType.java
index 5b87a771edc..57df822c59b 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/api/job/type/AbstractJobType.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/api/job/type/AbstractJobType.java
@@ -31,7 +31,7 @@ public abstract class AbstractJobType implements JobType {
private final String typeCode;
- public AbstractJobType(final String typeName, final String typeCode) {
+ protected AbstractJobType(final String typeName, final String typeCode) {
this.typeName = typeName;
Preconditions.checkArgument(2 == typeCode.length(), "code length is
not 2");
this.typeCode = typeCode;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/algorithm/AbstractStreamingDataConsistencyCalculateAlgorithm.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/algorithm/AbstractStreamingDataConsistencyCalculateAlgorithm.java
index c890cbccdc7..41aa4874a30 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/algorithm/AbstractStreamingDataConsistencyCalculateAlgorithm.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/algorithm/AbstractStreamingDataConsistencyCalculateAlgorithm.java
@@ -29,7 +29,6 @@ import java.util.Optional;
/**
* Streaming data consistency calculate algorithm.
*/
-@RequiredArgsConstructor
@Getter
@Slf4j
public abstract class AbstractStreamingDataConsistencyCalculateAlgorithm
extends AbstractDataConsistencyCalculateAlgorithm {
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/AbstractInventoryIncrementalProcessContext.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/AbstractInventoryIncrementalProcessContext.java
index 0f966ac513d..e17877a2304 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/AbstractInventoryIncrementalProcessContext.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/AbstractInventoryIncrementalProcessContext.java
@@ -51,7 +51,7 @@ public abstract class
AbstractInventoryIncrementalProcessContext implements Inve
private final LazyInitializer<ExecuteEngine>
incrementalExecuteEngineLazyInitializer;
- public AbstractInventoryIncrementalProcessContext(final String jobId,
final PipelineProcessConfiguration originalProcessConfig) {
+ protected AbstractInventoryIncrementalProcessContext(final String jobId,
final PipelineProcessConfiguration originalProcessConfig) {
PipelineProcessConfiguration processConfig =
PipelineProcessConfigurationUtils.convertWithDefaultValue(originalProcessConfig);
this.pipelineProcessConfig = processConfig;
PipelineReadConfiguration readConfig = processConfig.getRead();
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineSQLException.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineSQLException.java
index 16e8a250471..d8a581c2a72 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineSQLException.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineSQLException.java
@@ -29,11 +29,11 @@ public abstract class PipelineSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 8;
- public PipelineSQLException(final SQLState sqlState, final int errorCode,
final String reason) {
+ protected PipelineSQLException(final SQLState sqlState, final int
errorCode, final String reason) {
super(sqlState, KERNEL_CODE, errorCode, reason);
}
- public PipelineSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Exception cause) {
+ protected PipelineSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Exception cause) {
super(sqlState, KERNEL_CODE, errorCode, reason, cause);
}
}
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractPipelineJobId.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractPipelineJobId.java
index 926402a2574..ef9819e3000 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractPipelineJobId.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractPipelineJobId.java
@@ -17,7 +17,9 @@
package org.apache.shardingsphere.data.pipeline.core.job;
+import lombok.AccessLevel;
import lombok.Getter;
+import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.data.pipeline.api.job.PipelineJobId;
import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
import org.apache.shardingsphere.data.pipeline.spi.job.JobType;
@@ -25,6 +27,7 @@ import
org.apache.shardingsphere.data.pipeline.spi.job.JobType;
/**
* Abstract pipeline job id.
*/
+@RequiredArgsConstructor(access = AccessLevel.PROTECTED)
@Getter
public abstract class AbstractPipelineJobId implements PipelineJobId {
@@ -34,11 +37,6 @@ public abstract class AbstractPipelineJobId implements
PipelineJobId {
private final PipelineContextKey contextKey;
- public AbstractPipelineJobId(final JobType jobType, final
PipelineContextKey contextKey) {
- this.jobType = jobType;
- this.contextKey = contextKey;
- }
-
@Override
public String getFormatVersion() {
return CURRENT_VERSION;
diff --git
a/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/ddlgenerator/AbstractPostgreSQLDDLAdapter.java
b/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/ddlgenerator/AbstractPostgreSQLDDLAdapter.java
index 373d25a1470..2bf9d448867 100644
---
a/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/ddlgenerator/AbstractPostgreSQLDDLAdapter.java
+++
b/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/ddlgenerator/AbstractPostgreSQLDDLAdapter.java
@@ -17,7 +17,9 @@
package org.apache.shardingsphere.data.pipeline.postgresql.ddlgenerator;
+import lombok.AccessLevel;
import lombok.Getter;
+import lombok.RequiredArgsConstructor;
import lombok.SneakyThrows;
import
org.apache.shardingsphere.data.pipeline.postgresql.util.PostgreSQLPipelineFreemarkerManager;
@@ -37,6 +39,7 @@ import java.util.stream.Collectors;
/**
* Abstract ddl adapter for PostgreSQL.
*/
+@RequiredArgsConstructor(access = AccessLevel.PROTECTED)
@Getter
public abstract class AbstractPostgreSQLDDLAdapter {
@@ -48,12 +51,6 @@ public abstract class AbstractPostgreSQLDDLAdapter {
private final int minorVersion;
- protected AbstractPostgreSQLDDLAdapter(final Connection connection, final
int majorVersion, final int minorVersion) {
- this.connection = connection;
- this.majorVersion = majorVersion;
- this.minorVersion = minorVersion;
- }
-
@SneakyThrows(SQLException.class)
protected Collection<Map<String, Object>> executeByTemplate(final
Map<String, Object> params, final String path) {
try (
diff --git
a/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/exception/GlobalClockSQLException.java
b/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/exception/GlobalClockSQLException.java
index 6380049cce5..94f47dc6852 100644
---
a/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/exception/GlobalClockSQLException.java
+++
b/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/exception/GlobalClockSQLException.java
@@ -29,7 +29,7 @@ public abstract class GlobalClockSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 10;
- public GlobalClockSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
+ protected GlobalClockSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, KERNEL_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/kernel/sql-translator/api/src/main/java/org/apache/shardingsphere/sqltranslator/exception/SQLTranslationException.java
b/kernel/sql-translator/api/src/main/java/org/apache/shardingsphere/sqltranslator/exception/SQLTranslationException.java
index 058d2c6c47a..1b0303fcc70 100644
---
a/kernel/sql-translator/api/src/main/java/org/apache/shardingsphere/sqltranslator/exception/SQLTranslationException.java
+++
b/kernel/sql-translator/api/src/main/java/org/apache/shardingsphere/sqltranslator/exception/SQLTranslationException.java
@@ -29,7 +29,7 @@ public abstract class SQLTranslationException extends
FeatureSQLException {
private static final int FEATURE_CODE = 4;
- public SQLTranslationException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
+ protected SQLTranslationException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, FEATURE_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/kernel/traffic/core/src/main/java/org/apache/shardingsphere/traffic/exception/TrafficException.java
b/kernel/traffic/core/src/main/java/org/apache/shardingsphere/traffic/exception/TrafficException.java
index 73bb8b8f556..482a71702d1 100644
---
a/kernel/traffic/core/src/main/java/org/apache/shardingsphere/traffic/exception/TrafficException.java
+++
b/kernel/traffic/core/src/main/java/org/apache/shardingsphere/traffic/exception/TrafficException.java
@@ -29,7 +29,7 @@ public abstract class TrafficException extends
FeatureSQLException {
private static final int FEATURE_CODE = 5;
- public TrafficException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected TrafficException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
super(sqlState, FEATURE_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/kernel/transaction/core/src/main/java/org/apache/shardingsphere/transaction/exception/TransactionSQLException.java
b/kernel/transaction/core/src/main/java/org/apache/shardingsphere/transaction/exception/TransactionSQLException.java
index b49899de145..e9e80774e25 100644
---
a/kernel/transaction/core/src/main/java/org/apache/shardingsphere/transaction/exception/TransactionSQLException.java
+++
b/kernel/transaction/core/src/main/java/org/apache/shardingsphere/transaction/exception/TransactionSQLException.java
@@ -29,7 +29,7 @@ public abstract class TransactionSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 4;
- public TransactionSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
+ protected TransactionSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, KERNEL_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/workerid/exception/ClusterSQLException.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/workerid/exception/ClusterSQLException.java
index 3f33b80cc8b..f816b4ebadc 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/workerid/exception/ClusterSQLException.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/workerid/exception/ClusterSQLException.java
@@ -29,7 +29,7 @@ public abstract class ClusterSQLException extends
KernelSQLException {
private static final int KERNEL_CODE = 7;
- public ClusterSQLException(final SQLState sqlState, final int errorCode,
final String reason, final Object... messageArgs) {
+ protected ClusterSQLException(final SQLState sqlState, final int
errorCode, final String reason, final Object... messageArgs) {
super(sqlState, KERNEL_CODE, errorCode, reason, messageArgs);
}
}
diff --git
a/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rdl/create/CreateRuleStatement.java
b/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rdl/create/CreateRuleStatement.java
index c84c79abca8..c1055e809e1 100644
---
a/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rdl/create/CreateRuleStatement.java
+++
b/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rdl/create/CreateRuleStatement.java
@@ -30,7 +30,7 @@ public abstract class CreateRuleStatement extends
RuleDefinitionStatement {
private final boolean ifNotExists;
- public CreateRuleStatement() {
+ protected CreateRuleStatement() {
this(false);
}
}
diff --git
a/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rdl/drop/DropRuleStatement.java
b/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rdl/drop/DropRuleStatement.java
index af9ccbed96c..165cb1e5a14 100644
---
a/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rdl/drop/DropRuleStatement.java
+++
b/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rdl/drop/DropRuleStatement.java
@@ -30,7 +30,7 @@ public abstract class DropRuleStatement extends
RuleDefinitionStatement {
private final boolean ifExists;
- public DropRuleStatement() {
+ protected DropRuleStatement() {
this(false);
}
}
diff --git
a/parser/sql/statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/AlterDatabaseStatement.java
b/parser/sql/statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/AlterDatabaseStatement.java
index 1fce31d30c7..454ce31d083 100644
---
a/parser/sql/statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/AlterDatabaseStatement.java
+++
b/parser/sql/statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/AlterDatabaseStatement.java
@@ -17,14 +17,10 @@
package org.apache.shardingsphere.sql.parser.sql.common.statement.ddl;
-import lombok.Getter;
-import lombok.Setter;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.AbstractSQLStatement;
/**
* Alter Database statement.
*/
-@Getter
-@Setter
public abstract class AlterDatabaseStatement extends AbstractSQLStatement
implements DDLStatement {
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/executor/callback/ProxyJDBCExecutorCallback.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/executor/callback/ProxyJDBCExecutorCallback.java
index 687e44c836f..8e2470b8f0c 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/executor/callback/ProxyJDBCExecutorCallback.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/executor/callback/ProxyJDBCExecutorCallback.java
@@ -53,9 +53,9 @@ public abstract class ProxyJDBCExecutorCallback extends
JDBCExecutorCallback<Exe
private boolean hasMetaData;
- public ProxyJDBCExecutorCallback(final DatabaseType protocolType, final
Map<String, DatabaseType> storageTypes, final SQLStatement sqlStatement,
- final DatabaseConnector databaseConnector,
- final boolean isReturnGeneratedKeys,
final boolean isExceptionThrown, final boolean fetchMetaData) {
+ protected ProxyJDBCExecutorCallback(final DatabaseType protocolType, final
Map<String, DatabaseType> storageTypes, final SQLStatement sqlStatement,
+ final DatabaseConnector
databaseConnector,
+ final boolean isReturnGeneratedKeys,
final boolean isExceptionThrown, final boolean fetchMetaData) {
super(protocolType, storageTypes, sqlStatement, isExceptionThrown);
this.databaseConnector = databaseConnector;
this.isReturnGeneratedKeys = isReturnGeneratedKeys;
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/storage/unit/StorageUnitDefinitionBackendHandler.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/storage/unit/StorageUnitDefinitionBackendHandler.java
index 00c9892bb18..1c618377f05 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/storage/unit/StorageUnitDefinitionBackendHandler.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/storage/unit/StorageUnitDefinitionBackendHandler.java
@@ -28,7 +28,7 @@ import
org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
*/
public abstract class StorageUnitDefinitionBackendHandler<T extends
StorageUnitDefinitionStatement> extends RDLBackendHandler<T> {
- public StorageUnitDefinitionBackendHandler(final T sqlStatement, final
ConnectionSession connectionSession) {
+ protected StorageUnitDefinitionBackendHandler(final T sqlStatement, final
ConnectionSession connectionSession) {
super(sqlStatement, connectionSession);
}
diff --git
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/DockerITContainer.java
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/DockerITContainer.java
index f55167cb5ca..bd601b2fc2f 100644
---
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/DockerITContainer.java
+++
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/DockerITContainer.java
@@ -38,7 +38,7 @@ public abstract class DockerITContainer extends
GenericContainer<DockerITContain
private final String name;
- public DockerITContainer(final String name, final String containerImage) {
+ protected DockerITContainer(final String name, final String
containerImage) {
super(new RemoteDockerImage(DockerImageName.parse(containerImage)));
this.name = name;
}
diff --git
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/governance/GovernanceContainer.java
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/governance/GovernanceContainer.java
index e9517d65052..bc0842e1dec 100644
---
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/governance/GovernanceContainer.java
+++
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/governance/GovernanceContainer.java
@@ -24,7 +24,7 @@ import
org.apache.shardingsphere.test.e2e.env.container.atomic.DockerITContainer
*/
public abstract class GovernanceContainer extends DockerITContainer {
- public GovernanceContainer(final String name, final String containerImage)
{
+ protected GovernanceContainer(final String name, final String
containerImage) {
super(name, containerImage);
}
diff --git
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/DockerStorageContainer.java
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/DockerStorageContainer.java
index 4779a0e074a..2fda37cce57 100644
---
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/DockerStorageContainer.java
+++
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/DockerStorageContainer.java
@@ -57,7 +57,7 @@ public abstract class DockerStorageContainer extends
DockerITContainer implement
private final Map<String, DataSource> expectedDataSourceMap;
- public DockerStorageContainer(final DatabaseType databaseType, final
String containerImage, final String scenario) {
+ protected DockerStorageContainer(final DatabaseType databaseType, final
String containerImage, final String scenario) {
super(databaseType.getType().toLowerCase(), containerImage);
this.databaseType = databaseType;
this.scenario = scenario;
diff --git
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/EmbeddedStorageContainer.java
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/EmbeddedStorageContainer.java
index 15bea8bdaaf..e89a1e1dd24 100644
---
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/EmbeddedStorageContainer.java
+++
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/EmbeddedStorageContainer.java
@@ -46,7 +46,7 @@ public abstract class EmbeddedStorageContainer implements
EmbeddedITContainer, S
private final Map<String, DataSource> expectedDataSourceMap;
- public EmbeddedStorageContainer(final DatabaseType databaseType, final
String scenario) {
+ protected EmbeddedStorageContainer(final DatabaseType databaseType, final
String scenario) {
this.databaseType = databaseType;
this.scenario = scenario;
actualDataSourceMap = createActualDataSourceMap();
diff --git
a/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/cases/migration/AbstractMigrationE2EIT.java
b/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/cases/migration/AbstractMigrationE2EIT.java
index ac649a80140..a3fa80535d2 100644
---
a/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/cases/migration/AbstractMigrationE2EIT.java
+++
b/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/cases/migration/AbstractMigrationE2EIT.java
@@ -47,7 +47,7 @@ public abstract class AbstractMigrationE2EIT {
private final MigrationDistSQLCommand migrationDistSQL;
- public AbstractMigrationE2EIT() {
+ protected AbstractMigrationE2EIT() {
migrationDistSQL =
JAXB.unmarshal(Objects.requireNonNull(AbstractMigrationE2EIT.class.getClassLoader().getResource("env/common/migration-command.xml")),
MigrationDistSQLCommand.class);
}
diff --git
a/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/container/compose/BaseContainerComposer.java
b/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/container/compose/BaseContainerComposer.java
index 10ae400bb13..3133f5eb80e 100644
---
a/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/container/compose/BaseContainerComposer.java
+++
b/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/container/compose/BaseContainerComposer.java
@@ -26,7 +26,7 @@ public abstract class BaseContainerComposer implements
Startable {
private final ITContainers containers;
- public BaseContainerComposer() {
+ protected BaseContainerComposer() {
containers = new ITContainers("");
}
diff --git
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/readonly/SetReadOnlyTestCase.java
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/readonly/SetReadOnlyTestCase.java
index 747e563d7a9..5164dae0df5 100644
---
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/readonly/SetReadOnlyTestCase.java
+++
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/readonly/SetReadOnlyTestCase.java
@@ -34,7 +34,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*/
public abstract class SetReadOnlyTestCase extends BaseTransactionTestCase {
- public SetReadOnlyTestCase(final TransactionBaseE2EIT
baseTransactionITCase, final DataSource dataSource) {
+ protected SetReadOnlyTestCase(final TransactionBaseE2EIT
baseTransactionITCase, final DataSource dataSource) {
super(baseTransactionITCase, dataSource);
}
diff --git
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/savepoint/BaseSavePointTestCase.java
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/savepoint/BaseSavePointTestCase.java
index 8d5d688ddb5..084e6970a99 100644
---
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/savepoint/BaseSavePointTestCase.java
+++
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/savepoint/BaseSavePointTestCase.java
@@ -30,7 +30,7 @@ import java.sql.Savepoint;
*/
public abstract class BaseSavePointTestCase extends BaseTransactionTestCase {
- public BaseSavePointTestCase(final TransactionBaseE2EIT
baseTransactionITCase, final DataSource dataSource) {
+ protected BaseSavePointTestCase(final TransactionBaseE2EIT
baseTransactionITCase, final DataSource dataSource) {
super(baseTransactionITCase, dataSource);
}
diff --git
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/engine/base/AutoDataSource.java
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/engine/base/AutoDataSource.java
index 70bfbcf5578..95ac386ae94 100644
---
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/engine/base/AutoDataSource.java
+++
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/engine/base/AutoDataSource.java
@@ -30,9 +30,9 @@ import java.util.logging.Logger;
/**
* Datasource for caching connections.
*/
+@Getter
public abstract class AutoDataSource implements DataSource {
- @Getter
private final Set<Connection> connectionCache = new HashSet<>();
/**
diff --git
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/engine/base/TransactionBaseE2EIT.java
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/engine/base/TransactionBaseE2EIT.java
index 040ba7e0826..2a0672255af 100644
---
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/engine/base/TransactionBaseE2EIT.java
+++
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/engine/base/TransactionBaseE2EIT.java
@@ -81,7 +81,7 @@ public abstract class TransactionBaseE2EIT {
private final CommonSQLCommand commonSQL;
- public TransactionBaseE2EIT() {
+ protected TransactionBaseE2EIT() {
commonSQL = loadCommonSQLCommand();
}
diff --git
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/framework/container/compose/BaseContainerComposer.java
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/framework/container/compose/BaseContainerComposer.java
index e5320bd100d..c23efe6b4f6 100644
---
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/framework/container/compose/BaseContainerComposer.java
+++
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/framework/container/compose/BaseContainerComposer.java
@@ -26,7 +26,7 @@ public abstract class BaseContainerComposer implements
Startable {
@Getter
private final ITContainers containers;
- public BaseContainerComposer(final String scenario) {
+ protected BaseContainerComposer(final String scenario) {
this.containers = new ITContainers(scenario);
}
diff --git
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/composer/E2EContainerComposer.java
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/composer/E2EContainerComposer.java
index c770b46745d..7857a5893a3 100644
---
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/composer/E2EContainerComposer.java
+++
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/composer/E2EContainerComposer.java
@@ -64,7 +64,7 @@ public abstract class E2EContainerComposer implements
AutoCloseable {
private final Map<String, DataSource> expectedDataSourceMap;
- public E2EContainerComposer(final E2ETestParameter testParam) {
+ protected E2EContainerComposer(final E2ETestParameter testParam) {
containerComposer =
CONTAINER_COMPOSER_REGISTRY.getContainerComposer(testParam);
containerComposer.start();
actualDataSourceMap = containerComposer.getActualDataSourceMap();
