mschaefer@8971: /* Copyright (C) 2017 by Bundesanstalt für Gewässerkunde mschaefer@8971: * Software engineering by mschaefer@8971: * Björnsen Beratende Ingenieure GmbH mschaefer@8971: * Dr. Schumacher Ingenieurbüro für Wasser und Umwelt mschaefer@8971: * mschaefer@8971: * This file is Free Software under the GNU AGPL (>=v3) mschaefer@8971: * and comes with ABSOLUTELY NO WARRANTY! Check out the mschaefer@8971: * documentation coming with Dive4Elements River for details. mschaefer@8971: */ mschaefer@8971: mschaefer@8971: package org.dive4elements.river.importer.sinfo.importitem; mschaefer@8971: mschaefer@8971: import java.util.List; mschaefer@8971: mschaefer@8971: import org.apache.log4j.Logger; mschaefer@8971: import org.dive4elements.river.importer.ImporterSession; mschaefer@8971: import org.dive4elements.river.model.sinfo.CollisionType; mschaefer@8971: import org.hibernate.Query; mschaefer@8971: import org.hibernate.Session; mschaefer@8971: mschaefer@8971: /** mschaefer@8971: * Imported collision type mschaefer@8971: * mschaefer@8971: * @author Matthias Schäfer mschaefer@8971: * mschaefer@8971: */ mschaefer@8971: public class CollisionTypeImport implements Comparable { mschaefer@8971: mschaefer@8971: /***** FIELDS *****/ mschaefer@8971: mschaefer@8971: private static final Logger log = Logger.getLogger(CollisionTypeImport.class); mschaefer@8971: mschaefer@8971: protected String name; mschaefer@8971: mschaefer@8971: protected CollisionType peer; mschaefer@8971: mschaefer@8971: /***** CONSTRUCTOR *****/ mschaefer@8971: mschaefer@8971: public CollisionTypeImport() { mschaefer@8971: } mschaefer@8971: mschaefer@8971: public CollisionTypeImport(final String name) { mschaefer@8971: this.name = name; mschaefer@8971: } mschaefer@8971: mschaefer@8971: /***** METHODS *****/ mschaefer@8971: mschaefer@8971: @Override mschaefer@8971: public int compareTo(final CollisionTypeImport other) { mschaefer@8971: return this.name.compareTo(other.name); mschaefer@8971: } mschaefer@8971: mschaefer@8971: @Override mschaefer@8971: public int hashCode() { mschaefer@8971: return this.name.hashCode(); mschaefer@8971: } mschaefer@8971: mschaefer@8971: public String getName() { mschaefer@8971: return this.name; mschaefer@8971: } mschaefer@8971: mschaefer@8971: public void setName(final String name) { mschaefer@8971: this.name = name; mschaefer@8971: } mschaefer@8971: mschaefer@8971: public CollisionType getPeer() { mschaefer@8971: if (this.peer != null) mschaefer@8971: return this.peer; mschaefer@8971: final Session session = ImporterSession.getInstance().getDatabaseSession(); mschaefer@8971: final Query query = session.createQuery("FROM CollisionType WHERE lower(name)=:name"); mschaefer@8971: query.setParameter("name", this.name.trim().toLowerCase()); mschaefer@8971: final List types = query.list(); mschaefer@8971: if (types.isEmpty()) { mschaefer@8971: this.peer = new CollisionType(this.name); mschaefer@8971: session.save(this.peer); mschaefer@8971: log.info(String.format("Create new database instance: %d, '%s'", this.peer.getId(), this.name)); mschaefer@8971: } mschaefer@8971: else { mschaefer@8971: this.peer = types.get(0); mschaefer@8971: } mschaefer@8971: return this.peer; mschaefer@8971: } mschaefer@8971: }