[shardingsphere] branch master updated: Change sys_data to statistics (#26615)

[duanzhengqiang]

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 331028b25d3 Change sys_data to statistics (#26615)
331028b25d3 is described below

commit 331028b25d32a95e487910048ab6e98535591105
Author: zhaojinchao <zhaojinc...@apache.org>
AuthorDate: Tue Jun 27 17:35:00 2023 +0800

    Change sys_data to statistics (#26615)
---
 .../main/java/org/apache/shardingsphere/infra/lock/GlobalLockNames.java | 2 +-
 .../shardingsphere/metadata/persist/node/ShardingSphereDataNode.java    | 2 +-
 .../metadata/subscriber/ShardingSphereSchemaDataRegistrySubscriber.java | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/infra/common/src/main/java/org/apache/shardingsphere/infra/lock/GlobalLockNames.java
 
b/infra/common/src/main/java/org/apache/shardingsphere/infra/lock/GlobalLockNames.java
index fcd1fc8824c..356bdacbc31 100644
--- 
a/infra/common/src/main/java/org/apache/shardingsphere/infra/lock/GlobalLockNames.java
+++ 
b/infra/common/src/main/java/org/apache/shardingsphere/infra/lock/GlobalLockNames.java
@@ -24,7 +24,7 @@ import lombok.RequiredArgsConstructor;
 @Getter
 public enum GlobalLockNames {
     
-    SYS_DATA("sys_data_%s_%s_%s"),
+    STATISTICS("statistics_%s_%s_%s"),
     
     CLUSTER_LOCK("cluster_lock"),
     
diff --git 
a/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/node/ShardingSphereDataNode.java
 
b/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/node/ShardingSphereDataNode.java
index 6674370e97f..0414d3c472b 100644
--- 
a/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/node/ShardingSphereDataNode.java
+++ 
b/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/node/ShardingSphereDataNode.java
@@ -30,7 +30,7 @@ import java.util.regex.Pattern;
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public final class ShardingSphereDataNode {
     
-    private static final String ROOT_NODE = "sys_data";
+    private static final String ROOT_NODE = "statistics";
     
     private static final String SCHEMAS_NODE = "schemas";
     
diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/subscriber/ShardingSphereSchemaDataRegistrySubscriber.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/subscriber/ShardingSphereSchemaDataRegistrySubscriber.java
index 5b0734609e7..dc8f62aa4ea 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/subscriber/ShardingSphereSchemaDataRegistrySubscriber.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/subscriber/ShardingSphereSchemaDataRegistrySubscriber.java
@@ -51,7 +51,7 @@ public final class ShardingSphereSchemaDataRegistrySubscriber 
{
     public void update(final ShardingSphereSchemaDataAlteredEvent event) {
         String databaseName = event.getDatabaseName();
         String schemaName = event.getSchemaName();
-        GlobalLockDefinition lockDefinition = new 
GlobalLockDefinition(String.format(GlobalLockNames.SYS_DATA.getLockName(), 
event.getDatabaseName(), event.getSchemaName(), event.getTableName()));
+        GlobalLockDefinition lockDefinition = new 
GlobalLockDefinition(String.format(GlobalLockNames.STATISTICS.getLockName(), 
event.getDatabaseName(), event.getSchemaName(), event.getTableName()));
         if (lockPersistService.tryLock(lockDefinition, 10_000)) {
             try {
                 
persistService.getTableRowDataPersistService().persist(databaseName, 
schemaName, event.getTableName(), event.getAddedRows());