diff --git a/core/stores/sqlx/tx.go b/core/stores/sqlx/tx.go index 0ae35ff9..cbb5c4db 100644 --- a/core/stores/sqlx/tx.go +++ b/core/stores/sqlx/tx.go @@ -19,6 +19,12 @@ type ( } ) +// NewSessionFromTx returns a Session with the given sql.Tx. +// Use it with caution, it's provided for other ORM to interact with. +func NewSessionFromTx(tx *sql.Tx) Session { + return txSession{Tx: tx} +} + func (t txSession) Exec(q string, args ...interface{}) (sql.Result, error) { return exec(t.Tx, q, args...) }