Java:CSV文件读写

问题描述 投票:0回答:7

我正在阅读 2 个 csv 文件:

store_inventory
new_acquisitions

我希望能够将
store_inventory
csv 文件与
new_acquisitions
进行比较。 1) 如果商品名称匹配,只需更新 store_inventory 中的数量。 2) 如果 new_acquisitions 有一个新项目不存在于
store_inventory
中,则将其添加到
store_inventory
中。

这是我到目前为止所做的,但不是很好。我在需要添加任务 12 的地方添加了评论。
任何执行上述任务的建议或代码都会很棒!谢谢。

    File new_acq = new File("/src/test/new_acquisitions.csv");
    Scanner acq_scan = null;
    try {
        acq_scan = new Scanner(new_acq);
    } catch (FileNotFoundException ex) {
        Logger.getLogger(mainpage.class.getName()).log(Level.SEVERE, null, ex);
    }
    String itemName;
    int quantity;
    Double cost;
    Double price;

    File store_inv = new File("/src/test/store_inventory.csv");
    Scanner invscan = null;
    try {
        invscan = new Scanner(store_inv);
    } catch (FileNotFoundException ex) {
        Logger.getLogger(mainpage.class.getName()).log(Level.SEVERE, null, ex);
    }
    String itemNameInv;
    int quantityInv;
    Double costInv;
    Double priceInv;


    while (acq_scan.hasNext()) {
        String line = acq_scan.nextLine();
        if (line.charAt(0) == '#') {
            continue;
        }
        String[] split = line.split(",");

        itemName = split[0];
        quantity = Integer.parseInt(split[1]);
        cost = Double.parseDouble(split[2]);
        price = Double.parseDouble(split[3]);


        while(invscan.hasNext()) {
            String line2 = invscan.nextLine();
            if (line2.charAt(0) == '#') {
                continue;
            }
            String[] split2 = line2.split(",");

            itemNameInv = split2[0];
            quantityInv = Integer.parseInt(split2[1]);
            costInv = Double.parseDouble(split2[2]);
            priceInv = Double.parseDouble(split2[3]);


            if(itemName == itemNameInv) {
                //update quantity

            }
        }
        //add new entry into csv file

     }

再次感谢您的帮助。 =]

java file csv java.util.scanner
7个回答
5
投票

建议您使用现有的 CSV 解析器之一,例如 Commons CSVSuper CSV,而不是重新发明轮子。应该会让你的生活变得更轻松。


2
投票

在开源库uniVocity-parsers的帮助下,您可以使用非常干净的代码进行开发,如下所示:

private void processInventory() throws IOException {
    /**
     * ---------------------------------------------
     *  Read CSV rows into list of beans you defined
     * ---------------------------------------------
     */
    // 1st, config the CSV reader with row processor attaching the bean definition
    CsvParserSettings settings = new CsvParserSettings();
    settings.getFormat().setLineSeparator("\n");
    BeanListProcessor<Inventory> rowProcessor = new BeanListProcessor<Inventory>(Inventory.class);
    settings.setRowProcessor(rowProcessor);
    settings.setHeaderExtractionEnabled(true);

    // 2nd, parse all rows from the CSV file into the list of beans you defined
    CsvParser parser = new CsvParser(settings);
    parser.parse(new FileReader("/src/test/store_inventory.csv"));
    List<Inventory> storeInvList = rowProcessor.getBeans();
    Iterator<Inventory> storeInvIterator = storeInvList.iterator();

    parser.parse(new FileReader("/src/test/new_acquisitions.csv"));
    List<Inventory> newAcqList = rowProcessor.getBeans();
    Iterator<Inventory> newAcqIterator = newAcqList.iterator();

    // 3rd, process the beans with business logic
    while (newAcqIterator.hasNext()) {

        Inventory newAcq = newAcqIterator.next();
        boolean isItemIncluded = false;
        while (storeInvIterator.hasNext()) {
            Inventory storeInv = storeInvIterator.next();

            // 1) If the item names match just update the quantity in store_inventory
            if (storeInv.getItemName().equalsIgnoreCase(newAcq.getItemName())) {
                storeInv.setQuantity(newAcq.getQuantity());
                isItemIncluded = true;
            }
        }

        // 2) If new_acquisitions has a new item that does not exist in store_inventory,
        // then add it to the store_inventory.
        if (!isItemIncluded) {
            storeInvList.add(newAcq);
        }
    }
}

只需按照我根据您的要求制定的代码示例即可。请注意,该库提供了简化的 API 和解析 CSV 文件的显着性能。


1
投票

您正在执行的操作将要求对于新采购的每件商品,您都需要在库存中搜索每件商品以查找匹配项。这不仅效率低下,而且您为库存文件设置的扫描仪需要在每件商品之后重置。

我建议您将新购买的商品和库存添加到集合中,然后迭代新购买的商品并在库存集合中查找新商品。如果该项目存在,则更新该项目。如果没有,请将其添加到库存集合中。对于此活动,最好编写一个简单的类来包含库存项目。它可用于新采购和库存。为了快速查找,我建议您使用 HashSet 或 HashMap 来进行库存集合。

在此过程结束时,不要忘记保留对库存文件的更改。


1
投票

由于Java本身不支持CSV文件的解析,因此我们必须依赖第三方库。 Opencsv 是可用于此目的的最佳库之一。它是开源的,并附带 Apache 2.0 许可证,这使得它可以用于商业用途。

在这里,这个链接应该可以帮助您和其他人!


0
投票

用于写入 CSV

public void writeCSV() {

        // Delimiter used in CSV file
        private static final String NEW_LINE_SEPARATOR = "\n";

        // CSV file header
        private static final Object[] FILE_HEADER = { "Empoyee Name","Empoyee Code", "In Time", "Out Time", "Duration", "Is Working Day" };

        String fileName = "fileName.csv");
        List<Objects> objects = new ArrayList<Objects>();
        FileWriter fileWriter = null;
        CSVPrinter csvFilePrinter = null;

        // Create the CSVFormat object with "\n" as a record delimiter
        CSVFormat csvFileFormat = CSVFormat.DEFAULT.withRecordSeparator(NEW_LINE_SEPARATOR);

        try {
            fileWriter = new FileWriter(fileName);

            csvFilePrinter = new CSVPrinter(fileWriter, csvFileFormat);

            csvFilePrinter.printRecord(FILE_HEADER);

            // Write a new student object list to the CSV file
            for (Object object : objects) {
                List<String> record = new ArrayList<String>();

                record.add(object.getValue1().toString());
                record.add(object.getValue2().toString());
                record.add(object.getValue3().toString());

                csvFilePrinter.printRecord(record);
            }

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                fileWriter.flush();
                fileWriter.close();
                csvFilePrinter.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

0
投票

您可以使用 Apache Commons CSV API。 仅供参考:https://stackoverflow.com/a/42198895/6549532

读/写示例


0
投票

您的实现犯了一个常见错误,即使用 line.split(",") 在逗号上换行。这不起作用,因为值本身可能包含逗号。如果发生这种情况,则必须将该值加引号,并且您需要忽略引号内的逗号。 split 方法不能做到这一点——我经常看到这个错误。

有支持此功能的开源库。我试图链接一个,但我的答案被删除了,因为它被认为是自我推销。到处看看,有一些库可以正确地做到这一点。

© www.soinside.com 2019 - 2024. All rights reserved.