From 74bf9537a7c2446ff1d4b0fb7fee0fbf0dd55146 Mon Sep 17 00:00:00 2001
From: somnath ghorpade <somnathg@mkcl.org>
Date: Wed, 17 Apr 2024 10:55:32 +0530
Subject: [PATCH] Added find allowDiskUse options.
---
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..d84c14d 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("allowDiskUse").Value() != nil {
+ ops.SetAllowDiskUse(obj.Get("allowDiskUse").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