Function processRows

plugins/destination/mssql/client/util.go:7–19

(rows *sql.Rows, process func(row *sql.Rows) error)

)

func processRows(rows *sql.Rows, process func(row *sql.Rows) error) error {
	defer rows.Close()

	for next := true; next; next = rows.NextResultSet() {
		for rows.Next() {
			if err := process(rows); err != nil {
				return err
			}
		}
	}

	return rows.Err()
}