package datalaag;

import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Date;
import java.util.List;
import objecten.DvD;
import objecten.Klant;
import org.sql2o.Connection;
import org.sql2o.Sql2o;

/**
 *
 * @author
 */
public class DataLaag {

    Sql2o dataLaag;
    DvD dvd;
    private Connection con;
    Date date;
    private Sql2o sql2o;

    // methode om de connectie aan te maken
    public DataLaag() throws SQLException {
        date = new Date();
        try (Connection con = sql2o.open()) {
            this.sql2o = new Sql2o("jdbc:mysql://localhost:3306/dvd", "root", "Azerty123");
        } catch (Exception e) {

        }

    }

    // geeft een array terug van DVD objecten
    /**
     *
     * @return
     */
    public List<DvD> geefDvdLijst() {
        String sql = "select * from DvDs";

        try {
            return con.createQuery(sql).executeAndFetch(DvD.class);
        } catch (Exception e) {
            return null;
        }

    }

    // methode die true teruggeeft als de data toegevoegd is in de databank
    // gebruikt de methode maakKlantAan om eerst een klant aan te maken en deze
    // dan te gebruiken om een ontlening aan te maken
//    public boolean doeOntlening(Klant k, int dvdNr) {
//
//        return true;
//    }
    // maakt een klant aan in de databank. Geeft het id terug van de nieuw
    // aangemaakte klant
    // ga alvorens de klant aan te maken na of deze al niet bestaat
    public List<DvD> maakKlantAan(Klant k) {
        String sql = "insert into klanten (KLant_id, Naam, Adres, postcode, Gemeente, KlantSinds, tel) values(:KLant_id, :Naam, :Adres, :postcode, :Gemeente, :KlantSinds, :tel);";
        return con.createQuery(sql)
                .addParameter("KLant_id", k.getKlantID())
                .addParameter("Naam", k.getNaam())
                .addParameter("Adres", k.getAdres())
                .addParameter("postcode", k.getPostcode())
                .addParameter("Gemeente", k.getGemeente())
                .addParameter("KlantSinds", k.getKlantSinds())
                .executeAndFetch(DvD.class);

    }

    public boolean doeOntlening(Klant k, int nummer) {
        String sql = "insert into verhuuringen (Verhuurdatum, DVD_DVDNummer, Klanten_klant_id) values(NOW(), :DVD_DVDNummer, :Klanten_klant_id);";

        con.createQuery(sql)
                .addParameter("DVD_DVDNummer", nummer)
                .addParameter("Klanten_klant_id", k.getKlantID())
                .executeUpdate();
        return true;

    }
}