Method getDB

admin/database/postgres/tx.go:58–64

getDB either returns the current tx (if one is present) or c.db.

(ctx context.Context)

// getDB either returns the current tx (if one is present) or c.db.
func (c *connection) getDB(ctx context.Context) dbHandle {
	tx := txFromContext(ctx)
	if tx == nil {
		return c.db
	}
	return tx
}

// noopTx implements a database.Tx that does nothing on Commit/Rollback.
// It is used in nested transactions to avoid committing too early.