package cz.frantovo.hrisniciSpameri.dao;

 import cz.frantovo.hrisniciSpameri.dto.Cil;

 import java.sql.Connection;

 import java.sql.Date;

 import java.sql.PreparedStatement;

 import java.sql.ResultSet;

 import java.util.Collection;

 import java.util.logging.Level;

 /**

  *

  * @author fiki

  */

 public class GeneratorSouhrnuDAO extends HrisniciSuperDAO {

     private enum SQL {

         VLOZ_SOUHRN

     }

     /**

      * Vygeneruje souhrn pro daný cíl a datum a uloží ho do databáze

      * @param cil cíl, pro který generujeme souhrn

      * @param den den, pro který souhrn generujeme.

      */

     private void generujSouhrn(Cil cil, Date den) {

         Connection dbZdroj = getSpojeni(cil.getDatabaze());

         Connection dbSouhrn = getSpojeni(null);

         if (dbZdroj == null || dbSouhrn == null) {

             /** TODO: Chyba spojení */

         } else {

             PreparedStatement ps = null;

             ResultSet rs = null;

             try {

                 ps = dbZdroj.prepareStatement(cil.getSelekt());

                 ps.setDate(1, den);

                 rs = ps.executeQuery();

                 PreparedStatement psSouhrn = dbSouhrn.prepareStatement(getSQL(SQL.VLOZ_SOUHRN));

                 while (rs.next()) {

                     /**

                      * Souhrn bychom mohli vkládat pomocí SouhrnDAO,

                      * ale z výkonnostních důvodů to budeme dělat tady

                      * (jedno spojení a jeden předpřipravený příkaz).

                      */

                     psSouhrn.setDate(1, den);

                     psSouhrn.setString(2, rs.getString("ip"));

                     psSouhrn.setString(3, "TODO: přeložit " + rs.getString("ip"));

                     psSouhrn.setInt(4, rs.getInt("pocet"));

                     psSouhrn.setInt(5, cil.getId());

                     psSouhrn.executeUpdate();

                 }

                 zavri(null, psSouhrn, null);

                 dbSouhrn.commit();

             } catch (Exception e) {

                 log.log(Level.SEVERE, "Chyba při generování souhrnu.", e);

             } finally {

                 zavri(dbZdroj, ps, rs);

                 zavri(dbSouhrn, null, null);

             }

         }

     }

     /**

      * Vygeneruje denní souhrny pro všechny cíle.

      * @param den den, pro který souhrny generujeme.

      */

     public void generujSouhrny(Date den) {

         Collection<Cil> cile = new CilDAO().getCile();

         for (Cil c : cile) {

             generujSouhrn(c, den);

         }

     }

 }