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)) {






            Tabulka t = new Tabulka();



            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);
                    rs = ps.executeQuery();

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

                    if (t.getHodnoty().size() > 0 && pocetSloupecku > 0) {

                        v.getTabulky().add(t);
                    } else {
                        v.getHlasky().add(new Hlaska("SQL příkaz byl proveden.", 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;
    }
}