package cz.frantovo.superPostak;

 import cz.frantovo.postak.InternetAddressKomu;

 import java.io.UnsupportedEncodingException;

 import java.sql.Connection;

 import java.sql.PreparedStatement;

 import java.sql.ResultSet;

 import java.sql.SQLException;

 import java.util.ArrayList;

 import java.util.Collection;

 import java.util.logging.Level;

 import java.util.logging.Logger;

 /**

  * Třída pro vykonávání SQL dotazů

  * @author fiki

  */

 public class DataSQL {

     private static final Logger log = Logger.getLogger(DataSQL.class.getName());

     private Connection spojeni;

     public DataSQL(Connection spojeni) {

         this.spojeni = spojeni;

     }

     /**

      * Provede SQL příkaz a získá z něj e-mailové adresy.

      * Zatím předpokládá pouze jediný sloupec, který obsahuje adresu.

      */

     public Collection<InternetAddressKomu> getAdresy(String sql) throws SQLException, UnsupportedEncodingException {

         ArrayList<InternetAddressKomu> vysledek = new ArrayList<InternetAddressKomu>();

         if (sql == null || sql.length() < 3) {

             log.log(Level.FINER, "Prázdný SQL dotaz");

             return null;

         } else {

             PreparedStatement ps = spojeni.prepareStatement(sql);

             ResultSet rs = ps.executeQuery();

             while (rs.next()) {

                 vysledek.add(new InternetAddressKomu(rs.getString(1), rs.getString(1)));

             }

             return vysledek;

         }

     }

 }