使用GoLang的mongodb中的事务示例

package main

import (
    "context"
    "fmt"
    "log"
    "time"

    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
    "go.mongodb.org/mongo-driver/mongo/readpref"
    "go.mongodb.org/mongo-driver/mongo/writeconcern"
    "go.mongodb.org/mongo-driver/mongo/transaction"
)

func main() {
    // 设置MongoDB连接选项
    clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

    // 建立与MongoDB的连接
    client, err := mongo.Connect(context.Background(), clientOptions)
    if err != nil {
        log.Fatal(err)
    }

    // 检查与MongoDB的连接是否正常
    err = client.Ping(context.Background(), readpref.Primary())
    if err != nil {
        log.Fatal(err)
    }

    // 创建一个事务
    session, err := client.StartSession()
    if err != nil {
        log.Fatal(err)
    }
    defer session.EndSession(context.Background())

    // 设置事务选项
    transactionOptions := options.Transaction().SetWriteConcern(writeconcern.New(writeconcern.WMajority()))

    // 开始事务
    err = session.StartTransaction(transactionOptions)
    if err != nil {
        log.Fatal(err)
    }

    // 在事务中执行操作
    collection := client.Database("mydb").Collection("mycollection")
    _, err = collection.InsertOne(session, bson.M{"name": "John Doe", "age": 30})
    if err != nil {
        // 回滚事务
        _ = session.AbortTransaction(context.Background())
        log.Fatal(err)
    }

    // 提交事务
    err = session.CommitTransaction(context.Background())
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("Transaction committed successfully!")
}