sascha@196: package de.intevation.flys.importer;
sascha@196: 
sascha@196: import de.intevation.flys.model.Wst;
sascha@201: import de.intevation.flys.model.River;
sascha@201: 
sascha@201: import org.hibernate.Session;
sascha@201: import org.hibernate.Query;
sascha@201: 
sascha@201: import java.util.List;
sascha@201: import java.util.Map;
sascha@201: import java.util.HashMap;
sascha@196: 
sascha@196: public class ImportWst
sascha@196: {
sascha@201:     protected String description;
sascha@201: 
sascha@467:     protected Integer kind;
sascha@467: 
sascha@201:     protected Map<String, ImportWstColumn> columns;
sascha@201: 
sascha@196:     protected Wst peer;
sascha@196: 
sascha@196:     public ImportWst() {
sascha@467:         kind = 0;
sascha@201:         columns = new HashMap<String, ImportWstColumn>();
sascha@196:     }
sascha@196: 
sascha@201:     public ImportWst(String description) {
sascha@201:         this();
sascha@201:         this.description = description;
sascha@201:     }
sascha@201: 
sascha@201:     public String getDescription() {
sascha@201:         return description;
sascha@201:     }
sascha@201: 
sascha@201:     public void setDescription(String description) {
sascha@201:         this.description = description;
sascha@201:     }
sascha@201: 
sascha@201:     public ImportWstColumn getColumn(String name) {
sascha@201:         ImportWstColumn column = columns.get(name);
sascha@201:         if (column == null) {
sascha@471:             column = new ImportWstColumn(this, name, null, columns.size());
sascha@201:             columns.put(name, column);
sascha@201:         }
sascha@201:         return column;
sascha@201:     }
sascha@201: 
sascha@201:     public void storeDependencies(River river) {
sascha@201:         Wst wst = getPeer(river);
sascha@201: 
sascha@201:         for (ImportWstColumn column: columns.values()) {
sascha@201:             column.storeDependencies(river);
sascha@201:         }
sascha@201:     }
sascha@201: 
sascha@201:     public Wst getPeer(River river) {
sascha@196:         if (peer == null) {
sascha@201:             Session session = Importer.sessionHolder.get();
sascha@201:             Query query = session.createQuery(
sascha@201:                 "from Wst where " +
sascha@467:                 "river=:river and description=:description and kind=:kind");
sascha@201:             query.setParameter("river",       river);
sascha@201:             query.setParameter("description", description);
sascha@467:             query.setParameter("kind",        kind);
sascha@201:             List<Wst> wsts = query.list();
sascha@201:             if (wsts.isEmpty()) {
sascha@467:                 peer = new Wst(river, description, kind);
sascha@201:                 session.save(peer);
sascha@201:             }
sascha@201:             else {
sascha@201:                 peer = wsts.get(0);
sascha@201:             }
sascha@201: 
sascha@196:         }
sascha@196:         return peer;
sascha@196:     }
sascha@196: }
sascha@196: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :