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 43bdccbd20d Add global clock dependency in jdbc adapter (#24651)
43bdccbd20d is described below
commit 43bdccbd20dc268643124d35713ca411edb41c23
Author: ZhangCheng <[email protected]>
AuthorDate: Thu Mar 16 20:02:29 2023 +0800
Add global clock dependency in jdbc adapter (#24651)
* Add global clock dependency in jdbc adapter
* fix
---
jdbc/core/pom.xml | 10 ++++++++++
.../globalclock/core/executor/GlobalClockTransactionHook.java | 2 +-
.../globalclock/type/tso/provider/LocalTSOProvider.java | 2 +-
.../globalclock/type/tso/provider/RedisTSOProvider.java | 2 +-
4 files changed, 13 insertions(+), 3 deletions(-)
diff --git a/jdbc/core/pom.xml b/jdbc/core/pom.xml
index 53afd2384e5..46146d9e734 100644
--- a/jdbc/core/pom.xml
+++ b/jdbc/core/pom.xml
@@ -33,6 +33,16 @@
<artifactId>shardingsphere-transaction-core</artifactId>
<version>${project.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-global-clock-core</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-global-clock-tso-core</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-sql-parser-sql92</artifactId>
diff --git
a/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/executor/GlobalClockTransactionHook.java
b/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/executor/GlobalClockTransactionHook.java
index b70a2ed1644..e65eced4167 100644
---
a/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/executor/GlobalClockTransactionHook.java
+++
b/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/executor/GlobalClockTransactionHook.java
@@ -40,7 +40,7 @@ public final class GlobalClockTransactionHook extends
TransactionHookAdapter {
private GlobalClockTransactionExecutor globalClockTransactionExecutor;
- private LockDefinition lockDefinition = new
GlobalLockDefinition("global_clock");
+ private final LockDefinition lockDefinition = new
GlobalLockDefinition("global_clock");
private boolean enabled;
diff --git
a/kernel/global-clock/type/tso/core/src/main/java/org/apache/shardingsphere/globalclock/type/tso/provider/LocalTSOProvider.java
b/kernel/global-clock/type/tso/core/src/main/java/org/apache/shardingsphere/globalclock/type/tso/provider/LocalTSOProvider.java
index a9edf3e859c..1dd05cf1671 100644
---
a/kernel/global-clock/type/tso/core/src/main/java/org/apache/shardingsphere/globalclock/type/tso/provider/LocalTSOProvider.java
+++
b/kernel/global-clock/type/tso/core/src/main/java/org/apache/shardingsphere/globalclock/type/tso/provider/LocalTSOProvider.java
@@ -23,7 +23,7 @@ import java.util.concurrent.atomic.AtomicLong;
/**
* Local timestamp oracle provider.
*/
-public class LocalTSOProvider implements TSOProvider {
+public final class LocalTSOProvider implements TSOProvider {
private final AtomicLong localClock = new AtomicLong();
diff --git
a/kernel/global-clock/type/tso/provider/redis/src/main/java/org/apache/shardingsphere/globalclock/type/tso/provider/RedisTSOProvider.java
b/kernel/global-clock/type/tso/provider/redis/src/main/java/org/apache/shardingsphere/globalclock/type/tso/provider/RedisTSOProvider.java
index 66ff2c24c6e..05f74ab0213 100644
---
a/kernel/global-clock/type/tso/provider/redis/src/main/java/org/apache/shardingsphere/globalclock/type/tso/provider/RedisTSOProvider.java
+++
b/kernel/global-clock/type/tso/provider/redis/src/main/java/org/apache/shardingsphere/globalclock/type/tso/provider/RedisTSOProvider.java
@@ -22,7 +22,7 @@ import java.util.Properties;
/**
* Redis timestamp oracle provider.
*/
-public class RedisTSOProvider implements TSOProvider {
+public final class RedisTSOProvider implements TSOProvider {
@Override
public void init(final Properties props) {
