Mongo-go 驱动版本的 session.copy()

Question

我正在将 go 后端从使用

mgo

迁移到

mongo-go

。该服务有很多代码，除了处理旧

session.Copy()

中的

mgo

方法的部分之外，我已经完成了大部分代码。相关片段如下：

import (
    "gopkg.in/mgo.v2"
)
...
type Store struct {
    session *mgo.Session
}


func (s *Store) collection(collectionName string) (*mgo.Session, *mgo.Collection) {
    session := s.session.Copy()
    collection := session.DB("").C(collectionName)

    return session, collection
}

我想在尊重整体设计的同时重写这个，但我不确定该怎么处理该行

session := s.session.Copy()

- 我想做类似的事情：

import(
    "go.mongodb.org/mongo-driver/mongo"
)
type Store struct {
    client *mongo.Client
}


func (s *Store) collection(collectionName string) (*mongo.Client, *mongo.Collection) {
    client, err := s.client."what method to call here"
    if err != nil {
       //error will be handled here
    }
    collection := session.Database(DBName).Collection(collectionName)

    return session, collection
}

我的理解是，

session.Copy()

方法尊重已经存在的原始连接，但仅基于此启动一个新会话，如此处所述https://pkg.go.dev/gopkg.in/mgo.v2#Session .复制。我似乎可以使用多种方法，而

m.client.StartSession(opts ...*options.SessionOptions)

看起来是自然的候选者。但它的文档让我感到困惑，因为连接已经通过类似以下内容在

main.go

中建立：

clientOptions := options.Client().ApplyURI("URI")

    // Connect to MongoDB
    client, err := mongo.Connect(context.TODO(), clientOptions)

    if err != nil {
        log.Fatal(err)
    }