[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/config/db DBBasicJobControllerConfig.java,1.3,1.4 DBJobConfigFactory.java,1.2,1.3 DBPoolJobControllerConfig.java,1.3,1.4

[Suresh <sur...@us...>]

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv25642

Modified Files:
	DBBasicJobControllerConfig.java DBJobConfigFactory.java 
	DBPoolJobControllerConfig.java 
Log Message:
no message

Index: DBJobConfigFactory.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db/DBJobConfigFactory.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** DBJobConfigFactory.java	10 Mar 2006 08:15:16 -0000	1.2
--- DBJobConfigFactory.java	10 Mar 2006 08:57:18 -0000	1.3
***************
*** 146,152 ****
                  jobConfig=null;
          }
          finally
          {
!             connection.close();
          }
          
--- 146,156 ----
                  jobConfig=null;
          }
+         catch(SQLException exception)
+         {
+             exception.printStackTrace();
+         }
          finally
          {
!             try{  connection.close();    } catch(Exception exception){  exception.printStackTrace();    }
          }
          

Index: DBBasicJobControllerConfig.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db/DBBasicJobControllerConfig.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** DBBasicJobControllerConfig.java	10 Mar 2006 08:15:16 -0000	1.3
--- DBBasicJobControllerConfig.java	10 Mar 2006 08:57:18 -0000	1.4
***************
*** 80,83 ****
--- 80,84 ----
          {
              exception.printStackTrace();
+             throw new ConfigurationException(ErrorCode.DB_CONNECTIVITY_ERROR);
          }
      }

Index: DBPoolJobControllerConfig.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db/DBPoolJobControllerConfig.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** DBPoolJobControllerConfig.java	10 Mar 2006 08:15:16 -0000	1.3
--- DBPoolJobControllerConfig.java	10 Mar 2006 08:57:18 -0000	1.4
***************
*** 12,30 ****
  
  import java.sql.Connection;
  import org.jmonks.batchserver.framework.config.PoolJobControllerConfig;
  
  /**
   *
!  * @author Suresh Pragada
   */
  public class DBPoolJobControllerConfig extends PoolJobControllerConfig
  {
!     /** Creates a new instance of DBPoolJobControllerConfig */
      public DBPoolJobControllerConfig(String jobName,Connection connection)
      {
!         /**
!          * Load all the properties defined in base classes using the object passed
!          * as input.
!          */
      }
      
--- 12,104 ----
  
  import java.sql.Connection;
+ import java.sql.PreparedStatement;
+ import java.sql.ResultSet;
+ import java.sql.SQLException;
+ import org.jmonks.batchserver.framework.common.ErrorCode;
+ import org.jmonks.batchserver.framework.common.FrameworkUtil;
+ import org.jmonks.batchserver.framework.config.ConfigurationException;
  import org.jmonks.batchserver.framework.config.PoolJobControllerConfig;
  
  /**
+  *  <p>
+  *  DBPoolJobControllerConfig loads the job controller configuration from the defined
+  *  database. This loads the pool controller configuration from the table "pool_job_controller_config".
+  *  Following is the schema of that table defined in the database.
+  *  <br><br>
+  *  <pre>
+  *      <table>
+  *          <tr><td><b>Column Name</b></td><td><b>Data Type</b></td></tr>
+  *          <tr><td>JOB_NAME</td><td>VARCHAR2(64)</td></tr>
+  *          <tr><td>POOL_JOB_PROCESSOR_CLASS_NAME</td><td>VARCHAR2(256)</td></tr>
+  *          <tr><td>POOL_JOB_PROCESSOR_THREAD_CNT</td><td>NUMBER</td></tr>
+  *          <tr><td>POOL_JOB_PROCESSOR_PROPS</td><td>VARCHAR2(1024)</td></tr>
+  *          <tr><td>POOL_JOB_LOADER_CLASS_NAME</td><td>VARCHAR2(256)</td></tr>
+  *          <tr><td>POOL_JOB_LOADER_PROPS</td><td>VARCHAR2(1024)</td></tr>
+  *          <tr><td>JOB_POOL_CLASS_NAME</td><td>VARCHAR2(256)</td></tr>
+  *          <tr><td>JOB_POOL_PROPS</td><td>VARCHAR2(1024)</td></tr>
   *
!  *      </table>
!  *  </pre>
!  *  </p>
!  *
!  *  @author     Suresh Pragada
!  *  @version    1.0
!  *  @since      1.0
   */
  public class DBPoolJobControllerConfig extends PoolJobControllerConfig
  {
!     /**
!      *  SQL Query pulls the information pool_job_controller_config table.
!      */
!     private static final String POOL_JOB_CONTROLLER_CONFIG_QUERY = "select pool_job_processor_class_name, " +
!             "pool_job_processor_thread_cnt, pool_job_processor_props, pool_job_loader_class_name, " +
!             "pool_job_loader_props, job_pool_class_name, job_pool_props from pool_job_controller_config " +
!             "where job_name=?";
!     /** 
!      *  Loads the pool job controller configuration from table pool_job_controller_config 
!      *  into DBPoolJobControllerConfig object.
!      *
!      *  @param  jobName Name of the job.
!      *  @param  connection  Connection to the defined database.
!      *
!      *  @throws ConfigurationException  If controller class name or job processor name doest not found.
!      */
      public DBPoolJobControllerConfig(String jobName,Connection connection)
      {
! 
!         try
!         {
!             PreparedStatement statement=connection.prepareStatement(DBPoolJobControllerConfig.POOL_JOB_CONTROLLER_CONFIG_QUERY);
!             statement.setString(1,jobName);
!             ResultSet resultSet=statement.executeQuery();
!             if(resultSet.next())
!             {
!                 this.poolJobProcessorClassName=resultSet.getString(1);
!                 this.poolJobProcessorThreadCount=resultSet.getInt(2);
!                 String processorConfigProps=resultSet.getString(3);
!                 if(processorConfigProps!=null)
!                     FrameworkUtil.loadPropertiesFromStringToMap(processorConfigProps,this.poolJobProcessorConfigProps);
! 
!                 this.poolJobLoaderClassName=resultSet.getString(4);
!                 String loaderConfigProps=resultSet.getString(5);
!                 if(loaderConfigProps!=null)
!                     FrameworkUtil.loadPropertiesFromStringToMap(loaderConfigProps,this.poolJobLoaderConfigProps);
! 
!                 this.poolClassName=resultSet.getString(6);
!                 String poolConfigProps=resultSet.getString(7);
!                 if(poolConfigProps!=null)
!                     FrameworkUtil.loadPropertiesFromStringToMap(poolConfigProps,this.poolConfigProps);
!             }
!             else
!             {
!                 throw new ConfigurationException(ErrorCode.POOL_JOB_CONTROLLER_CONFIG_NOT_FOUND);
!             }
!         }
!         catch(SQLException exception)
!         {
!             exception.printStackTrace();
!             throw new ConfigurationException(ErrorCode.DB_CONNECTIVITY_ERROR);
!         }
!         
      }