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 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;
        }
    }
}