Skip to content

Commit d2a4fb6

Browse files
committed
fix #106
1 parent 7841eb9 commit d2a4fb6

File tree

2 files changed

+15
-0
lines changed

2 files changed

+15
-0
lines changed

nitrite/src/main/java/org/dizitart/no2/NitriteContext.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import org.dizitart.no2.mapper.JacksonMapper;
2929
import org.dizitart.no2.mapper.NitriteMapper;
3030
import org.dizitart.no2.util.ExecutorUtils;
31+
import org.dizitart.no2.util.StringUtils;
3132

3233
import java.util.HashSet;
3334
import java.util.Map;
@@ -36,6 +37,7 @@
3637
import java.util.concurrent.ScheduledExecutorService;
3738

3839
import static org.dizitart.no2.util.ExecutorUtils.shutdownAndAwaitTermination;
40+
import static org.dizitart.no2.util.ObjectUtils.isObjectStore;
3941

4042
/**
4143
* Represents a readonly view of all contextual information of a nitrite database.
@@ -174,6 +176,18 @@ public Set<Module> getRegisteredModules() {
174176
return new HashSet<>(jacksonModule);
175177
}
176178

179+
public void dropCollection(String name) {
180+
if (!StringUtils.isNullOrEmpty(name)) {
181+
if (isObjectStore(name)) {
182+
repositoryRegistry.remove(name);
183+
} else {
184+
collectionRegistry.remove(name);
185+
}
186+
}
187+
}
188+
189+
190+
177191
void shutdown() {
178192
shutdownAndAwaitTermination(scheduledWorkerPool, 5);
179193
shutdownAndAwaitTermination(workerPool, 5);

nitrite/src/main/java/org/dizitart/no2/internals/NitriteService.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -377,6 +377,7 @@ WriteResultImpl remove(Filter filter, RemoveOptions removeOptions) {
377377
*/
378378
void dropCollection() {
379379
indexingService.dropAllIndices();
380+
nitriteContext.dropCollection(mapStore.getName());
380381
mapStore.getStore().removeMap(mapStore);
381382
}
382383

0 commit comments

Comments
 (0)