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 | | } |
| 35 | public VysledekSQL vykonejSQL(String sql, Uzivatel uzivatel) { |
| 36 | VysledekSQL v = new VysledekSQL(); |
| 37 | if (historie.ulozPrikaz(sql, uzivatel)) { |
48 | | long casPred = System.currentTimeMillis(); |
49 | | ps = db.prepareStatement(sql); |
50 | | boolean isRS = ps.execute(); |
| 39 | Connection db = getSpojeni(DATABAZE.PISKOVISTE); |
| 40 | if (db == null) { |
| 41 | v.getHlasky().add(new Hlaska("Došlo k chybě spojení.", Typ.Chyba)); |
| 42 | } else { |
| 43 | PreparedStatement ps = null; |
| 44 | ResultSet rs = null; |
| 45 | try { |
| 46 | /** |
| 47 | * Uživatelskému SQL příkazu předřadíme výchozí cestu (search_path). |
| 48 | * Protože uživatelé si ji mohou měnit a kvůli recyklaci databázových zdrojů |
| 49 | * by jeden uživatel mohl ovlivnit jiného. |
| 50 | */ |
| 51 | if (getVlastnost(VLASTNOSTI.VYCHOZI_CESTA) != null) { |
| 52 | sql = orizni(getVlastnost(VLASTNOSTI.VYCHOZI_CESTA)) + sql; |
| 53 | } |
| 54 | |
| 55 | /** |
| 56 | * TODO: |
| 57 | * použít ps.setQueryTimeout(LIMIT_ČASU); |
| 58 | * až ho bude podporovat JDBC ovladač, |
| 59 | * viz níže. |
| 60 | * Uživatel ale stejně může zadat: |
| 61 | * SET statement_timeout 0; |
| 62 | * do svého SQL dotazu. |
| 63 | */ |
| 64 | if (getVlastnost(VLASTNOSTI.LIMIT_ČASU) != null) { |
| 65 | sql = orizni(getVlastnost(VLASTNOSTI.LIMIT_ČASU)) + sql; |
| 66 | } |
52 | | if (isRS) { |
53 | | rs = ps.getResultSet(); |
54 | | v.getTabulky().add(zpracujVysledek(rs)); |
55 | | } |
| 68 | long casPred = System.currentTimeMillis(); |
| 69 | ps = db.prepareStatement(sql); |
| 70 | /** |
| 71 | * Limit času bohužel není podporován JDBC ovladačem. |
| 72 | * Alespoň ne v postgresql-9.1-901.jdbc4.jar |
| 73 | * http://jdbc.postgresql.org/todo.html |
| 74 | * |
| 75 | * TODO: |
| 76 | * ps.setQueryTimeout(LIMIT_ČASU); |
| 77 | */ |
| 78 | ps.setMaxRows(LIMIT_POČTU); |
| 79 | boolean isRS = ps.execute(); |
57 | | /** |
58 | | * Ošetříme případ, kdy uživatel zadá SQL příkaz, který nevrací výsledkovou sadu. |
59 | | * Typicky nastavení výchozího schématu: SET search_path = '…'; |
60 | | * Poznámka: jeden „SET search_path TO "…"“ se obvykle předřazuje uživatelskému SQL (viz PiskovisteDAO.xml). |
61 | | */ |
62 | | while (ps.getMoreResults() || ps.getUpdateCount() > -1) { |
63 | | rs = ps.getResultSet(); |
64 | | if (rs == null) { |
65 | | /** Jedná se o „update count“. */ |
66 | | } else { |
67 | | v.getTabulky().add(zpracujVysledek(rs)); |
68 | | } |
69 | | } |
70 | | long dobaProvadeni = System.currentTimeMillis() - casPred; |
| 81 | if (isRS) { |
| 82 | rs = ps.getResultSet(); |
| 83 | v.getTabulky().add(zpracujVysledek(rs)); |
| 84 | } |
72 | | /** Varování */ |
73 | | if (v.getHlasky().size() < 1 && v.getTabulky().size() < 1) { |
74 | | v.getHlasky().add(new Hlaska("SQL příkaz proběhl, ale nevrátil žádná data.", Typ.Varovani)); |
75 | | } |
| 86 | /** |
| 87 | * Ošetříme případ, kdy uživatel zadá SQL příkaz, který nevrací výsledkovou |
| 88 | * sadu. |
| 89 | * Typicky nastavení výchozího schématu: SET search_path = '…'; |
| 90 | * Poznámka: jeden „SET search_path TO "…"“ se obvykle předřazuje uživatelskému |
| 91 | * SQL (viz PiskovisteDAO.xml). |
| 92 | */ |
| 93 | while (ps.getMoreResults() || ps.getUpdateCount() > -1) { |
| 94 | rs = ps.getResultSet(); |
| 95 | if (rs == null) { |
| 96 | /** Jedná se o „update count“. */ |
| 97 | } else { |
| 98 | v.getTabulky().add(zpracujVysledek(rs)); |
| 99 | } |
| 100 | } |
| 101 | long dobaProvadeni = System.currentTimeMillis() - casPred; |
88 | | } catch (SQLException e) { |
89 | | log.log(Level.SEVERE, "SQL chyba při vykonávání uživatelského dotazu.", e); |
90 | | v.getHlasky().add(new Hlaska("Chybné SQL: " + e.getMessage(), Typ.Chyba)); |
91 | | } catch (Exception e) { |
92 | | log.log(Level.SEVERE, "Chyba při vykonávání uživatelského dotazu.", e); |
93 | | v.getHlasky().add(new Hlaska("Došlo k chybě dotazu.", Typ.Chyba)); |
94 | | } finally { |
95 | | zavri(db, ps, rs); |
96 | | } |
97 | | } |
| 117 | v.getHlasky().add(new Hlaska("SQL příkaz byl proveden úspěšně, během " + dobaProvadeni + " ms.", Typ.OK)); |
99 | | /** Tip pro uživatele */ |
100 | | String tip = tipy.getTip(); |
101 | | if (tip != null) { |
102 | | v.getHlasky().add(new Hlaska(tip, Typ.Tip, false)); |
103 | | } |
| 119 | } catch (SQLException e) { |
| 120 | log.log(Level.SEVERE, "SQL chyba při vykonávání uživatelského dotazu.", e); |
| 121 | v.getHlasky().add(new Hlaska("Chybné SQL: " + e.getMessage(), Typ.Chyba)); |
| 122 | } catch (Exception e) { |
| 123 | log.log(Level.SEVERE, "Chyba při vykonávání uživatelského dotazu.", e); |
| 124 | v.getHlasky().add(new Hlaska("Došlo k chybě dotazu.", Typ.Chyba)); |
| 125 | } finally { |
| 126 | zavri(db, ps, rs); |
| 127 | } |
| 128 | } |