我需要一個示例來使用 GoLang 在 MongoDB 中實現(xiàn)事務(wù)。我正在為 mongodb 使用這個 golang 驅(qū)動程序沒有關(guān)于如何實現(xiàn)事務(wù)的明確文檔。誰能幫我？
2 回答
HUX布斯
TA貢獻1876條經(jīng)驗 獲得超6個贊
這可能會令人困惑。下面是一個簡單的例子。
if session, err = client.StartSession(); err != nil {
? ? t.Fatal(err)
}
if err = session.StartTransaction(); err != nil {
? ? t.Fatal(err)
}
if err = mongo.WithSession(ctx, session, func(sc mongo.SessionContext) error {
? ? if result, err = collection.UpdateOne(sc, bson.M{"_id": id}, update); err != nil {
? ? ? ? t.Fatal(err)
? ? }
? ? if result.MatchedCount != 1 || result.ModifiedCount != 1 {
? ? ? ? t.Fatal("replace failed, expected 1 but got", result.MatchedCount)
? ? }
? ? if err = session.CommitTransaction(sc); err != nil {
? ? ? ? t.Fatal(err)
? ? }
? ? return nil
}); err != nil {
? ? t.Fatal(err)
}
session.EndSession(ctx)
偶然的你
TA貢獻1841條經(jīng)驗 獲得超3個贊
這會幫助你
ctx := context.Background()
client, err := mongo.Connect(ctx, options.Client().ApplyURI("mongodb://localhost:27017"))
if err != nil {
panic(err)
}
db := client.Database("testdb")
defer db.Client().Disconnect(ctx)
col := db.Collection("testcol")
// transaction
err = db.Client().UseSession(ctx, func(sessionContext mongo.SessionContext) error {
err := sessionContext.StartTransaction()
if err != nil {
return err
}
_, err = col.InsertOne(sessionContext, bson.M{"_id": "1", "name": "berry"})
if err != nil {
return err
}
_, err = col.InsertOne(sessionContext, bson.M{"_id": "2", "name": "gucci"})
if err != nil {
sessionContext.AbortTransaction(sessionContext)
return err
}
if err = session.CommitTransaction(sessionContext); err != nil {
return err
}
return nil
})
- 2 回答
- 0 關(guān)注
- 379 瀏覽
添加回答
舉報
0/150
提交
取消