請問Golang的mgo升級qmgo，交易的txn該如何處理？

golang mongodb mgo qmgo txn

breakgod 2021-06-30 14:53:59 ‧ 1045 瀏覽

分享至

各位好

如題，小弟在作golang的mgo升級時
原本想說整個改版成mongo-driver
後來找到qmgo這個與mgo較為相似且可以相容srv的連線
但qmgo的相關文章資訊不多
想請教如何處理原本mgo的txn呢？
還請各位多多指點一下，謝謝

type mgoDBModel struct {
	db  *mgo.Database
	log *log.Logger

	indexExistMap map[string]bool
}

func (mm *mgoDBModel) RunTxn(ops []txn.Op) error {
	r := txn.NewRunner(mm.db.c("txn"))
	id := bson.ObjectId
	err := r.Run(ops, id, nil)
	if err != nil {
		r.Resume(id)
		return err
	}
	return nil
}