package carRentalRefactoring;

import com.opencsv.CSVReader;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.io.*;
import java.sql.PreparedStatement;

public class CSVFileReader {

	public static final String csvFile = "C:\\Users\\crm0093\\workspace\\car_data.csv";

    public static void main(String[] args) {

        Connection connection = null;
        Statement statement = null;

        String url = "jdbc:oracle:thin:@localhost:1521:xe";
        String user = "admin_01";
        String password = "admin";
		int totalcount = 0;
        try {

			CSVReader reader = new CSVReader(new FileReader(csvFile),';');
			String[] nextLine;

			connection = DriverManager.getConnection(url, user, password);
			statement = connection.createStatement();
			PreparedStatement executeQuery = connection.prepareStatement(getQuery());

			while ((nextLine = reader.readNext()) != null) {
				if(isValid(nextLine)) {
					executeQuery.setString(1, nextLine[0]);
					executeQuery.setInt(2, Integer.parseInt(nextLine[1]));
					executeQuery.setInt(3, Integer.parseInt(nextLine[2]));
					executeQuery.setFloat(4, Float.parseFloat(nextLine[3]));
					executeQuery.setInt(5, Integer.parseInt(nextLine[4]));
					executeQuery.setInt(6, Integer.parseInt(nextLine[5]));
					executeQuery.executeUpdate();
				}
				totalcount++;
			}
			reader.close();
        } catch (SQLException ex) {
            Logger logger = Logger.getLogger(CSVReader.class.getName());
            logger.log(Level.SEVERE, ex.getMessage(), ex);

        	} catch(Exception e){
        		e.printStackTrace();
        	} finally {
        			try {
        				if (statement != null) {
        					statement.close();
        				}
        				if (connection != null) {
        					connection.close();
        				}

            } catch (SQLException ex) {
                Logger logger = Logger.getLogger(CSVReader.class.getName());
                logger.log(Level.WARNING, ex.getMessage(), ex);
            }
        }
		System.out.println(totalcount);
    }

    private static String getQuery() {
    	return "insert into CARS(registration_number,current_mileage,daily_rate,engine_size,production_year,year_rating)"
    			+"values(?,?,?,?,?,?)";
    }


    private static boolean isValid(String[] values) {
		if(values[0] == null ||
				Integer.parseInt(values[1]) < 0 ||
				Integer.parseInt(values[2])  < 0||
				Float.parseFloat(values[3]) < 0 ||
				Integer.parseInt(values[4]) < 0 ||
				Integer.parseInt(values[5]) < 0)
			throw new IllegalArgumentException("Input is too small.");
		return true;
	}
}