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 {

	/** maximální doba trvání SQL dotazu – vteřiny */

	private static final int LIMIT_ČASU = 3;

	/** maximální počet řádků */

	private static final int LIMIT_POČTU = 10000;

	private enum VLASTNOSTI {

		VYCHOZI_CESTA,

		LIMIT_ČASU

	}

	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;

					}

					/**

					 * TODO:

					 * použít ps.setQueryTimeout(LIMIT_ČASU);

					 * až ho bude podporovat JDBC ovladač,

					 * viz níže.

					 * Uživatel ale stejně může zadat:

					 * SET statement_timeout 0;

					 * do svého SQL dotazu.

					 */

					if (getVlastnost(VLASTNOSTI.LIMIT_ČASU) != null) {

						sql = orizni(getVlastnost(VLASTNOSTI.LIMIT_ČASU)) + sql;

					}

					long casPred = System.currentTimeMillis();

					ps = db.prepareStatement(sql);

					/**

					 * Limit času bohužel není podporován JDBC ovladačem.

					 * Alespoň ne v postgresql-9.1-901.jdbc4.jar

					 * http://jdbc.postgresql.org/todo.html

					 * 

					 * TODO:

					 * ps.setQueryTimeout(LIMIT_ČASU);

					 */

					ps.setMaxRows(LIMIT_POČTU);

					boolean isRS = ps.execute();

					if (isRS) {

						rs = ps.getResultSet();

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

					}

					/**

					 * Ošetříme případ, kdy uživatel zadá SQL příkaz, který nevrací výsledkovou

					 * sadu.

					 * Typicky nastavení výchozího schématu: SET search_path = '…';

					 * Poznámka: jeden „SET search_path TO "…"“ se obvykle předřazuje uživatelskému

					 * SQL (viz PiskovisteDAO.xml).

					 */

					while (ps.getMoreResults() || ps.getUpdateCount() > -1) {

						rs = ps.getResultSet();

						if (rs == null) {

							/** Jedná se o „update count“. */

						} else {

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

				}

			}

			/** Tip pro uživatele */

			String tip = tipy.getTip();

			if (tip != null) {

				v.getHlasky().add(new Hlaska(tip, 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;

	}

}