我在下面有一个 CSV 文件,我编写了下面的方法来解析该文件。
"PRODUCT_NAME","PRODUCT_CATEGORY","SALES_PRICE"
"Hair Gel","Beauty",6.99
"Scotch tape","Office Supply",2.99
"Office Chair","Office Supply",134.99
我的代码:
public static void ReadFile(String path, Map<String, List<Double>> db){
try(BufferedReader br = new BufferedReader(new FileReader(path))){
String line;
if((line = br.readLine()) != null){
//this line is the heading..and needed to be skipped
}
while ((line = br.readLine()) != null) {
String[] keys = line.split(",");
keys[1] = keys[1].replace("\"", "");
if(db.containsKey(keys[1])){
List<Double> list = db.get(keys[1]);
list.add(Double.valueOf(keys[2]));
db.put(keys[1], list);
}
else{
List<Double> list = new ArrayList<>();
list.add(Double.valueOf(keys[2]));
db.put(keys[1],list);
}
}
}catch(IOException e){}
}
它在解析文件时工作正常,但我的主要问题是如何利用 java8 流和 lambda 功能编写上述方法?
最佳答案
您可以使用 Files.lines(path)
在文件的行上检索流(你可以用 Path
得到一个 Paths.get
)。使用 skip(1)
跳过标题行, 然后每行围绕 ","
拆分.
最后,Stream 元素按键的第一个元素分组(删除引号)并将值映射到 Double
键的第二个元素的值并收集到 List
中.组操作是用 groupingBy(classifier, downstream)
完成的collector:classifier是一个方法,返回key给group by,下游collector收集所有分组到同一个key的Stream元素;在这种情况下,对于具有相同键的值,我们希望将 Stream 元素映射到 Double
值 ( mapping
) 并收集那些 Double
进入 List
( toList()
)。
您设计中的问题是您的方法采用了 Map<String, List<Double>> db
作为参数并在最好让方法返回它时对其进行变异。
public static Map<String, List<Double>> readFile(String path) throws IOException {
try (Stream<String> stream = Files.lines(Paths.get(path))) {
return stream.skip(1)
.map(l -> l.split(","))
.collect(Collectors.groupingBy(
keys -> keys[1].replace("\"", ""),
Collectors.mapping(keys -> Double.valueOf(keys[2]), Collectors.toList())
));
}
}
请注意,我还修改了您的代码,让它抛出 IOException
而不是捕获它什么都不做。如果您想在方法本身中处理该异常,您仍然可以添加 catch 部分。
关于java 8 i/o 流应用程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35385554/