(shardingsphere) branch master updated: Fix typo of segment (#34460)

[zhangliang]

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 7cac9cc3d86 Fix typo of segment (#34460)
7cac9cc3d86 is described below

commit 7cac9cc3d86ee0960b7794bbfa34670700ca4c8d
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Fri Jan 24 11:54:15 2025 +0800

    Fix typo of segment (#34460)
---
 .../infra/binder/context/segment/table/TablesContext.java           | 2 +-
 .../shardingsphere/infra/binder/context/type/WithAvailable.java     | 4 ++--
 .../refresher/metadata/pushdown/PushDownMetaDataRefreshEngine.java  | 6 +++---
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/segment/table/TablesContext.java
 
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/segment/table/TablesContext.java
index d7804d9e06a..f3324621100 100644
--- 
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/segment/table/TablesContext.java
+++ 
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/segment/table/TablesContext.java
@@ -77,7 +77,7 @@ public final class TablesContext {
                 if 
(!"DUAL".equalsIgnoreCase(tableName.getIdentifier().getValue())) {
                     simpleTables.add(simpleTableSegment);
                     tableNames.add(tableName.getIdentifier().getValue());
-                    // TODO support bind with all statement contains table 
segement @duanzhengqiang
+                    // TODO support bind with all statement contains table 
segment @duanzhengqiang
                     tableName.getTableBoundInfo().ifPresent(optional -> 
schemaNames.add(optional.getOriginalSchema().getValue()));
                     tableName.getTableBoundInfo().ifPresent(optional -> 
databaseNames.add(optional.getOriginalDatabase().getValue()));
                 }
diff --git 
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/type/WithAvailable.java
 
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/type/WithAvailable.java
index 310c7b1380a..1568270158b 100644
--- 
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/type/WithAvailable.java
+++ 
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/type/WithAvailable.java
@@ -27,9 +27,9 @@ import java.util.Optional;
 public interface WithAvailable {
     
     /**
-     * Get with segement.
+     * Get with segment.
      *
-     * @return with segement
+     * @return with segment
      */
     Optional<WithSegment> getWith();
 }
diff --git 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefreshEngine.java
 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefreshEngine.java
index 1ade5a772c8..f1c0a5d161c 100644
--- 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefreshEngine.java
+++ 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefreshEngine.java
@@ -68,14 +68,14 @@ public final class PushDownMetaDataRefreshEngine {
     @SuppressWarnings({"unchecked", "rawtypes"})
     public void refresh(final SQLStatementContext sqlStatementContext, final 
Collection<RouteUnit> routeUnits) throws SQLException {
         Class<?> sqlStatementClass = 
sqlStatementContext.getSqlStatement().getClass().getSuperclass();
-        Optional<PushDownMetaDataRefresher> metaDataRefresher = 
TypedSPILoader.findService(PushDownMetaDataRefresher.class, sqlStatementClass);
-        if (!metaDataRefresher.isPresent()) {
+        Optional<PushDownMetaDataRefresher> refresher = 
TypedSPILoader.findService(PushDownMetaDataRefresher.class, sqlStatementClass);
+        if (!refresher.isPresent()) {
             return;
         }
         Collection<String> logicDataSourceNames = routeUnits.stream().map(each 
-> each.getDataSourceMapper().getLogicName()).collect(Collectors.toList());
         String schemaName = sqlStatementContext instanceof TableAvailable ? 
SchemaRefreshUtils.getSchemaName(database, sqlStatementContext) : null;
         DatabaseType databaseType = routeUnits.stream().map(each -> 
database.getResourceMetaData().getStorageUnits().get(each.getDataSourceMapper().getActualName()))
                 
.filter(Objects::nonNull).findFirst().map(StorageUnit::getStorageType).orElseGet(sqlStatementContext::getDatabaseType);
-        metaDataRefresher.get().refresh(metaDataManagerPersistService, 
database, logicDataSourceNames, schemaName, databaseType, 
sqlStatementContext.getSqlStatement(), props);
+        refresher.get().refresh(metaDataManagerPersistService, database, 
logicDataSourceNames, schemaName, databaseType, 
sqlStatementContext.getSqlStatement(), props);
     }
 }