In this EJB-JPA tutorial, we will use JPAQL to retrieve SavingsAc Entity by Person Name search.
Remote Interface
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 |
package tube.codingexamples.ejb.statelessbean; import javax.ejb.Remote; import tube.coding.examples.jpa.entity.SavingsAccount; @Remote public interface SavingAcBeanRemote { //Sample 3.7: Declare the interface method public int newAccount(String accountHolderName, int initialBalance); //Sample 4.00a: Add Methods for Deposit, Withdraw and Account Closure public int depositMoney(int PersonalBankingId, int amount); public int withdrawMoney(int PersonalBankingId, int amount); public boolean closeSavingsAc(int PersonalBankingId); //Sample 5.04: Find Account & return public SavingsAccount findById(int pid); public void TransferFund( SavingsAccount fromAc, SavingsAccount toAc, int amount); //Sample 6.04: Declare method to Search By Id public SavingsAccount queryById(int personalBankingId); //Sample 6.11: Declare method to search by name public SavingsAccount queryByName(String personName); } |
Bean Implementation [JPAQL]
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 |
package tube.codingexamples.ejb.statelessbean; import javax.ejb.LocalBean; import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import javax.persistence.Query; import tube.coding.examples.jpa.entity.SavingsAccount; @Stateless(mappedName = "SavingAcBean") @LocalBean public class SavingAcBean implements SavingAcBeanRemote { //Sample 3.6: Create Entiry Manager //UnitName is from persistance.xml @PersistenceContext(unitName = "JPASavingAccount") EntityManager em; public SavingAcBean() {} //Sample 3.8: Create New Account public int newAccount(String accountHolderName, int initialBalance) { SavingsAccount account = new SavingsAccount(); account.setBal(initialBalance); account.setpName(accountHolderName); em.persist(account); return account.getPid(); } //Sample 4.00b: Deposit amount to Bank Account @Override public int depositMoney(int PersonalBankingId, int amount) { //Sample 4.20: Find the Account & call deposit on JPA SavingsAccount SavingAc = em.find(SavingsAccount.class, PersonalBankingId); return SavingAc.deposit(amount); } //Sample 4.00c: Withdraw amount from Savings Account public int withdrawMoney(int PersonalBankingId, int amount) { //Sample 4.21: Find the account & Call withdraw on JPA SavingsAccount SavingAc = em.find(SavingsAccount.class, PersonalBankingId); return SavingAc.withdraw(amount); } //Sample 4.00d: Close the account. public boolean closeSavingsAc(int PersonalBankingId) { //Sample 4.22: Find the account and delete the record. Note=> em.remove boolean ret = false; SavingsAccount SavingAc = em.find(SavingsAccount.class, PersonalBankingId); if (SavingAc != null) { em.remove(SavingAc); ret = true; } return ret; } //Sample 5.05: Find account by id and return it @Override public SavingsAccount findById(int pid) { SavingsAccount SavingAc = em.find(SavingsAccount.class,pid); return SavingAc; } //Sample 5.06: Perform Fund Transfer @Override public void TransferFund( SavingsAccount fromAc, SavingsAccount toAc, int amount) { //5.03.1: First Change the From Account SavingsAccount ac1 = em.merge(fromAc); ac1.withdraw(amount); //5.03.2: Now Change the To Account SavingsAccount ac2 = em.merge(toAc); ac2.deposit(amount); } //Sample 6.05: Use Entity manager to filter account by id public SavingsAccount queryById(int personalBankingId) { SavingsAccount SavingAc = em.find(SavingsAccount.class, personalBankingId); return SavingAc; } //Sample 6.12: Use JPA QL to filter by account name public SavingsAccount queryByName(String personName) { String JpaSql = "Select sac from SavingsAccount sac " + "where sac.pName = :PersonName"; Query query = em.createQuery(JpaSql); query.setParameter("PersonName", personName); SavingsAccount sa = (SavingsAccount) query.getSingleResult(); return sa; } } |
Servlet Layer
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 |
package tube.codingexamples.servlets; import java.io.IOException; import javax.ejb.EJB; import javax.servlet.RequestDispatcher; import javax.servlet.ServletException; import javax.servlet.annotation.WebServlet; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import tube.coding.examples.jpa.entity.SavingsAccount; import tube.codingexamples.ejb.statelessbean.SavingAcBeanRemote; @WebServlet("/QuerySavingAc") public class QuerySavingAc extends HttpServlet { //Sample 6.03: Have EJB Reference via Annotation @EJB(beanName="SavingAcBean") SavingAcBeanRemote SACBean; private static final long serialVersionUID = 1L; public QuerySavingAc() { super(); } protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { //Sample 6.02: Get the request Parameters SavingsAccount account = null; String pid = request.getParameter("Pid"); String submit1 = request.getParameter("Submit1"); String pname = request.getParameter("Pname"); String submit2 = request.getParameter("Submit2"); String balance = request.getParameter("Balance"); String submit3 = request.getParameter("Submit3"); String BalSearchOption = request.getParameter("BalSearch"); String submit4 = request.getParameter("Submit4"); //Sample 6.06: Search By Customer Id if ( (pid != null && pid.trim().length() > 0) && (submit1 != null && submit1.trim().length() > 0) && (submit1.equalsIgnoreCase("Search") == true) ) { int personalBankingId = new Integer(pid).intValue(); account = SACBean.queryById(personalBankingId); //Sample 6.07: Delegate Display output to Query Result JSP request.setAttribute("Account", account); RequestDispatcher respJSP = request.getRequestDispatcher("QueryResultByIdorName.jsp"); respJSP.forward(request, response); } //Sample 6.13: Search by Owner Name if ( (pname != null && pname.trim().length() > 0) && (submit2 != null && submit2.trim().length() > 0) && (submit2.equalsIgnoreCase("Search") == true) ) { account = SACBean.queryByName(pname); request.setAttribute("Account", account); RequestDispatcher respJSP = request.getRequestDispatcher("QueryResultByIdorName.jsp"); respJSP.forward(request, response); } } } |
Categories: JavaEE-EJB-Tube
Do you like this Example? Please comment about it for others!!
This site uses Akismet to reduce spam. Learn how your comment data is processed.