E.1 The com.mediamania.appserver package

This package includes classes that are described in Chapter 16 and Chapter 17 for using JDO in an application server environment.

E.1.1 com.mediamania.appserver.CashierBean

 1    package com.mediamania.appserver;  2      3    import javax.ejb.*;  4      5    import javax.naming.InitialContext;  6    import javax.naming.Context;  7    import javax.naming.NamingException;  8      9    import java.util.Iterator; 10    import java.util.Date; 11     12    import com.mediamania.store.StoreQueries; 13    import com.mediamania.store.Customer; 14    import com.mediamania.store.Purchase; 15    import com.mediamania.store.Rental; 16    import com.mediamania.store.RentalItem; 17    import com.mediamania.store.MediaItem; 18     19    import javax.jdo.PersistenceManager; 20    import javax.jdo.PersistenceManagerFactory; 21     22    public class CashierBean implements javax.ejb.SessionBean { 23        private javax.ejb.SessionContext context; 24        private PersistenceManagerFactory pmf; 25        private PersistenceManager pm; 26        private String pmfName = "java:comp/env/jdo/MediaManiaPMF"; 27     28        /** 29         * @see javax.ejb.SessionBean#setSessionContext(javax.ejb.SessionContext) 30         */ 31        public void setSessionContext(javax.ejb.SessionContext aContext) { 32            context = aContext; 33            try { 34                Context ic = new InitialContext(  ); 35                pmf = (PersistenceManagerFactory)ic.lookup(pmfName); 36            } catch (NamingException ex) { 37                throw new EJBException("setSessionContext", ex); 38            } 39        } 40         41        public void ejbActivate(  ) { 42        } 43        public void ejbPassivate(  ) { 44        } 45        public void ejbRemove(  ) { 46        } 47        public void ejbCreate(  ) { 48        } 49         50        public void checkout( 51            final java.lang.String lastName,  52            final java.lang.String firstName,  53            final java.util.Collection rentals,  54            final java.util.Collection purchases)  55                throws java.rmi.RemoteException { 56            PersistenceManager pm = pmf.getPersistenceManager(  ); 57            Customer customer = StoreQueries.getCustomer(pm, firstName, lastName); 58            Iterator it = rentals.iterator(  ); 59            while (it.hasNext(  )) { 60                RentalValueObject rvo = (RentalValueObject)it.next(  ); 61                RentalItem ri = StoreQueries.getRentalItem 62                    (pm, rvo.serialNumber); 63                Rental rental = new Rental(customer, new Date(  ), ri); 64                customer.addTransaction(rental); 65                customer.addRental(rental); 66            } 67            it = purchases.iterator(  ); 68            while (it.hasNext(  )) { 69                PurchaseValueObject pvo = (PurchaseValueObject)it.next(  ); 70                MediaItem mediaItem = StoreQueries.getMediaItem( 71                    pm, pvo.title, pvo.format); 72                Purchase purchase = new Purchase(customer, new Date(  ), mediaItem); 73                customer.addTransaction(purchase); 74            } 75            pm.close(  ); 76        } 77    } 

E.1.2 com.mediamania.appserver.JDOPlugIn

 1    package com.mediamania.appserver;  2      3    import javax.servlet.*;  4    import javax.servlet.http.*;  5      6    import javax.jdo.PersistenceManagerFactory;  7    import javax.jdo.PersistenceManager;  8    import javax.jdo.JDOHelper;  9    import javax.jdo.Extent; 10     11    import java.util.Properties; 12    import java.util.Iterator; 13     14    import java.io.InputStream; 15    import java.io.IOException; 16     17    import javax.naming.Context; 18    import javax.naming.InitialContext; 19    import javax.naming.NamingException; 20     21    import org.apache.struts.action.ActionServlet; 22    import org.apache.struts.action.PlugIn; 23    import org.apache.struts.config.ModuleConfig; 24     25    public class JDOPlugIn implements PlugIn { 26        private ServletContext ctx; 27        private String name; 28        private String path; 29        private String jndiName; 30        public JDOPlugIn(  ) { 31        } 32         33        public void setName(String name) { 34            this.name = name; 35        } 36         37        public void setPath(String path) { 38            this.path = path; 39        } 40         41        public void setJndiName(String jndiName) { 42            this.jndiName = jndiName; 43        } 44         45        public void init(ActionServlet servlet, ModuleConfig config)  46                throws ServletException { 47            ctx = servlet.getServletContext(  ); 48            if (name == null  name.length(  ) == 0) { 49                throw new ServletException 50                    ("You must specify name."); 51            } 52            try { 53                PersistenceManagerFactory pmf; 54                if (path != null) { 55                    pmf = getPersistenceManagerFactoryFromPath(path); 56                } else if (jndiName != null) { 57                    pmf = getPersistenceManagerFactoryFromJndi(jndiName); 58                } else { 59                    throw new ServletException 60                        ("You must specify either path or jndiName."); 61                } 62                ctx.setAttribute(name, pmf); 63            } catch (Exception ex) { 64                throw new ServletException( 65                    "Unable to load PMF: name:" + name + 66                    ", path: " + path +  67                    ", jndiName: " + jndiName, 68                    ex); 69            } 70        } 71         72        private PersistenceManagerFactory  73                getPersistenceManagerFactoryFromPath(String path)  74                    throws IOException { 75            Properties props = new Properties(  ); 76            InputStream in = ctx.getResourceAsStream(path); 77            props.load(in); 78            return JDOHelper.getPersistenceManagerFactory(props); 79        } 80         81        private PersistenceManagerFactory  82                getPersistenceManagerFactoryFromJndi(String jndiName)  83                    throws NamingException { 84                Context ic = new InitialContext(  ); 85                return (PersistenceManagerFactory) ic.lookup(jndiName); 86        } 87         88        public void destroy(  ) {} 89    } 

E.1.3 com.mediamania.appserver.LookupMovieAction

 1    package com.mediamania.appserver;  2      3    import javax.servlet.ServletContext;  4    import javax.servlet.http.HttpServletRequest;  5    import javax.servlet.http.HttpServletResponse;  6    import org.apache.struts.action.Action;  7    import org.apache.struts.action.ActionForm;  8    import org.apache.struts.action.ActionForward;  9    import org.apache.struts.action.ActionMapping; 10     11    import javax.jdo.PersistenceManagerFactory; 12    import javax.jdo.PersistenceManager; 13    import javax.jdo.JDOHelper; 14    import javax.jdo.Extent; 15    import javax.jdo.Transaction; 16    import javax.jdo.Query; 17    import javax.jdo.JDOException; 18     19    import java.util.Collection; 20    import java.util.Iterator; 21    import com.mediamania.content.Movie; 22     23    public class LookupMovieAction extends Action { 24        PersistenceManagerFactory pmf = null; 25        PersistenceManager pm = null; 26        public ActionForward execute(ActionMapping mapping, 27            ActionForm form, 28            HttpServletRequest request, 29            HttpServletResponse response) 30            throws Exception { 31            try { 32                ServletContext ctx = getServlet().getServletContext(  ); 33                pmf = (PersistenceManagerFactory)ctx.getAttribute("jdo.Movies"); 34                pm = pmf.getPersistenceManager(  ); 35                Query q = pm.newQuery(Movie.class, "title == param1"); 36                q.declareParameters ("String param1"); 37                String movieName = request.getParameter("movieName"); 38                Collection movies = (Collection)q.execute(movieName); 39                Movie movie = (Movie)movies.iterator().next(  ); 40                String description = movie.getDescription(  ); 41                ctx.setAttribute("movieDescription", description); 42            } catch (JDOException e) { 43            } finally { 44                if (pm != null) { 45                    pm.close(  ); 46                } 47                pm = null; 48            } 49            return (mapping.findForward("success")); 50        } 51    } 

E.1.4 com.mediamania.appserver.MediaValueObject

 1    package com.mediamania.appserver;  2      3    import java.io.Serializable;  4      5    public class MediaValueObject implements Serializable {  6        public String title;  7    } 

E.1.5 com.mediamania.appserver.MovieInfo

 1    package com.mediamania.appserver;  2      3    import javax.servlet.*;  4    import javax.servlet.http.*;  5      6    import javax.jdo.PersistenceManagerFactory;  7    import javax.jdo.PersistenceManager;  8    import javax.jdo.JDOHelper;  9    import javax.jdo.Extent; 10    import javax.jdo.JDOException; 11     12    import java.util.Properties; 13    import java.util.Iterator; 14     15    import java.io.InputStream; 16    import java.io.IOException; 17     18    import javax.naming.Context; 19    import javax.naming.InitialContext; 20    import javax.naming.NamingException; 21     22    import com.mediamania.content.Movie; 23     24    public class MovieInfo extends HttpServlet { 25        PersistenceManagerFactory persistenceManagerFactory; 26        PersistenceManager pm; 27        public void init(  ) throws ServletException { 28            try { 29                ServletContext ctx = getServletContext(  ); 30                InputStream in = ctx.getResourceAsStream("WEB-INF/pmf.properties"); 31                Properties props = new Properties(  ); 32                props.load(in); 33                persistenceManagerFactory =  34                    JDOHelper.getPersistenceManagerFactory(props); 35            } catch (IOException ex) { 36                throw new ServletException("Unable to load PMF properties.", ex); 37            } catch (JDOException ex) { 38                throw new ServletException("Unable to create PMF resource.", ex); 39            } catch (Exception ex) { 40                throw new ServletException("Unable to initialize.", ex); 41            } 42             43        } 44                 45        /** 46           Destroys the servlet. 47         */ 48        public void destroy(  ) { 49        } 50         51        /** Processes requests for both HTTP <code>GET</code> 52         * and <code>POST</code> methods. 53         * @param request servlet request 54         * @param response servlet response 55         */ 56        protected void processRequest(HttpServletRequest request,  57            HttpServletResponse response) 58                throws ServletException, java.io.IOException { 59            pm = persistenceManagerFactory.getPersistenceManager(  ); 60            response.setContentType("text/html"); 61            java.io.PrintWriter out = response.getWriter(  ); 62            out.println("<html>"); 63            out.println("<head>"); 64            out.println("<title>Servlet</title>"); 65            out.println("</head>"); 66            out.println("<body>"); 67            out.print(formatMovieInfo(  )); 68            out.println("</body>"); 69            out.println("</html>"); 70            out.close(  ); 71            pm.close(  ); 72        } 73         74        protected String formatMovieInfo(  ) { 75            StringBuffer result = new StringBuffer(  ); 76            Extent movies = pm.getExtent(Movie.class, true); 77            Iterator it = movies.iterator(  ); 78            while (it.hasNext(  )) { 79                result.append("<P>"); 80                Movie movie = (Movie)it.next(  ); 81                result.append(movie.getDescription(  )); 82            } 83            return result.toString(  ); 84        } 85        /** Handles the HTTP <code>GET</code> method. 86         * @param request servlet request 87         * @param response servlet response 88         */ 89        protected void doGet(HttpServletRequest request, 90            HttpServletResponse response) 91                throws ServletException, java.io.IOException { 92            processRequest(request, response); 93        } 94         95        /** Handles the HTTP <code>POST</code> method. 96         * @param request servlet request 97         * @param response servlet response 98         */ 99        protected void doPost(HttpServletRequest request,  100            HttpServletResponse response) 101                throws ServletException, java.io.IOException { 102            processRequest(request, response); 103        } 104         105        /** Returns a short description of the servlet. 106         */ 107        public String getServletInfo(  ) { 108            return "Movie Information"; 109        } 110         111    } 

E.1.6 com.mediamania.appserver.PurchaseValueObject

 1    package com.mediamania.appserver;  2      3    public class PurchaseValueObject extends MediaValueObject {  4        public String format;  5    } 

E.1.7 com.mediamania.appserver.RentalValueObject

 1    package com.mediamania.appserver;  2      3    public class RentalValueObject extends MediaValueObject {  4         public String serialNumber;  5    }