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 {

    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 {
                    ps = db.prepareStatement(sql);
                    boolean isRS = ps.execute();

                    if (isRS) {
                        rs = ps.getResultSet();
                        v.getTabulky().add(zpracujVysledek(rs));

                        while (ps.getMoreResults()) {
                            rs = ps.getResultSet();
                            v.getTabulky().add(zpracujVysledek(rs));
                        }
                    } else {
                        /** TODO: zobrazit počet aktualizovaných? */
                        v.getHlasky().add(new Hlaska("SQL příkaz byl proveden, ale nevrátil žádná data.", Typ.Varovani));
                    }

                } 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;
    }
}