我确定我遗漏了一些东西，但我无法让以下简单事务按预期工作。这种行为与我能找到的所有其他 SO 问题不同。
下面的函数MultipleInsertsTransaction()灵感来自官方的例子。
它成功写入一个文档，然后尝试写入第二个文档，但返回错误，因为再次（有意）使用了相同的 ID。
我的理解是，这些文档都没有保存在数据库中，因为我们从来没有达到过sc.CommitTransaction(sc)，所以里面的所有操作都StartTransaction()应该AbortTransaction()回滚，或者甚至对其他会话不可见。
然而，事实并非如此。第一个文档写入，第二个按预期抛出错误，但是函数返回后，第一个文档被持久化在数据库中。
这笔交易有什么问题？我错过了什么？或者这甚至是预期的？
package main
import (
"context"
"fmt"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/bson/primitive"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
"go.mongodb.org/mongo-driver/mongo/readconcern"
"go.mongodb.org/mongo-driver/mongo/writeconcern"
)
const (
db = "test"
coll = "test"
)
func main() {
client, _ := mongo.Connect(context.Background(), options.Client().ApplyURI("<put replica set connection string here>"))
want, _ := client.Database(db).Collection(coll).CountDocuments(context.Background(), bson.M{})
if err := MultipleInsertsTransaction(context.Background(), client); err != nil {
fmt.Println("expected error occured...")
}
got, _ := client.Database(db).Collection(coll).CountDocuments(context.Background(), bson.M{})
if got != want {
fmt.Printf("expected %d entries in database, but got %d", want, got)
return
}
fmt.Println("it worked!!")
}
func MultipleInsertsTransaction(ctx context.Context, client *mongo.Client) (err error) {
return client.UseSession(ctx, func(sc mongo.SessionContext) error {
err := sc.StartTransaction(options.Transaction().
SetReadConcern(readconcern.Snapshot()).
SetWriteConcern(writeconcern.New(writeconcern.WMajority())),
)
if err != nil {
return err
}
}
非常感谢！
慕容708150
相关分类