From 6234ea441b6388838a19635c656316047f42917d Mon Sep 17 00:00:00 2001 From: bukton Date: Sun, 19 Apr 2020 00:20:00 +0700 Subject: [PATCH] filer mongodb delete --- weed/filer2/mongodb/mongodb_store.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/weed/filer2/mongodb/mongodb_store.go b/weed/filer2/mongodb/mongodb_store.go index 912053cbe..d0d8dcf2c 100644 --- a/weed/filer2/mongodb/mongodb_store.go +++ b/weed/filer2/mongodb/mongodb_store.go @@ -110,6 +110,12 @@ func (store *MongodbStore) FindEntry(ctx context.Context, fullpath util.FullPath func (store *MongodbStore) DeleteEntry(ctx context.Context, fullpath util.FullPath) error { + where := bson.M{"directory": fullpath} + _, err := store.connect.Database(store.database).Collection(store.collectionName).DeleteOne(ctx, where) + if err != nil { + return fmt.Errorf("delete %s : %v", fullpath, err) + } + return nil } @@ -120,7 +126,7 @@ func (store *MongodbStore) DeleteFolderChildren(ctx context.Context, fullpath ut func (store *MongodbStore) ListDirectoryEntries(ctx context.Context, fullpath util.FullPath, startFileName string, inclusive bool, limit int) (entries []*filer2.Entry, err error) { - var where = bson.M{"directory": string(fullpath), "name": bson.M{ "$gt": startFileName, }} + var where = bson.M{"directory": string(fullpath), "name": bson.M{"$gt": startFileName,}} if inclusive { where["name"] = bson.M{ "$gte": startFileName,