我正在阅读 2 个 csv 文件:
store_inventory
和 new_acquisitions
。store_inventory
csv 文件与 new_acquisitions
进行比较。
1) 如果商品名称匹配,只需更新 store_inventory 中的数量。
2) 如果 new_acquisitions 有一个新项目不存在于 store_inventory
中,则将其添加到 store_inventory
中。
这是我到目前为止所做的,但不是很好。我在需要添加任务 1 和 2 的地方添加了评论。
任何执行上述任务的建议或代码都会很棒!谢谢。
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
}
再次感谢您的帮助。 =]
建议您使用现有的 CSV 解析器之一,例如 Commons CSV 或 Super CSV,而不是重新发明轮子。应该会让你的生活变得更轻松。
在开源库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 文件的显着性能。
您正在执行的操作将要求对于新采购的每件商品,您都需要在库存中搜索每件商品以查找匹配项。这不仅效率低下,而且您为库存文件设置的扫描仪需要在每件商品之后重置。
我建议您将新购买的商品和库存添加到集合中,然后迭代新购买的商品并在库存集合中查找新商品。如果该项目存在,则更新该项目。如果没有,请将其添加到库存集合中。对于此活动,最好编写一个简单的类来包含库存项目。它可用于新采购和库存。为了快速查找,我建议您使用 HashSet 或 HashMap 来进行库存集合。
在此过程结束时,不要忘记保留对库存文件的更改。
用于写入 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();
}
}
}
您可以使用 Apache Commons CSV API。 仅供参考:https://stackoverflow.com/a/42198895/6549532
您的实现犯了一个常见错误,即使用 line.split(",") 在逗号上换行。这不起作用,因为值本身可能包含逗号。如果发生这种情况,则必须将该值加引号,并且您需要忽略引号内的逗号。 split 方法不能做到这一点——我经常看到这个错误。
有支持此功能的开源库。我试图链接一个,但我的答案被删除了,因为它被认为是自我推销。到处看看,有一些库可以正确地做到这一点。