Page History

package sample.jpa.appclient;

import java.util.ArrayList;
import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;



public class AccountClient {

 //@PersistenceContext(unitName="JPA-App-Client")
 private EntityManager em;

 public AccountClient(){

  EntityManagerFactory emf = 
   Persistence.createEntityManagerFactory("JPA-App-Client");

  if(emf == null) 
     System.out.println("emf is null!!!");

  em = emf.createEntityManager();
  if(em == null) 
     System.out.println("em is null!!!");

 }

 public static void main(String[] args) {

  AccountClient client = new AccountClient();

  String opt = args[0];

  if(opt.equals("create")){

   if (args.length != 6){

   System.out.println("Enter values for accountNo, 
    name, address, branchCode and balance;");

   System.exit(0);
  }
  else{

   int accNo = Integer.parseInt(args[1]);
   String name = args[2];
   String address = args[3];
   int branchCode = Integer.parseInt(args[4]);
   double balance = Double.parseDouble(args[5]);
   client.createAccount(accNo,name,address,branchCode,balance);

  }

 }else if (opt.equals("list")){

   List accList = client.listAccounts();
   for(int i = 0; i < accList.size(); i++){
    System.out.println("_________________________________");
    Account acc = (Account)accList.get(i);
    System.out.println(acc.getAccountNo());
    System.out.println(acc.getName());
    System.out.println(acc.getAddress());
    System.out.println(acc.getBranchCode());
    System.out.println(acc.getBalance());
    System.out.println("____________________________________________");
    System.out.println("");
   }

 }else if (opt.equals("update")){

  if (args.length != 3){
   System.out.println("Enter values for accountNo and new balace value ;");
   System.exit(0);
  }

  else{
   int accNo = Integer.parseInt(args[1]);
   double newbalance = Double.parseDouble(args[2]); 
   client.updateAccountBalance(accNo,newbalance);
  }
			
 }else if (opt.equals("delete")){

  if (args.length != 2){
   System.out.println("Enter values for accountNo for delete");
   System.exit(0);
  }
  else {
   int accNo = Integer.parseInt(args[1]);
   client.deleteAccount(accNo);
  } 
 
 else {
   System.out.println("Unknown option selected...!!");
  }

 }
	
 public Account createAccount
        (int accNo, String name, 
	 String address, int branchCode,
	 double balance){
		
  Account acc1 = em.find(Account.class, accNo);
  if(acc1 != null) throw new 
   IllegalArgumentException
   ("Account already exists: Account Number ("+accNo+")");

  Account acc = new Account();
  acc.setAccountNo(accNo);
  acc.setAddress(address);
  acc.setBalance(balance);
  acc.setBranchCode(branchCode);
  acc.setName(name);
  System.out.println("Persisting account entity (accNo = "+accNo+")");
  em.persist(acc);
  System.out.println("Persisted successfully account entity (accNo = "+accNo+")");
  return acc;

 }
	
 public List listAccounts(){
  if(em == null) System.out.println("em is null!!!");
  Query q = em.createQuery("SELECT a FROM Account a");
  List currList = q.getResultList();
  return currList;
 }

	
 public Account updateAccountBalance
       (int accNo, double newBalance){

  Account acc = em.find(Account.class, accNo);

  if(acc == null) throw new 
   IllegalArgumentException
  ("Account not found : Account Number ("+accNo+")");

  acc.setBalance(newBalance);
		em.merge(acc);
  return acc;
		 
 }
	
 public void deleteAccount(int accNo){
  Account acc = em.find(Account.class, accNo);
  if(acc == null) throw new IllegalArgumentException
   ("Account not found : Account Number ("+accNo+")");
  em.remove(acc);
 }
}