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;

     }

 }