Merge pull request #107 from pinguo/ft_iter41_merge-mongodb

code for findAndModify
pinguo · Sep 25, 2024 · 1f38d6f · 1f38d6f
2 parents 283693f + eb49096
commit 1f38d6f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/adapter/mongodb.go b/adapter/mongodb.go
@@ -86,7 +86,8 @@ func (m *Mongodb) FindAndModify(query interface{}, change qmgo.Change, result in
 	m.Context().ProfileStart(profile)
 	defer m.Context().ProfileStop(profile)
 	ctx := context.Background()
-	q := m.Collection.Find(ctx, query)
+	col := m.client.MClient.Database(m.db).Collection(m.coll)
+	q := col.Find(ctx, query)
 	q, err := handleOptions(q, options...)
 	if err != nil {
 		return err