[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/repository/db4o Db4oRepository.
Brought to you by:
suresh_pragada
From: Suresh <sur...@us...> - 2006-09-10 17:57:17
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/db4o In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10050 Modified Files: Db4oRepository.java Log Message: no message Index: Db4oRepository.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/db4o/Db4oRepository.java,v retrieving revision 1.6 retrieving revision 1.7 diff -C2 -d -r1.6 -r1.7 *** Db4oRepository.java 6 Sep 2006 22:08:05 -0000 1.6 --- Db4oRepository.java 10 Sep 2006 17:57:14 -0000 1.7 *************** *** 431,524 **** } ! /** ! * @see org.jmonks.batchserver.framework.repository.Repository#saveController(String,org.jmonks.batchserver.framework.controller.JobController) ! */ ! public boolean saveController(String jobName, final JobController controller) ! { ! logger.trace("Entering saveController"); ! logger.debug("saveController :: job name = " + jobName + " controller = " + controller); ! if(jobName==null || controller==null) ! throw new IllegalArgumentException("job name and controller cannot be null to save the controller."); ! ! boolean saved=true; ! ! if(container==null) ! saved=false; ! else ! { ! ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! ! while(jobControllerHolderResultSet.hasNext()) ! container.delete(jobControllerHolderResultSet.next()); ! container.commit(); ! ! container.set(new Db4oJobControllerHolder(jobName, controller)); ! container.commit(); ! logger.debug(jobName + " controller has been added to the repository."); ! saved=true; ! } ! logger.trace("Exiting saveController"); ! return saved; ! } ! ! /** ! * @see org.jmonks.batchserver.framework.repository.Repository#loadController(String) ! */ ! public JobController loadController(String jobName) ! { ! logger.trace("Entering loadController"); ! logger.debug(" loadController :: job name = " + jobName); ! ! if(jobName==null) ! throw new IllegalArgumentException("jobName cannot be null to load the controller."); ! ! JobController controller=null; ! if(container==null) ! controller=null; ! else ! { ! ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! if(jobControllerHolderResultSet.hasNext()) ! { ! controller=((Db4oJobControllerHolder)jobControllerHolderResultSet.next()).getJobController(); ! logger.debug(jobName + " controller found and being returned"); ! } ! else ! controller=null; ! } ! logger.trace("Exiting loadController"); ! return controller; ! } ! ! /** ! * @see org.jmonks.batchserver.framework.repository.Repository#releaseController(String) ! */ ! public boolean releaseController(String jobName) ! { ! logger.trace("Entering releaseController"); ! logger.debug(" releaseController :: job name = " + jobName); ! ! if(jobName==null) ! throw new IllegalArgumentException("jobName cannot be null to release the controller."); ! ! boolean released=false; ! ! if(container==null) ! released=false; ! else ! { ! ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! if(jobControllerHolderResultSet.hasNext()) ! { ! container.delete(jobControllerHolderResultSet.next()); ! container.commit(); ! logger.debug(jobName + " controller has been released"); ! released=true; ! } ! else ! released=false; ! } ! logger.trace("Exiting releaseController"); ! return released; ! } } --- 431,524 ---- } ! //////// /** ! //////// * @see org.jmonks.batchserver.framework.repository.Repository#saveController(String,org.jmonks.batchserver.framework.controller.JobController) ! //////// */ ! //////// public boolean saveController(String jobName, final JobController controller) ! //////// { ! //////// logger.trace("Entering saveController"); ! //////// logger.debug("saveController :: job name = " + jobName + " controller = " + controller); ! //////// if(jobName==null || controller==null) ! //////// throw new IllegalArgumentException("job name and controller cannot be null to save the controller."); ! //////// ! //////// boolean saved=true; ! //////// ! //////// if(container==null) ! //////// saved=false; ! //////// else ! //////// { ! //////// ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! //////// ! //////// while(jobControllerHolderResultSet.hasNext()) ! //////// container.delete(jobControllerHolderResultSet.next()); ! //////// container.commit(); ! //////// ! //////// container.set(new Db4oJobControllerHolder(jobName, controller)); ! //////// container.commit(); ! //////// logger.debug(jobName + " controller has been added to the repository."); ! //////// saved=true; ! //////// } ! //////// logger.trace("Exiting saveController"); ! //////// return saved; ! //////// } ! //////// ! //////// /** ! //////// * @see org.jmonks.batchserver.framework.repository.Repository#loadController(String) ! //////// */ ! //////// public JobController loadController(String jobName) ! //////// { ! //////// logger.trace("Entering loadController"); ! //////// logger.debug(" loadController :: job name = " + jobName); ! //////// ! //////// if(jobName==null) ! //////// throw new IllegalArgumentException("jobName cannot be null to load the controller."); ! //////// ! //////// JobController controller=null; ! //////// if(container==null) ! //////// controller=null; ! //////// else ! //////// { ! //////// ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! //////// if(jobControllerHolderResultSet.hasNext()) ! //////// { ! //////// controller=((Db4oJobControllerHolder)jobControllerHolderResultSet.next()).getJobController(); ! //////// logger.debug(jobName + " controller found and being returned"); ! //////// } ! //////// else ! //////// controller=null; ! //////// } ! //////// logger.trace("Exiting loadController"); ! //////// return controller; ! //////// } ! //////// ! //////// /** ! //////// * @see org.jmonks.batchserver.framework.repository.Repository#releaseController(String) ! //////// */ ! //////// public boolean releaseController(String jobName) ! //////// { ! //////// logger.trace("Entering releaseController"); ! //////// logger.debug(" releaseController :: job name = " + jobName); ! //////// ! //////// if(jobName==null) ! //////// throw new IllegalArgumentException("jobName cannot be null to release the controller."); ! //////// ! //////// boolean released=false; ! //////// ! //////// if(container==null) ! //////// released=false; ! //////// else ! //////// { ! //////// ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! //////// if(jobControllerHolderResultSet.hasNext()) ! //////// { ! //////// container.delete(jobControllerHolderResultSet.next()); ! //////// container.commit(); ! //////// logger.debug(jobName + " controller has been released"); ! //////// released=true; ! //////// } ! //////// else ! //////// released=false; ! //////// } ! //////// logger.trace("Exiting releaseController"); ! //////// return released; ! //////// } } |