From: <pka...@us...> - 2009-07-29 21:50:26
|
Revision: 400 http://cse-ip.svn.sourceforge.net/cse-ip/?rev=400&view=rev Author: pkasprzak Date: 2009-07-29 21:50:19 +0000 (Wed, 29 Jul 2009) Log Message: ----------- * Fix query Modified Paths: -------------- trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/java/de/campussource/cse/core/DependencyManagerImpl.java Modified: trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/java/de/campussource/cse/core/DependencyManagerImpl.java =================================================================== --- trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/java/de/campussource/cse/core/DependencyManagerImpl.java 2009-07-29 20:59:13 UTC (rev 399) +++ trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/java/de/campussource/cse/core/DependencyManagerImpl.java 2009-07-29 21:50:19 UTC (rev 400) @@ -82,18 +82,19 @@ // ---------------------------------------------------------------------------------------------------------------- protected WaitingProcess getWaitingProcess(int entityId, String system) { - WaitingProcess process = (WaitingProcess) em.createNamedQuery(WaitingProcess.QUERY_getByEntityIdAndSystem). setParameter("system", system). - setParameter("entityId", entityId). - getSingleResult(); - if (process == null) { + List<WaitingProcess> processes = em.createNamedQuery(WaitingProcess.QUERY_getByEntityIdAndSystem). setParameter("system", system). + setParameter("entityId", entityId). + getResultList(); + if (processes.isEmpty()) { /* No existing process found => create a new one */ - process = new WaitingProcess(); + WaitingProcess process = new WaitingProcess(); process.setEntityId(entityId); process.setSystem(system); em.persist(process); + return process; } - return process; + return processes.get(0); } // ---------------------------------------------------------------------------------------------------------------- This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |