This is an automated email from the ASF dual-hosted git repository.
jianglongtao 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 94b84dc4a36 Rename LockJudgeEngineFactory (#19331)
94b84dc4a36 is described below
commit 94b84dc4a36901cdb62f39df1ceb81050b6cbb0f
Author: Liang Zhang <[email protected]>
AuthorDate: Mon Jul 18 19:40:23 2022 +0800
Rename LockJudgeEngineFactory (#19331)
---
...LockJudgeEngineBuilder.java => LockJudgeEngineFactory.java} | 10 +++++-----
.../backend/communication/DatabaseCommunicationEngine.java | 4 ++--
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/lock/LockJudgeEngineBuilder.java
b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/lock/LockJudgeEngineFactory.java
similarity index 87%
rename from
shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/lock/LockJudgeEngineBuilder.java
rename to
shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/lock/LockJudgeEngineFactory.java
index 8841a024478..80c7214ce96 100644
---
a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/lock/LockJudgeEngineBuilder.java
+++
b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/lock/LockJudgeEngineFactory.java
@@ -23,21 +23,21 @@ import
org.apache.shardingsphere.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.spi.type.required.RequiredSPIRegistry;
/**
- * Lock judge engine builder.
+ * Lock judge engine factory.
*/
@NoArgsConstructor(access = AccessLevel.PRIVATE)
-public final class LockJudgeEngineBuilder {
+public final class LockJudgeEngineFactory {
static {
ShardingSphereServiceLoader.register(LockJudgeEngine.class);
}
/**
- * Build.
+ * Get instance of lock judge engine.
*
- * @return lock judge engine
+ * @return got instance
*/
- public static LockJudgeEngine build() {
+ public static LockJudgeEngine getInstance() {
return RequiredSPIRegistry.getRegisteredService(LockJudgeEngine.class);
}
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/DatabaseCommunicationEngine.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/DatabaseCommunicationEngine.java
index d8c79076162..9504bb30d82 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/DatabaseCommunicationEngine.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/DatabaseCommunicationEngine.java
@@ -36,7 +36,7 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.event.MetaDataRe
import org.apache.shardingsphere.infra.rule.ShardingSphereRule;
import
org.apache.shardingsphere.infra.rule.identifier.type.DataNodeContainedRule;
import org.apache.shardingsphere.mode.manager.lock.LockJudgeEngine;
-import org.apache.shardingsphere.mode.manager.lock.LockJudgeEngineBuilder;
+import org.apache.shardingsphere.mode.manager.lock.LockJudgeEngineFactory;
import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
import
org.apache.shardingsphere.proxy.backend.exception.UnsupportedUpdateOperationException;
import org.apache.shardingsphere.proxy.backend.response.data.QueryResponseCell;
@@ -90,7 +90,7 @@ public abstract class DatabaseCommunicationEngine<T> {
ProxyContext.getInstance().getContextManager().getMetaDataContexts().getOptimizerContext().getFederationMetaData().getDatabases().get(databaseName),
ProxyContext.getInstance().getContextManager().getMetaDataContexts().getOptimizerContext().getPlannerContexts(),
ProxyContext.getInstance().getContextManager().getMetaDataContexts().getMetaData().getProps());
- lockJudgeEngine = LockJudgeEngineBuilder.build();
+ lockJudgeEngine = LockJudgeEngineFactory.getInstance();
}
/**