public class RDBMTicketRegistry implements TicketRegistry {
   private Connection con = getConnection();
   
   /** The Commons Logging instance. */
    private final Log log = LogFactory.getLog(getClass());

   
   /**
    * Add a ticket to the DB
    */
   public void addTicket(final Ticket ticket) {
      
      if (log.isDebugEnabled())
         log.debug("Entre en addTicket");
      
      if (ticket == null) {
            throw new IllegalArgumentException("ticket cannot be null");
        }

      try {                  
         ByteArrayOutputStream baos = new ByteArrayOutputStream();
         ObjectOutputStream oos = new ObjectOutputStream(baos);
         oos.writeObject(ticket);
         // serialize the employee object into a byte array
         byte[] ticketAsBytes = baos.toByteArray();
         PreparedStatement pstmt = con.prepareStatement
                  ("INSERT INTO tickets VALUES(?, ?)");
         ByteArrayInputStream bais =
            new ByteArrayInputStream(ticketAsBytes);
         // bind our byte array  to the emp column
         pstmt.setString(1, ticket.getId());
         pstmt.setBinaryStream(2,bais, ticketAsBytes.length);
         pstmt.executeUpdate();         
         pstmt.close();                           
      } catch(IOException ioe) {
         log.error("Error IOE al insertar ticket id " + ticket.getId() + " exception: " + ioe.getMessage());
      } catch(SQLException sqle) {
         log.error("Error SQL al insertar ticket id " + ticket.getId() + " exception: " + sqle.getMessage());
      }
   }
   
   
   
   
   /**
    *
    * @return
    */
   private Connection getConnection() {
      Connection c = null;
      
      System.out.println("Entre en getConnection");

      
      try {
         // Obtain our environment naming context
         Context initCtx = new InitialContext();
         Context envCtx = (Context) initCtx.lookup("java:comp/env");

         // Look up our data source
         DataSource ds = (DataSource) envCtx.lookup("jdbc/MySQLDB");

         // Allocate and use a connection from the pool
         c = ds.getConnection();
      } catch(Exception e) {
         log.error("Excepcion al conectar a Db " + e.getMessage());
      }      
      
      if (c != null) {         
         System.out.println("Connection a DB es Ok");
      }
      
      return c;
   }
}