Function readRows

src/go/plugin/go.d/pkg/sqlquery/query.go:36–56

readRows scans all rows and invokes assign for every column value.

(rows *sql.Rows, assign AssignFunc)

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

	columns, err := rows.Columns()
	if err != nil {
		return err
	}

	values := makeValues(len(columns))
	for rows.Next() {
		if err := rows.Scan(values...); err != nil {
			return err
		}
		for i := range values {
			assign(columns[i], valueToString(values[i]), i == len(values)-1)
		}
	}
	return rows.Err()
}

func valueToString(value any) string {
	v, ok := value.(*sql.NullString)