使用Java 8 Stream解析.csv文件

Mic*_*han 5 java csv java-8 java-stream

我有一个.csv文件,其中包含500多家公司的数据.文件中的每一行都指特定的公司数据集.我需要解析这个文件并从每个文件中推断数据以调用4个不同的Web服务.

.csv文件的第一行包含列名.我正在尝试编写一个采用字符串参数的方法,这与.csv文件中的列标题有关.

基于此参数,我希望该方法使用Java 8的Stream功能解析文件,并返回从每个行/公司的列标题中获取的数据列表.

我觉得我让它变得比它需要的更复杂但却想不出更有效的方法来实现我的目标.

任何想法或想法将不胜感激.

通过stackoverflow搜索我发现以下帖子类似但不完全相同. 使用新的Java 8 Streams API解析唯一行的CSV文件

    public static List<String> getData(String titleToSearchFor) throws IOException{
    Path path = Paths.get("arbitoryPath");
    int titleIndex;
    String retrievedData = null;
    List<String> listOfData = null;

    if(Files.exists(path)){ 
        try(Stream<String> lines = Files.lines(path)){
            List<String> columns = lines
                    .findFirst()
                    .map((line) -> Arrays.asList(line.split(",")))
                    .get();

            titleIndex = columns.indexOf(titleToSearchFor);

            List<List<String>> values = lines
                    .skip(1)
                    .map(line -> Arrays.asList(line.split(",")))
                    .filter(list -> list.get(titleIndex) != null)
                    .collect(Collectors.toList());

            String[] line = (String[]) values.stream().flatMap(l -> l.stream()).collect(Collectors.collectingAndThen(
                    Collectors.toList(), 
                    list -> list.toArray()));
            String value = line[titleIndex];
            if(value != null && value.trim().length() > 0){
                retrievedData = value;
            }
            listOfData.add(retrievedData);
        }
    }
    return listOfTitles;
}
Run Code Online (Sandbox Code Playgroud)

谢谢

ixe*_*ion 12

您不应该重新发明轮子并使用常见的csv解析器库.例如,您可以使用Apache Commons CSV.

它将为您处理很多想法,并且更具可读性.还有OpenCSV,它更强大,并且带有基于注释的数据类映射.

 try (Reader reader = Files.newBufferedReader(Paths.get("file.csv"));
            CSVParser csvParser = new CSVParser(reader, CSVFormat.DEFAULT
                    .withFirstRecordAsHeader()        
        ) {
            for (CSVRecord csvRecord : csvParser) {
                // Access
                String name = csvRecord.get("MyColumn");
                // (..)
          }
Run Code Online (Sandbox Code Playgroud)

编辑:无论如何,如果你真的想自己做,请看一下这个例子.