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 a79a4266aea Fix typo (#37237)
a79a4266aea is described below
commit a79a4266aeab3f5a42a20a06fe11254326232f33
Author: Liang Zhang <[email protected]>
AuthorDate: Sun Nov 30 23:20:25 2025 +0800
Fix typo (#37237)
* Fix typo
* Fix typo
---
.../config/yaml/loader/YamlPluginConfigurationLoader.java | 2 +-
.../metadata/data/loader/OpenGaussMetaDataLoader.java | 6 +++---
.../metadata/data/loader/PostgreSQLMetaDataLoader.java | 6 +++---
.../buffer/type/FirebirdDatabaseParameterBufferType.java | 4 ++--
.../type/FirebirdTransactionParameterBufferType.java | 2 +-
.../protocol/FirebirdConnectionProtocolVersion.java | 2 +-
.../execute/protocol/util/FirebirdDateTimeUtils.java | 14 +++++++-------
.../collector/DialectDatabaseStatisticsCollector.java | 2 +-
.../infra/rewrite/context/SQLRewriteContext.java | 2 +-
9 files changed, 20 insertions(+), 20 deletions(-)
diff --git
a/agent/core/src/main/java/org/apache/shardingsphere/agent/core/plugin/config/yaml/loader/YamlPluginConfigurationLoader.java
b/agent/core/src/main/java/org/apache/shardingsphere/agent/core/plugin/config/yaml/loader/YamlPluginConfigurationLoader.java
index f547434299a..ee9939d7518 100644
---
a/agent/core/src/main/java/org/apache/shardingsphere/agent/core/plugin/config/yaml/loader/YamlPluginConfigurationLoader.java
+++
b/agent/core/src/main/java/org/apache/shardingsphere/agent/core/plugin/config/yaml/loader/YamlPluginConfigurationLoader.java
@@ -38,7 +38,7 @@ public final class YamlPluginConfigurationLoader {
/**
* Load plugin configurations.
*
- * @param yamlFile yaml file
+ * @param yamlFile YAML file
* @return plugin configurations
* @throws IOException IO exception
*/
diff --git
a/database/connector/dialect/opengauss/src/main/java/org/apache/shardingsphere/database/connector/opengauss/metadata/data/loader/OpenGaussMetaDataLoader.java
b/database/connector/dialect/opengauss/src/main/java/org/apache/shardingsphere/database/connector/opengauss/metadata/data/loader/OpenGaussMetaDataLoader.java
index a6ecfd7a6cb..d14984e31b4 100644
---
a/database/connector/dialect/opengauss/src/main/java/org/apache/shardingsphere/database/connector/opengauss/metadata/data/loader/OpenGaussMetaDataLoader.java
+++
b/database/connector/dialect/opengauss/src/main/java/org/apache/shardingsphere/database/connector/opengauss/metadata/data/loader/OpenGaussMetaDataLoader.java
@@ -103,11 +103,11 @@ public final class OpenGaussMetaDataLoader implements
DialectMetaDataLoader {
String columnName = resultSet.getString("column_name");
String indexName = resultSet.getString("index_name");
boolean isUnique = resultSet.getBoolean("is_unique");
- Collection<IndexMetaData> indexMetaDatas =
result.getOrDefault(schemaName, LinkedHashMultimap.create()).get(tableName);
- if (indexMetaDatas.isEmpty()) {
+ Collection<IndexMetaData> indexMetaDataList =
result.getOrDefault(schemaName, LinkedHashMultimap.create()).get(tableName);
+ if (indexMetaDataList.isEmpty()) {
continue;
}
- Optional<IndexMetaData> indexMetaData =
indexMetaDatas.stream().filter(each ->
each.getName().equals(indexName)).findFirst();
+ Optional<IndexMetaData> indexMetaData =
indexMetaDataList.stream().filter(each ->
each.getName().equals(indexName)).findFirst();
if (indexMetaData.isPresent()) {
indexMetaData.get().setUnique(isUnique);
indexMetaData.get().getColumns().add(columnName);
diff --git
a/database/connector/dialect/postgresql/src/main/java/org/apache/shardingsphere/database/connector/postgresql/metadata/data/loader/PostgreSQLMetaDataLoader.java
b/database/connector/dialect/postgresql/src/main/java/org/apache/shardingsphere/database/connector/postgresql/metadata/data/loader/PostgreSQLMetaDataLoader.java
index f4c062d7b74..69cae09775d 100644
---
a/database/connector/dialect/postgresql/src/main/java/org/apache/shardingsphere/database/connector/postgresql/metadata/data/loader/PostgreSQLMetaDataLoader.java
+++
b/database/connector/dialect/postgresql/src/main/java/org/apache/shardingsphere/database/connector/postgresql/metadata/data/loader/PostgreSQLMetaDataLoader.java
@@ -121,11 +121,11 @@ public final class PostgreSQLMetaDataLoader implements
DialectMetaDataLoader {
String columnName = resultSet.getString("column_name");
String indexName = resultSet.getString("index_name");
boolean isUnique = resultSet.getBoolean("is_unique");
- Collection<IndexMetaData> indexMetaDatas =
result.getOrDefault(schemaName, LinkedHashMultimap.create()).get(tableName);
- if (indexMetaDatas.isEmpty()) {
+ Collection<IndexMetaData> indexMetaDataList =
result.getOrDefault(schemaName, LinkedHashMultimap.create()).get(tableName);
+ if (indexMetaDataList.isEmpty()) {
continue;
}
- Optional<IndexMetaData> indexMetaData =
indexMetaDatas.stream().filter(each ->
each.getName().equals(indexName)).findFirst();
+ Optional<IndexMetaData> indexMetaData =
indexMetaDataList.stream().filter(each ->
each.getName().equals(indexName)).findFirst();
if (indexMetaData.isPresent()) {
indexMetaData.get().setUnique(isUnique);
indexMetaData.get().getColumns().add(columnName);
diff --git
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/buffer/type/FirebirdDatabaseParameterBufferType.java
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/buffer/type/FirebirdDatabaseParameterBufferType.java
index f50372559cc..cace1e3e089 100644
---
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/buffer/type/FirebirdDatabaseParameterBufferType.java
+++
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/buffer/type/FirebirdDatabaseParameterBufferType.java
@@ -175,8 +175,8 @@ public enum FirebirdDatabaseParameterBufferType implements
FirebirdParameterBuff
/**
* Decides whether to use a traditional type for integers.
*
- * @param version verstion of parameter buffer
- * @return Is traditional type
+ * @param version version of parameter buffer
+ * @return is traditional type
*/
public static boolean isTraditionalType(final int version) {
return version == 1;
diff --git
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/buffer/type/FirebirdTransactionParameterBufferType.java
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/buffer/type/FirebirdTransactionParameterBufferType.java
index 7117005189e..a36accd27e9 100644
---
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/buffer/type/FirebirdTransactionParameterBufferType.java
+++
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/buffer/type/FirebirdTransactionParameterBufferType.java
@@ -89,7 +89,7 @@ public enum FirebirdTransactionParameterBufferType implements
FirebirdParameterB
/**
* Decides whether to use a traditional type for integers.
*
- * @param version verstion of parameter buffer
+ * @param version version of parameter buffer
* @return Is traditional type
*/
public static boolean isTraditionalType(final int version) {
diff --git
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/protocol/FirebirdConnectionProtocolVersion.java
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/protocol/FirebirdConnectionProtocolVersion.java
index 048c7f5893f..e1d9985964f 100644
---
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/protocol/FirebirdConnectionProtocolVersion.java
+++
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/constant/protocol/FirebirdConnectionProtocolVersion.java
@@ -53,7 +53,7 @@ public final class FirebirdConnectionProtocolVersion {
}
/**
- * Get current Firebird protocl version for connection.
+ * Get the current Firebird protocol version for connection.
*
* @param connectionId connection ID
* @return Firebird protocol version
diff --git
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/packet/command/query/statement/execute/protocol/util/FirebirdDateTimeUtils.java
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/packet/command/query/statement/execute/protocol/util/FirebirdDateTimeUtils.java
index 1b170e2a4a2..dcaae1f97c4 100644
---
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/packet/command/query/statement/execute/protocol/util/FirebirdDateTimeUtils.java
+++
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/packet/command/query/statement/execute/protocol/util/FirebirdDateTimeUtils.java
@@ -117,17 +117,17 @@ public final class FirebirdDateTimeUtils {
* @return this instance with updated date fields
*/
public FirebirdDateTimeUtils setDate(final int encodedDate) {
- int sqldate = encodedDate - 1721119 + 2400001;
- int century = (4 * sqldate - 1) / 146097;
- sqldate = 4 * sqldate - 1 - 146097 * century;
- day = sqldate / 4;
- sqldate = (4 * day + 3) / 1461;
- day = 4 * day + 3 - 1461 * sqldate;
+ int sqlDate = encodedDate - 1721119 + 2400001;
+ int century = (4 * sqlDate - 1) / 146097;
+ sqlDate = 4 * sqlDate - 1 - 146097 * century;
+ day = sqlDate / 4;
+ sqlDate = (4 * day + 3) / 1461;
+ day = 4 * day + 3 - 1461 * sqlDate;
day = (day + 5) / 5;
month = (5 * day - 3) / 153;
day = 5 * day - 3 - 153 * month;
day = (day + 5) / 5;
- year = 100 * century + sqldate;
+ year = 100 * century + sqlDate;
if (month < 10) {
month += 3;
} else {
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/DialectDatabaseStatisticsCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/DialectDatabaseStatisticsCollector.java
index 055e5867e35..ee8dc0d744f 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/DialectDatabaseStatisticsCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/DialectDatabaseStatisticsCollector.java
@@ -38,7 +38,7 @@ public interface DialectDatabaseStatisticsCollector extends
DatabaseTypedSPI {
* @param schemaName schema name
* @param tableName table name
* @param metaData shardingsphere meta data
- * @return row column datas
+ * @return row column data list
*/
Optional<Collection<Map<String, Object>>> collectRowColumnValues(String
databaseName, String schemaName, String tableName, ShardingSphereMetaData
metaData);
diff --git
a/infra/rewrite/core/src/main/java/org/apache/shardingsphere/infra/rewrite/context/SQLRewriteContext.java
b/infra/rewrite/core/src/main/java/org/apache/shardingsphere/infra/rewrite/context/SQLRewriteContext.java
index f15bcd168f7..bcb8c116235 100644
---
a/infra/rewrite/core/src/main/java/org/apache/shardingsphere/infra/rewrite/context/SQLRewriteContext.java
+++
b/infra/rewrite/core/src/main/java/org/apache/shardingsphere/infra/rewrite/context/SQLRewriteContext.java
@@ -82,7 +82,7 @@ public final class SQLRewriteContext {
List<Object> afterGenericParams = new ArrayList<>();
if (sqlStatementContext instanceof InsertStatementContext) {
groupedParams.addAll(((InsertStatementContext)
sqlStatementContext).getGroupedParameters());
- // TODO check insertstatment whether has beforeGenericParams
+ // TODO check insert statement whether has beforeGenericParams
afterGenericParams.addAll(((InsertStatementContext)
sqlStatementContext).getOnDuplicateKeyUpdateParameters());
}
return new GroupedParameterBuilder(groupedParams, beforeGenericParams,
afterGenericParams);
