package cz.frantovo.sql.vyuka.dao;

import cz.frantovo.sql.vyuka.dao.VyukaSuperDAO.DATABAZE;

import cz.frantovo.sql.vyuka.dto.Hlaska;

import cz.frantovo.sql.vyuka.dto.Hlaska.Typ;

import cz.frantovo.sql.vyuka.dto.Tabulka;

import cz.frantovo.sql.vyuka.dto.Uzivatel;

import cz.frantovo.sql.vyuka.dto.VysledekSQL;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.logging.Level;

/**

 * Pro spouštění uživatelových příkazů.

 * @author fiki

 */

public class PiskovisteDAO extends VyukaSuperDAO {

    private enum VLASTNOSTI {

        VYCHOZI_CESTA

    }

    TipyDAO tipy = new TipyDAO();

    HistorieDAO historie = new HistorieDAO();

    public VysledekSQL vykonejSQL(String sql, Uzivatel uzivatel) {

        VysledekSQL v = new VysledekSQL();

        if (historie.ulozPrikaz(sql, uzivatel)) {

            Connection db = getSpojeni(DATABAZE.PISKOVISTE);

            if (db == null) {

                v.getHlasky().add(new Hlaska("Došlo k chybě spojení.", Typ.Chyba));

            } else {

                PreparedStatement ps = null;

                ResultSet rs = null;

                try {

                    /**

                     * Uživatelskému SQL příkazu předřadíme výchozí cestu (search_path).

                     * Protože uživatelé si ji mohou měnit a kvůli recyklaci databázových zdrojů

                     * by jeden uživatel mohl ovlivnit jiného.

                     */

                    if (getVlastnost(VLASTNOSTI.VYCHOZI_CESTA) != null) {

                        sql = orizni(getVlastnost(VLASTNOSTI.VYCHOZI_CESTA)) + sql;

                    }

                    long casPred = System.currentTimeMillis();

                    ps = db.prepareStatement(sql);

                    boolean isRS = ps.execute();

                    if (isRS) {

                        rs = ps.getResultSet();

                        v.getTabulky().add(zpracujVysledek(rs));

                    }

                    /** TODO: ošetřit případ, kdy vykonáme dva příkazy bez výsledkové sady a třetí příkaz ji už má (teď se nezobrazí výsledná tabulka). */

                    while (ps.getMoreResults()) {

                        rs = ps.getResultSet();

                        v.getTabulky().add(zpracujVysledek(rs));

                    }

                    long dobaProvadeni = System.currentTimeMillis() - casPred;

                    /** Varování */

                    if (v.getHlasky().size() < 1 && v.getTabulky().size() < 1) {

                        v.getHlasky().add(new Hlaska("SQL příkaz proběhl, ale nevrátil žádná data.", Typ.Varovani));

                    }

                    /** Varování */

                    int pocitadloTabulek = 1;

                    for (Tabulka t : v.getTabulky()) {

                        if (t.getHodnoty().size() < 1) {

                            v.getHlasky().add(new Hlaska("Tabulka " + pocitadloTabulek + "  je prázdná.", Typ.Varovani));

                        }

                        pocitadloTabulek++;

                    }

                    v.getHlasky().add(new Hlaska("SQL příkaz byl proveden úspěšně, během " + dobaProvadeni + " ms.", Typ.OK));

                } catch (SQLException e) {

                    log.log(Level.SEVERE, "SQL chyba při vykonávání uživatelského dotazu.", e);

                    v.getHlasky().add(new Hlaska("Chybné SQL: " + e.getMessage(), Typ.Chyba));

                } catch (Exception e) {

                    log.log(Level.SEVERE, "Chyba při vykonávání uživatelského dotazu.", e);

                    v.getHlasky().add(new Hlaska("Došlo k chybě dotazu.", Typ.Chyba));

                } finally {

                    zavri(db, ps, rs);

                }

            }

            v.getHlasky().add(new Hlaska(tipy.getTip(), Typ.Tip, false));

        } else {

            v.getHlasky().add(new Hlaska("Došlo k chybě historie.", Typ.Chyba));

        }

        return v;

    }

    private Tabulka zpracujVysledek(ResultSet rs) throws SQLException {

        Tabulka t = new Tabulka();

        int pocetSloupecku = rs.getMetaData().getColumnCount();

        String[] zahlavi = new String[pocetSloupecku];

        t.setZahlavi(zahlavi);

        for (int i = 0; i < pocetSloupecku; i++) {

            zahlavi[i] = rs.getMetaData().getColumnName(i + 1);

        }

        while (rs.next()) {

            Object[] hodnoty = new Object[pocetSloupecku];

            for (int i = 0; i < pocetSloupecku; i++) {

                hodnoty[i] = rs.getObject(i + 1);

            }

            t.getHodnoty().add(hodnoty);

        }

        return t;

    }

}