Function readAllRows

cmd/cql-mysql-adapter/scanner.go:85–106

(rows *sql.Rows)

}

func readAllRows(rows *sql.Rows) (result [][]interface{}, err error) {
	var columns []string
	if columns, err = rows.Columns(); err != nil {
		return
	}

	rs := newRowScanner(len(columns))
	result = make([][]interface{}, 0)

	for rows.Next() {
		err = rows.Scan(rs.ScanArgs()...)
		if err != nil {
			return
		}

		result = append(result, rs.GetRow())
	}

	err = rows.Err()

	return
}