This is an automated email from the ASF dual-hosted git repository. CRZbulabula pushed a commit to branch drop-db-rpc in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8b8b3358ea60253c9d2c8fcb353a016fd2d94569 Author: Yongzao <[email protected]> AuthorDate: Fri Apr 24 09:20:33 2026 +0800 f --- .../org/apache/iotdb/confignode/manager/ConfigManager.java | 10 ++++++++++ .../java/org/apache/iotdb/confignode/manager/IManager.java | 2 ++ 2 files changed, 12 insertions(+) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java index 182dc2f9fb2..8a12d53c91f 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java @@ -805,6 +805,16 @@ public class ConfigManager implements IManager { } } + public synchronized TSStatus dangerDeleteDatabase(final String database) { + final TSStatus status = confirmLeader(); + if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) { + final TDatabaseSchema databaseSchema = new TDatabaseSchema(database); + return procedureManager.deleteDatabases(Collections.singletonList(databaseSchema), false); + } else { + return status; + } + } + private List<TSeriesPartitionSlot> calculateRelatedSlot( final PartialPath path, final PartialPath database) { // The path contains `**` diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java index 02c82164595..caab626722c 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java @@ -422,6 +422,8 @@ public interface IManager { */ TSStatus deleteDatabases(TDeleteDatabasesReq tDeleteReq); + TSStatus dangerDeleteDatabase(String database); + /** * Get SchemaPartition. *
