You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by ji...@apache.org on 2022/08/09 02:02:43 UTC
[shardingsphere] branch master updated: Optimize set databaseName. (#19965)
This is an automated email from the ASF dual-hosted git repository.
jianglongtao 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 08ee770476b Optimize set databaseName. (#19965)
08ee770476b is described below
commit 08ee770476b3e7665913ae787df3e1b82025ac63
Author: CHENJIAHAO <37...@users.noreply.github.com>
AuthorDate: Tue Aug 9 10:02:38 2022 +0800
Optimize set databaseName. (#19965)
---
.../database/schema/loader/dialect/MySQLSchemaMetaDataLoader.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/loader/dialect/MySQLSchemaMetaDataLoader.java b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/loader/dialect/MySQLSchemaMetaDataLoader.java
index 2936436cd2d..0a758c856b5 100644
--- a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/loader/dialect/MySQLSchemaMetaDataLoader.java
+++ b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/loader/dialect/MySQLSchemaMetaDataLoader.java
@@ -141,7 +141,6 @@ public final class MySQLSchemaMetaDataLoader implements DialectSchemaMetaDataLoa
try (
Connection connection = dataSource.getConnection();
PreparedStatement preparedStatement = connection.prepareStatement(getIndexMetaDataSQL(tableNames))) {
- preparedStatement.setString(1, connection.getCatalog());
String databaseName = "".equals(connection.getCatalog()) ? GlobalDataSourceRegistry.getInstance().getCachedDatabaseTables().get(tableNames.iterator().next()) : connection.getCatalog();
preparedStatement.setString(1, databaseName);
try (ResultSet resultSet = preparedStatement.executeQuery()) {