code for findAndModify

pinguo · Sep 25, 2024 · eb49096 · eb49096
1 parent 718d471
commit eb49096
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