// MAIN.java

import java.util.ArrayList;
public class Main {
    public static void main(String[] args) {

        // 1. Sukurti naują statybiniką ir išsaugoti duomenų bazėje
        Statybininkas statybininkas = new Statybininkas(5, "Mintautas", "Jurmalavičius",
                                            1, "Akmentašys", "Dainava");
        StatybininkasDAO.insert(statybininkas);

        // 2. Atlikti paiešką pagal pareigas
        ArrayList<Statybininkas> plytelčikai = StatybininkasDAO.searchByPareigos("Plytelčikas");
        System.out.println("Spausdinamas Array Listas: " + plytelčikai);

        // 3. Galimybė redaguoti įrašą
        Statybininkas pirmasPlytelčikas = plytelčikai.get(0);
        System.out.println("PirmasPlytelčikas prieš update: " + pirmasPlytelčikas);
        pirmasPlytelčikas.setDarboviete("Kolūkis");
        StatybininkasDAO.update(pirmasPlytelčikas);

        plytelčikai = StatybininkasDAO.searchByPareigos("Plytelčikas");
        pirmasPlytelčikas = plytelčikai.get(0);
        System.out.println("PirmasPlytelčikas po update: " + pirmasPlytelčikas);

        // 4. Įrašo trynimas iš lentelės
        StatybininkasDAO.delete(5);

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

// Statybininkas.java

public class Statybininkas {
    private int id;
    private String vardas;
    private String pavarde;
    private int stazas;
    private String pareigos;
    private String darboviete;

    //Reikalingas naudojant search, edit, delete bei naujo įrašo kūrimui
    public Statybininkas(int id, String vardas, String pavarde, int stazas, String pareigos, String darboviete) {
        this.id = id;
        this.vardas = vardas;
        this.pavarde = pavarde;
        this.stazas = stazas;
        this.pareigos = pareigos;
        this.darboviete = darboviete;
    }

    // getteriai ir setteriai
    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getVardas() {
        return vardas;
    }

    public void setVardas(String vardas) {
        this.vardas = vardas;
    }

    public String getPavarde() {
        return pavarde;
    }

    public void setPavarde(String pavarde) {
        this.pavarde = pavarde;
    }

    public int getStazas() {
        return stazas;
    }

    public void setStazas(int stazas) {
        this.stazas = stazas;
    }

    public String getPareigos() {
        return pareigos;
    }

    public void setPareigos(String pareigos) {
        this.pareigos = pareigos;
    }

    public String getDarboviete() {
        return darboviete;
    }

    public void setDarboviete(String darboviete) {
        this.darboviete = darboviete;
    }

    @Override
    public String toString() {
        return "Statybininkas {" +
                "id=" + id +
                ", vardas='" + vardas + '\'' +
                ", pavarde='" + pavarde + '\'' +
                ", stazas=" + stazas +
                ", pareigos='" + pareigos + '\'' +
                ", darboviete='" + darboviete + '\'' +
                '}';
    }
}

// StatybininkasDAO.java

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

public class StatybininkasDAO {
    public static void insert(Statybininkas statybininkas) {
        String query = "INSERT INTO statybininkai (id, vardas, pavarde, stazas, pareigos, darboviete) VALUES (?,?,?,?,?,?)";
        String url = "jdbc:mysql://localhost:3306/darbenai?useUnicode=true&characterEncoding=UTF-8";
        try {
            Connection jungtis = DriverManager.getConnection(url, "root", "");
            PreparedStatement st = jungtis.prepareStatement(query);
            st.setInt(1, statybininkas.getId());
            st.setString(2, statybininkas.getVardas());
            st.setString(3, statybininkas.getPavarde());
            st.setInt(4, statybininkas.getStazas());
            st.setString(5, statybininkas.getPareigos());
            st.setString(6, statybininkas.getDarboviete());
            st.executeUpdate();
            st.close(); // uzdaroma prisijungimas prie db
            System.out.println("Duomenys įterpti sekmingai");
        } catch (SQLException e) {
            System.out.println("Klaida įterpiant duomenis");
            e.printStackTrace();
        }
    }

    public static ArrayList<Statybininkas> searchByPareigos(String pareigos) {
        String query = "SELECT * FROM statybininkai WHERE pareigos = ? ORDER BY darboviete ASC";
        String url = "jdbc:mysql://localhost:3306/darbenai?useUnicode=true&characterEncoding=UTF-8";
        ArrayList<Statybininkas> statybinikai = new ArrayList<>();
        try {
            Connection jungtis = DriverManager.getConnection(url, "root", "");
            PreparedStatement st = jungtis.prepareStatement(query);
            st.setString(1, pareigos);
            ResultSet rezultatuRinkinys = st.executeQuery();
            while (rezultatuRinkinys.next()){
                statybinikai.add(new Statybininkas(
                        // int id, String vardas, String pavarde, int stazas, String pareigos, String darboviete
                        rezultatuRinkinys.getInt("id"),
                        rezultatuRinkinys.getString("vardas"),
                        rezultatuRinkinys.getString("pavarde"),
                        rezultatuRinkinys.getInt("stazas"),
                        rezultatuRinkinys.getString("pareigos"),
                        rezultatuRinkinys.getString("darboviete")
                ));
            }
            st.close(); // uzdaroma prisijungimas prie db
            System.out.println("Paieska pagal pareigas ivykdyta sekmingai");
        } catch (SQLException e) {
            System.out.println("Paieska nesekminga");
            e.printStackTrace();
        }
        return statybinikai;
    }

    public static void update(Statybininkas statybininkas) {
        // int id, String vardas, String pavarde, int stazas, String pareigos, String darboviete
        String query = "Update statybininkai SET id=?, vardas=?, pavarde=?, stazas=?, pareigos=?, darboviete=? WHERE id=?";
        String url = "jdbc:mysql://localhost:3306/darbenai?useUnicode=true&characterEncoding=UTF-8";
        try {
            Connection jungtis = DriverManager.getConnection(url, "root", "");
            PreparedStatement st = jungtis.prepareStatement(query);
            st.setInt(1, statybininkas.getId());
            st.setString(2, statybininkas.getVardas());
            st.setString(3, statybininkas.getPavarde());
            st.setInt(4, statybininkas.getStazas());
            st.setString(5, statybininkas.getPareigos());
            st.setString(6, statybininkas.getDarboviete());
            // WHERE sąlygos ID
            st.setInt(7, statybininkas.getId());
            st.executeUpdate();
            st.close(); // uzdaroma prisijungimas prie db
            System.out.println("Duomenys redaguoti sekmingai");
        } catch (SQLException e) {
            System.out.println("Duomenų redagavimas nepavyko");
            e.printStackTrace();
        }
    }
    public static void delete(int id) {
        String query = "DELETE FROM statybininkai WHERE id=?";
        String url = "jdbc:mysql://localhost:3306/darbenai?useUnicode=true&characterEncoding=UTF-8";
        try {
            Connection jungtis = DriverManager.getConnection(url, "root", "");
            PreparedStatement st = jungtis.prepareStatement(query);
            st.setInt(1, id);
            st.executeUpdate();
            st.close(); // uzdaroma prisijungimas prie db
            System.out.println("Duomenys ištrinti sėkmingai");
        } catch (SQLException e) {
            System.out.println("Duomenų ištrinti nepavyko");
            e.printStackTrace();
        }
    }

    public static int statybininkuStazoMetai(int metai){
        String query = "SELECT COUNT(*) as statybininku_kiekis FROM statybininkai WHERE stazas = ?";
        String url = "jdbc:mysql://localhost:3306/darbenai?useUnicode=true&characterEncoding=UTF-8";
        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;
    }
}