sql-vyuka: java/sql-vyuka/src/java/cz/frantovo/sql/vyuka/dao/PiskovisteDAO.java@2ffdd7be6d5e

     1 package cz.frantovo.sql.vyuka.dao;

     3 import cz.frantovo.sql.vyuka.dao.VyukaSuperDAO.DATABAZE;

     4 import cz.frantovo.sql.vyuka.dto.Hlaska;

     5 import cz.frantovo.sql.vyuka.dto.Hlaska.Typ;

     6 import cz.frantovo.sql.vyuka.dto.Tabulka;

     7 import cz.frantovo.sql.vyuka.dto.Uzivatel;

     8 import cz.frantovo.sql.vyuka.dto.VysledekSQL;

     9 import java.sql.Connection;

    10 import java.sql.PreparedStatement;

    11 import java.sql.ResultSet;

    12 import java.sql.SQLException;

    13 import java.util.logging.Level;

    15 /**

    16  * Pro spouštění uživatelových příkazů.

    17  * @author fiki

    18  */

    19 public class PiskovisteDAO extends VyukaSuperDAO {

    21     private enum VLASTNOSTI {

    23         VYCHOZI_CESTA

    24     }

    25     TipyDAO tipy = new TipyDAO();

    26     HistorieDAO historie = new HistorieDAO();

    28     public VysledekSQL vykonejSQL(String sql, Uzivatel uzivatel) {

    29         VysledekSQL v = new VysledekSQL();

    30         if (historie.ulozPrikaz(sql, uzivatel)) {

    32             Connection db = getSpojeni(DATABAZE.PISKOVISTE);

    33             if (db == null) {

    34                 v.getHlasky().add(new Hlaska("Došlo k chybě spojení.", Typ.Chyba));

    35             } else {

    36                 PreparedStatement ps = null;

    37                 ResultSet rs = null;

    38                 try {

    39                     /**

    40                      * Uživatelskému SQL příkazu předřadíme výchozí cestu (search_path).

    41                      * Protože uživatelé si ji mohou měnit a kvůli recyklaci databázových zdrojů

    42                      * by jeden uživatel mohl ovlivnit jiného.

    43                      */

    44                     if (getVlastnost(VLASTNOSTI.VYCHOZI_CESTA) != null) {

    45                         sql = orizni(getVlastnost(VLASTNOSTI.VYCHOZI_CESTA)) + sql;

    46                     }

    48                     ps = db.prepareStatement(sql);

    49                     boolean isRS = ps.execute();

    51                     if (isRS) {

    52                         rs = ps.getResultSet();

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

    54                     }

    56                     /** TODO: ošetřit případ, kdy vykonáme dva příkazy bez výsledkové sady a třetí příkaz ji už má (teď se nezobrazí výsledná tabulka). */

    57                     while (ps.getMoreResults()) {

    58                         rs = ps.getResultSet();

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

    60                     }

    62                     /** Varování */

    63                     if (v.getHlasky().size() < 1 && v.getTabulky().size() < 1) {

    64                         v.getHlasky().add(new Hlaska("SQL příkaz proběhl, ale nevrátil žádná data.", Typ.Varovani));

    65                     }

    67                     /** Varování */

    68                     int pocitadloTabulek = 1;

    69                     for (Tabulka t : v.getTabulky()) {

    70                         if (t.getHodnoty().size() < 1) {

    71                             v.getHlasky().add(new Hlaska("Tabulka " + pocitadloTabulek + "  je prázdná.", Typ.Varovani));

    72                         }

    73                         pocitadloTabulek++;

    74                     }

    77                 } catch (SQLException e) {

    78                     log.log(Level.SEVERE, "SQL chyba při vykonávání uživatelského dotazu.", e);

    79                     v.getHlasky().add(new Hlaska("Chybné SQL: " + e.getMessage(), Typ.Chyba));

    80                 } catch (Exception e) {

    81                     log.log(Level.SEVERE, "Chyba při vykonávání uživatelského dotazu.", e);

    82                     v.getHlasky().add(new Hlaska("Došlo k chybě dotazu.", Typ.Chyba));

    83                 } finally {

    84                     zavri(db, ps, rs);

    85                 }

    86             }

    88             v.getHlasky().add(new Hlaska(tipy.getTip(), Typ.Tip, false));

    90         } else {

    91             v.getHlasky().add(new Hlaska("Došlo k chybě historie.", Typ.Chyba));

    92         }

    93         return v;

    94     }

    96     private Tabulka zpracujVysledek(ResultSet rs) throws SQLException {

    97         Tabulka t = new Tabulka();

    99         int pocetSloupecku = rs.getMetaData().getColumnCount();

   100         String[] zahlavi = new String[pocetSloupecku];

   101         t.setZahlavi(zahlavi);

   102         for (int i = 0; i < pocetSloupecku; i++) {

   103             zahlavi[i] = rs.getMetaData().getColumnName(i + 1);

   104         }

   106         while (rs.next()) {

   107             Object[] hodnoty = new Object[pocetSloupecku];

   108             for (int i = 0; i < pocetSloupecku; i++) {

   109                 hodnoty[i] = rs.getObject(i + 1);

   110             }

   111             t.getHodnoty().add(hodnoty);

   112         }

   114         return t;

   115     }

   116 }

author	František Kučera <franta-hg@frantovo.cz>
	Sat May 30 13:56:04 2009 +0200 (2009-05-30)
changeset 19	2ffdd7be6d5e
parent 18	e7a5763c789c
child 30	d65581701671
permissions	-rw-r--r--