You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by du...@apache.org on 2022/02/04 08:58:18 UTC
[shardingsphere] branch master updated: Adjust codes format (#15242)
This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang 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 968fff1 Adjust codes format (#15242)
968fff1 is described below
commit 968fff16ef230c34a170eed9a3375fe5a07017bc
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Fri Feb 4 16:56:51 2022 +0800
Adjust codes format (#15242)
* For code format
* For code format
---
.../MemoryLocalDbDiscoveryJdbcConfiguration.java | 13 +++---
.../MemoryLocalDbDiscoveryJdbcExampleService.java | 12 +++---
...scoverySpringBootStarterJdbcExampleService.java | 11 ++---
...iscoverySpringBootStarterJpaExampleService.java | 27 +++++--------
...verySpringBootStarterMybatisExampleService.java | 28 +++++--------
...DiscoverySpringNamespaceJdbcExampleService.java | 11 +++--
...bDiscoverySpringNamespaceJpaExampleService.java | 27 +++++--------
...coverySpringNamespaceMybatisExampleService.java | 28 +++++--------
.../jdbc/MemoryLocalEncryptJdbcConfiguration.java | 5 ++-
.../jdbc/MemoryLocalEncryptJdbcExampleService.java | 11 +++--
...EncryptSpringBootStarterJdbcExampleService.java | 12 +++---
...lEncryptSpringBootStarterJpaExampleService.java | 28 +++++--------
...ryptSpringBootStarterMybatisExampleService.java | 28 +++++--------
...alEncryptSpringNamespaceJdbcExampleService.java | 13 +++---
...calEncryptSpringNamespaceJpaExampleService.java | 28 +++++--------
...ncryptSpringNamespaceMybatisExampleService.java | 28 +++++--------
...alMixedSpringBootStarterJdbcExampleService.java | 12 +++---
...ocalMixedSpringNamespaceJdbcExampleService.java | 13 +++---
...ryLocalReadwriteSplittingJdbcConfiguration.java | 5 ++-
...yLocalReadwriteSplittingJdbcExampleService.java | 13 +++---
...littingSpringBootStarterJdbcExampleService.java | 11 ++---
...plittingSpringBootStarterJpaExampleService.java | 28 +++++--------
...tingSpringBootStarterMybatisExampleService.java | 28 +++++--------
...SplittingSpringNamespaceJdbcExampleService.java | 13 +++---
...eSplittingSpringNamespaceJpaExampleService.java | 26 +++++-------
...ittingSpringNamespaceMybatisExampleService.java | 28 +++++--------
.../jdbc/MemoryLocalShadowJdbcConfiguration.java | 13 +++---
.../jdbc/MemoryLocalShadowJdbcExampleService.java | 10 +++--
...lShadowSpringBootStarterJdbcExampleService.java | 10 +++--
...adowSpringBootStarterMybatisExampleService.java | 25 +++++-------
...calShadowSpringNamespaceJdbcExampleService.java | 10 +++--
...ShadowSpringNamespaceMybatisExampleService.java | 25 +++++-------
.../jdbc/MemoryLocalShardingJdbcConfiguration.java | 5 ++-
.../MemoryLocalShardingJdbcExampleService.java | 13 +++---
...hardingSpringBootStarterJdbcExampleService.java | 13 +++---
...ShardingSpringBootStarterJpaExampleService.java | 28 +++++--------
...dingSpringBootStarterMybatisExampleService.java | 28 +++++--------
...lShardingSpringNamespaceJdbcExampleService.java | 13 +++---
...alShardingSpringNamespaceJpaExampleService.java | 28 +++++--------
...ardingSpringNamespaceMybatisExampleService.java | 28 +++++--------
.../cosid/CosIdIntervalShardingAlgorithmTest.java | 2 -
.../RuleDefinitionAlterPreprocessor.java | 2 +-
.../mode/manager/ContextManager.java | 18 ++-------
.../mode/metadata/persist/node/CacheNode.java | 2 +-
.../persist/service/ComputeNodePersistService.java | 10 ++---
.../mode/manager/ContextManagerTest.java | 47 +++++++++-------------
.../lock/service/LockRegistryService.java | 2 +-
47 files changed, 356 insertions(+), 463 deletions(-)
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/jdbc/MemoryLocalDbDiscoveryJdbcConfiguration.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/jdbc/M [...]
index 90932fd..cea04da 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/jdbc/MemoryLocalDbDiscoveryJdbcConfiguration.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/jdbc/MemoryLocalDbDiscoveryJdbcConfiguration.java
@@ -42,13 +42,14 @@ public final class MemoryLocalDbDiscoveryJdbcConfiguration {
/**
* Create a DataSource object, which is an object rewritten by ShardingSphere itself
* and contains various rules for rewriting the original data storage. When in use, you only need to use this object.
- * @return
- * @throws SQLException
+ *
+ * @return data source
+ * @throws SQLException SQL exception
*/
public DataSource getDataSource() throws SQLException {
return ShardingSphereDataSourceFactory.createDataSource(createDataSourceMap(), Collections.singleton(createDatabaseDiscoveryRuleConfiguration()), new Properties());
}
-
+
private DatabaseDiscoveryRuleConfiguration createDatabaseDiscoveryRuleConfiguration() {
return new DatabaseDiscoveryRuleConfiguration(createDataSources(), createDiscoveryHeartbeats(), createDiscoveryTypes());
}
@@ -65,7 +66,7 @@ public final class MemoryLocalDbDiscoveryJdbcConfiguration {
DatabaseDiscoveryDataSourceRuleConfiguration dsRuleConf1 = new DatabaseDiscoveryDataSourceRuleConfiguration("rule", Lists.newArrayList("ds_0", "ds_0_replica_0", "ds_0_replica_1"), "mgr-heartbeat", "mgr");
return Lists.newArrayList(dsRuleConf1);
}
-
+
private Map<String, DatabaseDiscoveryHeartBeatConfiguration> createDiscoveryHeartbeats() {
Map<String, DatabaseDiscoveryHeartBeatConfiguration> discoveryHeartBeatConfiguration = new HashMap<>(1, 1);
Properties props = new Properties();
@@ -91,7 +92,7 @@ public final class MemoryLocalDbDiscoveryJdbcConfiguration {
result.setPassword(PASSWORD);
return result;
}
-
+
private DataSource createReplicaDataSource1() {
HikariDataSource result = new HikariDataSource();
result.setDriverClassName("com.mysql.jdbc.Driver");
@@ -100,7 +101,7 @@ public final class MemoryLocalDbDiscoveryJdbcConfiguration {
result.setPassword(PASSWORD);
return result;
}
-
+
private DataSource createReplicaDataSource2() {
HikariDataSource result = new HikariDataSource();
result.setDriverClassName("com.mysql.jdbc.Driver");
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/jdbc/MemoryLocalDbDiscoveryJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/jdbc/ [...]
index 868bbfb..b633054 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/jdbc/MemoryLocalDbDiscoveryJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/jdbc/MemoryLocalDbDiscoveryJdbcExampleService.java
@@ -46,7 +46,7 @@ public final class MemoryLocalDbDiscoveryJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -59,7 +59,8 @@ public final class MemoryLocalDbDiscoveryJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -96,7 +97,7 @@ public final class MemoryLocalDbDiscoveryJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -133,13 +134,12 @@ public final class MemoryLocalDbDiscoveryJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/jdbc/MemoryLocalDbDiscoverySpringBootStarterJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-jd [...]
index e174410..3e6d335 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/jdbc/MemoryLocalDbDiscoverySpringBootStarterJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/jdbc/MemoryLocalDbDiscoverySpringBootStarterJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -136,13 +137,13 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/jpa/MemoryLocalDbDiscoverySpringBootStarterJpaExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-jpa-e [...]
index b374479..ff3595a 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/jpa/MemoryLocalDbDiscoverySpringBootStarterJpaExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/jpa/MemoryLocalDbDiscoverySpringBootStarterJpaExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.db.discovery.spring.boot.starter.jpa.en
import org.apache.shardingsphere.example.db.discovery.spring.boot.starter.jpa.repository.AddressRepository;
import org.apache.shardingsphere.example.db.discovery.spring.boot.starter.jpa.repository.OrderItemRepository;
import org.apache.shardingsphere.example.db.discovery.spring.boot.starter.jpa.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -47,9 +46,8 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJpaExampleService {
/**
* Execute test.
*
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +58,8 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJpaExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +68,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJpaExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +77,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJpaExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +94,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJpaExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +105,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJpaExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +115,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJpaExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +130,14 @@ public final class MemoryLocalDbDiscoverySpringBootStarterJpaExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/mybatis/MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-s [...]
index a9751dd..dfbc546 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/mybatis/MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/boot/starter/mybatis/MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.db.discovery.spring.boot.starter.mybati
import org.apache.shardingsphere.example.db.discovery.spring.boot.starter.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.db.discovery.spring.boot.starter.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.db.discovery.spring.boot.starter.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalDbDiscoverySpringBootStarterMybatisExampleService
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/jdbc/MemoryLocalDbDiscoverySpringNamespaceJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-jdbc-example/ [...]
index 79150f5..e9743794 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/jdbc/MemoryLocalDbDiscoverySpringNamespaceJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/jdbc/MemoryLocalDbDiscoverySpringNamespaceJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -99,7 +99,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -136,13 +136,12 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/jpa/MemoryLocalDbDiscoverySpringNamespaceJpaExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-jpa-example/src/ [...]
index df67188..76d1b77 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/jpa/MemoryLocalDbDiscoverySpringNamespaceJpaExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/jpa/MemoryLocalDbDiscoverySpringNamespaceJpaExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.db.discovery.spring.namespace.jpa.entit
import org.apache.shardingsphere.example.db.discovery.spring.namespace.jpa.repository.AddressRepository;
import org.apache.shardingsphere.example.db.discovery.spring.namespace.jpa.repository.OrderItemRepository;
import org.apache.shardingsphere.example.db.discovery.spring.namespace.jpa.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -47,9 +46,8 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJpaExampleService {
/**
* Execute test.
*
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +58,8 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJpaExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +68,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJpaExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +77,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJpaExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +94,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJpaExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +105,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJpaExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +115,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJpaExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +130,14 @@ public final class MemoryLocalDbDiscoverySpringNamespaceJpaExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/mybatis/MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-myba [...]
index a96c108..821fdda 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/mybatis/MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-db-discovery-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/db/discovery/spring/namespace/mybatis/MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.db.discovery.spring.namespace.mybatis.e
import org.apache.shardingsphere.example.db.discovery.spring.namespace.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.db.discovery.spring.namespace.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.db.discovery.spring.namespace.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalDbDiscoverySpringNamespaceMybatisExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/jdbc/MemoryLocalEncryptJdbcConfiguration.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/jdbc/MemoryLocalEncryptJdbcCon [...]
index 9c770c1..9fd7bdc 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/jdbc/MemoryLocalEncryptJdbcConfiguration.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/jdbc/MemoryLocalEncryptJdbcConfiguration.java
@@ -45,8 +45,9 @@ public final class MemoryLocalEncryptJdbcConfiguration {
/**
* Create a DataSource object, which is an object rewritten by ShardingSphere itself
* and contains various rules for rewriting the original data storage. When in use, you only need to use this object.
- * @return
- * @throws SQLException
+ *
+ * @return data source
+ * @throws SQLException SQL exception
*/
public DataSource getDataSource() throws SQLException {
return ShardingSphereDataSourceFactory.createDataSource(createDataSource("demo_ds_0"), Collections.singleton(createEncryptRuleConfiguration()), new Properties());
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/jdbc/MemoryLocalEncryptJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/jdbc/MemoryLocalEncryptJdbcEx [...]
index 973a299..4ab3cad 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/jdbc/MemoryLocalEncryptJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/jdbc/MemoryLocalEncryptJdbcExampleService.java
@@ -46,7 +46,7 @@ public final class MemoryLocalEncryptJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -59,7 +59,7 @@ public final class MemoryLocalEncryptJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -96,7 +96,7 @@ public final class MemoryLocalEncryptJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -133,13 +133,12 @@ public final class MemoryLocalEncryptJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/jdbc/MemoryLocalEncryptSpringBootStarterJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-jdbc-example/src/main [...]
index 5451946..c49e265 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/jdbc/MemoryLocalEncryptSpringBootStarterJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/jdbc/MemoryLocalEncryptSpringBootStarterJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalEncryptSpringBootStarterJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalEncryptSpringBootStarterJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -99,7 +100,7 @@ public final class MemoryLocalEncryptSpringBootStarterJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -136,13 +137,12 @@ public final class MemoryLocalEncryptSpringBootStarterJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/jpa/MemoryLocalEncryptSpringBootStarterJpaExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-jpa-example/src/main/jav [...]
index deb11e7..b93ff1a 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/jpa/MemoryLocalEncryptSpringBootStarterJpaExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/jpa/MemoryLocalEncryptSpringBootStarterJpaExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.encrypt.spring.boot.starter.jpa.entity.
import org.apache.shardingsphere.example.encrypt.spring.boot.starter.jpa.repository.AddressRepository;
import org.apache.shardingsphere.example.encrypt.spring.boot.starter.jpa.repository.OrderItemRepository;
import org.apache.shardingsphere.example.encrypt.spring.boot.starter.jpa.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalEncryptSpringBootStarterJpaExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalEncryptSpringBootStarterJpaExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalEncryptSpringBootStarterJpaExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalEncryptSpringBootStarterJpaExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalEncryptSpringBootStarterJpaExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalEncryptSpringBootStarterJpaExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalEncryptSpringBootStarterJpaExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalEncryptSpringBootStarterJpaExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/mybatis/MemoryLocalEncryptSpringBootStarterMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-mybatis-exam [...]
index 5900a09..301bcac 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/mybatis/MemoryLocalEncryptSpringBootStarterMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/boot/starter/mybatis/MemoryLocalEncryptSpringBootStarterMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.encrypt.spring.boot.starter.mybatis.ent
import org.apache.shardingsphere.example.encrypt.spring.boot.starter.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.encrypt.spring.boot.starter.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.encrypt.spring.boot.starter.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalEncryptSpringBootStarterMybatisExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalEncryptSpringBootStarterMybatisExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalEncryptSpringBootStarterMybatisExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalEncryptSpringBootStarterMybatisExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalEncryptSpringBootStarterMybatisExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalEncryptSpringBootStarterMybatisExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalEncryptSpringBootStarterMybatisExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalEncryptSpringBootStarterMybatisExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/jdbc/MemoryLocalEncryptSpringNamespaceJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-jdbc-example/src/main/java/org/a [...]
index 17a25b9..449107b 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/jdbc/MemoryLocalEncryptSpringNamespaceJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/jdbc/MemoryLocalEncryptSpringNamespaceJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalEncryptSpringNamespaceJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalEncryptSpringNamespaceJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -99,7 +100,7 @@ public final class MemoryLocalEncryptSpringNamespaceJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -136,13 +137,13 @@ public final class MemoryLocalEncryptSpringNamespaceJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/jpa/MemoryLocalEncryptSpringNamespaceJpaExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-jpa-example/src/main/java/org/apach [...]
index 02b0450..7c63b2b 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/jpa/MemoryLocalEncryptSpringNamespaceJpaExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/jpa/MemoryLocalEncryptSpringNamespaceJpaExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.encrypt.spring.namespace.jpa.entity.Ord
import org.apache.shardingsphere.example.encrypt.spring.namespace.jpa.repository.AddressRepository;
import org.apache.shardingsphere.example.encrypt.spring.namespace.jpa.repository.OrderItemRepository;
import org.apache.shardingsphere.example.encrypt.spring.namespace.jpa.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalEncryptSpringNamespaceJpaExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalEncryptSpringNamespaceJpaExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalEncryptSpringNamespaceJpaExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalEncryptSpringNamespaceJpaExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalEncryptSpringNamespaceJpaExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalEncryptSpringNamespaceJpaExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalEncryptSpringNamespaceJpaExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalEncryptSpringNamespaceJpaExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/mybatis/MemoryLocalEncryptSpringNamespaceMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-mybatis-example/src/mai [...]
index b2b15c2..11772cc 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/mybatis/MemoryLocalEncryptSpringNamespaceMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-encrypt-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/encrypt/spring/namespace/mybatis/MemoryLocalEncryptSpringNamespaceMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.encrypt.spring.namespace.mybatis.entity
import org.apache.shardingsphere.example.encrypt.spring.namespace.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.encrypt.spring.namespace.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.encrypt.spring.namespace.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalEncryptSpringNamespaceMybatisExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalEncryptSpringNamespaceMybatisExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalEncryptSpringNamespaceMybatisExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalEncryptSpringNamespaceMybatisExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalEncryptSpringNamespaceMybatisExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalEncryptSpringNamespaceMybatisExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalEncryptSpringNamespaceMybatisExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalEncryptSpringNamespaceMybatisExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-mixed-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/mixed/spring/boot/starter/jdbc/MemoryLocalMixedSpringBootStarterJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-mixed-spring-boot-starter-jdbc-example/src/main/java/or [...]
index 5c13fad..4298d74 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-mixed-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/mixed/spring/boot/starter/jdbc/MemoryLocalMixedSpringBootStarterJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-mixed-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/mixed/spring/boot/starter/jdbc/MemoryLocalMixedSpringBootStarterJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalMixedSpringBootStarterJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalMixedSpringBootStarterJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -99,7 +100,7 @@ public final class MemoryLocalMixedSpringBootStarterJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -136,13 +137,12 @@ public final class MemoryLocalMixedSpringBootStarterJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-mixed-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/mixed/spring/namespace/jdbc/MemoryLocalMixedSpringNamespaceJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-mixed-spring-namespace-jdbc-example/src/main/java/org/apache/sh [...]
index 348607b..b7c9dba 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-mixed-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/mixed/spring/namespace/jdbc/MemoryLocalMixedSpringNamespaceJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-mixed-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/mixed/spring/namespace/jdbc/MemoryLocalMixedSpringNamespaceJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalMixedSpringNamespaceJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalMixedSpringNamespaceJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -99,7 +100,7 @@ public final class MemoryLocalMixedSpringNamespaceJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -136,13 +137,13 @@ public final class MemoryLocalMixedSpringNamespaceJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/jdbc/MemoryLocalReadwriteSplittingJdbcConfiguration.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-jdbc-example/src/main/java/org/apache/shardingsphere [...]
index 83b5238..35373b8 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/jdbc/MemoryLocalReadwriteSplittingJdbcConfiguration.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/jdbc/MemoryLocalReadwriteSplittingJdbcConfiguration.java
@@ -42,8 +42,9 @@ public final class MemoryLocalReadwriteSplittingJdbcConfiguration {
/**
* Create a DataSource object, which is an object rewritten by ShardingSphere itself
* and contains various rules for rewriting the original data storage. When in use, you only need to use this object.
- * @return
- * @throws SQLException
+ *
+ * @return data source
+ * @throws SQLException SQL exception
*/
public DataSource getDataSource() throws SQLException {
return ShardingSphereDataSourceFactory.createDataSource(createDataSourceMap(), Collections.singleton(createReadwriteSplittingRuleConfiguration()), new Properties());
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/jdbc/MemoryLocalReadwriteSplittingJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-jdbc-example/src/main/java/org/apache/shardingspher [...]
index f051d74..fd2e495 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/jdbc/MemoryLocalReadwriteSplittingJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/jdbc/MemoryLocalReadwriteSplittingJdbcExampleService.java
@@ -46,7 +46,7 @@ public final class MemoryLocalReadwriteSplittingJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -59,7 +59,8 @@ public final class MemoryLocalReadwriteSplittingJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -96,7 +97,7 @@ public final class MemoryLocalReadwriteSplittingJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -133,13 +134,13 @@ public final class MemoryLocalReadwriteSplittingJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/jdbc/MemoryLocalReadwriteSplittingSpringBootStarterJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-spli [...]
index 0d29b56..8343690 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/jdbc/MemoryLocalReadwriteSplittingSpringBootStarterJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/jdbc/MemoryLocalReadwriteSplittingSpringBootStarterJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJdbcExampleServ
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJdbcExampleServ
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -136,13 +137,13 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJdbcExampleServ
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/jpa/MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitti [...]
index 286aead..fcedcf4 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/jpa/MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/jpa/MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.readwrite.splitting.spring.boot.starter
import org.apache.shardingsphere.example.readwrite.splitting.spring.boot.starter.jpa.repository.AddressRepository;
import org.apache.shardingsphere.example.readwrite.splitting.spring.boot.starter.jpa.repository.OrderItemRepository;
import org.apache.shardingsphere.example.readwrite.splitting.spring.boot.starter.jpa.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleServi
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleServi
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleServi
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleServi
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleServi
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleServi
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleServi
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterJpaExampleServi
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/mybatis/MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readw [...]
index 7086925..931ac4e 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/mybatis/MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/boot/starter/mybatis/MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.readwrite.splitting.spring.boot.starter
import org.apache.shardingsphere.example.readwrite.splitting.spring.boot.starter.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.readwrite.splitting.spring.boot.starter.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.readwrite.splitting.spring.boot.starter.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleS
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleS
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleS
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleS
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleS
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleS
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleS
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalReadwriteSplittingSpringBootStarterMybatisExampleS
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/jdbc/MemoryLocalReadwriteSplittingSpringNamespaceJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-sp [...]
index b887dd7..6034273 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/jdbc/MemoryLocalReadwriteSplittingSpringNamespaceJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/jdbc/MemoryLocalReadwriteSplittingSpringNamespaceJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJdbcExampleServic
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJdbcExampleServic
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -99,7 +100,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJdbcExampleServic
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -136,13 +137,13 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJdbcExampleServic
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/jpa/MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-sprin [...]
index c99eade..f0608ab 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/jpa/MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/jpa/MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.readwrite.splitting.spring.namespace.jp
import org.apache.shardingsphere.example.readwrite.splitting.spring.namespace.jpa.repository.AddressRepository;
import org.apache.shardingsphere.example.readwrite.splitting.spring.namespace.jpa.repository.OrderItemRepository;
import org.apache.shardingsphere.example.readwrite.splitting.spring.namespace.jpa.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -108,7 +104,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceJpaExampleService
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/mybatis/MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-spl [...]
index 3f7e4c7..5353fb8 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/mybatis/MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-readwrite-splitting-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/readwrite/splitting/spring/namespace/mybatis/MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.readwrite.splitting.spring.namespace.my
import org.apache.shardingsphere.example.readwrite.splitting.spring.namespace.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.readwrite.splitting.spring.namespace.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.readwrite.splitting.spring.namespace.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleSer
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleSer
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleSer
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleSer
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleSer
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleSer
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleSer
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalReadwriteSplittingSpringNamespaceMybatisExampleSer
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/jdbc/MemoryLocalShadowJdbcConfiguration.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/jdbc/MemoryLocalShadowJdbcConfigura [...]
index 49a63fe..67e2d51 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/jdbc/MemoryLocalShadowJdbcConfiguration.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/jdbc/MemoryLocalShadowJdbcConfiguration.java
@@ -51,20 +51,20 @@ public final class MemoryLocalShadowJdbcConfiguration {
Collection<RuleConfiguration> ruleConfigurations = createRuleConfiguration();
return ShardingSphereDataSourceFactory.createDataSource(dataSourceMap, ruleConfigurations, createShardingSphereProps());
}
-
+
private Map<String, DataSource> createDataSourceMap() {
Map<String, DataSource> result = new LinkedHashMap<>();
result.put("demo_ds_0", createDataSource("demo_ds_0"));
result.put("ds_shadow", createDataSource("ds_shadow"));
return result;
}
-
+
private Properties createShardingSphereProps() {
Properties result = new Properties();
result.setProperty(ConfigurationPropertyKey.SQL_SHOW.getKey(), "true");
return result;
}
-
+
private Collection<RuleConfiguration> createRuleConfiguration() {
Collection<RuleConfiguration> result = new LinkedList<>();
result.add(createShadowRuleConfiguration());
@@ -79,7 +79,7 @@ public final class MemoryLocalShadowJdbcConfiguration {
result.setTables(createShadowTables());
return result;
}
-
+
private RuleConfiguration createSQLParserRuleConfiguration() {
SQLParserRuleConfiguration result = new DefaultSQLParserRuleConfigurationBuilder().build();
result.setSqlCommentParseEnabled(true);
@@ -106,13 +106,13 @@ public final class MemoryLocalShadowJdbcConfiguration {
result.add("shadow-data-source");
return result;
}
-
+
private Map<String, ShadowDataSourceConfiguration> createShadowDataSources() {
Map<String, ShadowDataSourceConfiguration> result = new LinkedHashMap<>();
result.put("shadow-data-source", new ShadowDataSourceConfiguration("demo_ds_0", "ds_shadow"));
return result;
}
-
+
private Map<String, ShardingSphereAlgorithmConfiguration> createShadowAlgorithmConfigurations() {
Map<String, ShardingSphereAlgorithmConfiguration> result = new LinkedHashMap<>();
Properties userIdInsertProps = new Properties();
@@ -136,6 +136,7 @@ public final class MemoryLocalShadowJdbcConfiguration {
result.put("simple-hint-algorithm", new ShardingSphereAlgorithmConfiguration("SIMPLE_HINT", noteAlgorithmProps));
return result;
}
+
private DataSource createDataSource(final String dataSourceName) {
HikariDataSource result = new HikariDataSource();
result.setDriverClassName("com.mysql.jdbc.Driver");
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/jdbc/MemoryLocalShadowJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/jdbc/MemoryLocalShadowJdbcExampleS [...]
index f7be77f..43189fb 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/jdbc/MemoryLocalShadowJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/jdbc/MemoryLocalShadowJdbcExampleService.java
@@ -46,7 +46,7 @@ public final class MemoryLocalShadowJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -59,7 +59,8 @@ public final class MemoryLocalShadowJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -98,7 +99,7 @@ public final class MemoryLocalShadowJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -143,7 +144,8 @@ public final class MemoryLocalShadowJdbcExampleService {
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTableShadow();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/boot/starter/jdbc/MemoryLocalShadowSpringBootStarterJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-boot-starter-jdbc-example/src/main/jav [...]
index cde05ac..dbf8d8b 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/boot/starter/jdbc/MemoryLocalShadowSpringBootStarterJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/boot/starter/jdbc/MemoryLocalShadowSpringBootStarterJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalShadowSpringBootStarterJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalShadowSpringBootStarterJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -101,7 +102,7 @@ public final class MemoryLocalShadowSpringBootStarterJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -146,7 +147,8 @@ public final class MemoryLocalShadowSpringBootStarterJdbcExampleService {
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTableShadow();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/boot/starter/mybatis/MemoryLocalShadowSpringBootStarterMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-boot-starter-mybatis-example/ [...]
index 619f72c..0b48059 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/boot/starter/mybatis/MemoryLocalShadowSpringBootStarterMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/boot/starter/mybatis/MemoryLocalShadowSpringBootStarterMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.shadow.spring.boot.starter.mybatis.enti
import org.apache.shardingsphere.example.shadow.spring.boot.starter.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.shadow.spring.boot.starter.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.shadow.spring.boot.starter.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -73,7 +69,7 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
orderRepository.truncateTableShadow();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -82,7 +78,7 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -99,7 +95,7 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -110,7 +106,7 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -121,7 +117,7 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -136,7 +132,7 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
+ private List<Order> selectAll() {
List<Order> result = orderRepository.selectAll();
result.addAll(orderRepository.selectShadowOrder());
return result;
@@ -144,9 +140,8 @@ public final class MemoryLocalShadowSpringBootStarterMybatisExampleService {
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTableShadow();
orderRepository.dropTable();
orderItemRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/namespace/jdbc/MemoryLocalShadowSpringNamespaceJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-namespace-jdbc-example/src/main/java/org/apach [...]
index 0870ff0..c4d6e9f 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/namespace/jdbc/MemoryLocalShadowSpringNamespaceJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/namespace/jdbc/MemoryLocalShadowSpringNamespaceJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalShadowSpringNamespaceJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalShadowSpringNamespaceJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -101,7 +102,7 @@ public final class MemoryLocalShadowSpringNamespaceJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -146,7 +147,8 @@ public final class MemoryLocalShadowSpringNamespaceJdbcExampleService {
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTableShadow();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/namespace/mybatis/MemoryLocalShadowSpringNamespaceMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-namespace-mybatis-example/src/main/ja [...]
index 47d9143..e99b391 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/namespace/mybatis/MemoryLocalShadowSpringNamespaceMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-shadow-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/shadow/spring/namespace/mybatis/MemoryLocalShadowSpringNamespaceMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.shadow.spring.namespace.mybatis.entity.
import org.apache.shardingsphere.example.shadow.spring.namespace.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.shadow.spring.namespace.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.shadow.spring.namespace.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -73,7 +69,7 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
orderRepository.truncateTableShadow();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -82,7 +78,7 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -99,7 +95,7 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -110,7 +106,7 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -121,7 +117,7 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -136,7 +132,7 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
+ private List<Order> selectAll() {
List<Order> result = orderRepository.selectAll();
result.addAll(orderRepository.selectShadowOrder());
return result;
@@ -144,9 +140,8 @@ public final class MemoryLocalShadowSpringNamespaceMybatisExampleService {
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTableShadow();
orderRepository.dropTable();
orderItemRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/jdbc/MemoryLocalShardingJdbcConfiguration.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/jdbc/MemoryLocalShardingJ [...]
index 002cc7e..ab8ed7f 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/jdbc/MemoryLocalShardingJdbcConfiguration.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/jdbc/MemoryLocalShardingJdbcConfiguration.java
@@ -47,8 +47,9 @@ public final class MemoryLocalShardingJdbcConfiguration {
/**
* Create a DataSource object, which is an object rewritten by ShardingSphere itself
* and contains various rules for rewriting the original data storage. When in use, you only need to use this object.
- * @return
- * @throws SQLException
+ *
+ * @return data source
+ * @throws SQLException SQL exception
*/
public DataSource getDataSource() throws SQLException {
return ShardingSphereDataSourceFactory.createDataSource(createModeConfiguration(), createDataSourceMap(), Collections.singleton(createShardingRuleConfiguration()), new Properties());
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/jdbc/MemoryLocalShardingJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/jdbc/MemoryLocalSharding [...]
index c234235..4123137 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/jdbc/MemoryLocalShardingJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/jdbc/MemoryLocalShardingJdbcExampleService.java
@@ -46,7 +46,7 @@ public final class MemoryLocalShardingJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -59,7 +59,8 @@ public final class MemoryLocalShardingJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -96,7 +97,7 @@ public final class MemoryLocalShardingJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -133,13 +134,13 @@ public final class MemoryLocalShardingJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/jdbc/MemoryLocalShardingSpringBootStarterJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-jdbc-example/src/ [...]
index fced245..aea0d6f 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/jdbc/MemoryLocalShardingSpringBootStarterJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/jdbc/MemoryLocalShardingSpringBootStarterJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalShardingSpringBootStarterJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalShardingSpringBootStarterJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -99,7 +100,7 @@ public final class MemoryLocalShardingSpringBootStarterJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -136,13 +137,13 @@ public final class MemoryLocalShardingSpringBootStarterJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/jpa/MemoryLocalShardingSpringBootStarterJpaExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-jpa-example/src/main [...]
index 7fc9705..7d2b16e 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/jpa/MemoryLocalShardingSpringBootStarterJpaExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-jpa-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/jpa/MemoryLocalShardingSpringBootStarterJpaExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.sharding.spring.boot.starter.jpa.entity
import org.apache.shardingsphere.example.sharding.spring.boot.starter.jpa.repository.AddressRepository;
import org.apache.shardingsphere.example.sharding.spring.boot.starter.jpa.repository.OrderItemRepository;
import org.apache.shardingsphere.example.sharding.spring.boot.starter.jpa.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalShardingSpringBootStarterJpaExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalShardingSpringBootStarterJpaExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalShardingSpringBootStarterJpaExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalShardingSpringBootStarterJpaExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalShardingSpringBootStarterJpaExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalShardingSpringBootStarterJpaExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalShardingSpringBootStarterJpaExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalShardingSpringBootStarterJpaExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/mybatis/MemoryLocalShardingSpringBootStarterMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-mybatis- [...]
index ca33ae4..3bc0a01 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/mybatis/MemoryLocalShardingSpringBootStarterMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-boot-starter-mybatis-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/boot/starter/mybatis/MemoryLocalShardingSpringBootStarterMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.sharding.spring.boot.starter.mybatis.en
import org.apache.shardingsphere.example.sharding.spring.boot.starter.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.sharding.spring.boot.starter.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.sharding.spring.boot.starter.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalShardingSpringBootStarterMybatisExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalShardingSpringBootStarterMybatisExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalShardingSpringBootStarterMybatisExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalShardingSpringBootStarterMybatisExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalShardingSpringBootStarterMybatisExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalShardingSpringBootStarterMybatisExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalShardingSpringBootStarterMybatisExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalShardingSpringBootStarterMybatisExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/jdbc/MemoryLocalShardingSpringNamespaceJdbcExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-jdbc-example/src/main/java/o [...]
index 92e225b..65b5334 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/jdbc/MemoryLocalShardingSpringNamespaceJdbcExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-jdbc-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/jdbc/MemoryLocalShardingSpringNamespaceJdbcExampleService.java
@@ -49,7 +49,7 @@ public final class MemoryLocalShardingSpringNamespaceJdbcExampleService {
/**
* Execute test.
*
- * @throws SQLException
+ * @throws SQLException SQL exception
*/
public void run() throws SQLException {
try {
@@ -62,7 +62,8 @@ public final class MemoryLocalShardingSpringNamespaceJdbcExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void initEnvironment() throws SQLException {
orderRepository.createTableIfNotExists();
@@ -99,7 +100,7 @@ public final class MemoryLocalShardingSpringNamespaceJdbcExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -136,13 +137,13 @@ public final class MemoryLocalShardingSpringNamespaceJdbcExampleService {
}
private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
+ *
+ * @throws SQLException SQL exception
*/
private void cleanEnvironment() throws SQLException {
orderRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/jpa/MemoryLocalShardingSpringNamespaceJpaExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-jpa-example/src/main/java/org/a [...]
index a4ea9ed..21da6fe 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/jpa/MemoryLocalShardingSpringNamespaceJpaExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-jpa-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/jpa/MemoryLocalShardingSpringNamespaceJpaExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.sharding.spring.namespace.jpa.entity.Or
import org.apache.shardingsphere.example.sharding.spring.namespace.jpa.repository.AddressRepository;
import org.apache.shardingsphere.example.sharding.spring.namespace.jpa.repository.OrderItemRepository;
import org.apache.shardingsphere.example.sharding.spring.namespace.jpa.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalShardingSpringNamespaceJpaExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalShardingSpringNamespaceJpaExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalShardingSpringNamespaceJpaExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalShardingSpringNamespaceJpaExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalShardingSpringNamespaceJpaExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalShardingSpringNamespaceJpaExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalShardingSpringNamespaceJpaExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalShardingSpringNamespaceJpaExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/mybatis/MemoryLocalShardingSpringNamespaceMybatisExampleService.java b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-mybatis-example/src [...]
index e16f3e6..e07fff6 100644
--- a/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/mybatis/MemoryLocalShardingSpringNamespaceMybatisExampleService.java
+++ b/examples/shardingsphere-sample/shardingsphere-example-generated/shardingsphere-jdbc-sample/shardingsphere-jdbc-memory-local-sharding-spring-namespace-mybatis-example/src/main/java/org/apache/shardingsphere/example/sharding/spring/namespace/mybatis/MemoryLocalShardingSpringNamespaceMybatisExampleService.java
@@ -23,9 +23,8 @@ import org.apache.shardingsphere.example.sharding.spring.namespace.mybatis.entit
import org.apache.shardingsphere.example.sharding.spring.namespace.mybatis.repository.AddressRepository;
import org.apache.shardingsphere.example.sharding.spring.namespace.mybatis.repository.OrderItemRepository;
import org.apache.shardingsphere.example.sharding.spring.namespace.mybatis.repository.OrderRepository;
-
import org.springframework.stereotype.Service;
-import java.sql.SQLException;
+
import java.util.ArrayList;
import java.util.List;
@@ -46,10 +45,8 @@ public final class MemoryLocalShardingSpringNamespaceMybatisExampleService {
/**
* Execute test.
- *
- * @throws SQLException
*/
- public void run() throws SQLException {
+ public void run() {
try {
this.initEnvironment();
this.processSuccess();
@@ -60,9 +57,8 @@ public final class MemoryLocalShardingSpringNamespaceMybatisExampleService {
/**
* Initialize the database test environment.
- * @throws SQLException
*/
- private void initEnvironment() throws SQLException {
+ private void initEnvironment() {
orderRepository.createTableIfNotExists();
orderItemRepository.createTableIfNotExists();
addressRepository.createTableIfNotExists();
@@ -71,7 +67,7 @@ public final class MemoryLocalShardingSpringNamespaceMybatisExampleService {
addressRepository.truncateTable();
}
- private void processSuccess() throws SQLException {
+ private void processSuccess() {
System.out.println("-------------- Process Success Begin ---------------");
List<Long> orderIds = insertData();
printData();
@@ -80,7 +76,7 @@ public final class MemoryLocalShardingSpringNamespaceMybatisExampleService {
System.out.println("-------------- Process Success Finish --------------");
}
- private List<Long> insertData() throws SQLException {
+ private List<Long> insertData() {
System.out.println("---------------------------- Insert Data ----------------------------");
List<Long> result = new ArrayList<>(10);
for (int i = 1; i <= 10; i++) {
@@ -97,7 +93,7 @@ public final class MemoryLocalShardingSpringNamespaceMybatisExampleService {
orderItem.setPhone("13800000001");
orderItem.setStatus("INSERT_TEST");
orderItemRepository.insert(orderItem);
-
+
Address address = new Address();
address.setAddressId((long) i);
address.setAddressName("address_test_" + i);
@@ -108,7 +104,7 @@ public final class MemoryLocalShardingSpringNamespaceMybatisExampleService {
return result;
}
- private void deleteData(final List<Long> orderIds) throws SQLException {
+ private void deleteData(final List<Long> orderIds) {
System.out.println("---------------------------- Delete Data ----------------------------");
long count = 1;
for (Long each : orderIds) {
@@ -118,7 +114,7 @@ public final class MemoryLocalShardingSpringNamespaceMybatisExampleService {
}
}
- private void printData() throws SQLException {
+ private void printData() {
System.out.println("---------------------------- Print Order Data -----------------------");
for (Object each : this.selectAll()) {
System.out.println(each);
@@ -133,16 +129,14 @@ public final class MemoryLocalShardingSpringNamespaceMybatisExampleService {
}
}
- private List<Order> selectAll() throws SQLException {
- List<Order> result = orderRepository.selectAll();
- return result;
+ private List<Order> selectAll() {
+ return orderRepository.selectAll();
}
/**
* Restore the environment.
- * @throws SQLException
*/
- private void cleanEnvironment() throws SQLException {
+ private void cleanEnvironment() {
orderRepository.dropTable();
orderItemRepository.dropTable();
addressRepository.dropTable();
diff --git a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/java/org/apache/shardingsphere/sharding/algorithm/sharding/cosid/CosIdIntervalShardingAlgorithmTest.java b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/java/org/apache/shardingsphere/sharding/algorithm/sharding/cosid/CosIdIntervalShardingAlgorithmTest.java
index 7a35abb..7d99c22 100644
--- a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/java/org/apache/shardingsphere/sharding/algorithm/sharding/cosid/CosIdIntervalShardingAlgorithmTest.java
+++ b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/java/org/apache/shardingsphere/sharding/algorithm/sharding/cosid/CosIdIntervalShardingAlgorithmTest.java
@@ -120,7 +120,6 @@ public final class CosIdIntervalShardingAlgorithmTest {
new ExactCollection<>("table_202101", "table_202102", "table_202103", "table_202104", "table_202105", "table_202106",
"table_202107", "table_202108", "table_202109", "table_202110", "table_202111", "table_202112")),
Arguments.of(Range.openClosed(datetimeConvert.apply(LOWER_DATE_TIME), datetimeConvert.apply(UPPER_DATE_TIME)), ALL_NODES),
-
Arguments.of(Range.greaterThan(datetimeConvert.apply(LOWER_DATE_TIME)), ALL_NODES),
Arguments.of(Range.atLeast(datetimeConvert.apply(LOWER_DATE_TIME)), ALL_NODES),
Arguments.of(Range.greaterThan(datetimeConvert.apply(UPPER_DATE_TIME)), new ExactCollection<>("table_202201")),
@@ -129,7 +128,6 @@ public final class CosIdIntervalShardingAlgorithmTest {
new ExactCollection<>("table_202112", "table_202201")),
Arguments.of(Range.atLeast(datetimeConvert.apply(LocalDateTime.of(2021, 12, 5, 0, 0))),
new ExactCollection<>("table_202112", "table_202201")),
-
Arguments.of(Range.lessThan(datetimeConvert.apply(LOWER_DATE_TIME)), ExactCollection.empty()),
Arguments.of(Range.atMost(datetimeConvert.apply(LOWER_DATE_TIME)), new ExactCollection<>("table_202101")),
Arguments.of(Range.lessThan(datetimeConvert.apply(UPPER_DATE_TIME)), new ExactCollection<>("table_202101",
diff --git a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/distsql/preprocess/RuleDefinitionAlterPreprocessor.java b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/distsql/preprocess/RuleDefinitionAlterPreprocessor.java
index ec0dd3c..b36c043 100644
--- a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/distsql/preprocess/RuleDefinitionAlterPreprocessor.java
+++ b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/distsql/preprocess/RuleDefinitionAlterPreprocessor.java
@@ -34,7 +34,7 @@ public interface RuleDefinitionAlterPreprocessor<T extends SQLStatement, R exten
*
* @param currentRuleConfig current rule configuration to be updated
* @param toBeAlteredRuleConfig to be altered rule configuration
- * @return altered current rule configuration
+ * @return altered current rule configuration
*/
R preprocess(R currentRuleConfig, R toBeAlteredRuleConfig);
}
diff --git a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
index 3e3c283..ce2a586 100644
--- a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
+++ b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
@@ -22,7 +22,6 @@ import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.infra.config.RuleConfiguration;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
-import org.apache.shardingsphere.infra.config.schema.SchemaConfiguration;
import org.apache.shardingsphere.infra.config.schema.impl.DataSourceProvidedSchemaConfiguration;
import org.apache.shardingsphere.infra.database.type.DatabaseType;
import org.apache.shardingsphere.infra.datasource.pool.creator.DataSourcePoolCreator;
@@ -208,7 +207,7 @@ public final class ContextManager implements AutoCloseable {
*
* @param schemaName schema name
* @param dataSourcePropsMap data source properties map
- * @throws SQLException SQL exception
+ * @throws SQLException SQL exception
*/
public void addResource(final String schemaName, final Map<String, DataSourceProperties> dataSourcePropsMap) throws SQLException {
refreshMetaDataContext(schemaName, dataSourcePropsMap);
@@ -220,7 +219,7 @@ public final class ContextManager implements AutoCloseable {
*
* @param schemaName schema name
* @param dataSourcePropsMap data source properties map
- * @throws SQLException SQL exception
+ * @throws SQLException SQL exception
*/
public void alterResource(final String schemaName, final Map<String, DataSourceProperties> dataSourcePropsMap) throws SQLException {
refreshMetaDataContext(schemaName, dataSourcePropsMap);
@@ -318,7 +317,7 @@ public final class ContextManager implements AutoCloseable {
* Reload table meta data.
*
* @param schemaName schema name
- * @param tableName logic table name
+ * @param tableName logic table name
*/
public void reloadMetaData(final String schemaName, final String tableName) {
try {
@@ -336,7 +335,7 @@ public final class ContextManager implements AutoCloseable {
*
* @param schemaName schema name
* @param tableName logic table name
- * @param dataSourceName data source name
+ * @param dataSourceName data source name
*/
public void reloadMetaData(final String schemaName, final String tableName, final String dataSourceName) {
try {
@@ -470,15 +469,6 @@ public final class ContextManager implements AutoCloseable {
return DataSourcePoolCreator.create(getChangedDataSourceConfiguration(originalMetaData, newDataSourcePropsMap));
}
- private Map<String, ShardingSphereSchema> getShardingSphereSchemas(final Map<String, ? extends SchemaConfiguration> schemaConfigs, final Map<String, Collection<ShardingSphereRule>> rules,
- final Properties props) throws SQLException {
- Map<String, ShardingSphereSchema> result = new LinkedHashMap<>(schemaConfigs.size(), 1);
- for (String each : schemaConfigs.keySet()) {
- result.put(each, SchemaLoader.load(schemaConfigs.get(each).getDataSources(), rules.get(each), props));
- }
- return result;
- }
-
private void renewTransactionContext(final String schemaName, final ShardingSphereResource resource) {
ShardingSphereTransactionManagerEngine changedStaleEngine = transactionContexts.getEngines().get(schemaName);
if (null != changedStaleEngine) {
diff --git a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/node/CacheNode.java b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/node/CacheNode.java
index f428577..a524cad 100644
--- a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/node/CacheNode.java
+++ b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/node/CacheNode.java
@@ -57,7 +57,7 @@ public final class CacheNode {
* Get cache path.
*
* @param path path
- * @param cacheId cache id
+ * @param cacheId cache id
* @return cache path
*/
public static String getCachePath(final String path, final String cacheId) {
diff --git a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/service/ComputeNodePersistService.java b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/service/ComputeNodePersistService.java
index f3a6aa6..dce27d6 100644
--- a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/service/ComputeNodePersistService.java
+++ b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/service/ComputeNodePersistService.java
@@ -72,7 +72,7 @@ public final class ComputeNodePersistService {
* Load instance labels.
*
* @param instanceId instance id
- * @return collection of label
+ * @return labels
*/
public Collection<String> loadInstanceLabels(final String instanceId) {
String yamlContent = repository.get(ComputeNode.getInstanceLabelsNodePath(instanceId));
@@ -83,7 +83,7 @@ public final class ComputeNodePersistService {
* Load instance status.
*
* @param instanceId instance id
- * @return collection of status
+ * @return status
*/
public Collection<String> loadInstanceStatus(final String instanceId) {
String yamlContent = repository.get(ComputeNode.getInstanceStatusNodePath(instanceId));
@@ -110,8 +110,8 @@ public final class ComputeNodePersistService {
* Load compute node instances by instance type and labels.
*
* @param instanceType instance type
- * @param labels collection of contained label
- * @return collection of compute node instance
+ * @param labels collection of contained label
+ * @return compute node instances
*/
public Collection<ComputeNodeInstance> loadComputeNodeInstances(final InstanceType instanceType, final Collection<String> labels) {
Collection<String> onlineComputeNodes = repository.getChildrenKeys(ComputeNode.getOnlineNodePath(instanceType));
@@ -133,7 +133,7 @@ public final class ComputeNodePersistService {
/**
* Load all compute node instances.
*
- * @return collection of compute node instance
+ * @return compute node instances
*/
public Collection<ComputeNodeInstance> loadAllComputeNodeInstances() {
Collection<ComputeNodeInstance> result = new ArrayList<>();
diff --git a/shardingsphere-mode/shardingsphere-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/ContextManagerTest.java b/shardingsphere-mode/shardingsphere-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/ContextManagerTest.java
index 8000fea..20ffdd6 100644
--- a/shardingsphere-mode/shardingsphere-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/ContextManagerTest.java
+++ b/shardingsphere-mode/shardingsphere-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/ContextManagerTest.java
@@ -24,7 +24,6 @@ import org.apache.shardingsphere.infra.database.type.DatabaseType;
import org.apache.shardingsphere.infra.datasource.props.DataSourceProperties;
import org.apache.shardingsphere.infra.federation.optimizer.context.parser.OptimizerParserContext;
import org.apache.shardingsphere.infra.federation.optimizer.context.planner.OptimizerPlannerContext;
-import org.apache.shardingsphere.infra.federation.optimizer.metadata.FederationMetaData;
import org.apache.shardingsphere.infra.federation.optimizer.metadata.FederationSchemaMetaData;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
@@ -83,7 +82,7 @@ public final class ContextManagerTest {
public void setUp() throws SQLException {
contextManager = new ContextManager();
contextManager.init(metaDataContexts, mock(TransactionContexts.class), mock(InstanceContext.class));
- when(metaDataContexts.getGlobalRuleMetaData()).thenReturn(mock(ShardingSphereRuleMetaData.class, RETURNS_DEEP_STUBS));
+ when(metaDataContexts.getGlobalRuleMetaData().getRules()).thenReturn(Collections.emptyList());
when(metaDataContexts.getOptimizerContext().getFederationMetaData().getSchemas()).thenReturn(new LinkedHashMap<>());
when(metaDataContexts.getProps()).thenReturn(new ConfigurationProperties(new Properties()));
}
@@ -99,16 +98,16 @@ public final class ContextManagerTest {
@Test
public void assertRenewMetaDataContexts() {
- MetaDataContexts metaDataContexts = mock(MetaDataContexts.class);
- contextManager.renewMetaDataContexts(metaDataContexts);
- assertThat(contextManager.getMetaDataContexts(), is(metaDataContexts));
+ MetaDataContexts contexts = mock(MetaDataContexts.class);
+ contextManager.renewMetaDataContexts(contexts);
+ assertThat(contextManager.getMetaDataContexts(), is(contexts));
}
@Test
public void assertRenewTransactionContexts() {
- TransactionContexts transactionContexts = mock(TransactionContexts.class);
- contextManager.renewTransactionContexts(transactionContexts);
- assertThat(contextManager.getTransactionContexts(), is(transactionContexts));
+ TransactionContexts contexts = mock(TransactionContexts.class);
+ contextManager.renewTransactionContexts(contexts);
+ assertThat(contextManager.getTransactionContexts(), is(contexts));
}
@Test
@@ -143,7 +142,6 @@ public final class ContextManagerTest {
public void assertAddResource() throws SQLException {
when(metaDataContexts.getMetaDataMap()).thenReturn(new HashMap<>(Collections.singletonMap("foo_schema", new ShardingSphereMetaData(
"foo_schema", mock(ShardingSphereResource.class), new ShardingSphereRuleMetaData(new LinkedList<>(), new LinkedList<>()), mock(ShardingSphereSchema.class)))));
- when(metaDataContexts.getGlobalRuleMetaData().getRules()).thenReturn(Collections.emptyList());
contextManager.addResource("foo_schema", createToBeAddedDataSourceProperties());
assertAddedDataSources(contextManager.getMetaDataContexts().getMetaDataMap().get("foo_schema").getResource().getDataSources());
}
@@ -169,22 +167,18 @@ public final class ContextManagerTest {
@Test
public void assertAlterResource() throws SQLException {
- Map<String, DataSource> dataSources = new LinkedHashMap<>();
- dataSources.put("original_ds", new MockedDataSource());
- ShardingSphereResource originalResource = mock(ShardingSphereResource.class);
- when(originalResource.getDataSources()).thenReturn(dataSources);
- ShardingSphereRuleMetaData originalShardingSphereRuleMetaData = mock(ShardingSphereRuleMetaData.class);
- when(originalShardingSphereRuleMetaData.getConfigurations()).thenReturn(new LinkedList<>());
- ShardingSphereMetaData originalMetaData = new ShardingSphereMetaData("test_schema", originalResource, originalShardingSphereRuleMetaData, mock(ShardingSphereSchema.class));
- Map<String, ShardingSphereMetaData> metaDataMap = new LinkedHashMap<>();
- metaDataMap.put("test_schema", originalMetaData);
- when(metaDataContexts.getMetaDataMap()).thenReturn(metaDataMap);
- when(metaDataContexts.getMetaData("test_schema")).thenReturn(originalMetaData);
- when(metaDataContexts.getGlobalRuleMetaData().getRules()).thenReturn(Collections.emptyList());
- when(metaDataContexts.getOptimizerContext().getFederationMetaData()).thenReturn(mock(FederationMetaData.class));
- when(metaDataContexts.getOptimizerContext().getParserContexts()).thenReturn(new LinkedHashMap<>());
- contextManager.alterResource("test_schema", Collections.singletonMap("foo_ds", new DataSourceProperties(MockedDataSource.class.getName(), createProperties("test", "test"))));
- assertAlteredDataSource((MockedDataSource) contextManager.getMetaDataContexts().getMetaDataMap().get("test_schema").getResource().getDataSources().get("foo_ds"));
+ Map<String, ShardingSphereMetaData> originalMetaDataMap = new HashMap<>(Collections.singletonMap("foo_schema", createOriginalMetaData()));
+ when(metaDataContexts.getMetaDataMap()).thenReturn(originalMetaDataMap);
+ contextManager.alterResource("foo_schema", Collections.singletonMap("foo_ds", new DataSourceProperties(MockedDataSource.class.getName(), createProperties("test", "test"))));
+ assertAlteredDataSource((MockedDataSource) contextManager.getMetaDataContexts().getMetaDataMap().get("foo_schema").getResource().getDataSources().get("foo_ds"));
+ }
+
+ private ShardingSphereMetaData createOriginalMetaData() {
+ ShardingSphereResource resource = mock(ShardingSphereResource.class);
+ when(resource.getDataSources()).thenReturn(Collections.singletonMap("original_ds", new MockedDataSource()));
+ ShardingSphereRuleMetaData ruleMetaData = mock(ShardingSphereRuleMetaData.class);
+ when(ruleMetaData.getConfigurations()).thenReturn(new LinkedList<>());
+ return new ShardingSphereMetaData("foo_schema", resource, ruleMetaData, mock(ShardingSphereSchema.class));
}
private void assertAlteredDataSource(final MockedDataSource actual) {
@@ -235,9 +229,6 @@ public final class ContextManagerTest {
when(metaDataContexts.getMetaDataMap()).thenReturn(originalMetaDataMap);
Map<String, DataSourceProperties> newDataSourceProps = new LinkedHashMap<>();
newDataSourceProps.put("ds_1", new DataSourceProperties(MockedDataSource.class.getName(), createProperties("test", "test")));
- ShardingSphereRuleMetaData globalRuleMetaData = mock(ShardingSphereRuleMetaData.class);
- when(globalRuleMetaData.getConfigurations()).thenReturn(new LinkedList<>());
- when(metaDataContexts.getGlobalRuleMetaData()).thenReturn(globalRuleMetaData);
contextManager.alterDataSourceConfiguration("test_schema", newDataSourceProps);
assertTrue(contextManager.getMetaDataContexts().getMetaDataMap().containsKey("test_schema"));
assertThat(contextManager.getMetaDataContexts().getMetaDataMap().get("test_schema").getResource().getDataSources().size(), is(1));
diff --git a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/service/LockRegistryService.java b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/service/LockRegistryService.java
index 18ea080..8adfa7a 100644
--- a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/service/LockRegistryService.java
+++ b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/service/LockRegistryService.java
@@ -99,7 +99,7 @@ public final class LockRegistryService {
* Check lock ack.
*
* @param lockName lock name
- * @param timeoutMilliseconds the maximum time in milliseconds to ack
+ * @param timeoutMilliseconds the maximum time in milliseconds to ack
* @return true if all instances ack lock, false if not
*/
public boolean checkLockAck(final String lockName, final long timeoutMilliseconds) {