This is an automated email from the ASF dual-hosted git repository.
panjuan 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 37651f3 Remove ShardingSphereSchema.cachedDatabaseMetaData (#8040)
37651f3 is described below
commit 37651f3aca8e05042be192ce7a08bbaa31fee6d8
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Nov 5 21:44:47 2020 +0800
Remove ShardingSphereSchema.cachedDatabaseMetaData (#8040)
---
.../parameterized/EncryptSQLRewriterParameterizedTest.java | 13 ++++++-------
.../parameterized/MixSQLRewriterParameterizedTest.java | 3 +--
.../parameterized/ShardingSQLRewriterParameterizedTest.java | 3 +--
.../route/engine/type/standard/AbstractSQLRouteTest.java | 3 +--
.../governance/context/schema/GovernanceSchemaContexts.java | 3 +--
.../infra/schema/model/ShardingSphereSchema.java | 3 ---
.../schema/refresh/AbstractMetaDataRefreshStrategyTest.java | 3 +--
.../infra/context/schema/SchemaContextsBuilder.java | 3 +--
.../executor/sql/context/ExecutionContextBuilderTest.java | 7 +++----
.../datasource/metadata/ShardingSphereDatabaseMetaData.java | 2 +-
.../metadata/ShardingSphereDatabaseMetaDataTest.java | 2 +-
.../text/sctl/hint/ShardingCTLHintBackendHandlerTest.java | 5 ++---
12 files changed, 19 insertions(+), 31 deletions(-)
diff --git
a/shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-rewrite/src/test/java/org/apache/shardingsphere/encrypt/rewrite/parameterized/EncryptSQLRewriterParameterizedTest.java
b/shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-rewrite/src/test/java/org/apache/shardingsphere/encrypt/rewrite/parameterized/EncryptSQLRewriterParameterizedTest.java
index 50a322d..4327ba8 100644
---
a/shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-rewrite/src/test/java/org/apache/shardingsphere/encrypt/rewrite/parameterized/EncryptSQLRewriterParameterizedTest.java
+++
b/shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-rewrite/src/test/java/org/apache/shardingsphere/encrypt/rewrite/parameterized/EncryptSQLRewriterParameterizedTest.java
@@ -22,12 +22,8 @@ import org.apache.shardingsphere.infra.binder.LogicSQL;
import org.apache.shardingsphere.infra.binder.SQLStatementContextFactory;
import org.apache.shardingsphere.infra.binder.statement.SQLStatementContext;
import
org.apache.shardingsphere.infra.config.properties.ConfigurationProperties;
+import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.resource.ShardingSphereResource;
-import org.apache.shardingsphere.infra.schema.model.ShardingSphereSchema;
-import
org.apache.shardingsphere.infra.schema.model.addressing.TableAddressingMetaData;
-import
org.apache.shardingsphere.infra.schema.model.datasource.CachedDatabaseMetaData;
-import
org.apache.shardingsphere.infra.schema.model.datasource.DataSourcesMetaData;
-import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.schema.PhysicalSchemaMetaData;
import org.apache.shardingsphere.infra.parser.sql.SQLStatementParserEngine;
import org.apache.shardingsphere.infra.rewrite.SQLRewriteEntry;
import
org.apache.shardingsphere.infra.rewrite.engine.result.GenericSQLRewriteResult;
@@ -41,7 +37,10 @@ import
org.apache.shardingsphere.infra.route.context.RouteContext;
import org.apache.shardingsphere.infra.route.engine.SQLRouteEngine;
import org.apache.shardingsphere.infra.rule.ShardingSphereRule;
import org.apache.shardingsphere.infra.rule.ShardingSphereRulesBuilder;
-import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
+import org.apache.shardingsphere.infra.schema.model.ShardingSphereSchema;
+import
org.apache.shardingsphere.infra.schema.model.addressing.TableAddressingMetaData;
+import
org.apache.shardingsphere.infra.schema.model.datasource.DataSourcesMetaData;
+import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.schema.PhysicalSchemaMetaData;
import org.apache.shardingsphere.infra.yaml.config.YamlRootRuleConfigurations;
import org.apache.shardingsphere.infra.yaml.engine.YamlEngine;
import
org.apache.shardingsphere.infra.yaml.swapper.YamlRuleConfigurationSwapperEngine;
@@ -99,6 +98,6 @@ public final class EncryptSQLRewriterParameterizedTest
extends AbstractSQLRewrit
PhysicalSchemaMetaData schemaMetaData =
mock(PhysicalSchemaMetaData.class);
when(schemaMetaData.getAllColumnNames("t_account")).thenReturn(Arrays.asList("account_id",
"certificate_number", "password", "amount", "status"));
when(schemaMetaData.getAllColumnNames("t_account_bak")).thenReturn(Arrays.asList("account_id",
"certificate_number", "password", "amount", "status"));
- return new ShardingSphereSchema(mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class), schemaMetaData,
mock(CachedDatabaseMetaData.class));
+ return new ShardingSphereSchema(mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class), schemaMetaData);
}
}
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/java/org/apache/shardingsphere/sharding/rewrite/parameterized/MixSQLRewriterParameterizedTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/java/org/apache/shardingsphere/sharding/rewrite/parameterized/MixSQLRewriterParameterizedTest.java
index 9f453b2..44b25a1 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/java/org/apache/shardingsphere/sharding/rewrite/parameterized/MixSQLRewriterParameterizedTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/java/org/apache/shardingsphere/sharding/rewrite/parameterized/MixSQLRewriterParameterizedTest.java
@@ -39,7 +39,6 @@ import
org.apache.shardingsphere.infra.rule.ShardingSphereRule;
import org.apache.shardingsphere.infra.rule.ShardingSphereRulesBuilder;
import org.apache.shardingsphere.infra.schema.model.ShardingSphereSchema;
import
org.apache.shardingsphere.infra.schema.model.addressing.TableAddressingMetaData;
-import
org.apache.shardingsphere.infra.schema.model.datasource.CachedDatabaseMetaData;
import
org.apache.shardingsphere.infra.schema.model.datasource.DataSourcesMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.column.PhysicalColumnMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.index.PhysicalIndexMetaData;
@@ -119,7 +118,7 @@ public final class MixSQLRewriterParameterizedTest extends
AbstractSQLRewriterPa
when(schemaMetaData.get("t_account_detail")).thenReturn(mock(PhysicalTableMetaData.class));
when(schemaMetaData.getAllColumnNames("t_account")).thenReturn(Arrays.asList("account_id",
"password", "amount", "status"));
when(schemaMetaData.getAllColumnNames("t_account_bak")).thenReturn(Arrays.asList("account_id",
"password", "amount", "status"));
- return new ShardingSphereSchema(mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class), schemaMetaData,
mock(CachedDatabaseMetaData.class));
+ return new ShardingSphereSchema(mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class), schemaMetaData);
}
private Map<String, PhysicalColumnMetaData> createColumnMetaDataMap() {
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/java/org/apache/shardingsphere/sharding/rewrite/parameterized/ShardingSQLRewriterParameterizedTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/java/org/apache/shardingsphere/sharding/rewrite/parameterized/ShardingSQLRewriterParameterizedTest.java
index 64a5b1a..e5922bc 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/java/org/apache/shardingsphere/sharding/rewrite/parameterized/ShardingSQLRewriterParameterizedTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/java/org/apache/shardingsphere/sharding/rewrite/parameterized/ShardingSQLRewriterParameterizedTest.java
@@ -39,7 +39,6 @@ import
org.apache.shardingsphere.infra.rule.ShardingSphereRule;
import org.apache.shardingsphere.infra.rule.ShardingSphereRulesBuilder;
import org.apache.shardingsphere.infra.schema.model.ShardingSphereSchema;
import
org.apache.shardingsphere.infra.schema.model.addressing.TableAddressingMetaData;
-import
org.apache.shardingsphere.infra.schema.model.datasource.CachedDatabaseMetaData;
import
org.apache.shardingsphere.infra.schema.model.datasource.DataSourcesMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.column.PhysicalColumnMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.index.PhysicalIndexMetaData;
@@ -114,7 +113,7 @@ public final class ShardingSQLRewriterParameterizedTest
extends AbstractSQLRewri
when(schemaMetaData.get("t_account")).thenReturn(accountTableMetaData);
when(schemaMetaData.get("t_account_detail")).thenReturn(mock(PhysicalTableMetaData.class));
when(schemaMetaData.getAllColumnNames("t_account")).thenReturn(Arrays.asList("account_id",
"amount", "status"));
- return new ShardingSphereSchema(mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class), schemaMetaData,
mock(CachedDatabaseMetaData.class));
+ return new ShardingSphereSchema(mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class), schemaMetaData);
}
private Map<String, PhysicalColumnMetaData> createColumnMetaDataMap() {
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-route/src/test/java/org/apache/shardingsphere/sharding/route/engine/type/standard/AbstractSQLRouteTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-route/src/test/java/org/apache/shardingsphere/sharding/route/engine/type/standard/AbstractSQLRouteTest.java
index 7dd2628..4da7e19 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-route/src/test/java/org/apache/shardingsphere/sharding/route/engine/type/standard/AbstractSQLRouteTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-route/src/test/java/org/apache/shardingsphere/sharding/route/engine/type/standard/AbstractSQLRouteTest.java
@@ -30,7 +30,6 @@ import
org.apache.shardingsphere.infra.route.context.RouteContext;
import org.apache.shardingsphere.infra.route.engine.SQLRouteEngine;
import org.apache.shardingsphere.infra.schema.model.ShardingSphereSchema;
import
org.apache.shardingsphere.infra.schema.model.addressing.TableAddressingMetaData;
-import
org.apache.shardingsphere.infra.schema.model.datasource.CachedDatabaseMetaData;
import
org.apache.shardingsphere.infra.schema.model.datasource.DataSourcesMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.column.PhysicalColumnMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.schema.PhysicalSchemaMetaData;
@@ -57,7 +56,7 @@ public abstract class AbstractSQLRouteTest extends
AbstractRoutingEngineTest {
ShardingRule shardingRule = createAllShardingRule();
TableAddressingMetaData tableAddressingMetaData = new
TableAddressingMetaData();
tableAddressingMetaData.getTableDataSourceNamesMapper().put("t_category",
Collections.singletonList("single_db"));
- ShardingSphereSchema schema = new
ShardingSphereSchema(buildDataSourceMetas(), tableAddressingMetaData,
buildPhysicalSchemaMetaData(), mock(CachedDatabaseMetaData.class));
+ ShardingSphereSchema schema = new
ShardingSphereSchema(buildDataSourceMetas(), tableAddressingMetaData,
buildPhysicalSchemaMetaData());
ConfigurationProperties props = new ConfigurationProperties(new
Properties());
SQLStatementParserEngine sqlStatementParserEngine = new
SQLStatementParserEngine("MySQL");
SQLStatementContext<?> sqlStatementContext =
SQLStatementContextFactory.newInstance(schema.getSchemaMetaData(), parameters,
sqlStatementParserEngine.parse(sql, false));
diff --git
a/shardingsphere-governance/shardingsphere-governance-core/shardingsphere-governance-core-context/src/main/java/org/apache/shardingsphere/governance/context/schema/GovernanceSchemaContexts.java
b/shardingsphere-governance/shardingsphere-governance-core/shardingsphere-governance-core-context/src/main/java/org/apache/shardingsphere/governance/context/schema/GovernanceSchemaContexts.java
index 041cfdd..ecc5320 100644
---
a/shardingsphere-governance/shardingsphere-governance-core/shardingsphere-governance-core-context/src/main/java/org/apache/shardingsphere/governance/context/schema/GovernanceSchemaContexts.java
+++
b/shardingsphere-governance/shardingsphere-governance-core/shardingsphere-governance-core-context/src/main/java/org/apache/shardingsphere/governance/context/schema/GovernanceSchemaContexts.java
@@ -300,8 +300,7 @@ public final class GovernanceSchemaContexts implements
SchemaContexts {
private ShardingSphereMetaData getChangedMetaData(final
ShardingSphereMetaData oldMetaData, final PhysicalSchemaMetaData
newSchemaMetaData, final String schemaName) {
// TODO refresh tableAddressingMetaData
- ShardingSphereSchema schema = new ShardingSphereSchema(
- oldMetaData.getSchema().getDataSourcesMetaData(),
oldMetaData.getSchema().getTableAddressingMetaData(), newSchemaMetaData,
oldMetaData.getSchema().getCachedDatabaseMetaData());
+ ShardingSphereSchema schema = new
ShardingSphereSchema(oldMetaData.getSchema().getDataSourcesMetaData(),
oldMetaData.getSchema().getTableAddressingMetaData(), newSchemaMetaData);
return new ShardingSphereMetaData(schemaName,
oldMetaData.getConfigurations(), oldMetaData.getRules(),
oldMetaData.getResource(), schema);
}
diff --git
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/schema/model/ShardingSphereSchema.java
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/schema/model/ShardingSphereSchema.java
index 9b82e3c..a46ad38 100644
---
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/schema/model/ShardingSphereSchema.java
+++
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/schema/model/ShardingSphereSchema.java
@@ -20,7 +20,6 @@ package org.apache.shardingsphere.infra.schema.model;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.infra.schema.model.addressing.TableAddressingMetaData;
-import
org.apache.shardingsphere.infra.schema.model.datasource.CachedDatabaseMetaData;
import
org.apache.shardingsphere.infra.schema.model.datasource.DataSourcesMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.schema.PhysicalSchemaMetaData;
@@ -36,6 +35,4 @@ public final class ShardingSphereSchema {
private final TableAddressingMetaData tableAddressingMetaData;
private final PhysicalSchemaMetaData schemaMetaData;
-
- private final CachedDatabaseMetaData cachedDatabaseMetaData;
}
diff --git
a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/schema/refresh/AbstractMetaDataRefreshStrategyTest.java
b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/schema/refresh/AbstractMetaDataRefreshStrategyTest.java
index 5bfb831..cdd61cc 100644
---
a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/schema/refresh/AbstractMetaDataRefreshStrategyTest.java
+++
b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/schema/refresh/AbstractMetaDataRefreshStrategyTest.java
@@ -21,7 +21,6 @@ import com.google.common.collect.ImmutableMap;
import lombok.Getter;
import org.apache.shardingsphere.infra.schema.model.ShardingSphereSchema;
import
org.apache.shardingsphere.infra.schema.model.addressing.TableAddressingMetaData;
-import
org.apache.shardingsphere.infra.schema.model.datasource.CachedDatabaseMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.column.PhysicalColumnMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.index.PhysicalIndexMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.schema.PhysicalSchemaMetaData;
@@ -45,7 +44,7 @@ public abstract class AbstractMetaDataRefreshStrategyTest {
private ShardingSphereSchema buildSchema() {
PhysicalSchemaMetaData schemaMetaData = new
PhysicalSchemaMetaData(ImmutableMap.of("t_order", new PhysicalTableMetaData(
Collections.singletonList(new
PhysicalColumnMetaData("order_id", 1, "String", false, false, false)),
Collections.singletonList(new PhysicalIndexMetaData("index")))));
- return new ShardingSphereSchema(null,
mock(TableAddressingMetaData.class), schemaMetaData,
mock(CachedDatabaseMetaData.class));
+ return new ShardingSphereSchema(null,
mock(TableAddressingMetaData.class), schemaMetaData);
}
}
diff --git
a/shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/schema/SchemaContextsBuilder.java
b/shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/schema/SchemaContextsBuilder.java
index aa41eb5..928d477 100644
---
a/shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/schema/SchemaContextsBuilder.java
+++
b/shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/schema/SchemaContextsBuilder.java
@@ -135,8 +135,7 @@ public final class SchemaContextsBuilder {
DataSourcesMetaData dataSourceMetas = new
DataSourcesMetaData(databaseType,
getDatabaseAccessConfigurationMap(dataSourceMap));
TableAddressingMetaData tableAddressingMetaData =
TableAddressingMetaDataLoader.load(databaseType, dataSourceMap, rules);
PhysicalSchemaMetaData physicalSchemaMetaData = new
SchemaMetaDataLoader(rules).load(databaseType, dataSourceMap, props);
- CachedDatabaseMetaData cachedDatabaseMetaData =
createCachedDatabaseMetaData(dataSourceMap).orElse(null);
- ShardingSphereSchema result = new
ShardingSphereSchema(dataSourceMetas, tableAddressingMetaData,
physicalSchemaMetaData, cachedDatabaseMetaData);
+ ShardingSphereSchema result = new
ShardingSphereSchema(dataSourceMetas, tableAddressingMetaData,
physicalSchemaMetaData);
log.info("Load meta data for schema {} finished, cost {}
milliseconds.", schemaName, System.currentTimeMillis() - start);
return result;
}
diff --git
a/shardingsphere-infra/shardingsphere-infra-executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/context/ExecutionContextBuilderTest.java
b/shardingsphere-infra/shardingsphere-infra-executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/context/ExecutionContextBuilderTest.java
index 27ab273..59b5671 100644
---
a/shardingsphere-infra/shardingsphere-infra-executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/context/ExecutionContextBuilderTest.java
+++
b/shardingsphere-infra/shardingsphere-infra-executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/context/ExecutionContextBuilderTest.java
@@ -59,7 +59,7 @@ public final class ExecutionContextBuilderTest {
String firstDataSourceName = "firstDataSourceName";
when(dataSourcesMetaData.getAllInstanceDataSourceNames()).thenReturn(Arrays.asList(firstDataSourceName,
"lastDataSourceName"));
ShardingSphereResource resource = new
ShardingSphereResource(Collections.emptyMap(), dataSourcesMetaData,
mock(CachedDatabaseMetaData.class));
- ShardingSphereSchema schema = new
ShardingSphereSchema(dataSourcesMetaData, mock(TableAddressingMetaData.class),
buildPhysicalSchemaMetaData(), mock(CachedDatabaseMetaData.class));
+ ShardingSphereSchema schema = new
ShardingSphereSchema(dataSourcesMetaData, mock(TableAddressingMetaData.class),
buildPhysicalSchemaMetaData());
ShardingSphereMetaData metaData = new ShardingSphereMetaData("name",
Collections.emptyList(), Collections.emptyList(), resource, schema);
Collection<ExecutionUnit> actual =
ExecutionContextBuilder.build(metaData, genericSQLRewriteResult,
mock(SQLStatementContext.class));
Collection<ExecutionUnit> expected = Collections.singletonList(new
ExecutionUnit(firstDataSourceName, new SQLUnit(sql, parameters)));
@@ -77,7 +77,7 @@ public final class ExecutionContextBuilderTest {
sqlRewriteUnits.put(routeUnit2, sqlRewriteUnit2);
ShardingSphereResource resource = new
ShardingSphereResource(Collections.emptyMap(), mock(DataSourcesMetaData.class),
mock(CachedDatabaseMetaData.class));
ShardingSphereSchema schema = new ShardingSphereSchema(
- mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class), buildPhysicalSchemaMetaData(),
mock(CachedDatabaseMetaData.class));
+ mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class), buildPhysicalSchemaMetaData());
ShardingSphereMetaData metaData = new ShardingSphereMetaData("name",
Collections.emptyList(), Collections.emptyList(), resource, schema);
Collection<ExecutionUnit> actual =
ExecutionContextBuilder.build(metaData, new
RouteSQLRewriteResult(sqlRewriteUnits), mock(SQLStatementContext.class));
ExecutionUnit expectedUnit1 = new ExecutionUnit("actualName1", new
SQLUnit("sql1", Collections.singletonList("parameter1")));
@@ -96,8 +96,7 @@ public final class ExecutionContextBuilderTest {
Map<RouteUnit, SQLRewriteUnit> sqlRewriteUnits = new HashMap<>(2, 1);
sqlRewriteUnits.put(routeUnit2, sqlRewriteUnit2);
ShardingSphereResource resource = new
ShardingSphereResource(Collections.emptyMap(), mock(DataSourcesMetaData.class),
mock(CachedDatabaseMetaData.class));
- ShardingSphereSchema schema = new ShardingSphereSchema(
- mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class),
buildPhysicalSchemaMetaDataWithoutPrimaryKey(),
mock(CachedDatabaseMetaData.class));
+ ShardingSphereSchema schema = new
ShardingSphereSchema(mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class),
buildPhysicalSchemaMetaDataWithoutPrimaryKey());
ShardingSphereMetaData metaData = new ShardingSphereMetaData("name",
Collections.emptyList(), Collections.emptyList(), resource, schema);
Collection<ExecutionUnit> actual =
ExecutionContextBuilder.build(metaData, new
RouteSQLRewriteResult(sqlRewriteUnits), mock(SQLStatementContext.class));
ExecutionUnit expectedUnit2 = new ExecutionUnit("actualName2", new
SQLUnit("sql2", Collections.singletonList("parameter2")));
diff --git
a/shardingsphere-jdbc/shardingsphere-jdbc-core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaData.java
b/shardingsphere-jdbc/shardingsphere-jdbc-core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaData.java
index 84362b8..38eb83f 100644
---
a/shardingsphere-jdbc/shardingsphere-jdbc-core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaData.java
+++
b/shardingsphere-jdbc/shardingsphere-jdbc-core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaData.java
@@ -57,7 +57,7 @@ public final class ShardingSphereDatabaseMetaData extends
AdaptedDatabaseMetaDat
private DatabaseMetaData currentDatabaseMetaData;
public ShardingSphereDatabaseMetaData(final AbstractConnectionAdapter
connection) {
-
super(connection.getSchemaContexts().getDefaultMetaData().getSchema().getCachedDatabaseMetaData());
+
super(connection.getSchemaContexts().getDefaultMetaData().getResource().getCachedDatabaseMetaData());
this.connection = connection;
rules = connection.getSchemaContexts().getDefaultMetaData().getRules();
datasourceNames = connection.getDataSourceMap().keySet();
diff --git
a/shardingsphere-jdbc/shardingsphere-jdbc-core/src/test/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaDataTest.java
b/shardingsphere-jdbc/shardingsphere-jdbc-core/src/test/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaDataTest.java
index 8b28dc3..665b5c9 100644
---
a/shardingsphere-jdbc/shardingsphere-jdbc-core/src/test/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaDataTest.java
+++
b/shardingsphere-jdbc/shardingsphere-jdbc-core/src/test/java/org/apache/shardingsphere/driver/jdbc/core/datasource/metadata/ShardingSphereDatabaseMetaDataTest.java
@@ -94,7 +94,7 @@ public final class ShardingSphereDatabaseMetaDataTest {
when(shardingSphereConnection.getSchemaContexts()).thenReturn(schemaContexts);
ShardingSphereMetaData metaData = mock(ShardingSphereMetaData.class,
RETURNS_DEEP_STUBS);
when(schemaContexts.getDefaultMetaData()).thenReturn(metaData);
-
when(metaData.getSchema().getCachedDatabaseMetaData()).thenReturn(cachedDatabaseMetaData);
+
when(metaData.getResource().getCachedDatabaseMetaData()).thenReturn(cachedDatabaseMetaData);
when(metaData.getRules()).thenReturn(Collections.singletonList(mockShardingRule()));
shardingSphereDatabaseMetaData = new
ShardingSphereDatabaseMetaData(shardingSphereConnection);
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/sctl/hint/ShardingCTLHintBackendHandlerTest.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/sctl/hint/ShardingCTLHintBackendHandlerTest.java
index 10798a7..dca9770 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/sctl/hint/ShardingCTLHintBackendHandlerTest.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/sctl/hint/ShardingCTLHintBackendHandlerTest.java
@@ -26,13 +26,12 @@ import
org.apache.shardingsphere.infra.context.schema.impl.StandardSchemaContext
import org.apache.shardingsphere.infra.database.type.dialect.MySQLDatabaseType;
import org.apache.shardingsphere.infra.executor.kernel.ExecutorKernel;
import org.apache.shardingsphere.infra.hint.HintManager;
+import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import org.apache.shardingsphere.infra.schema.model.ShardingSphereSchema;
import
org.apache.shardingsphere.infra.schema.model.addressing.TableAddressingMetaData;
-import
org.apache.shardingsphere.infra.schema.model.datasource.CachedDatabaseMetaData;
import
org.apache.shardingsphere.infra.schema.model.datasource.DataSourcesMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.schema.PhysicalSchemaMetaData;
import
org.apache.shardingsphere.infra.schema.model.schema.physical.model.table.PhysicalTableMetaData;
-import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.proxy.backend.communication.jdbc.connection.BackendConnection;
import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
import org.apache.shardingsphere.proxy.backend.response.BackendResponse;
@@ -207,7 +206,7 @@ public final class ShardingCTLHintBackendHandlerTest {
private Map<String, ShardingSphereMetaData> getMetaDataMap() {
ShardingSphereMetaData metaData = mock(ShardingSphereMetaData.class);
when(metaData.getSchema()).thenReturn(new
ShardingSphereSchema(mock(DataSourcesMetaData.class),
mock(TableAddressingMetaData.class),
- new PhysicalSchemaMetaData(ImmutableMap.of("user",
mock(PhysicalTableMetaData.class))), mock(CachedDatabaseMetaData.class)));
+ new PhysicalSchemaMetaData(ImmutableMap.of("user",
mock(PhysicalTableMetaData.class)))));
when(metaData.isComplete()).thenReturn(true);
return Collections.singletonMap("schema", metaData);
}
