1 package org.contineo.documan.dao; 2 3 import org.apache.log4j.Level; 4 import org.apache.log4j.Logger; 5 import org.apache.ojb.broker.PBKey; 6 import org.apache.ojb.broker.PersistenceBroker; 7 import org.apache.ojb.broker.PersistenceBrokerFactory; 8 import org.apache.ojb.broker.query.Criteria; 9 import org.apache.ojb.broker.query.Query; 10 import org.apache.ojb.broker.query.QueryByCriteria; 11 import org.contineo.core.LoggingManager; 12 import org.contineo.documan.DownloadTicket; 13 14 18 public class DownloadTicketDAO { 19 20 private PersistenceBroker broker = null; 21 private PBKey pbkey; 22 private Logger logger; 23 24 27 public DownloadTicketDAO() { 28 logger = LoggingManager.getLogger(this.getClass()); 29 pbkey = new PBKey("contineo"); 30 } 31 32 37 public boolean store(DownloadTicket ticket) { 38 boolean result = true; 39 try { 40 broker = PersistenceBrokerFactory.createPersistenceBroker(pbkey); 41 broker.beginTransaction(); 42 broker.store(ticket); 43 broker.commitTransaction(); 44 } 45 catch (Exception e) { 46 broker.abortTransaction(); 47 if (logger.isEnabledFor(Level.ERROR)) 48 logger.error(e.getMessage()); 49 result = false; 50 } finally { 51 if (broker != null) broker.close(); 52 } 53 return result; 54 } 55 56 60 public boolean delete(int ticketid) { 61 boolean result = true; 62 try { 63 broker = PersistenceBrokerFactory.createPersistenceBroker(pbkey); 64 Criteria crit = new Criteria(); 65 crit.addEqualTo("co_ticketid", new Integer (ticketid)); 66 Query query = new QueryByCriteria(org.contineo.documan.DownloadTicket.class, crit); 67 broker.beginTransaction(); 68 broker.deleteByQuery(query); 69 broker.commitTransaction(); 70 } 71 catch (Exception e) { 72 broker.abortTransaction(); 73 if (logger.isEnabledFor(Level.ERROR)) 74 logger.error(e.getMessage()); 75 result = false; 76 } finally { 77 if (broker != null) broker.close(); 78 } 79 return result; 80 } 81 82 87 public DownloadTicket findByPrimaryKey(String ticketid) { 88 DownloadTicket ticket = null; 89 try { 90 broker = PersistenceBrokerFactory.createPersistenceBroker(pbkey); 91 Criteria crit = new Criteria(); 92 crit.addEqualTo("co_ticketid", ticketid); 93 Query query = new QueryByCriteria(org.contineo.documan.DownloadTicket.class, crit); 94 ticket = (DownloadTicket)broker.getObjectByQuery(query); 95 } 96 catch (Exception e) { 97 if (logger.isEnabledFor(Level.ERROR)) 98 logger.error(e.getMessage()); 99 } finally { 100 if (broker != null) broker.close(); 101 } 102 return ticket; 103 } 104 } 105 | Popular Tags |