Method QueryContext

stmt.go:125–158

QueryContext executes a query that may return rows, such as a SELECT. QueryContext must honor the context timeout and return when it is canceled.

(
	ctx context.Context, args []driver.NamedValue,
)

//
// QueryContext must honor the context timeout and return when it is canceled.
func (s *proxyStmt) QueryContext(
	ctx context.Context, args []driver.NamedValue,
) (driver.Rows, error) {
	if IsRecording() {
		var rows driver.Rows
		var err error
		if stmtCtx, ok := s.stmt.(driver.StmtQueryContext); ok {
			rows, err = stmtCtx.QueryContext(ctx, args)
		} else {
			var vals []driver.Value
			vals, err = namedValueToValue(args)
			if err != nil {
				return nil, err
			}
			rows, err = s.stmt.Query(vals)
		}

		currentSession.AddRecord(&record{Typ: StmtQuery, Args: recordArgs{err}})
		if err != nil {
			return nil, err
		}
		return &proxyRows{rows: rows}, nil
	}

	rec, err := currentSession.VerifyRecord(StmtQuery)
	if err != nil {
		return nil, err
	}
	err, _ = rec.Args[0].(error)
	if err != nil {
		return nil, err
	}
	return &proxyRows{}, nil
}

func namedValueToValue(named []driver.NamedValue) ([]driver.Value, error) {
	dargs := make([]driver.Value, len(named))