001: package org.enhydra.shark.ws;
002:
003: import javax.naming.InitialContext;
004: import javax.transaction.Status;
005: import javax.transaction.UserTransaction;
006:
007: import org.enhydra.shark.Shark;
008: import org.enhydra.shark.api.client.wfmc.wapi.WMFilter;
009: import org.enhydra.shark.api.client.wfmc.wapi.WMSessionHandle;
010: import org.enhydra.shark.api.common.FilterBuilder;
011: import org.enhydra.shark.api.common.ProcessMgrFilterBuilder;
012: import org.enhydra.shark.ejb.SharkEJBUtilities;
013:
014: /**
015: * @author Vladimir Puskas
016: * @author T.Jovanovic
017: * @version 0.1
018: */
019: public class ProcessMgrFilterBuilderWrapper extends
020: FilterBuilderWrapper implements ProcessMgrFilterBuilder {
021:
022: /**
023: * @ejb:interface-method view-type="all"
024: */
025: public WMFilter addPackageIdEquals(WMSessionHandle sHandle,
026: String exp) throws Exception {
027: if (SharkEJBUtilities.getEnvType() == 1) {
028: UserTransaction t = null;
029: WMFilter retVal = null;
030: try {
031: t = (UserTransaction) new InitialContext()
032: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
033: t.begin();
034: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
035: .addPackageIdEquals(sHandle, exp);
036: t.commit();
037:
038: } catch (Exception ex) {
039: try {
040: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
041: t.rollback();
042: } catch (Exception ex1) {
043: ex1.printStackTrace();
044: }
045: throw ex;
046: }
047:
048: return retVal;
049: } else {
050: return ((ProcessMgrFilterBuilder) getSharkObject())
051: .addPackageIdEquals(sHandle, exp);
052: }
053: }
054:
055: /**
056: * @ejb:interface-method view-type="all"
057: */
058: public WMFilter addProcessDefIdEquals(WMSessionHandle sHandle,
059: String exp) throws Exception {
060: if (SharkEJBUtilities.getEnvType() == 1) {
061: UserTransaction t = null;
062: WMFilter retVal = null;
063: try {
064: t = (UserTransaction) new InitialContext()
065: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
066: t.begin();
067: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
068: .addProcessDefIdEquals(sHandle, exp);
069: t.commit();
070:
071: } catch (Exception ex) {
072: try {
073: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
074: t.rollback();
075: } catch (Exception ex1) {
076: ex1.printStackTrace();
077: }
078: throw ex;
079: }
080:
081: return retVal;
082: } else {
083: return ((ProcessMgrFilterBuilder) getSharkObject())
084: .addProcessDefIdEquals(sHandle, exp);
085: }
086: }
087:
088: /**
089: * @ejb:interface-method view-type="all"
090: */
091: public WMFilter addNameEquals(WMSessionHandle sHandle, String exp)
092: throws Exception {
093: if (SharkEJBUtilities.getEnvType() == 1) {
094: UserTransaction t = null;
095: WMFilter retVal = null;
096: try {
097: t = (UserTransaction) new InitialContext()
098: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
099: t.begin();
100: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
101: .addNameEquals(sHandle, exp);
102: t.commit();
103:
104: } catch (Exception ex) {
105: try {
106: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
107: t.rollback();
108: } catch (Exception ex1) {
109: ex1.printStackTrace();
110: }
111: throw ex;
112: }
113:
114: return retVal;
115: } else {
116: return ((ProcessMgrFilterBuilder) getSharkObject())
117: .addNameEquals(sHandle, exp);
118: }
119: }
120:
121: /**
122: * @ejb:interface-method view-type="all"
123: */
124: public WMFilter addVersionEquals(WMSessionHandle sHandle, String exp)
125: throws Exception {
126: if (SharkEJBUtilities.getEnvType() == 1) {
127: UserTransaction t = null;
128: WMFilter retVal = null;
129: try {
130: t = (UserTransaction) new InitialContext()
131: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
132: t.begin();
133: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
134: .addVersionEquals(sHandle, exp);
135: t.commit();
136:
137: } catch (Exception ex) {
138: try {
139: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
140: t.rollback();
141: } catch (Exception ex1) {
142: ex1.printStackTrace();
143: }
144: throw ex;
145: }
146:
147: return retVal;
148: } else {
149: return ((ProcessMgrFilterBuilder) getSharkObject())
150: .addVersionEquals(sHandle, exp);
151: }
152: }
153:
154: /**
155: * @ejb:interface-method view-type="all"
156: */
157: public WMFilter addCreatedTimeEquals(WMSessionHandle sHandle,
158: long arg) throws Exception {
159: if (SharkEJBUtilities.getEnvType() == 1) {
160: UserTransaction t = null;
161: WMFilter retVal = null;
162: try {
163: t = (UserTransaction) new InitialContext()
164: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
165: t.begin();
166: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
167: .addCreatedTimeEquals(sHandle, arg);
168: t.commit();
169:
170: } catch (Exception ex) {
171: try {
172: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
173: t.rollback();
174: } catch (Exception ex1) {
175: ex1.printStackTrace();
176: }
177: throw ex;
178: }
179:
180: return retVal;
181: } else {
182: return ((ProcessMgrFilterBuilder) getSharkObject())
183: .addCreatedTimeEquals(sHandle, arg);
184: }
185: }
186:
187: /**
188: * @ejb:interface-method view-type="all"
189: */
190: public WMFilter addCreatedTimeBefore(WMSessionHandle sHandle,
191: long arg) throws Exception {
192: if (SharkEJBUtilities.getEnvType() == 1) {
193: UserTransaction t = null;
194: WMFilter retVal = null;
195: try {
196: t = (UserTransaction) new InitialContext()
197: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
198: t.begin();
199: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
200: .addCreatedTimeBefore(sHandle, arg);
201: t.commit();
202:
203: } catch (Exception ex) {
204: try {
205: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
206: t.rollback();
207: } catch (Exception ex1) {
208: ex1.printStackTrace();
209: }
210: throw ex;
211: }
212:
213: return retVal;
214: } else {
215: return ((ProcessMgrFilterBuilder) getSharkObject())
216: .addCreatedTimeBefore(sHandle, arg);
217: }
218: }
219:
220: /**
221: * @ejb:interface-method view-type="all"
222: */
223: public WMFilter addCreatedTimeAfter(WMSessionHandle sHandle,
224: long arg) throws Exception {
225: if (SharkEJBUtilities.getEnvType() == 1) {
226: UserTransaction t = null;
227: WMFilter retVal = null;
228: try {
229: t = (UserTransaction) new InitialContext()
230: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
231: t.begin();
232: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
233: .addCreatedTimeAfter(sHandle, arg);
234: t.commit();
235:
236: } catch (Exception ex) {
237: try {
238: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
239: t.rollback();
240: } catch (Exception ex1) {
241: ex1.printStackTrace();
242: }
243: throw ex;
244: }
245:
246: return retVal;
247: } else {
248: return ((ProcessMgrFilterBuilder) getSharkObject())
249: .addCreatedTimeAfter(sHandle, arg);
250: }
251: }
252:
253: /**
254: * @ejb:interface-method view-type="all"
255: */
256: public WMFilter addIsEnabled(WMSessionHandle sHandle)
257: throws Exception {
258: if (SharkEJBUtilities.getEnvType() == 1) {
259: UserTransaction t = null;
260: WMFilter retVal = null;
261: try {
262: t = (UserTransaction) new InitialContext()
263: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
264: t.begin();
265: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
266: .addIsEnabled(sHandle);
267: t.commit();
268:
269: } catch (Exception ex) {
270: try {
271: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
272: t.rollback();
273: } catch (Exception ex1) {
274: ex1.printStackTrace();
275: }
276: throw ex;
277: }
278:
279: return retVal;
280: } else {
281: return ((ProcessMgrFilterBuilder) getSharkObject())
282: .addIsEnabled(sHandle);
283: }
284: }
285:
286: /**
287: * @ejb:interface-method view-type="all"
288: */
289: public WMFilter setOrderByPackageId(WMSessionHandle sHandle,
290: WMFilter filter, boolean ascending) throws Exception {
291: if (SharkEJBUtilities.getEnvType() == 1) {
292: UserTransaction t = null;
293: WMFilter retVal = null;
294: try {
295: t = (UserTransaction) new InitialContext()
296: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
297: t.begin();
298: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
299: .setOrderByPackageId(sHandle, filter, ascending);
300: t.commit();
301:
302: } catch (Exception ex) {
303: try {
304: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
305: t.rollback();
306: } catch (Exception ex1) {
307: ex1.printStackTrace();
308: }
309: throw ex;
310: }
311:
312: return retVal;
313: } else {
314: return ((ProcessMgrFilterBuilder) getSharkObject())
315: .setOrderByPackageId(sHandle, filter, ascending);
316: }
317: }
318:
319: /**
320: * @ejb:interface-method view-type="all"
321: */
322: public WMFilter setOrderByProcessDefId(WMSessionHandle sHandle,
323: WMFilter filter, boolean ascending) throws Exception {
324: if (SharkEJBUtilities.getEnvType() == 1) {
325: UserTransaction t = null;
326: WMFilter retVal = null;
327: try {
328: t = (UserTransaction) new InitialContext()
329: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
330: t.begin();
331: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
332: .setOrderByProcessDefId(sHandle, filter,
333: ascending);
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 ((ProcessMgrFilterBuilder) getSharkObject())
349: .setOrderByProcessDefId(sHandle, filter, ascending);
350: }
351: }
352:
353: /**
354: * @ejb:interface-method view-type="all"
355: */
356: public WMFilter setOrderByName(WMSessionHandle sHandle,
357: WMFilter filter, boolean ascending) throws Exception {
358: if (SharkEJBUtilities.getEnvType() == 1) {
359: UserTransaction t = null;
360: WMFilter retVal = null;
361: try {
362: t = (UserTransaction) new InitialContext()
363: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
364: t.begin();
365: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
366: .setOrderByName(sHandle, filter, ascending);
367: t.commit();
368:
369: } catch (Exception ex) {
370: try {
371: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
372: t.rollback();
373: } catch (Exception ex1) {
374: ex1.printStackTrace();
375: }
376: throw ex;
377: }
378:
379: return retVal;
380: } else {
381: return ((ProcessMgrFilterBuilder) getSharkObject())
382: .setOrderByName(sHandle, filter, ascending);
383: }
384: }
385:
386: /**
387: * @ejb:interface-method view-type="all"
388: */
389: public WMFilter setOrderByVersion(WMSessionHandle sHandle,
390: WMFilter filter, boolean ascending) throws Exception {
391: if (SharkEJBUtilities.getEnvType() == 1) {
392: UserTransaction t = null;
393: WMFilter retVal = null;
394: try {
395: t = (UserTransaction) new InitialContext()
396: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
397: t.begin();
398: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
399: .setOrderByVersion(sHandle, filter, ascending);
400: t.commit();
401:
402: } catch (Exception ex) {
403: try {
404: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
405: t.rollback();
406: } catch (Exception ex1) {
407: ex1.printStackTrace();
408: }
409: throw ex;
410: }
411:
412: return retVal;
413: } else {
414: return ((ProcessMgrFilterBuilder) getSharkObject())
415: .setOrderByVersion(sHandle, filter, ascending);
416: }
417: }
418:
419: /**
420: * @ejb:interface-method view-type="all"
421: */
422: public WMFilter setOrderByCreatedTime(WMSessionHandle sHandle,
423: WMFilter filter, boolean ascending) throws Exception {
424: if (SharkEJBUtilities.getEnvType() == 1) {
425: UserTransaction t = null;
426: WMFilter retVal = null;
427: try {
428: t = (UserTransaction) new InitialContext()
429: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
430: t.begin();
431: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
432: .setOrderByCreatedTime(sHandle, filter,
433: ascending);
434: t.commit();
435:
436: } catch (Exception ex) {
437: try {
438: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
439: t.rollback();
440: } catch (Exception ex1) {
441: ex1.printStackTrace();
442: }
443: throw ex;
444: }
445:
446: return retVal;
447: } else {
448: return ((ProcessMgrFilterBuilder) getSharkObject())
449: .setOrderByCreatedTime(sHandle, filter, ascending);
450: }
451: }
452:
453: /**
454: * @ejb:interface-method view-type="all"
455: */
456: public WMFilter setOrderByEnabled(WMSessionHandle sHandle,
457: WMFilter filter, boolean ascending) throws Exception {
458: if (SharkEJBUtilities.getEnvType() == 1) {
459: UserTransaction t = null;
460: WMFilter retVal = null;
461: try {
462: t = (UserTransaction) new InitialContext()
463: .lookup(SharkEJBUtilities.TOMCAT_USER_TRANS_JNDI_NAME);
464: t.begin();
465: retVal = ((ProcessMgrFilterBuilder) getSharkObject())
466: .setOrderByEnabled(sHandle, filter, ascending);
467: t.commit();
468:
469: } catch (Exception ex) {
470: try {
471: if (t.getStatus() != Status.STATUS_NO_TRANSACTION)
472: t.rollback();
473: } catch (Exception ex1) {
474: ex1.printStackTrace();
475: }
476: throw ex;
477: }
478:
479: return retVal;
480: } else {
481: return ((ProcessMgrFilterBuilder) getSharkObject())
482: .setOrderByEnabled(sHandle, filter, ascending);
483: }
484:
485: }
486:
487: protected FilterBuilder getSharkObject() throws Exception {
488: return Shark.getInstance().getProcessMgrFilterBuilder();
489: }
490: }
|