From f943ec81462b911a3efbc0002f9a702ef1f32c4e Mon Sep 17 00:00:00 2001
From: somnath ghorpade <somnathg@mkcl.org>
Date: Tue, 16 Apr 2024 16:50:44 +0530
Subject: [PATCH] added find allowdisk usage option.
---
dalmdl/coremongo/coremongo.go | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/dalmdl/coremongo/coremongo.go b/dalmdl/coremongo/coremongo.go
index 43192c1..abda114 100644
--- a/dalmdl/coremongo/coremongo.go
+++ b/dalmdl/coremongo/coremongo.go
@@ -152,7 +152,7 @@ func InitNewSession(hostDetails MongoHost) error {
return nil
}
-//GetMongoConnection method
+// GetMongoConnection method
func GetMongoConnection(hostName string) (*mongo.Client, error) {
mutex.Lock()
defer mutex.Unlock()
@@ -359,7 +359,7 @@ func (mg *MongoDAO) DeleteAll(selector map[string]interface{}) error {
return deleteError
}
-//Set Find Options
+// Set Find Options
func (mg *MongoDAO) SetFindOps(findOps map[string]interface{}) {
mg.MetaData.Findops = findOps
}
@@ -405,6 +405,9 @@ func (mg *MongoDAO) GetProjectedData(selector map[string]interface{}, projector
})
ops.SetSort(sort)
}
+ if obj.Get("allowDiskUsage").Value() != nil {
+ ops.SetAllowDiskUse(obj.Get("allowDiskUsage").Bool())
+ }
}
ops.Projection = projector
cur, err := collection.Find(context.Background(), selector, ops)
@@ -551,7 +554,7 @@ func (mg *MongoDAO) PushData(selector map[string]interface{}, data interface{})
return nil
}
-//set update option for custom update
+// set update option for custom update
func (mg *MongoDAO) SetUpdateOps(updateOps map[string]interface{}) {
mg.MetaData.UpdateOps = updateOps
}
--
GitLab