package pkjio;

import db.DB;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.StringWriter;
import log.ErrorLog;

public class TessToCSV {
    StringWriter errors = new StringWriter();
    public TessToCSV(boolean toDB){
        String vOutputFileName = "C://Temp//Javacode//myfile.csv";
        String vInputFileName = "C://Temp//Javacode//AirPagssangers.txt";
        try {
            BufferedReader br = new BufferedReader(new FileReader(vInputFileName));
            String data = ",";
            int begin = 0;
            int end = 3;
            String months = br.readLine().toString();
                for(int i=0; i<=11; i++){
                    data += months.substring(begin, end) + ",";
                    begin = end;
                    end += 3;
                }
             new TestWriter2(vOutputFileName, data.toString());

            data = "";

            for(String line; (line = br.readLine()) != null; ) {
                begin = 0;
                end = 4;
                String vtoTable = "";
                for(int i=0; i<=12; i++){
                    if(toDB){
                        vtoTable += "'" + line.substring(begin, end).toString() + "', ";
                    }
                    data += line.substring(begin, end) + ",";
                    begin = end;
                    end += 3;
                }
                new TestWriter2(vOutputFileName, data.toString());
                data = "";
                if(toDB){
                    doInserData(vtoTable.substring(0, vtoTable.length() -2));
                }
            }

        } catch(IOException e){
           doPrintLog(e);
        }
    }


    public void doInserData(String vdata){
        DB db = new DB();
        String vSQL = "INSERT INTO ap ";
        vSQL += "( Year, Jan, Feb, Mar, Apr, May, Jun, Jul, Aug, Sep, Oct, Nov, `Dec` ) ";
        vSQL += " VALUES ( "  + vdata + ")";

        System.out.println(vSQL);
        try {
             db.ExcuteSQL(vSQL);
        }catch(Exception e){
            e.printStackTrace();
        } finally{
            db.doClose();
        }
    }
    private void doPrintLog(Exception e){
      e.printStackTrace(new PrintWriter(errors));
      new ErrorLog(errors.toString());
    }
}