Function ScanTypedRows

src/go/plugin/go.d/pkg/sqlquery/scan.go:33–54

ScanTypedRows scans all rows according to specs and returns normalized [][]any rows. The function intentionally does not call rows.Err(); callers keep control over that.

(rows RowScanner, specs []ScanColumnSpec)

// ScanTypedRows scans all rows according to specs and returns normalized [][]any rows.
// The function intentionally does not call rows.Err(); callers keep control over that.
func ScanTypedRows(rows RowScanner, specs []ScanColumnSpec) ([][]any, error) {
	data := make([][]any, 0, 500)
	holders := makeScanHolders(specs)

	for rows.Next() {
		if err := rows.Scan(holders.ptrs...); err != nil {
			return nil, fmt.Errorf("scan row: %w", err)
		}

		row := make([]any, len(specs))
		for i := range holders.ptrs {
			value, ok := holders.value(i)
			if ok && specs[i].Transform != nil {
				value = specs[i].Transform(value)
			}
			row[i] = value
		}
		data = append(data, row)
	}

	return data, nil
}

type scanHolders struct {
	ptrs []any