view backend/src/main/java/org/dive4elements/river/importer/ImportMorphWidthValue.java @ 9650:a2a42a6bac6b

Importer (s/u-info) extensions: outer try/catch for parse and log of line no, catching parsing exception if not enough value fields, parsing error and warning log messages with line number, detecting and rejecting duplicate data series, better differentiation between error and warning log messages
author mschaefer
date Mon, 23 Mar 2020 14:57:03 +0100
parents 5e38e2924c07
children 0a5239a1e46e
line wrap: on
line source
/* Copyright (C) 2011, 2012, 2013 by Bundesanstalt für Gewässerkunde
 * Software engineering by Intevation GmbH
 *
 * This file is Free Software under the GNU AGPL (>=v3)
 * and comes with ABSOLUTELY NO WARRANTY! Check out the
 * documentation coming with Dive4Elements River for details.
 */

package org.dive4elements.river.importer;

import java.math.BigDecimal;

import java.util.List;

import org.apache.log4j.Logger;

import org.hibernate.Session;
import org.hibernate.Query;

import org.dive4elements.river.model.MorphologicalWidth;
import org.dive4elements.river.model.MorphologicalWidthValue;


public class ImportMorphWidthValue {

    private static Logger log = Logger.getLogger(ImportMorphWidthValue.class);


    protected MorphologicalWidthValue peer;

    protected BigDecimal station;
    protected BigDecimal width;

    protected String description;


    public ImportMorphWidthValue(
        BigDecimal station,
        BigDecimal width,
        String     description
    ) {
        this.station     = station;
        this.width       = width;
        this.description = description;
    }


    public void storeDependencies(MorphologicalWidth parent) {
        getPeer(parent);
    }


    public MorphologicalWidthValue getPeer(MorphologicalWidth parent) {
        if (peer == null) {
            Session session = ImporterSession.getInstance()
                .getDatabaseSession();

            Query query = session.createQuery(
                "from MorphologicalWidthValue where " +
                "   morphologicalWidth=:morphologicalWidth and " +
                "   station=:station and " +
                "   width=:width and " +
                "   description=:description");

            query.setParameter("morphologicalWidth", parent);
            query.setParameter("station", station);
            query.setParameter("width", width);
            query.setParameter("description", description);

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

            if (values.isEmpty()) {
                peer = new MorphologicalWidthValue(
                    parent,
                    station,
                    width,
                    description
                );

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

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

http://dive4elements.wald.intevation.org