iT邦幫忙

0

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

各位好

如題,小弟在作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
}

尚未有邦友回答

立即登入回答