root/java/sql-vyuka/src/java/cz/frantovo/sql/vyuka/dao/HistorieDAO.java @ 17:08cd160ec1c6

package cz.frantovo.sql.vyuka.dao;

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.Timestamp;
import java.util.logging.Level;

/**
 * Ukládání a načítání uživatelské historie.
 * @author fiki
 */
public class HistorieDAO extends VyukaSuperDAO {

    TipyDAO tipy = new TipyDAO();

    private enum SQL {

        NACTI,
        ULOZ
    }

    /**
     * @param sql uživatelský SQL příkaz k uložení
     * @param uzivatel idSezení a IP adresa uživatele
     * @return zda se podařilo historii uložit
     */
    public boolean ulozPrikaz(String sql, Uzivatel uzivatel) {
        Connection db = getSpojeni(DATABAZE.APLIKACE);
        if (db == null) {
            return false;
        } else {
            PreparedStatement ps = null;
            ResultSet rs = null;
            try {
                ps = db.prepareStatement(getSQL(SQL.ULOZ));
                ps.setString(1, sql);
                ps.setString(2, uzivatel.getIdSezeni());
                ps.setString(3, uzivatel.getIpAdresa());
                ps.executeUpdate();
                return true;
            } catch (Exception e) {
                log.log(Level.SEVERE, "Chyba při ukládání historie.", e);
                return false;
            } finally {
                zavri(db, ps, rs);
            }
        }
    }

    public VysledekSQL nactiHistorii(Uzivatel uzivatel) {
        VysledekSQL v = new VysledekSQL();


        Tabulka t = new Tabulka();
        String[] zahlavi = {"Kdy", "SQL příkaz"};
        t.setZahlavi(zahlavi);


        Connection db = getSpojeni(DATABAZE.APLIKACE);
        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(getSQL(SQL.NACTI));
                ps.setString(1, uzivatel.getIdSezeni());
                rs = ps.executeQuery();

                while (rs.next()) {
                    Timestamp datum = rs.getTimestamp("datum");
                    String sql = rs.getString("sql");
                    Object[] hodnoty = {datum, sql};
                    t.getHodnoty().add(hodnoty);
                }

                if (t.getHodnoty().size() < 1) {
                    v.getHlasky().add(new Hlaska("Historie SQL příkazů nenalezena.", Typ.Varovani));
                } else {
                    v.getTabulky().add(t);
                }

            } catch (Exception e) {
                log.log(Level.SEVERE, "Chyba při ukládání historie.", 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));
        return v;
    }
}