/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package kjnkfdsf;

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JOptionPane;

/**
 *
 * @author fis4u
 */
public class Konekcja {
    Connection con;
    boolean connected = false;
    boolean created = false;

    public boolean isConnected() {
        return connected;
    }

    public boolean isCreated() {
        return connected;
    }

    private void connectDatabase() {
        try {
            // Stworzenie połączenia
            con = DriverManager.getConnection("jdbc:sqlite:moja_baza.db");

            // Pobranie meta danych bazy
            DatabaseMetaData dbm = con.getMetaData();
            try (
                // Pobranie tabeli
                ResultSet tables = dbm.getTables(null, null, "uzytkownicy", null)) {
                created = tables.next();
            }

            connected = true;

            System.out.println("Udało się połączyć z bazą!");
        } catch (SQLException ex) {
            JOptionPane.showMessageDialog(null, "Nie udało się połączyć z bazą!");
        }
    }

    private void disconnectDatabase() {
        try {
            con.close();
            connected = false;
        } catch (SQLException ex) {
            JOptionPane.showMessageDialog(null, "Nie udało się rozłączyć!");
        }
    }

    void addRecord(String login) {
        if(login.isEmpty()) {
            JOptionPane.showMessageDialog(null, "Oba pola muszą być wypełnione!");
        }

        connectDatabase();

        if(!isConnected()) {
            JOptionPane.showMessageDialog(null, "Nie udało się połączyć z bazą!");
        }

        if(!isCreated()) {
            JOptionPane.showMessageDialog(null, "Tabela nie istnieje w bazie!");
        } else {
            try {
                Statement st = con.createStatement();
                st.executeUpdate("INSERT INTO uzytkownicy (login) VALUES ('" + login + "')");
                st.close();

                JOptionPane.showMessageDialog(null, "Udało się dodać do bazy!");
            } catch (SQLException ex) {
                Logger.getLogger(Konekcja.class.getName()).log(Level.SEVERE, null, ex);
            }
        }

        disconnectDatabase();
    }

    void selectAll() {
        connectDatabase();

        if(!isConnected()) {
            JOptionPane.showMessageDialog(null, "Nie udało się połączyć z bazą!");
        }

        if(!isCreated()) {
            JOptionPane.showMessageDialog(null, "Tabela nie istnieje w bazie!");
        } else {
            Statement st;
            try {
                st = con.createStatement();
                ResultSet result = st.executeQuery("SELECT * FROM uzytkownicy");
                String finali = new String();

                while(result.next()) {
                    String val = result.getString(1) + ". " + result.getString(2) + " " + result.getString(3) + " " + result.getString(4) + "\n";
                    finali += val;
                }

                JOptionPane.showMessageDialog(null, finali);
                st.close();
                result.close();
            } catch (SQLException ex) {
                Logger.getLogger(Konekcja.class.getName()).log(Level.SEVERE, null, ex);
            }
        }

        disconnectDatabase();
    }

    void createTable() {
        connectDatabase();

        if(!isConnected()) {
            JOptionPane.showMessageDialog(null, "Nie udało się połączyć!");
        }

        if(isCreated()) {
            JOptionPane.showMessageDialog(null, "Tabela już istnieje w bazie!");
        } else {
            try {
                Statement st = con.createStatement();
                String query = "CREATE TABLE uzytkownicy ("
                             + "id INTEGER PRIMARY KEY AUTOINCREMENT,"
                             + "login TEXT NOT NULL,"
                             + "haslo TEXT,"
                             + "rola INTEGER)";
                st.executeUpdate(query);
                st.close();

                JOptionPane.showMessageDialog(null, "Stworzono tabele!");
                created = true;
            } catch (SQLException ex) {
                JOptionPane.showMessageDialog(null, "Nie udało się stworzyć tabeli!");
            }
        }

        disconnectDatabase();
    }
}