You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by pa...@apache.org on 2021/01/28 06:22:40 UTC
[shardingsphere] branch master updated: Revise code format for
#9192 (#9197)
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 36e5f86 Revise code format for #9192 (#9197)
36e5f86 is described below
commit 36e5f861c8fbeb51895472bb4e34b857c4b28974
Author: Liang Zhang <te...@163.com>
AuthorDate: Thu Jan 28 14:22:10 2021 +0800
Revise code format for #9192 (#9197)
---
.../metadata/schema/builder/SchemaBuilderTest.java | 37 +++++++++++-----------
...tainedFixtureRuleBasedTableMetaDataBuilder.java | 8 ++---
.../fixture/rule/DataNodeContainedFixtureRule.java | 20 ++++++------
3 files changed, 33 insertions(+), 32 deletions(-)
diff --git a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/SchemaBuilderTest.java b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/SchemaBuilderTest.java
index 08253f4..48863d8 100644
--- a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/SchemaBuilderTest.java
+++ b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/SchemaBuilderTest.java
@@ -46,49 +46,50 @@ import static org.mockito.Mockito.when;
@RunWith(MockitoJUnitRunner.class)
public final class SchemaBuilderTest {
+
private static final String TEST_CATALOG = "catalog";
-
+
private static final String TEST_SCHEMA = "schema";
-
+
private static final String TABLE_TYPE = "TABLE";
-
+
private static final String VIEW_TYPE = "VIEW";
-
+
private static final String TABLE_NAME = "TABLE_NAME";
-
- private final String[] unConfiguredTableNames = new String[]{"unconfigured_table1", "unconfigured_table2"};
-
+
+ private final String[] unConfiguredTableNames = {"unconfigured_table1", "unconfigured_table2"};
+
private SchemaBuilderMaterials schemaBuilderMaterials;
-
+
@Mock
private DatabaseType databaseType;
-
+
@Mock(answer = Answers.RETURNS_DEEP_STUBS)
private DataSource dataSource;
-
+
@Mock
private ConfigurationProperties props;
-
+
@Before
public void setUp() {
- schemaBuilderMaterials = new SchemaBuilderMaterials(databaseType, Collections.singletonMap("logic_db", dataSource), Arrays.asList(new CommonFixtureRule(), new DataNodeContainedFixtureRule()),
- props);
+ schemaBuilderMaterials = new SchemaBuilderMaterials(
+ databaseType, Collections.singletonMap("logic_db", dataSource), Arrays.asList(new CommonFixtureRule(), new DataNodeContainedFixtureRule()), props);
}
-
+
@Test
public void assertBuildOfAllShardingTables() throws SQLException {
ShardingSphereSchema actual = SchemaBuilder.build(schemaBuilderMaterials);
assertThat(actual.getAllTableNames().size(), is(2));
assertSchemaOfShardingTables(actual);
}
-
+
private void assertSchemaOfShardingTables(final ShardingSphereSchema actual) {
assertTrue(actual.containsTable("data_node_routed_table1"));
assertTrue(actual.get("data_node_routed_table1").getColumns().containsKey("id"));
assertTrue(actual.containsTable("data_node_routed_table2"));
assertTrue(actual.get("data_node_routed_table2").getColumns().containsKey("id"));
}
-
+
@Test
@SneakyThrows(SQLException.class)
public void assertBuildOfShardingTablesAndUnConfiguredTables() {
@@ -101,13 +102,13 @@ public final class SchemaBuilderTest {
when(connection.getSchema()).thenReturn(TEST_SCHEMA);
when(databaseMetaData.getTables(connection.getCatalog(), connection.getSchema(), null, new String[]{TABLE_TYPE, VIEW_TYPE})).thenReturn(resultSet);
when(resultSet.next()).thenReturn(true, true, true, true, true, true, false);
- String[] mockReturnTables = new String[]{unConfiguredTableNames[1], "data_node_routed_table1_0", "data_node_routed_table1_1", "data_node_routed_table2_0", "data_node_routed_table2_1"};
+ String[] mockReturnTables = {unConfiguredTableNames[1], "data_node_routed_table1_0", "data_node_routed_table1_1", "data_node_routed_table2_0", "data_node_routed_table2_1"};
when(resultSet.getString(TABLE_NAME)).thenReturn(unConfiguredTableNames[0], mockReturnTables);
ShardingSphereSchema actual = SchemaBuilder.build(schemaBuilderMaterials);
assertThat(actual.getAllTableNames().size(), is(4));
assertSchemaOfShardingTablesAndUnConfiguredTables(actual);
}
-
+
private void assertSchemaOfShardingTablesAndUnConfiguredTables(final ShardingSphereSchema actual) {
assertSchemaOfShardingTables(actual);
assertTrue(actual.containsTable(unConfiguredTableNames[0]));
diff --git a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/fixture/loader/DataNodeContainedFixtureRuleBasedTableMetaDataBuilder.java b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/fixture/loader/DataNodeContainedFixtureRuleBasedTableMetaDataBuilder.java
index e4e67de..bc1ccdb 100644
--- a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/fixture/loader/DataNodeContainedFixtureRuleBasedTableMetaDataBuilder.java
+++ b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/fixture/loader/DataNodeContainedFixtureRuleBasedTableMetaDataBuilder.java
@@ -31,25 +31,25 @@ import java.util.Map;
import java.util.Optional;
public final class DataNodeContainedFixtureRuleBasedTableMetaDataBuilder implements RuleBasedTableMetaDataBuilder<DataNodeContainedFixtureRule> {
-
+
@Override
public Optional<TableMetaData> load(final String tableName, final DatabaseType databaseType, final Map<String, DataSource> dataSourceMap,
final DataNodes dataNodes, final DataNodeContainedFixtureRule rule, final ConfigurationProperties props) {
return ("data_node_routed_table1".equals(tableName) || "data_node_routed_table2".equals(tableName))
? Optional.of(new TableMetaData(Collections.emptyList(), Collections.emptyList())) : Optional.empty();
}
-
+
@Override
public TableMetaData decorate(final String tableName, final TableMetaData tableMetaData, final DataNodeContainedFixtureRule rule) {
ColumnMetaData columnMetaData = new ColumnMetaData("id", 1, "INT", true, true, false);
return new TableMetaData(Collections.singletonList(columnMetaData), Collections.emptyList());
}
-
+
@Override
public int getOrder() {
return 1;
}
-
+
@Override
public Class<DataNodeContainedFixtureRule> getTypeClass() {
return DataNodeContainedFixtureRule.class;
diff --git a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/fixture/rule/DataNodeContainedFixtureRule.java b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/fixture/rule/DataNodeContainedFixtureRule.java
index 77ccb32..7b871cc 100644
--- a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/fixture/rule/DataNodeContainedFixtureRule.java
+++ b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/fixture/rule/DataNodeContainedFixtureRule.java
@@ -23,48 +23,48 @@ import org.apache.shardingsphere.infra.rule.type.TableContainedRule;
import java.util.Collection;
import java.util.HashMap;
+import java.util.HashSet;
import java.util.Map;
import java.util.Optional;
-import java.util.stream.Collectors;
public final class DataNodeContainedFixtureRule implements DataNodeContainedRule, TableContainedRule {
-
+
private final Map<String, String> actualTableNameMaps = new HashMap<>(4);
-
+
public DataNodeContainedFixtureRule() {
actualTableNameMaps.putIfAbsent("data_node_routed_table1_0", "data_node_routed_table1");
actualTableNameMaps.putIfAbsent("data_node_routed_table1_1", "data_node_routed_table1");
actualTableNameMaps.putIfAbsent("data_node_routed_table2_0", "data_node_routed_table2");
actualTableNameMaps.putIfAbsent("data_node_routed_table2_1", "data_node_routed_table2");
}
-
+
@Override
public Map<String, Collection<DataNode>> getAllDataNodes() {
return null;
}
-
+
@Override
public Collection<String> getAllActualTables() {
return actualTableNameMaps.keySet();
}
-
+
@Override
public Optional<String> findFirstActualTable(final String logicTable) {
return Optional.empty();
}
-
+
@Override
public boolean isNeedAccumulate(final Collection<String> tables) {
return false;
}
-
+
@Override
public Optional<String> findLogicTableByActualTable(final String actualTable) {
return Optional.ofNullable(actualTableNameMaps.get(actualTable));
}
-
+
@Override
public Collection<String> getTables() {
- return actualTableNameMaps.values().stream().collect(Collectors.toSet());
+ return new HashSet<>(actualTableNameMaps.values());
}
}