diff --git a/postgresql/database.go b/postgresql/database.go index 6d8bd6b7f1c69059bed0fcd43b8e2dd44bf53ce2..8f9ff55be9c513d33ee551d2b95a35c082e6ae5b 100644 --- a/postgresql/database.go +++ b/postgresql/database.go @@ -39,7 +39,6 @@ type database struct { db.SQLBuilder txMu sync.Mutex - tx sqladapter.DatabaseTx connURL db.ConnectionURL } @@ -89,9 +88,8 @@ func NewTx(sqlTx *sql.Tx) (db.SQLTx, error) { return nil, err } - d.tx = sqladapter.NewTx(d) - - return &tx{DatabaseTx: d.tx}, nil + newTx := sqladapter.NewTx(d) + return &tx{DatabaseTx: newTx}, nil } // New wraps the given *sql.DB session and creates a new db session. @@ -258,8 +256,6 @@ func (d *database) NewLocalTransaction() (sqladapter.DatabaseTx, error) { return nil, err } - clone.tx = sqladapter.NewTx(clone) - return sqladapter.NewTx(clone), nil }