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 b3b58561974 Rename NodePathSearcher (#34749)
b3b58561974 is described below
commit b3b58561974998155d112e85c59b66f906ef00ac
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Feb 22 16:12:34 2025 +0800
Rename NodePathSearcher (#34749)
* Rename NodePathSearcher
* Rename NodePathSearcher
---
.../{NodePathParser.java => NodePathSearcher.java} | 4 ++--
.../database/TableMetadataNodePathTest.java | 21 +++++++++++----------
.../database/ViewMetadataNodePathTest.java | 8 ++++----
.../database/metadata/MetaDataChangedHandler.java | 22 +++++++++++-----------
.../metadata/type/TableChangedHandler.java | 6 +++---
.../database/metadata/type/ViewChangedHandler.java | 6 +++---
.../type/DatabaseMetaDataChangedListener.java | 4 ++--
7 files changed, 36 insertions(+), 35 deletions(-)
diff --git
a/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/NodePathParser.java
b/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/NodePathSearcher.java
similarity index 98%
rename from
mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/NodePathParser.java
rename to
mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/NodePathSearcher.java
index afe1b522af5..e9191063e26 100644
---
a/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/NodePathParser.java
+++
b/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/NodePathSearcher.java
@@ -26,10 +26,10 @@ import java.util.regex.Matcher;
import java.util.regex.Pattern;
/**
- * Node path parser.
+ * Node path searcher.
*/
@NoArgsConstructor(access = AccessLevel.PRIVATE)
-public final class NodePathParser {
+public final class NodePathSearcher {
/**
* Find node segment.
diff --git
a/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/metadata/database/TableMetadataNodePathTest.java
b/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/metadata/database/TableMetadataNodePathTest.java
index be8c8094138..6f07c1b675b 100644
---
a/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/metadata/database/TableMetadataNodePathTest.java
+++
b/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/metadata/database/TableMetadataNodePathTest.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.mode.node.path.metadata.database;
import org.apache.shardingsphere.mode.node.path.NodePathGenerator;
-import org.apache.shardingsphere.mode.node.path.NodePathParser;
+import org.apache.shardingsphere.mode.node.path.NodePathSearcher;
import org.apache.shardingsphere.mode.node.path.NodePathPattern;
import org.apache.shardingsphere.mode.node.path.version.VersionNodePath;
import org.junit.jupiter.api.Test;
@@ -50,24 +50,25 @@ class TableMetadataNodePathTest {
@Test
void assertFind() {
- assertThat(NodePathParser.find("/metadata/foo_db/schemas/foo_schema",
new TableMetadataNodePath(NodePathPattern.IDENTIFIER, null, null), true, true,
1), is(Optional.of("foo_db")));
- assertFalse(NodePathParser.find("/xxx/foo_db/schemas/foo_schema", new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, null, null), true, true,
1).isPresent());
- assertThat(NodePathParser.find("/metadata/foo_db/schemas/foo_schema",
new TableMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, null), true, false, 2),
+
assertThat(NodePathSearcher.find("/metadata/foo_db/schemas/foo_schema", new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, null, null), true, true, 1),
is(Optional.of("foo_db")));
+ assertFalse(NodePathSearcher.find("/xxx/foo_db/schemas/foo_schema",
new TableMetadataNodePath(NodePathPattern.IDENTIFIER, null, null), true, true,
1).isPresent());
+
assertThat(NodePathSearcher.find("/metadata/foo_db/schemas/foo_schema", new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, false, 2),
is(Optional.of("foo_schema")));
assertFalse(
-
NodePathParser.find("/metadata/foo_db/schemas/foo_schema/tables", new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, false, 2).isPresent());
-
assertThat(NodePathParser.find("/metadata/foo_db/schemas/foo_schema/tables",
new TableMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, null), true, true, 2),
+
NodePathSearcher.find("/metadata/foo_db/schemas/foo_schema/tables", new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, false, 2)
+ .isPresent());
+
assertThat(NodePathSearcher.find("/metadata/foo_db/schemas/foo_schema/tables",
new TableMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, null), true, true, 2),
is(Optional.of("foo_schema")));
-
assertFalse(NodePathParser.find("/xxx/foo_db/schemas/foo_schema/tables", new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, true, 2).isPresent());
-
assertThat(NodePathParser.find("/metadata/foo_db/schemas/foo_schema/tables/foo_tbl",
+
assertFalse(NodePathSearcher.find("/xxx/foo_db/schemas/foo_schema/tables", new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, true, 2).isPresent());
+
assertThat(NodePathSearcher.find("/metadata/foo_db/schemas/foo_schema/tables/foo_tbl",
new TableMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER), false, false, 3),
is(Optional.of("foo_tbl")));
-
assertFalse(NodePathParser.find("/xxx/foo_db/schemas/foo_schema/tables/foo_tbl",
+
assertFalse(NodePathSearcher.find("/xxx/foo_db/schemas/foo_schema/tables/foo_tbl",
new TableMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER), false, false,
3).isPresent());
}
@Test
void assertIsTablePath() {
-
assertTrue(NodePathParser.isMatchedPath("/metadata/foo_db/schemas/foo_schema/tables/foo_tbl",
+
assertTrue(NodePathSearcher.isMatchedPath("/metadata/foo_db/schemas/foo_schema/tables/foo_tbl",
new TableMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER), false, false));
}
}
diff --git
a/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/metadata/database/ViewMetadataNodePathTest.java
b/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/metadata/database/ViewMetadataNodePathTest.java
index fd358c39445..4320a1478c6 100644
---
a/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/metadata/database/ViewMetadataNodePathTest.java
+++
b/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/metadata/database/ViewMetadataNodePathTest.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.mode.node.path.metadata.database;
import org.apache.shardingsphere.mode.node.path.NodePathGenerator;
-import org.apache.shardingsphere.mode.node.path.NodePathParser;
+import org.apache.shardingsphere.mode.node.path.NodePathSearcher;
import org.apache.shardingsphere.mode.node.path.NodePathPattern;
import org.apache.shardingsphere.mode.node.path.version.VersionNodePath;
import org.junit.jupiter.api.Test;
@@ -50,15 +50,15 @@ class ViewMetadataNodePathTest {
@Test
void assertFind() {
-
assertThat(NodePathParser.find("/metadata/foo_db/schemas/foo_schema/views/foo_view",
+
assertThat(NodePathSearcher.find("/metadata/foo_db/schemas/foo_schema/views/foo_view",
new ViewMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER), false, true, 3),
is(Optional.of("foo_view")));
-
assertFalse(NodePathParser.find("/xxx/foo_db/schemas/foo_schema/views/foo_view",
+
assertFalse(NodePathSearcher.find("/xxx/foo_db/schemas/foo_schema/views/foo_view",
new ViewMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER), false, true,
3).isPresent());
}
@Test
void assertIsMatchedPath() {
-
assertTrue(NodePathParser.isMatchedPath("/metadata/foo_db/schemas/foo_schema/views/foo_view",
+
assertTrue(NodePathSearcher.isMatchedPath("/metadata/foo_db/schemas/foo_schema/views/foo_view",
new ViewMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER), false, true));
}
}
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/MetaDataChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/MetaDataChangedHandler.java
index 0ffa37ab0fb..fed7a711918 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/MetaDataChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/MetaDataChangedHandler.java
@@ -25,7 +25,7 @@ import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.metadata.type.StorageUnitChangedHandler;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.metadata.type.TableChangedHandler;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.metadata.type.ViewChangedHandler;
-import org.apache.shardingsphere.mode.node.path.NodePathParser;
+import org.apache.shardingsphere.mode.node.path.NodePathSearcher;
import org.apache.shardingsphere.mode.node.path.NodePathPattern;
import
org.apache.shardingsphere.mode.node.path.metadata.database.TableMetadataNodePath;
import
org.apache.shardingsphere.mode.node.path.metadata.database.ViewMetadataNodePath;
@@ -67,12 +67,12 @@ public final class MetaDataChangedHandler {
*/
public boolean handle(final String databaseName, final DataChangedEvent
event) {
String eventKey = event.getKey();
- Optional<String> schemaName = NodePathParser.find(eventKey, new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, false, 2);
+ Optional<String> schemaName = NodePathSearcher.find(eventKey, new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, false, 2);
if (schemaName.isPresent()) {
handleSchemaChanged(databaseName, schemaName.get(), event);
return true;
}
- schemaName = NodePathParser.find(eventKey, new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, true, 2);
+ schemaName = NodePathSearcher.find(eventKey, new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
null), true, true, 2);
if (schemaName.isPresent() && isTableMetaDataChanged(eventKey)) {
handleTableChanged(databaseName, schemaName.get(), event);
return true;
@@ -97,31 +97,31 @@ public final class MetaDataChangedHandler {
}
private boolean isTableMetaDataChanged(final String key) {
- return NodePathParser.isMatchedPath(key, new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, false)
- || NodePathParser.getVersion(new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).isActiveVersionPath(key);
+ return NodePathSearcher.isMatchedPath(key, new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, false)
+ || NodePathSearcher.getVersion(new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).isActiveVersionPath(key);
}
private void handleTableChanged(final String databaseName, final String
schemaName, final DataChangedEvent event) {
if ((Type.ADDED == event.getType() || Type.UPDATED == event.getType())
- && NodePathParser.getVersion(new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).isActiveVersionPath(event.getKey())) {
+ && NodePathSearcher.getVersion(new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).isActiveVersionPath(event.getKey())) {
tableChangedHandler.handleCreatedOrAltered(databaseName,
schemaName, event);
} else if (Type.DELETED == event.getType()
- && NodePathParser.isMatchedPath(event.getKey(), new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, false)) {
+ && NodePathSearcher.isMatchedPath(event.getKey(), new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, false)) {
tableChangedHandler.handleDropped(databaseName, schemaName, event);
}
}
private boolean isViewMetaDataChanged(final String key) {
- return NodePathParser.getVersion(new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).isActiveVersionPath(key)
- || NodePathParser.isMatchedPath(key, new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, true);
+ return NodePathSearcher.getVersion(new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).isActiveVersionPath(key)
+ || NodePathSearcher.isMatchedPath(key, new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, true);
}
private void handleViewChanged(final String databaseName, final String
schemaName, final DataChangedEvent event) {
if ((Type.ADDED == event.getType() || Type.UPDATED == event.getType())
- && NodePathParser.getVersion(new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).isActiveVersionPath(event.getKey())) {
+ && NodePathSearcher.getVersion(new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).isActiveVersionPath(event.getKey())) {
viewChangedHandler.handleCreatedOrAltered(databaseName,
schemaName, event);
} else if (Type.DELETED == event.getType()
- && NodePathParser.isMatchedPath(event.getKey(), new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, true)) {
+ && NodePathSearcher.isMatchedPath(event.getKey(), new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, true)) {
viewChangedHandler.handleDropped(databaseName, schemaName, event);
}
}
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/type/TableChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/type/TableChangedHandler.java
index 32e004af733..30713ef8a70 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/type/TableChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/type/TableChangedHandler.java
@@ -22,7 +22,7 @@ import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.checker.ActiveVersionChecker;
import
org.apache.shardingsphere.mode.metadata.refresher.statistics.StatisticsRefreshEngine;
-import org.apache.shardingsphere.mode.node.path.NodePathParser;
+import org.apache.shardingsphere.mode.node.path.NodePathSearcher;
import org.apache.shardingsphere.mode.node.path.NodePathPattern;
import
org.apache.shardingsphere.mode.node.path.metadata.database.TableMetadataNodePath;
@@ -48,7 +48,7 @@ public final class TableChangedHandler {
* @param event data changed event
*/
public void handleCreatedOrAltered(final String databaseName, final String
schemaName, final DataChangedEvent event) {
- String tableName = NodePathParser.getVersion(new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER))
+ String tableName = NodePathSearcher.getVersion(new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER))
.findIdentifierByActiveVersionPath(event.getKey(),
3).orElseThrow(() -> new IllegalStateException("Table name not found."));
ActiveVersionChecker.checkActiveVersion(contextManager, event);
ShardingSphereTable table =
contextManager.getPersistServiceFacade().getMetaDataPersistFacade().getDatabaseMetaDataFacade().getTable().load(databaseName,
schemaName, tableName);
@@ -64,7 +64,7 @@ public final class TableChangedHandler {
* @param event data changed event
*/
public void handleDropped(final String databaseName, final String
schemaName, final DataChangedEvent event) {
- String tableName = NodePathParser.find(event.getKey(), new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, false, 3)
+ String tableName = NodePathSearcher.find(event.getKey(), new
TableMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, false, 3)
.orElseThrow(() -> new IllegalStateException("Table name not
found."));
contextManager.getMetaDataContextManager().getDatabaseMetaDataManager().dropTable(databaseName,
schemaName, tableName);
statisticsRefreshEngine.asyncRefresh();
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/type/ViewChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/type/ViewChangedHandler.java
index 65d07321fca..c36210e0bb6 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/type/ViewChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/type/ViewChangedHandler.java
@@ -22,7 +22,7 @@ import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.checker.ActiveVersionChecker;
import
org.apache.shardingsphere.mode.metadata.refresher.statistics.StatisticsRefreshEngine;
-import org.apache.shardingsphere.mode.node.path.NodePathParser;
+import org.apache.shardingsphere.mode.node.path.NodePathSearcher;
import org.apache.shardingsphere.mode.node.path.NodePathPattern;
import
org.apache.shardingsphere.mode.node.path.metadata.database.ViewMetadataNodePath;
@@ -48,7 +48,7 @@ public final class ViewChangedHandler {
* @param event data changed event
*/
public void handleCreatedOrAltered(final String databaseName, final String
schemaName, final DataChangedEvent event) {
- String viewName = NodePathParser.getVersion(
+ String viewName = NodePathSearcher.getVersion(
new ViewMetadataNodePath(NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER)).findIdentifierByActiveVersionPath(event.getKey(),
3)
.orElseThrow(() -> new IllegalStateException("View name not
found."));
ActiveVersionChecker.checkActiveVersion(contextManager, event);
@@ -65,7 +65,7 @@ public final class ViewChangedHandler {
* @param event data changed event
*/
public void handleDropped(final String databaseName, final String
schemaName, final DataChangedEvent event) {
- String viewName = NodePathParser.find(event.getKey(), new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, true, 3)
+ String viewName = NodePathSearcher.find(event.getKey(), new
ViewMetadataNodePath(NodePathPattern.IDENTIFIER, NodePathPattern.IDENTIFIER,
NodePathPattern.IDENTIFIER), false, true, 3)
.orElseThrow(() -> new IllegalStateException("View name not
found."));
contextManager.getMetaDataContextManager().getDatabaseMetaDataManager().dropView(databaseName,
schemaName, viewName);
statisticsRefreshEngine.asyncRefresh();
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java
index 13087eb691b..1276458e0f0 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java
@@ -24,7 +24,7 @@ import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.metadata.MetaDataChangedHandler;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.rule.RuleConfigurationChangedHandler;
-import org.apache.shardingsphere.mode.node.path.NodePathParser;
+import org.apache.shardingsphere.mode.node.path.NodePathSearcher;
import org.apache.shardingsphere.mode.node.path.NodePathPattern;
import
org.apache.shardingsphere.mode.node.path.metadata.database.TableMetadataNodePath;
import
org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener;
@@ -42,7 +42,7 @@ public final class DatabaseMetaDataChangedListener implements
DataChangedEventLi
@Override
public void onChange(final DataChangedEvent event) {
- Optional<String> databaseName = NodePathParser.find(event.getKey(),
new TableMetadataNodePath(NodePathPattern.IDENTIFIER, null, null), true, true,
1);
+ Optional<String> databaseName = NodePathSearcher.find(event.getKey(),
new TableMetadataNodePath(NodePathPattern.IDENTIFIER, null, null), true, true,
1);
if (!databaseName.isPresent()) {
return;
}
