关于多表事务

[fesed]

我看案例中的事务是单表的，请问多表事务是该怎么实现

[xsean2020]

事务不是基于 sessCtx实现的嘛， 保证操作多表使用同一个 sessCtx 就行了

[LLiuHuan]

事务不是基于 sessCtx实现的嘛， 保证操作多表使用同一个 sessCtx 就行了

大佬，有示例吗

[orangesobeautiful]

@fesed 使用 qmgo.Client 來進行操作即可 以下範例是 TestSession_AbortTransaction 函數的修改版

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/qiniu/qmgo"
	"go.mongodb.org/mongo-driver/bson"
)

const (
	// abortTransaction 是否要中斷 Transaction
	abortTransaction = false
)

func main() {
	bgCtx := context.Background()
	cfg := qmgo.Config{
		// 記得修改成自己的資料庫設定
		Uri: "mongodb://user:password@localhost:27017",
	}
	// 用 *qmgo.Client 才能達成多 Collection 操作需求
	qClient, err := qmgo.NewClient(bgCtx, &cfg)
	if err != nil {
		log.Fatalf("qmgo.Open failed, err=%s", err)
	}
	db := qClient.Database("testdb")
	col1 := db.Collection("coll1")
	col2 := db.Collection("coll2")
	sess, _ := qClient.Session()
	defer sess.EndSession(bgCtx)
	defer func() {
		_ = col1.DropCollection(bgCtx)
		_ = col2.DropCollection(bgCtx)
	}()

	// 定義 Transaction 中要做的事項
	// 注意 context 要使用的是傳進來的參數 sessCtx
	callback := func(sessCtx context.Context) (interface{}, error) {
		if _, err := col1.InsertOne(sessCtx, bson.M{"abc": int32(1)}); err != nil {
			return nil, err
		}
		if _, err := col2.InsertOne(sessCtx, bson.M{"xyz": int32(999)}); err != nil {
			return nil, err
		}
		if abortTransaction {
			_ = sess.AbortTransaction(sessCtx)
		}

		return nil, nil
	}

	// 執行 Transaction
	_, err = sess.StartTransaction(bgCtx, callback)
	if err != nil {
		log.Fatalf("StartTransaction failed, err=%s", err)
	}

	// 檢測資料有沒有寫入
	r := bson.M{}
	err = col1.Find(bgCtx, bson.M{"abc": 1}).One(&r)
	if err != nil {
		fmt.Println("abc found failed", err)
	} else {
		fmt.Println("find abc")
	}
	err = col2.Find(bgCtx, bson.M{"xyz": 999}).One(&r)
	if err != nil {
		fmt.Println("xyz found failed", err)
	} else {
		fmt.Println("find xyz")
	}
}