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 b86e34ea329 Optimize TableRefreshUtils. (#32610) b86e34ea329 is described below commit b86e34ea32907ad807ae641b7053b4060354b75a Author: Cong Hu <iamhuc...@gmail.com> AuthorDate: Wed Aug 21 14:56:46 2024 +0800 Optimize TableRefreshUtils. (#32610) --- .../mode/metadata/refresher/util/TableRefreshUtils.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/util/TableRefreshUtils.java b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/util/TableRefreshUtils.java index 4cff9115c19..bd197afa24f 100644 --- a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/util/TableRefreshUtils.java +++ b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/util/TableRefreshUtils.java @@ -23,7 +23,7 @@ import lombok.NoArgsConstructor; import org.apache.shardingsphere.infra.config.rule.RuleConfiguration; import org.apache.shardingsphere.infra.database.core.metadata.database.enums.QuoteCharacter; import org.apache.shardingsphere.infra.database.core.type.DatabaseType; -import org.apache.shardingsphere.infra.database.oracle.type.OracleDatabaseType; +import org.apache.shardingsphere.infra.database.core.type.DatabaseTypeRegistry; import org.apache.shardingsphere.infra.datanode.DataNode; import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase; import org.apache.shardingsphere.infra.metadata.database.rule.RuleMetaData; @@ -53,7 +53,8 @@ public final class TableRefreshUtils { * @return table name */ public static String getTableName(final DatabaseType databaseType, final IdentifierValue identifierValue) { - return databaseType instanceof OracleDatabaseType && QuoteCharacter.NONE == identifierValue.getQuoteCharacter() ? identifierValue.getValue().toUpperCase() : identifierValue.getValue(); + return QuoteCharacter.NONE == identifierValue.getQuoteCharacter() ? new DatabaseTypeRegistry(databaseType).getDialectDatabaseMetaData().formatTableNamePattern(identifierValue.getValue()) + : identifierValue.getValue(); } /**