--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/main/java/de/intevation/lada/data/LKommentarMRepository.java	Fri Jun 14 15:18:42 2013 +0200
@@ -0,0 +1,123 @@
+package de.intevation.lada.data;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import javax.ejb.EJBTransactionRolledbackException;
+import javax.inject.Inject;
+import javax.inject.Named;
+import javax.persistence.EntityExistsException;
+import javax.persistence.EntityManager;
+import javax.persistence.TransactionRequiredException;
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Predicate;
+import javax.persistence.criteria.Root;
+
+import de.intevation.lada.manage.LKommentarMManager;
+import de.intevation.lada.model.LKommentarM;
+import de.intevation.lada.rest.Response;
+
+/**
+ * This Container is an interface to request, filter and select LKommentarM
+ * obejcts from the connected database.
+ * 
+ * @author <a href="mailto:rrenkert@intevation.de">Raimund Renkert</a>
+ */
+@Named("lkommentarmrepository")
+public class LKommentarMRepository
+extends Repository
+{
+    /**
+     * The entitymanager managing the data.
+     */
+    @Inject
+    private EntityManager em;
+
+    /**
+     * Manager class for LPRobe. Used to manipulate data objects.
+     */
+    @Inject
+    private LKommentarMManager manager;
+
+    @Override
+    public Response create(Object object) {
+        if (!(object instanceof LKommentarM)) {
+            return new Response(false, 602, object);
+        }
+        LKommentarM kommentar = (LKommentarM)object;
+        Response response = new Response(true, 200, kommentar);
+        try {
+            manager.create(kommentar);
+            return response;
+        }
+        catch (EntityExistsException eee) {
+            response.setSuccess(false);
+            response.setMessage(601);
+        }
+        catch (IllegalArgumentException iae) {
+            response.setSuccess(false);
+            response.setMessage(602);
+        }
+        catch (TransactionRequiredException tre) {
+            response.setSuccess(false);
+            response.setMessage(603);
+        }
+        catch (EJBTransactionRolledbackException te) {
+            response.setSuccess(false);
+            response.setMessage(604);
+        }
+        return response;
+    }
+
+    @Override
+    public Response update(Object object) {
+        if (!(object instanceof LKommentarM)) {
+            return new Response(false, 602, object);
+        }
+        LKommentarM kommentar = (LKommentarM)object;
+        Response response = new Response(true, 200, kommentar);
+        try {
+            manager.update(kommentar);
+            return response;
+        }
+        catch (EntityExistsException eee) {
+            response.setSuccess(false);
+            response.setMessage(601);
+        }
+        catch (IllegalArgumentException iae) {
+            response.setSuccess(false);
+            response.setMessage(602);
+        }
+        catch (TransactionRequiredException tre) {
+            response.setSuccess(false);
+            response.setMessage(603);
+        }
+        catch (EJBTransactionRolledbackException te) {
+            response.setSuccess(false);
+            response.setMessage(604);
+        }
+        return response;
+    }
+
+    @Override
+    public Response filter(Map<String, String> filter) {
+        CriteriaBuilder cb = em.getCriteriaBuilder();
+        CriteriaQuery<LKommentarM> criteria = cb.createQuery(LKommentarM.class);
+        Root<LKommentarM> member = criteria.from(LKommentarM.class);
+        List<Predicate> andFilter = new ArrayList<Predicate>();
+        if (filter.containsKey("probe")) {
+            andFilter.add(cb.equal(member.get("probeId"), filter.get("probe")));
+        }
+        if (filter.containsKey("messung")) {
+            andFilter.add(cb.equal(member.get("messungsId"), filter.get("messung")));
+        }
+        criteria.distinct(true);
+        Predicate ap = cb.and(andFilter.toArray(new Predicate[andFilter.size()]));
+        criteria.where(ap);
+        List<LKommentarM> result = filter(criteria);
+        return new Response(true, 200, result);
+    }
+
+}