[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/repository/jdbc JdbcRepository.java, 1.1, 1.2

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/jdbc
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv7494/framework/repository/jdbc

Modified Files:
	JdbcRepository.java 
Log Message:
no message

Index: JdbcRepository.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/jdbc/JdbcRepository.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** JdbcRepository.java	10 Sep 2006 17:57:01 -0000	1.1
--- JdbcRepository.java	12 Sep 2006 04:07:55 -0000	1.2
***************
*** 104,108 ****
       * @see org.jmonks.batchserver.framework.repository.Repository#clearDataTransferredToNextJob(String)
       */    
!     public boolean clearDataTransferredToNextJob(String jobName)
      {
          logger.trace("Entering clearDataTransferredToNextJob");                
--- 104,108 ----
       * @see org.jmonks.batchserver.framework.repository.Repository#clearDataTransferredToNextJob(String)
       */    
!     public boolean clearDataTransferredFromThisJob(String jobName)
      {
          logger.trace("Entering clearDataTransferredToNextJob");                
***************
*** 132,136 ****
                  logger.error("Exception while trying to clear the data for requested job = " 
                          + jobName + ". Message = " + exception.getMessage(), exception);
!                 dataCleared=true;
              }
              finally
--- 132,136 ----
                  logger.error("Exception while trying to clear the data for requested job = " 
                          + jobName + ". Message = " + exception.getMessage(), exception);
!                 dataCleared=false;
              }
              finally
***************
*** 162,166 ****
              try
              {
!                 PreparedStatement deleteStatement=connection.prepareStatement("delete from job_data_transfer where source_job_name=? and target_job_name=? and job_data_identifier=?");
                  deleteStatement.setString(1, sourceJobName);
                  deleteStatement.setString(2, targetJobName);
--- 162,166 ----
              try
              {
!                 PreparedStatement deleteStatement=connection.prepareStatement("delete from job_data_transfer where source_job_name=? and destination_job_name=? and job_data_identifier=?");
                  deleteStatement.setString(1, sourceJobName);
                  deleteStatement.setString(2, targetJobName);
***************
*** 170,174 ****
                  logger.debug("Data has been cleared before loading = " + sourceJobName + " " + targetJobName + " " + dataIdentifier);
  
!                 PreparedStatement insertStatement=connection.prepareStatement("insert into job_data_transfer (source_job_name,target_job_name,job_data_identifier,job_data) values (?,?,?,?)");
                  insertStatement.setString(1, sourceJobName);
                  insertStatement.setString(2, targetJobName);
--- 170,174 ----
                  logger.debug("Data has been cleared before loading = " + sourceJobName + " " + targetJobName + " " + dataIdentifier);
  
!                 PreparedStatement insertStatement=connection.prepareStatement("insert into job_data_transfer (source_job_name,destination_job_name,job_data_identifier,job_data) values (?,?,?,?)");
                  insertStatement.setString(1, sourceJobName);
                  insertStatement.setString(2, targetJobName);
***************
*** 188,192 ****
                  logger.error("Exception while trying to send the data from " + sourceJobName + " to job = " 
                          + targetJobName + " with the identifier " + dataIdentifier + ". Message = " + exception.getMessage(), exception);
!                 dataSaved=true;
              }
              finally
--- 188,192 ----
                  logger.error("Exception while trying to send the data from " + sourceJobName + " to job = " 
                          + targetJobName + " with the identifier " + dataIdentifier + ". Message = " + exception.getMessage(), exception);
!                 dataSaved=false;
              }
              finally
***************
*** 219,223 ****
              try
              {
!                 PreparedStatement statement=connection.prepareStatement("select job_data from job_data_transfer where source_job_name=? and target_job_name=? and job_data_identifier=?");
                  statement.setString(1, sourceJobName);
                  statement.setString(2, targetJobName);
--- 219,223 ----
              try
              {
!                 PreparedStatement statement=connection.prepareStatement("select job_data from job_data_transfer where source_job_name=? and destination_job_name=? and job_data_identifier=?");
                  statement.setString(1, sourceJobName);
                  statement.setString(2, targetJobName);
***************
*** 226,230 ****
                  if(rs.next())
                  {
!                     InputStream inputStream=rs.getBinaryStream(4);
                      data=getObjectFromByteArray(inputStream);
                  }
--- 226,230 ----
                  if(rs.next())
                  {
!                     InputStream inputStream=rs.getBinaryStream(1);
                      data=getObjectFromByteArray(inputStream);
                  }
***************
*** 492,496 ****
                  exception.printStackTrace();
                  logger.error("Exception while trying to register the mgmt mntr info =  " + jobName+ ". Message = " + exception.getMessage(), exception);
!                 registered=true;
              }
              finally
--- 492,496 ----
                  exception.printStackTrace();
                  logger.error("Exception while trying to register the mgmt mntr info =  " + jobName+ ". Message = " + exception.getMessage(), exception);
!                 registered=false;
              }
              finally