// Main

import java.util.ArrayList;

public class Main {

    public static void main(String[] args) {
        Statybininkai statybininkai1 = new Statybininkai("Kristina", "Dubikoviene",3, "Spakliuotoja", "Pasaulis");

        //1. Įterpimas
        //StatybininkaiDAO.insert(statybininkai1);

        //2. Paieška
        ArrayList<Statybininkai> statybininkai3 = StatybininkaiDAO.searchById(6);

        System.out.println("Spausdinamas Array Listas: "+ "statybininkai3");

        Statybininkai statybininkaiDB=statybininkai3.get(0);
        statybininkaiDB.setVardas ("Petras");
        StatybininkaiDAO.update(statybininkaiDB);

        //4. Trynimas
        StatybininkaiDAO.delete(6);

        // 5. Metodas, kuris gražina statybinkų kiekį su tam tikru stažu
        System.out.println("Statybinikai su " + 5 + "metų stažu: " + StatybininkaiDAO.statybininkuStazoMetai(3));
    }
}

// ==============================================================================
// StatybininkaiDAO

import java.sql.*;
import java.util.ArrayList;

public class StatybininkaiDAO {

    //1. Įterpimas
    public static void insert(Statybininkai statybininkai1) {
        String url = "jdbc:mysql://localhost:3306/darbenai";
        String query = "INSERT INTO statybininkai"
                + "(vardas, pavarde, stazas, pareigos, darboviete )"
                + "VALUES (?,?,?,?,?)";
        try {
            Connection connection = DriverManager.getConnection(url, "root", "");
            PreparedStatement statement = connection.prepareStatement(query);

            statement.setString(1, statybininkai1.getVardas());
            statement.setString(2, statybininkai1.getPavarde());
            statement.setInt(3, statybininkai1.getStazas());
            statement.setString(4, statybininkai1.getPareigos());
            statement.setString(5, statybininkai1.getDarboviete());

            statement.executeUpdate();
            statement.close();
            System.out.println("Naujas statybininkas įterpta sėkmingai");
        } catch (SQLException e) {
            System.out.println("Naujo įrašo įterpti nepavyko");
            e.printStackTrace();
        }
    }

    // 2. Paieška
    public static ArrayList<Statybininkai> searchById(int id){

        String query = "SELECT * FROM statybininkai WHERE id = ?";
        String url = "jdbc:mysql://localhost:3306/darbenai";

        ArrayList <Statybininkai> statybininkai2= new ArrayList<Statybininkai>();
        try {

            Connection connection = DriverManager.getConnection(url, "root", "");
            PreparedStatement statement = connection.prepareStatement(query);
            statement.setInt(1, id);

            ResultSet statybininkuRinkinys = statement.executeQuery();

            while(statybininkuRinkinys.next()){
                statybininkai2.add(new Statybininkai(

                        statybininkuRinkinys.getString("vardas"),
                        statybininkuRinkinys.getString("pavarde"),
                        statybininkuRinkinys.getInt("stazas"),
                        statybininkuRinkinys.getString("pareigos"),
                        statybininkuRinkinys.getString("darboviete"),
                        statybininkuRinkinys.getInt("id")
                ));
            }
            statement.close();
            // System.out.println(rs.getString("name"));
            statement.close();
            System.out.println("Jūsų paieškos užklausa įvykdyta sėkmingai");
        } catch (SQLException e) {
            System.out.println("Rasti nepavyko");
            e.printStackTrace();
        }
        return  statybininkai2;
    }


    //3. Koregavimas
    public static void update( Statybininkai statybininkai1) {

        String query = "UPDATE statybininkai SET vardas = ?, pavarde = ?, stazas = ?, pareigos = ?, darboviete=? WHERE id = ?";

        String url = "jdbc:mysql://localhost:3306/darbenai";

        try {
            Connection connection = DriverManager.getConnection(url, "root", "");
            PreparedStatement statement = connection.prepareStatement(query);

            statement.setString(1, statybininkai1.getVardas());
            statement.setString(2, statybininkai1.getPavarde());
            statement.setInt(3, statybininkai1.getStazas());
            statement.setString(4, statybininkai1.getPareigos());
            statement.setString(5, statybininkai1.getDarboviete());
            statement.setInt(5, statybininkai1.getId());

            statement.executeUpdate();
            statement.close();
            System.out.println("Naujas įrašas pakeistas sėkmingai");
        } catch (SQLException e) {
            System.out.println("Įrašo pakeisti nepavyko");
            e.printStackTrace();
        }
    }

    //4. Trynimas
    public static void delete(int id) {
        String query = "DELETE FROM statybininkai WHERE id=?";

        String url = "jdbc:mysql://localhost:3306/darbenai";

        try {

            Connection connection = DriverManager.getConnection(url, "root", "");
            PreparedStatement statement = connection.prepareStatement(query);

            statement.setInt(1, id);

            statement.executeUpdate();
            statement.close();
            System.out.println("Įrašas ištrintas sėkmingai");
        } catch (SQLException e) {
            System.out.println("Įrašo ištrinti nepavyko");
            e.printStackTrace();
        }
    }

    //5. Metodas, kuris gražina statybinkų kiekį su tam tikru stažu
    public static int statybininkuStazoMetai(int metai){
        String query = "SELECT COUNT(*) as statybininku_kiekis FROM statybininkai WHERE stazas = ?";
        String url = "jdbc:mysql://localhost:3306/darbenai";
        int statybininku_kiekis = 0;
        try {
            Connection jungtis = DriverManager.getConnection(url, "root", "");
            PreparedStatement st = jungtis.prepareStatement(query);
            st.setInt(1, metai);
            ResultSet rezultatuRinkinys = st.executeQuery();
            if(rezultatuRinkinys.next())
                statybininku_kiekis = rezultatuRinkinys.getInt("statybininku_kiekis");
            else
                System.out.println("Statybininkų metų užklausa nepavyko");
            System.out.println("Statybininkų metų užklausa pavyko");
        } catch (SQLException e) {
            System.out.println("Statybininkų metų užklausa nepavyko");
            e.printStackTrace();
        }
        return statybininku_kiekis;
    }
}