package de.intevation.flys.importer;

import java.math.BigDecimal;
import java.sql.SQLException;
import java.util.Date;
import java.util.List;

import org.apache.log4j.Logger;

import org.hibernate.Session;
import org.hibernate.Query;
import org.hibernate.exception.ConstraintViolationException;

import de.intevation.flys.model.FlowVelocityMeasurement;
import de.intevation.flys.model.FlowVelocityMeasurementValue;


public class ImportFlowVelocityMeasurementValue {

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


    private Date datetime;

    private String description;

    private BigDecimal station;
    private BigDecimal w;
    private BigDecimal q;
    private BigDecimal v;

    private FlowVelocityMeasurementValue peer;


    public ImportFlowVelocityMeasurementValue(
        Date       datetime,
        BigDecimal station,
        BigDecimal w,
        BigDecimal q,
        BigDecimal v,
        String     description
    ) {
        this.datetime    = datetime;
        this.station     = station;
        this.w           = w;
        this.q           = q;
        this.v           = v;
        this.description = description;
    }



    public void storeDependencies(FlowVelocityMeasurement measurement)
    throws SQLException, ConstraintViolationException
    {
        log.debug("store dependencies");

        getPeer(measurement);
    }


    public FlowVelocityMeasurementValue getPeer(FlowVelocityMeasurement m) {
        if (peer == null) {
            Session session = ImporterSession.getInstance().getDatabaseSession();

            Query query = session.createQuery(
                "from FlowVelocityMeasurementValue where " +
                "   measurement=:measurement and " +
                "   station=:station and " +
                "   datetime=:datetime"
            );

            query.setParameter("measurement", m);
            query.setParameter("station", station);
            query.setParameter("datetime", datetime);

            List<FlowVelocityMeasurementValue> values = query.list();

            if (values.isEmpty()) {
                peer = new FlowVelocityMeasurementValue(
                    m,
                    datetime,
                    station,
                    w,
                    q,
                    v,
                    description);

                session.save(peer);
            }
            else {
                peer = values.get(0);
            }
        }

        return peer;
    }
}
// vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :