Main.java

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.sql.*;
import java.text.ParseException;
import java.time.LocalDate;
import java.time.Period;
import java.time.format.DateTimeFormatter;
import java.util.Locale;
import java.util.Objects;
import java.util.Scanner;
abstract class car{
    String car_no;
    String model;
    int availability;
    int charges;

    public car(String car_no, String model, int availability, int charges) {
        this.car_no = car_no;
        this.model = model;
        this.availability = availability;
        this.charges = charges;
    }
    public abstract void discount();
}
class discountCar extends car{
    public discountCar(String car_no, String model, int availability, int charges) {
        super(car_no, model, availability, charges);
    }

    public void discount(){
        charges = charges/2;
    }
}

class customer{
    int cust_id;
    String name;
    String address;
    String phone_no;

    public customer(int cust_id, String name, String address, String phone_no) {
        this.cust_id = cust_id;
        this.name = name;
        this.address = address;
        this.phone_no = phone_no;
    }
}
class rental{
    int cust_id;
    String car_no;
    String start;
    String end;
    int total_fee;

    public rental(int cust_id, String car_no, String start, String end) {
        this.cust_id = cust_id;
        this.car_no = car_no;
        this.start = start;
        this.end = end;
    }
}
class ConnectionFactory {
    public static Connection createConnection() throws ClassNotFoundException, SQLException {
        String url ="jdbc:mysql://localhost:3306/project";
        String uname = "root";
        String password ="MySQL&9146";
        Class.forName("com.mysql.cj.jdbc.Driver");
        return DriverManager.getConnection(url,uname,password);
    }
}

public class Main {
    public static void initialize() {
        try {
            Connection con = ConnectionFactory.createConnection();
            Statement st = con.createStatement();
            String query = "CREATE TABLE customer (cust_id int, name VARCHAR(20),address VARCHAR(100),phone_no varchar(10));";
            String query2 = "CREATE TABLE cars (car_no varchar(10), model VARCHAR(20),availability TINYINT(1),charges int);";
            String query3 = "CREATE TABLE rental (cust_id int,car_no varchar(10),start DATE,end DATE,total_fee int);";
            st.execute(query);
            st.execute(query2);
            st.execute(query3);
            String file = "carData.csv";
            Scanner sin = new Scanner(new BufferedReader(new FileReader(file)));
            String str = "";
            while (sin.hasNext()) {
                str = sin.nextLine();
                String[] tokens = str.split(",");
                PreparedStatement ps = con.prepareStatement("insert into cars(car_no,model,availability,charges) values(?,?,?,?)");
                ps.setString(1, tokens[0]);
                ps.setString(2, tokens[1]);
                ps.setString(3, tokens[2]);
                ps.setString(4, tokens[3]);
                ps.executeUpdate();
                st.close();
            }
            System.out.println("Program initialised! tables have been made !");
        }
        catch (Exception e){
            System.out.println("Program have already been initialised! ");
        }
    }
    public static void printHelp(){
        System.out.println("Help for commands:");
        System.out.println("| -initialize | to initializing the program");
        System.out.println("| -register <name> <address> <mobile no> | to make an account");
        System.out.println("| -booking <Cust_id> <Car_no> <start date> <end date> | to book a car, date should be in format(yyyy-MM-dd)");
        System.out.println("| -cancel <Cust_id> <Car_no> | to cancel your car booking");
        System.out.println("| -searchLessThanAmount <Amount> | to search for car less that cetain amount of rent ");
        System.out.println("| -searchFirstName <FirstName> | to search customer using first name");

    }

    public static void register(String[] args) throws SQLException, ClassNotFoundException, IOException {
        Connection con = ConnectionFactory.createConnection();
        Statement st = con.createStatement();
        Statement st2 = con.createStatement();
        String query = "select max(cust_id) from customer;";
        String query2 = "select * from customer;";

        ResultSet rs = st.executeQuery(query);
        ResultSet rs2 = st2.executeQuery(query2);

        rs.next();
        int maxId = rs.getInt("max(cust_id)");
        int valid = 1;
        while(rs2.next()){
            String name = rs2.getString("name");
            String phoneNo = rs2.getString("phone_no");
            if(Objects.equals(args[1], name) && Objects.equals(args[3], phoneNo)){
                System.out.println("User is already registered ! ");
                valid = 0;
                break;
            }
        }
        if(valid == 1){
            PreparedStatement ps = con.prepareStatement("insert into customer(cust_id, name,address,phone_no) values(?,?,?,?)");
            ps.setInt(1, maxId+1);
            ps.setString(2, args[1]);
            ps.setString(3, args[2]);
            ps.setString(4, args[3]);
            ps.executeUpdate();
            System.out.println("Registration done !");
            st.close();
        }
    }
    public static void booking(String[] args) throws SQLException, ClassNotFoundException, IOException, ParseException {
        Connection con = ConnectionFactory.createConnection();
        Statement st3 = con.createStatement();
        Statement st4 = con.createStatement();
        Statement st5 = con.createStatement();

        String query3 = "select max(cust_id) from customer;";
        String query4 = "select * from rental;";
        String query5 = "select * from cars;";

        ResultSet rs3 = st3.executeQuery(query3);
        ResultSet rs4 = st4.executeQuery(query4);
        ResultSet rs5 = st5.executeQuery(query5);

        rs3.next();
        int maxId = rs3.getInt("max(cust_id)");
        int valid = 1;
        int good =0;
        int x= Integer.parseInt(args[1]);
        while(rs5.next()){
            String car_no = rs5.getString("car_no");
            if(x<maxId && car_no.equals(args[2])){
                good =1;
                break;
            }
        }
        if(good == 1){
            while (rs4.next()) {
                String car_no = rs4.getString("car_no");
                Date start = rs4.getDate("start");
                Date end = rs4.getDate("end");
                if (car_no.equals(args[2])) {
                    System.out.println("Sorry, Car is not available(booked)");
                    valid = 0;
                    break;
                } else {
                    valid = 1;
                }
            }
            if (valid == 1) {
                PreparedStatement ps1 = con.prepareStatement("insert into rental(cust_id, car_no,start,end,total_fee) values(?,?,?,?,?)");

                int charges = rs5.getInt("charges");

                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd", Locale.ENGLISH);
                LocalDate start = LocalDate.parse(args[3], formatter);
                LocalDate end = LocalDate.parse(args[4], formatter);
                Period period = Period.between(start, end);
                int aa = period.getDays() * charges;
                ps1.setInt(1, x);
                ps1.setString(2, args[2]);
                ps1.setString(3, args[3]);
                ps1.setString(4, args[4]);
                ps1.setInt(5, aa);
                ps1.executeUpdate();
                System.out.println("Car Booked");

                st3.close();
            }
        }
        else{
            System.out.println("[INVALID] \ncustomer Id or Car number is wrong ! you seems sus ");
        }

    }
    public static void searchFirstName(String[] args) throws Exception{
        Connection con = ConnectionFactory.createConnection();
        String query = "select * from customer ;";
        PreparedStatement stmt = con.prepareStatement(query);
        ResultSet rs = stmt.executeQuery(query);
        int valid=0;
        while(rs.next()) {
            String name = rs.getString("name");
            if(Objects.equals(args[1], name)){
                System.out.println("Customer found");
                System.out.println(" cust_id:"+rs.getInt("cust_id")+ "\n name:" +rs.getString("name") +"\n address:" +rs.getString("address") + "\n ph_no:" +rs.getString("phone_no"));
                valid=1;
            }
        }
        if(valid ==0){
            System.out.println("Customer with that first name is not found");
        }

    }

    public static void carAmountLessThan(String[] args) throws Exception{
        Connection con = ConnectionFactory.createConnection();
        String query = "select * from cars";
        PreparedStatement stmt = con.prepareStatement(query);
        ResultSet rs = stmt.executeQuery(query);
        int found=0;
        while(rs.next()){
            int charges = rs.getInt("charges");
            int prop_amount = Integer.parseInt(String.valueOf(args[1]));
            int k = Integer.compare(prop_amount, charges);

            if(k>0)
            {
                System.out.println("Cars are found !!!");
                System.out.println(" car_no:"+rs.getString("car_no")+ "\n Model:" +rs.getString("model") +"\n Availability:" +rs.getInt("availability")+"\n Price:" +rs.getInt("charges"));
                found=1;
            }
        }
        if(found ==0 ){
            System.out.println("Cars are not not available for renting with the proposed amount");
        }

    }

    public static void cancel(String[] args) throws SQLException, ClassNotFoundException, IOException {
        Connection con = ConnectionFactory.createConnection();
        Statement st = con.createStatement();

        String query = "select * from rental;";

        ResultSet rs = st.executeQuery(query);

        int valid =0;
        while(rs.next()){
            int cust_id= rs.getInt("cust_id");
            int x=Integer.parseInt(args[1]);
            String car_no= rs.getString("car_no");
            if(x!=cust_id && !(Objects.equals(args[2], car_no))){
                System.out.println("Car is not booked on ur cust_id\n");
                valid = 0;
                break;
            }
            else{
                valid=1;
            }
        }
        if(valid ==1){
            PreparedStatement ps = con.prepareStatement("delete from rental where cust_id=? and car_no=?");
            ps.setInt(1, Integer.parseInt(args[1]));
            ps.setString(2, args[2]);
            ps.executeUpdate();
            System.out.println("Registration Cancelled");
            st.close();
        }
    }

    public static void main(String[] args){
        switch (args[0]) {
            case "-initialize":
                initialize();
                break;
            case "-register":
                try {
                    register(args);
                }
                catch(Exception a){
                    a.printStackTrace();
                }
                break;
            case "-booking":
                try{
                    booking(args);
                }
                catch (Exception a){
                    a.printStackTrace();
                }
                break;
            case "-searchFirstName":
                try{
                    searchFirstName(args);
                }
                catch (Exception a){
                    a.printStackTrace();
                }
                break;
            case "-carAmountLessThan":
                try{
                    carAmountLessThan(args);
                }
                catch (Exception a){
                    a.printStackTrace();
                }
                break;
            case "-cancel":
                try{
                    cancel(args);
                }
                catch (Exception a){
                    a.printStackTrace();
                }
                break;
            default:
                printHelp();
                break;
        }
    }
}