001: /* AssignmentFilterBuilderEJBBean.java */
002: package org.enhydra.shark.ws;
003:
004: import javax.naming.InitialContext;
005: import javax.transaction.Status;
006: import javax.transaction.UserTransaction;
007:
008: import org.enhydra.shark.Shark;
009: import org.enhydra.shark.api.client.wfmc.wapi.WMFilter;
010: import org.enhydra.shark.api.client.wfmc.wapi.WMSessionHandle;
011: import org.enhydra.shark.api.common.AssignmentFilterBuilder;
012: import org.enhydra.shark.api.common.FilterBuilder;
013: import org.enhydra.shark.ejb.SharkEJBUtilities;
014:
015: /**
016: *
017: * @author Vladimir Puskas
018: * @author T.Jovanovic
019: * @version 0.1
020: */
021: public class AssignmentFilterBuilderWrapper extends
022: FilterBuilderWrapper implements AssignmentFilterBuilder {
023:
024: /**
025: * @ejb:interface-method
026: * view-type="all"
027: * Appends condition "assignments resource username == value of un"
028: *
029: * @param un
030: * @return itself
031: */
032: public WMFilter addUsernameEquals(WMSessionHandle sHandle, String un)
033: throws Exception {
034: if (SharkEJBUtilities.getEnvType() == 1) {
035: UserTransaction t = null;
036: WMFilter retVal = null;
037: try {
038: t = (UserTransaction) new InitialContext()
039: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
040: t.begin();
041: retVal = ((AssignmentFilterBuilder) getSharkObject())
042: .addUsernameEquals(sHandle, un);
043: t.commit();
044:
045: } catch (Exception ex) {
046: try {
047: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
048: t.rollback();
049: } catch (Exception ex1) {
050: ex1.printStackTrace();
051: }
052: throw ex;
053: }
054:
055: return retVal;
056: } else {
057: return ((AssignmentFilterBuilder) getSharkObject())
058: .addUsernameEquals(sHandle, un);
059: }
060: }
061:
062: /**
063: * @ejb:interface-method
064: * view-type="all"
065: * Appends condition "assignments process id == value of un"
066: *
067: * @param un
068: * @return itself
069: */
070: public WMFilter addProcessIdEquals(WMSessionHandle sHandle,
071: String un) throws Exception {
072: if (SharkEJBUtilities.getEnvType() == 1) {
073: UserTransaction t = null;
074: WMFilter retVal = null;
075: try {
076: t = (UserTransaction) new InitialContext()
077: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
078: t.begin();
079: retVal = ((AssignmentFilterBuilder) getSharkObject())
080: .addProcessIdEquals(sHandle, un);
081: t.commit();
082:
083: } catch (Exception ex) {
084: try {
085: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
086: t.rollback();
087: } catch (Exception ex1) {
088: ex1.printStackTrace();
089: }
090: throw ex;
091: }
092:
093: return retVal;
094: } else {
095: return ((AssignmentFilterBuilder) getSharkObject())
096: .addProcessIdEquals(sHandle, un);
097: }
098: }
099:
100: /**
101: * @ejb:interface-method
102: * view-type="all"
103: */
104: public WMFilter addProcessPriorityEquals(WMSessionHandle sHandle,
105: int p) throws Exception {
106: if (SharkEJBUtilities.getEnvType() == 1) {
107: UserTransaction t = null;
108: WMFilter retVal = null;
109: try {
110: t = (UserTransaction) new InitialContext()
111: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
112: t.begin();
113: retVal = ((AssignmentFilterBuilder) getSharkObject())
114: .addProcessPriorityEquals(sHandle, p);
115: t.commit();
116:
117: } catch (Exception ex) {
118: try {
119: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
120: t.rollback();
121: } catch (Exception ex1) {
122: ex1.printStackTrace();
123: }
124: throw ex;
125: }
126:
127: return retVal;
128: } else {
129: return ((AssignmentFilterBuilder) getSharkObject())
130: .addProcessPriorityEquals(sHandle, p);
131: }
132: }
133:
134: /**
135: * @ejb:interface-method
136: * view-type="all"
137: */
138: public WMFilter addProcessPriorityLessThan(WMSessionHandle sHandle,
139: int p) throws Exception {
140: if (SharkEJBUtilities.getEnvType() == 1) {
141: UserTransaction t = null;
142: WMFilter retVal = null;
143: try {
144: t = (UserTransaction) new InitialContext()
145: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
146: t.begin();
147: retVal = ((AssignmentFilterBuilder) getSharkObject())
148: .addProcessPriorityLessThan(sHandle, p);
149: t.commit();
150:
151: } catch (Exception ex) {
152: try {
153: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
154: t.rollback();
155: } catch (Exception ex1) {
156: ex1.printStackTrace();
157: }
158: throw ex;
159: }
160:
161: return retVal;
162: } else {
163: return ((AssignmentFilterBuilder) getSharkObject())
164: .addProcessPriorityLessThan(sHandle, p);
165: }
166: }
167:
168: /**
169: * @ejb:interface-method
170: * view-type="all"
171: */
172: public WMFilter addProcessPriorityGreaterThan(
173: WMSessionHandle sHandle, int p) throws Exception {
174: if (SharkEJBUtilities.getEnvType() == 1) {
175: UserTransaction t = null;
176: WMFilter retVal = null;
177: try {
178: t = (UserTransaction) new InitialContext()
179: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
180: t.begin();
181: retVal = ((AssignmentFilterBuilder) getSharkObject())
182: .addProcessPriorityGreaterThan(sHandle, p);
183: t.commit();
184:
185: } catch (Exception ex) {
186: try {
187: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
188: t.rollback();
189: } catch (Exception ex1) {
190: ex1.printStackTrace();
191: }
192: throw ex;
193: }
194:
195: return retVal;
196: } else {
197: return ((AssignmentFilterBuilder) getSharkObject())
198: .addProcessPriorityGreaterThan(sHandle, p);
199: }
200: }
201:
202: /**
203: * @ejb:interface-method
204: * view-type="all"
205: * Appends condition "is assignment accepted"
206: *
207: * @return itself
208: */
209: public WMFilter addIsAccepted(WMSessionHandle sHandle)
210: throws Exception {
211: if (SharkEJBUtilities.getEnvType() == 1) {
212: UserTransaction t = null;
213: WMFilter retVal = null;
214: try {
215: t = (UserTransaction) new InitialContext()
216: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
217: t.begin();
218: retVal = ((AssignmentFilterBuilder) getSharkObject())
219: .addIsAccepted(sHandle);
220: t.commit();
221:
222: } catch (Exception ex) {
223: try {
224: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
225: t.rollback();
226: } catch (Exception ex1) {
227: ex1.printStackTrace();
228: }
229: throw ex;
230: }
231:
232: return retVal;
233: } else {
234: return ((AssignmentFilterBuilder) getSharkObject())
235: .addIsAccepted(sHandle);
236: }
237: }
238:
239: /**
240: * @ejb:interface-method
241: * view-type="all"
242: * Appends condition "assignments package id == value of un"
243: *
244: * @param un
245: * @return itself
246: */
247: public WMFilter addPackageIdEquals(WMSessionHandle sHandle,
248: String un) throws Exception {
249: if (SharkEJBUtilities.getEnvType() == 1) {
250: UserTransaction t = null;
251: WMFilter retVal = null;
252: try {
253: t = (UserTransaction) new InitialContext()
254: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
255: t.begin();
256: retVal = ((AssignmentFilterBuilder) getSharkObject())
257: .addPackageIdEquals(sHandle, un);
258: t.commit();
259:
260: } catch (Exception ex) {
261: try {
262: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
263: t.rollback();
264: } catch (Exception ex1) {
265: ex1.printStackTrace();
266: }
267: throw ex;
268: }
269:
270: return retVal;
271: } else {
272: return ((AssignmentFilterBuilder) getSharkObject())
273: .addPackageIdEquals(sHandle, un);
274: }
275: }
276:
277: /**
278: * @ejb:interface-method
279: * view-type="all"
280: * Appends condition "assignments package version == value of un"
281: *
282: * @param un
283: * @return itself
284: */
285: public WMFilter addPackageVersionEquals(WMSessionHandle sHandle,
286: String un) throws Exception {
287: if (SharkEJBUtilities.getEnvType() == 1) {
288: UserTransaction t = null;
289: WMFilter retVal = null;
290: try {
291: t = (UserTransaction) new InitialContext()
292: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
293: t.begin();
294: retVal = ((AssignmentFilterBuilder) getSharkObject())
295: .addPackageVersionEquals(sHandle, un);
296: t.commit();
297:
298: } catch (Exception ex) {
299: try {
300: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
301: t.rollback();
302: } catch (Exception ex1) {
303: ex1.printStackTrace();
304: }
305: throw ex;
306: }
307:
308: return retVal;
309: } else {
310: return ((AssignmentFilterBuilder) getSharkObject())
311: .addPackageVersionEquals(sHandle, un);
312: }
313: }
314:
315: /**
316: * @ejb:interface-method
317: * view-type="all"
318: * Appends condition "assignments package definition id == value of un"
319: *
320: * @param un
321: * @return itself
322: */
323: public WMFilter addProcessDefIdEquals(WMSessionHandle sHandle,
324: String un) throws Exception {
325: if (SharkEJBUtilities.getEnvType() == 1) {
326: UserTransaction t = null;
327: WMFilter retVal = null;
328: try {
329: t = (UserTransaction) new InitialContext()
330: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
331: t.begin();
332: retVal = ((AssignmentFilterBuilder) getSharkObject())
333: .addProcessDefIdEquals(sHandle, un);
334: t.commit();
335:
336: } catch (Exception ex) {
337: try {
338: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
339: t.rollback();
340: } catch (Exception ex1) {
341: ex1.printStackTrace();
342: }
343: throw ex;
344: }
345:
346: return retVal;
347: } else {
348: return ((AssignmentFilterBuilder) getSharkObject())
349: .addProcessDefIdEquals(sHandle, un);
350: }
351: }
352:
353: /**
354: * @ejb:interface-method
355: * view-type="all"
356: * Appends condition "assignments activity set id == value of un"
357: *
358: * @param un
359: * @return itself
360: */
361: public WMFilter addActivitySetDefIdEquals(WMSessionHandle sHandle,
362: String un) throws Exception {
363: if (SharkEJBUtilities.getEnvType() == 1) {
364: UserTransaction t = null;
365: WMFilter retVal = null;
366: try {
367: t = (UserTransaction) new InitialContext()
368: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
369: t.begin();
370: retVal = ((AssignmentFilterBuilder) getSharkObject())
371: .addActivitySetDefIdEquals(sHandle, un);
372: t.commit();
373:
374: } catch (Exception ex) {
375: try {
376: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
377: t.rollback();
378: } catch (Exception ex1) {
379: ex1.printStackTrace();
380: }
381: throw ex;
382: }
383:
384: return retVal;
385: } else {
386: return ((AssignmentFilterBuilder) getSharkObject())
387: .addActivitySetDefIdEquals(sHandle, un);
388: }
389: }
390:
391: /**
392: * @ejb:interface-method
393: * view-type="all"
394: * Appends condition "assignments activity definition id == value of un"
395: *
396: * @param un
397: * @return itself
398: */
399: public WMFilter addActivityDefIdEquals(WMSessionHandle sHandle,
400: String un) throws Exception {
401: if (SharkEJBUtilities.getEnvType() == 1) {
402: UserTransaction t = null;
403: WMFilter retVal = null;
404: try {
405: t = (UserTransaction) new InitialContext()
406: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
407: t.begin();
408: retVal = ((AssignmentFilterBuilder) getSharkObject())
409: .addActivityDefIdEquals(sHandle, un);
410: t.commit();
411:
412: } catch (Exception ex) {
413: try {
414: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
415: t.rollback();
416: } catch (Exception ex1) {
417: ex1.printStackTrace();
418: }
419: throw ex;
420: }
421:
422: return retVal;
423: } else {
424: return ((AssignmentFilterBuilder) getSharkObject())
425: .addActivityDefIdEquals(sHandle, un);
426: }
427: }
428:
429: /**
430: * @ejb:interface-method
431: * view-type="all"
432: * Appends condition "assignments activity id == value of un"
433: *
434: * @param un
435: * @return itself
436: */
437: public WMFilter addActivityIdEquals(WMSessionHandle sHandle,
438: String un) throws Exception {
439: if (SharkEJBUtilities.getEnvType() == 1) {
440: UserTransaction t = null;
441: WMFilter retVal = null;
442: try {
443: t = (UserTransaction) new InitialContext()
444: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
445: t.begin();
446: retVal = ((AssignmentFilterBuilder) getSharkObject())
447: .addActivityIdEquals(sHandle, un);
448: t.commit();
449:
450: } catch (Exception ex) {
451: try {
452: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
453: t.rollback();
454: } catch (Exception ex1) {
455: ex1.printStackTrace();
456: }
457: throw ex;
458: }
459:
460: return retVal;
461: } else {
462: return ((AssignmentFilterBuilder) getSharkObject())
463: .addActivityIdEquals(sHandle, un);
464: }
465: }
466:
467: /**
468: * @ejb:interface-method
469: * view-type="all"
470: */
471: public WMFilter addActivityPriorityEquals(WMSessionHandle sHandle,
472: int p) throws Exception {
473: if (SharkEJBUtilities.getEnvType() == 1) {
474: UserTransaction t = null;
475: WMFilter retVal = null;
476: try {
477: t = (UserTransaction) new InitialContext()
478: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
479: t.begin();
480: retVal = ((AssignmentFilterBuilder) getSharkObject())
481: .addActivityPriorityEquals(sHandle, p);
482: t.commit();
483:
484: } catch (Exception ex) {
485: try {
486: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
487: t.rollback();
488: } catch (Exception ex1) {
489: ex1.printStackTrace();
490: }
491: throw ex;
492: }
493:
494: return retVal;
495: } else {
496: return ((AssignmentFilterBuilder) getSharkObject())
497: .addActivityPriorityEquals(sHandle, p);
498: }
499: }
500:
501: /**
502: * @ejb:interface-method
503: * view-type="all"
504: */
505: public WMFilter addActivityPriorityLessThan(
506: WMSessionHandle sHandle, int p) throws Exception {
507: if (SharkEJBUtilities.getEnvType() == 1) {
508: UserTransaction t = null;
509: WMFilter retVal = null;
510: try {
511: t = (UserTransaction) new InitialContext()
512: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
513: t.begin();
514: retVal = ((AssignmentFilterBuilder) getSharkObject())
515: .addActivityPriorityLessThan(sHandle, p);
516: t.commit();
517:
518: } catch (Exception ex) {
519: try {
520: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
521: t.rollback();
522: } catch (Exception ex1) {
523: ex1.printStackTrace();
524: }
525: throw ex;
526: }
527:
528: return retVal;
529: } else {
530: return ((AssignmentFilterBuilder) getSharkObject())
531: .addActivityPriorityLessThan(sHandle, p);
532: }
533: }
534:
535: /**
536: * @ejb:interface-method
537: * view-type="all"
538: */
539: public WMFilter addActivityPriorityGreaterThan(
540: WMSessionHandle sHandle, int p) throws Exception {
541: if (SharkEJBUtilities.getEnvType() == 1) {
542: UserTransaction t = null;
543: WMFilter retVal = null;
544: try {
545: t = (UserTransaction) new InitialContext()
546: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
547: t.begin();
548: retVal = ((AssignmentFilterBuilder) getSharkObject())
549: .addActivityPriorityGreaterThan(sHandle, p);
550: t.commit();
551:
552: } catch (Exception ex) {
553: try {
554: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
555: t.rollback();
556: } catch (Exception ex1) {
557: ex1.printStackTrace();
558: }
559: throw ex;
560: }
561:
562: return retVal;
563: } else {
564: return ((AssignmentFilterBuilder) getSharkObject())
565: .addActivityPriorityGreaterThan(sHandle, p);
566: }
567: }
568:
569: /**
570: * @ejb:interface-method
571: * view-type="all"
572: * @param ascending
573: * @return itself
574: */
575: public WMFilter setOrderByUsername(WMSessionHandle sHandle,
576: WMFilter filter, boolean ascending) throws Exception {
577: if (SharkEJBUtilities.getEnvType() == 1) {
578: UserTransaction t = null;
579: WMFilter retVal = null;
580: try {
581: t = (UserTransaction) new InitialContext()
582: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
583: t.begin();
584: retVal = ((AssignmentFilterBuilder) getSharkObject())
585: .setOrderByUsername(sHandle, filter, ascending);
586: t.commit();
587:
588: } catch (Exception ex) {
589: try {
590: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
591: t.rollback();
592: } catch (Exception ex1) {
593: ex1.printStackTrace();
594: }
595: throw ex;
596: }
597:
598: return retVal;
599: } else {
600: return ((AssignmentFilterBuilder) getSharkObject())
601: .setOrderByUsername(sHandle, filter, ascending);
602: }
603: }
604:
605: /**
606: * @ejb:interface-method
607: * view-type="all"
608: * Methods starting with <tt>setOrderBy</tt> obviously don't affect actual expression
609: * (nor its evaluation), rather they affect sorting of the result.
610: * <p>
611: * This method sets ordering by process id value.
612: *
613: * @param ascending
614: * @return itself
615: */
616: public WMFilter setOrderByProcessId(WMSessionHandle sHandle,
617: WMFilter filter, boolean ascending) throws Exception {
618: if (SharkEJBUtilities.getEnvType() == 1) {
619: UserTransaction t = null;
620: WMFilter retVal = null;
621: try {
622: t = (UserTransaction) new InitialContext()
623: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
624: t.begin();
625: retVal = ((AssignmentFilterBuilder) getSharkObject())
626: .setOrderByProcessId(sHandle, filter, ascending);
627: t.commit();
628:
629: } catch (Exception ex) {
630: try {
631: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
632: t.rollback();
633: } catch (Exception ex1) {
634: ex1.printStackTrace();
635: }
636: throw ex;
637: }
638:
639: return retVal;
640: } else {
641: return ((AssignmentFilterBuilder) getSharkObject())
642: .setOrderByProcessId(sHandle, filter, ascending);
643: }
644: }
645:
646: /**
647: * @ejb:interface-method
648: * view-type="all"
649: * Methods starting with <tt>setOrderBy</tt> obviously don't affect actual expression
650: * (nor its evaluation), rather they affect sorting of the result.
651: * <p>
652: * This method sets ordering by assignment created time value.
653: *
654: * @param ascending
655: * @return itself
656: */
657: public WMFilter setOrderByCreatedTime(WMSessionHandle sHandle,
658: WMFilter filter, boolean ascending) throws Exception {
659: if (SharkEJBUtilities.getEnvType() == 1) {
660: UserTransaction t = null;
661: WMFilter retVal = null;
662: try {
663: t = (UserTransaction) new InitialContext()
664: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
665: t.begin();
666: retVal = ((AssignmentFilterBuilder) getSharkObject())
667: .setOrderByCreatedTime(sHandle, filter,
668: ascending);
669: t.commit();
670:
671: } catch (Exception ex) {
672: try {
673: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
674: t.rollback();
675: } catch (Exception ex1) {
676: ex1.printStackTrace();
677: }
678: throw ex;
679: }
680:
681: return retVal;
682: } else {
683: return ((AssignmentFilterBuilder) getSharkObject())
684: .setOrderByCreatedTime(sHandle, filter, ascending);
685: }
686: }
687:
688: /**
689: * @ejb:interface-method
690: * view-type="all"
691: * Methods starting with <tt>setOrderBy</tt> obviously don't affect actual expression
692: * (nor its evaluation), rather they affect sorting of the result.
693: * <p>
694: * This method sets ordering by assignment accepted status value.
695: *
696: * @param ascending
697: * @return itself
698: */
699: public WMFilter setOrderByAccepted(WMSessionHandle sHandle,
700: WMFilter filter, boolean ascending) throws Exception {
701: if (SharkEJBUtilities.getEnvType() == 1) {
702: UserTransaction t = null;
703: WMFilter retVal = null;
704: try {
705: t = (UserTransaction) new InitialContext()
706: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
707: t.begin();
708: retVal = ((AssignmentFilterBuilder) getSharkObject())
709: .setOrderByAccepted(sHandle, filter, ascending);
710: t.commit();
711:
712: } catch (Exception ex) {
713: try {
714: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
715: t.rollback();
716: } catch (Exception ex1) {
717: ex1.printStackTrace();
718: }
719: throw ex;
720: }
721:
722: return retVal;
723: } else {
724: return ((AssignmentFilterBuilder) getSharkObject())
725: .setOrderByAccepted(sHandle, filter, ascending);
726: }
727: }
728:
729: protected FilterBuilder getSharkObject() throws Exception {
730: return Shark.getInstance().getAssignmentFilterBuilder();
731: }
732: }
|