This is an automated email from the ASF dual-hosted git repository.

zhangliang 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 f43d8773560 Refactor ShardingSphereSchema (#37897)
f43d8773560 is described below

commit f43d8773560a79ebb799e8eb8315f4717d9dac83
Author: Liang Zhang <[email protected]>
AuthorDate: Fri Jan 30 15:01:12 2026 +0800

    Refactor ShardingSphereSchema (#37897)
---
 .../database/schema/model/ShardingSphereSchema.java   | 19 +++++--------------
 1 file changed, 5 insertions(+), 14 deletions(-)

diff --git 
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/model/ShardingSphereSchema.java
 
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/model/ShardingSphereSchema.java
index fbca13e7260..20d2b55b680 100644
--- 
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/model/ShardingSphereSchema.java
+++ 
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/model/ShardingSphereSchema.java
@@ -18,6 +18,7 @@
 package org.apache.shardingsphere.infra.metadata.database.schema.model;
 
 import lombok.Getter;
+import lombok.RequiredArgsConstructor;
 import org.apache.shardingsphere.database.connector.core.type.DatabaseType;
 import 
org.apache.shardingsphere.infra.metadata.identifier.ShardingSphereIdentifier;
 
@@ -30,6 +31,7 @@ import java.util.concurrent.ConcurrentHashMap;
 /**
  * ShardingSphere schema.
  */
+@RequiredArgsConstructor
 public final class ShardingSphereSchema {
     
     @Getter
@@ -38,23 +40,12 @@ public final class ShardingSphereSchema {
     @Getter
     private final DatabaseType protocolType;
     
-    private final Map<ShardingSphereIdentifier, ShardingSphereTable> tables;
+    private final Map<ShardingSphereIdentifier, ShardingSphereTable> tables = 
new ConcurrentHashMap<>();
     
-    private final Map<ShardingSphereIdentifier, ShardingSphereView> views;
-    
-    @SuppressWarnings("CollectionWithoutInitialCapacity")
-    public ShardingSphereSchema(final String name, final DatabaseType 
protocolType) {
-        this.name = name;
-        this.protocolType = protocolType;
-        tables = new ConcurrentHashMap<>();
-        views = new ConcurrentHashMap<>();
-    }
+    private final Map<ShardingSphereIdentifier, ShardingSphereView> views = 
new ConcurrentHashMap<>();
     
     public ShardingSphereSchema(final String name, final DatabaseType 
protocolType, final Collection<ShardingSphereTable> tables, final 
Collection<ShardingSphereView> views) {
-        this.name = name;
-        this.protocolType = protocolType;
-        this.tables = new ConcurrentHashMap<>(tables.size(), 1F);
-        this.views = new ConcurrentHashMap<>(views.size(), 1F);
+        this(name, protocolType);
         tables.forEach(each -> this.tables.put(new 
ShardingSphereIdentifier(each.getName()), each));
         views.forEach(each -> this.views.put(new 
ShardingSphereIdentifier(each.getName()), each));
     }

Reply via email to