package com.mkyong.form.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;
import org.springframework.stereotype.Repository;
import org.springframework.util.StringUtils;

import com.mkyong.form.model.UbezpieczenieSamochodu;

@Repository
public class UbezpieczenieSamochoduDAOImpl implements UbezpieczenieSamochoduDAO {

    NamedParameterJdbcTemplate namedParameterJdbcTemplate;

    @Autowired
     public void setNamedParameterJdbcTemplate(NamedParameterJdbcTemplate namedParameterJdbcTemplate) throws DataAccessException {
        this.namedParameterJdbcTemplate = namedParameterJdbcTemplate;
    }

    @Override
    public UbezpieczenieSamochodu findById(Integer id) {

        Map<String, Object> params = new HashMap<String, Object>();
        params.put("id", id);

        String sql = "SELECT * FROM ubezpieczeniaSamochodu WHERE id=:id";

        UbezpieczenieSamochodu result = null;
        try {
            result = namedParameterJdbcTemplate.queryForObject(sql, params, new UserMapper());
        } catch (EmptyResultDataAccessException e) {

        }

        return result;
    }

    @Override
    public List<UbezpieczenieSamochodu> findAll() {
        String sql = "SELECT * FROM ubezpieczeniaSamochodu";
        List<UbezpieczenieSamochodu> result = namedParameterJdbcTemplate.query(sql, new UserMapper());
        return result;
    }

    @Override
    public void save(UbezpieczenieSamochodu ubezpieczenieSamochodu) {
        KeyHolder keyHolder = new GeneratedKeyHolder();

        String sql = "INSERT INTO ubezpieczeniaSamochodu(stanCywilny, dataUrodzenia, rokWydaniaPrawaJazdy,kierowcyPonizej26RokuZycia"
                + ",liczbaLatJazdyBezszkod, liczbaSzkodOst5Lat, telefon, adresEmail, zakresUbezpieczenia, dataRozpoczeciaUbezpieczenia"
                + ",rokProdukcji ,marka, model, pojemnoscSilnika, wersjaNadwozia, sredniRocznyPrzebiegKm, plec)"

                + "VALUES ( :stanCywilny, :dataUrodzenia, :rokWydaniaPrawaJazdy, :kierowcyPonizej26RokuZycia"
                + ", :liczbaLatJazdyBezszkod, :liczbaSzkodOst5Lat, :telefon, :adresEmail, :zakresUbezpieczenia, :dataRozpoczeciaUbezpieczenia, :rokProdukcji , :marka, :model"
                + ", :pojemnoscSilnika, :wersjaNadwozia, :sredniRocznyPrzebiegKm, :plec)";

                namedParameterJdbcTemplate.update(sql, getSqlParameterByModel(ubezpieczenieSamochodu),keyHolder);
                ubezpieczenieSamochodu.setId(keyHolder.getKey().intValue());

    }


    public void obliczSkladkeUbezpieczenia(UbezpieczenieSamochodu ubezpieczenieSamochodu) {
        KeyHolder keyHolder = new GeneratedKeyHolder();

        String sql =  "INSERT INTO ubezpieczeniaSamochodu(wartoscUbezpieczenia)"

                      +"VALUES( :wartoscUbezpieczenia)";

        if (ubezpieczenieSamochodu.getZakresUbezpieczenia() == "OCiAC") {
            ubezpieczenieSamochodu.setWartoscUbezpieczenia(1500);

            namedParameterJdbcTemplate.update(sql, getSqlParameterByModel(ubezpieczenieSamochodu),keyHolder);
            ubezpieczenieSamochodu.setId(keyHolder.getKey().intValue());
        }
    }

/*  @Override
    public void update(UbezpieczenieSamochodu ubezpieczenieSamochodu) {
        String sql = "UPDATE ubezpieczeniaSamochodu SET stanCywilny =: stanCywilny, dataUrodzenia =: dataUrodzenia rokWydaniaPrawaJazdy =: rokWydaniaPrawaJazdy"
                 + "kierowcyPonizej26RokuZycia =: kierowcyPonizej26RokuZycia, liczbaLatJazdyBezszkod =: liczbaLatJazdyBezszkod, liczbaSzkodOst5Lat =: liczbaSzkodOst5Lat"
                + "telefon =: telefon, adresEmail =: adresEmail, zakresUbezpieczenia =: zakresUbezpieczenia"
                 +"dataRozpoczeciaUbezpieczenia =: dataRozpoczeciaUbezpieczenia, rokProdukcji =: rokProdukcji, marka =: marka"
                +"model =: model, pojemnoscSilnika =: pojemnoscSilnika, wersjaNadwozia =: wersjaNadwozia"
                 +"sredniRocznyPrzebiegKm =: sredniRocznyPrzebiegKm, wartoscUbezpieczenia =: wartoscUbezpieczenia, plec =: plec WHERE id =: id";

        namedParameterJdbcTemplate.update(sql, getSqlParameterByModel(ubezpieczenieSamochodu));

    }

    @Override
    public void delete(Integer id) {

        String sql =  "DELETE FROM ubezpieczeniaSamochodu WHERE id =:id";
        namedParameterJdbcTemplate.update(sql, new MapSqlParameterSource("id", id));
    }*/

    private SqlParameterSource getSqlParameterByModel (UbezpieczenieSamochodu ubezpieczenieSamochodu) {

        MapSqlParameterSource paramSource = new MapSqlParameterSource();

        paramSource.addValue("id", ubezpieczenieSamochodu.getId());
        paramSource.addValue("stanCywilny", ubezpieczenieSamochodu.getStanCywilny());
        paramSource.addValue("dataUrodzenia", ubezpieczenieSamochodu.getDataUrodzenia());
        paramSource.addValue("rokWydaniaPrawaJazdy", ubezpieczenieSamochodu.getRokWydaniaPrawaJazdy());
        paramSource.addValue("kierowcyPonizej26RokuZycia", ubezpieczenieSamochodu.getKierowcyPonizej26RokuZycia());
        paramSource.addValue("liczbaLatJazdyBezszkod", ubezpieczenieSamochodu.getLiczbaLatJazdyBezszkod());
        paramSource.addValue("liczbaSzkodOst5Lat", ubezpieczenieSamochodu.getLiczbaSzkodOst5Lat());
        paramSource.addValue("telefon", ubezpieczenieSamochodu.getTelefon());
        paramSource.addValue("adresEmail", ubezpieczenieSamochodu.getAdresEmail());
        paramSource.addValue("zakresUbezpieczenia", ubezpieczenieSamochodu.getZakresUbezpieczenia());
        paramSource.addValue("dataRozpoczeciaUbezpieczenia", ubezpieczenieSamochodu.getDataRozpoczeciaUbezpieczenia());
        paramSource.addValue("rokProdukcji", ubezpieczenieSamochodu.getRokProdukcji());
        paramSource.addValue("marka", ubezpieczenieSamochodu.getMarka());
        paramSource.addValue("model", ubezpieczenieSamochodu.getModel());
        paramSource.addValue("pojemnoscSilnika", ubezpieczenieSamochodu.getPojemnoscSilnika());
        paramSource.addValue("wersjaNadwozia", ubezpieczenieSamochodu.getWersjaNadwozia());
        paramSource.addValue("sredniRocznyPrzebiegKm", ubezpieczenieSamochodu.getSredniRocznyPrzebiegKm());
        paramSource.addValue("wartoscUbezpiecznia", ubezpieczenieSamochodu.getWartoscUbezpieczenia());
        paramSource.addValue("plec", ubezpieczenieSamochodu.getPlec());

        return paramSource;
    }

    private static final class UserMapper implements RowMapper<UbezpieczenieSamochodu> {

        public UbezpieczenieSamochodu mapRow(ResultSet rs, int rowNum) throws SQLException {
            UbezpieczenieSamochodu ubezpieczenieSamochodu = new UbezpieczenieSamochodu();
            ubezpieczenieSamochodu.setId(rs.getInt("id"));
            ubezpieczenieSamochodu.setRokProdukcji(rs.getInt("rokProdukcji"));
            ubezpieczenieSamochodu.setMarka(rs.getString("marka"));
            ubezpieczenieSamochodu.setModel(rs.getString("model"));
            ubezpieczenieSamochodu.setTelefon(rs.getInt("telefon"));
            ubezpieczenieSamochodu.setPojemnoscSilnika(rs.getString("pojemnoscSilnika"));
            ubezpieczenieSamochodu.setWersjaNadwozia(rs.getString("wersjaNadwozia"));
            ubezpieczenieSamochodu.setSredniRocznyPrzebiegKm(rs.getString("sredniRocznyPrzebiegKm"));
            ubezpieczenieSamochodu.setZakresUbezpieczenia(rs.getString("zakresUbezpieczenia"));
            ubezpieczenieSamochodu.setDataRozpoczeciaUbezpieczenia(rs.getString("dataRozpoczeciaUbezpieczenia"));
            ubezpieczenieSamochodu.setPlec(rs.getString("plec"));
            ubezpieczenieSamochodu.setStanCywilny(rs.getString("stanCywilny"));
            ubezpieczenieSamochodu.setDataUrodzenia(rs.getString("dataUrodzenia"));
            ubezpieczenieSamochodu.setRokWydaniaPrawaJazdy(rs.getInt("rokWydaniaPrawaJazdy"));
            ubezpieczenieSamochodu.setKierowcyPonizej26RokuZycia(rs.getString("kierowcyPonizej26RokuZycia"));
            ubezpieczenieSamochodu.setLiczbaLatJazdyBezszkod(rs.getString("liczbaLatJazdyBezszkod"));
            ubezpieczenieSamochodu.setLiczbaSzkodOst5Lat(rs.getString("liczbaSzkodOst5Lat"));
            ubezpieczenieSamochodu.setTelefon(rs.getInt("telefon"));
            ubezpieczenieSamochodu.setAdresEmail(rs.getString("adresEmail"));
            ubezpieczenieSamochodu.setWartoscUbezpieczenia(rs.getInt("wartoscUbezpiecznia"));

            return ubezpieczenieSamochodu;
        }
    }





}