* @param productCode
* @return
* @throws sg.edu.nus.iss.se07.common.exceptions.AppException
*/
public ProductSet readDataSet(String productCode) throws AppException {
ProductSet dataObjectSet = null;
BufferedReader br = null;
try {
br = FileUtil.getBufferedReader(fileName);
if (br != null) {
String contents = FileUtil.getContents(br);
if (contents == null) {
return null;
}
String[] lines = StringUtil.parse(contents, format.getEndOfLineSymbols());
if (lines == null) {
Logger.getLogger(ProductDA.class.getName()).log(Level.SEVERE, "[ProductDA::readDataSet]Record not found.");
throw new IOException("[ProductDA::readDataSet]Record not found.");
} else {
if (lines.length < 1) {
Logger.getLogger(ProductDA.class.getName()).log(Level.SEVERE, "[ProductDA::readDataSet]Record not found.");
throw new IOException("[ProductDA::readDataSet]Record not found.");
}
dataObjectSet = new ProductSet();
for (int i = 0; i < lines.length; i++) {
String record = lines[i];
String[] fields = StringUtil.parse(record, String.valueOf((char) format.getDelimiterChar()));
if (fields == null) {
Logger.getLogger(ProductDA.class.getName()).log(Level.SEVERE, "[ProductDA::readDataSet]Unable to read record no " + (String.valueOf(i + 1)));
throw new IOException("[ProductDA::readDataSet]Unable to read record no " + (String.valueOf(i + 1)));
} else {
if (fields.length != 8) {
Logger.getLogger(ProductDA.class.getName()).log(Level.SEVERE, "[ProductDA::readDataSet]Record no " + (String.valueOf(i + 1)) + " is corrupted");
//throw new IOException("[ProductDA::readDataSet]Record no " + (String.valueOf(i + 1)) + " is corrupted");
} else {
String code = fields[0];
if (productCode.equalsIgnoreCase(code)) {
Product product = new Product();
product.setProductID(fields[0]);
product.setProductName(fields[1]);
product.setProductDescription(fields[2]);
product.setQuantityAvailable(Integer.parseInt(fields[3]));
product.setProductPrice(Float.parseFloat(fields[4]));
product.setBarcodeNumber(fields[5]);
product.setReorderQuantity(Integer.parseInt(fields[6]));
product.setOrderQuantity(Integer.parseInt(fields[7]));
dataObjectSet.add(product);
product = null;
i = lines.length;
}
}
}