覆盖 Labix mgo 中的默认 writeConcern

Question

我labix mgo在 Go 应用程序中用作 mongodb 驱动程序，我想知道是否有办法覆盖writeConcern特定查询的默认值。关于配置的几句话：副本集有三个节点 - 一个主节点和两个辅助节点，writeConcern和readPreference是默认的。驱动程序使用monotonic一致性，这意味着所有读取都是从辅助节点完成的（当它可用时，否则 - 从主节点）。在某些情况下，我需要在写入数据库后立即读取更新的数据 - 由于上述 mongo 可能会返回旧数据：// update some data_ := collection.Update(bson.M{"_id": "some_id"}, bson.M{"key": "value"})// the data is still not updated when I read it immediately after updatevar obj interface{}_ := collection.Find(bson.M{"_id": "some_id"}).One(&obj)问题是：是否可以覆盖默认值writeConcern（或consistency驱动程序的默认值）并强制驱动程序等待数据写入辅助节点或从主节点读取某些查询？

Answer 1

好的，经过一些研究，我最终找到了解决方案。有一种方法SetMode可以让您更改特定数据库会话的默认一致性模式。在我们的应用程序中，我们每次在发出请求之前创建主会话的副本，然后在完成后关闭它：

// master session is configured to use monotonic consistency

session := masterSession.Copy()

// tell mgo to read from the primary in this session

session.SetMode(mgo.Strong, true)

collection := session.DB("db").C("collection")

var obj interface{}

// now we can be sure that the following request reads the data from the primary

_ := collection.Find(bson.M{"_id": "some_id"}).One(&obj)

session.Close()