Function QueryRows

src/go/plugin/go.d/pkg/sqlquery/query.go:21–33

QueryRows executes query and streams row values through assign. The returned duration measures query submission latency (QueryContext call).

(ctx context.Context, q Queryer, query string, assign AssignFunc, args ...any)

// QueryRows executes query and streams row values through assign.
// The returned duration measures query submission latency (QueryContext call).
func QueryRows(ctx context.Context, q Queryer, query string, assign AssignFunc, args ...any) (time.Duration, error) {
	start := time.Now()
	rows, err := q.QueryContext(ctx, query, args...)
	queryDuration := time.Since(start)
	if err != nil {
		return 0, err
	}
	defer func() { _ = rows.Close() }()
	if err := readRows(rows, assign); err != nil {
		return queryDuration, err
	}
	return queryDuration, nil
}

// readRows scans all rows and invokes assign for every column value.
func readRows(rows *sql.Rows, assign AssignFunc) error {