Parsing csv line to Java objects

Posted by Noobling on Stack Overflow See other posts from Stack Overflow or by Noobling
Published on 2014-08-21T15:48:33Z Indexed on 2014/08/21 16:20 UTC
Read the original article Hit count: 173

Filed under:
|

I was wondering if someone here could help me, I can't find a solution for my problem and I have tried everything.

What I am trying to do is read and parse lines in a csv file into java objects and I have succeeded in doing that but after it reads all the lines it should insert the lines into the database but it only inserts the 1st line the entire time and I don't no why. When I do a print it shows that it is reading all the lines and placing them in the objects but as soon as I do the insert it wants to insert only the 1st line.

Please see my code below:

public boolean lineReader(File file){
    BufferedReader br = null;
    String line= "";
    String splitBy = ",";
    storeList = new ArrayList<StoreFile>();

    try {

        br = new BufferedReader(new FileReader(file));
        while((line = br.readLine())!=null){
            line = line.replace('|', ',');
            //split on pipe ( | )
            String[] array = line.split(splitBy, 14);

            //Add values from csv to store object


            //Add values from csv to storeF objects
            StoreFile StoreF = new StoreFile();
            if (array[0].equals("H") || array[0].equals("T")) {
                return false;
            } else {
                StoreF.setRetailID(array[1].replaceAll("/", ""));
                StoreF.setChain(array[2].replaceAll("/",""));
                StoreF.setStoreID(array[3].replaceAll("/", ""));
                StoreF.setStoreName(array[4].replaceAll("/", ""));
                          StoreF.setAddress1(array[5].replaceAll("/", ""));
                          StoreF.setAddress2(array[6].replaceAll("/", ""));
                          StoreF.setAddress3(array[7].replaceAll("/", ""));
                          StoreF.setProvince(array[8].replaceAll("/", ""));
                          StoreF.setAddress4(array[9].replaceAll("/", ""));
                StoreF.setCountry(array[10].replaceAll("/", ""));
                          StoreF.setCurrency(array[11].replaceAll("/", ""));
                          StoreF.setAddress5(array[12].replaceAll("/", ""));                             
                StoreF.setTelNo(array[13].replaceAll("/", ""));

                //Add stores to list
                storeList.add(StoreF);

            }
        }              //print list stores in file

        printStoreList(storeList);
        executeStoredPro(storeList);

    } catch (Exception ex) {
        nmtbatchservice.NMTBatchService2.LOG.error("An exception accoured:  " + ex.getMessage(), ex);

                                    //copy to error folder
                                    //email
    }
    return false;
  }

  public void printStoreList(List<StoreFile> storeListToPrint) {
       for(int i = 0; i <storeListToPrint.size();i++){
      System.out.println( storeListToPrint.get(i).getRetailID()
                          +  storeListToPrint.get(i).getChain()
                          +  storeListToPrint.get(i).getStoreID()
                          +  storeListToPrint.get(i).getStoreName()
                          +  storeListToPrint.get(i).getAddress1()
                          +  storeListToPrint.get(i).getAddress2()
                          +  storeListToPrint.get(i).getAddress3()
                          +  storeListToPrint.get(i).getProvince()
                          +  storeListToPrint.get(i).getAddress4()
                          +  storeListToPrint.get(i).getCountry()
                          +  storeListToPrint.get(i).getCurrency()
                          +  storeListToPrint.get(i).getAddress5()                           
                          +  storeListToPrint.get(i).getTelNo());
                        }
                      }

public void unzip(String source, String destination) {
    try {
        ZipFile zipFile = new ZipFile(source);
        zipFile.extractAll(destination);
        deleteStoreFile(source);
    } catch (ZipException ex) {
        nmtbatchservice.NMTBatchService2.LOG.error("Error unzipping file :  " + ex.getMessage(), ex);
    }
}

public void deleteStoreFile(String directory) {
    try {
        File file = new File(directory);
        file.delete();
    } catch (Exception ex) {
        nmtbatchservice.NMTBatchService2.LOG.error("An exception accoured when trying to delete file " + directory + " : " + ex.getMessage(), ex);
    }
}


public void executeStoredPro(List<StoreFile> storeListToInsert) {
    Connection con = null;
    CallableStatement st = null;
    try {
        String connectionURL = MSSQLConnectionURL;
        Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver").newInstance();
        con = DriverManager.getConnection(connectionURL, MSSQLUsername, MSSQLPassword);
       for(int i = 0; i <storeListToInsert.size();i++){
        st = con.prepareCall( "IF EXISTS (SELECT * FROM tblPay@RetailStores WHERE StoreID = " + storeListToInsert.get(i).getStoreID() + " AND RetailID = "+ storeListToInsert.get(i).getRetailID() + ")" 
        + " UPDATE tblPay@RetailStores "
        + " SET RetailID = '" + storeListToInsert.get(i).getRetailID() + "',"  
        + " StoreID = '" + storeListToInsert.get(i).getStoreID()  + "',"
    + " StoreName = '" + storeListToInsert.get(i).getStoreName()  + "',"
    + " TestStore = 0,"
    + " Address1 = '" + storeListToInsert.get(i).getAddress1() + "',"
    + " Address2 = '" + storeListToInsert.get(i).getAddress2() + "',"  
    + " Address3 = '" + storeListToInsert.get(i).getAddress3() + "',"
    + " Address4 = '" + storeListToInsert.get(i).getAddress4()  + "'," 
    + " Address5 = '" + storeListToInsert.get(i).getAddress5() + "',"
    + " Province = '" + storeListToInsert.get(i).getProvince() + "',"
    + " TelNo = '" + storeListToInsert.get(i).getTelNo() + "',"
    + " Enabled = 1"   
        + " ELSE "        
        + " INSERT INTO tblPay@RetailStores ( [RetailID], [StoreID], [StoreName],  [TestStore], [Address1], [Address2],  [Address3],  [Address4], [Address5], [Province],  [TelNo] ,  [Enabled] ) "
        + " VALUES "        
        + "('" + storeListToInsert.get(i).getRetailID() + "',"  
        + "'"  + storeListToInsert.get(i).getStoreID()  + "',"
        + "'"  + storeListToInsert.get(i).getStoreName()  + "',"
        + "0,"
        + "'" + storeListToInsert.get(i).getAddress1() + "',"
        + "'" + storeListToInsert.get(i).getAddress2() + "',"    
        + "'" + storeListToInsert.get(i).getAddress3() + "',"
        + "'" + storeListToInsert.get(i).getAddress4()  + "',"   
        + "'" + storeListToInsert.get(i).getAddress5() + "',"   
        + "'" + storeListToInsert.get(i).getProvince() + "',"
        + "'" + storeListToInsert.get(i).getTelNo() + "',"
        + "1)"); 
        st.executeUpdate();

       }
        con.close();
    } catch (Exception ex) {
        nmtbatchservice.NMTBatchService2.LOG.error("Error executing Stored proc with error : " + ex.getMessage(), ex);
        nmtbatchservice.NMTBatchService2.mailingQueue.addToQueue(new Mail("[email protected]", "Service Email Error", "An error occurred during Store Import failed with error : " + ex.getMessage()));
    }
}

Any advise would be appreciated. Thanks

© Stack Overflow or respective owner

Related posts about java

Related posts about csv