f
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 182dc2f..8a12d53 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 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 02c8216..caab626 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 @@ */ TSStatus deleteDatabases(TDeleteDatabasesReq tDeleteReq); + TSStatus dangerDeleteDatabase(String database); + /** * Get SchemaPartition. *