[Babeldoc-devel] babeldoc/modules/sql/src/com/babeldoc/sql/pipeline/stage SqlQueryPipelineStage.java,1.6.2.1,1.6.2.2

[<mic...@us...>]

Update of /cvsroot/babeldoc/babeldoc/modules/sql/src/com/babeldoc/sql/pipeline/stage
In directory sc8-pr-cvs1:/tmp/cvs-serv5852/modules/sql/src/com/babeldoc/sql/pipeline/stage

Modified Files:
      Tag: TEMP_MIKEA
	SqlQueryPipelineStage.java 
Log Message:
Added some debug logging to a few classes

Index: SqlQueryPipelineStage.java
===================================================================
RCS file: /cvsroot/babeldoc/babeldoc/modules/sql/src/com/babeldoc/sql/pipeline/stage/SqlQueryPipelineStage.java,v
retrieving revision 1.6.2.1
retrieving revision 1.6.2.2
diff -C2 -d -r1.6.2.1 -r1.6.2.2
*** SqlQueryPipelineStage.java	12 Nov 2003 22:18:06 -0000	1.6.2.1
--- SqlQueryPipelineStage.java	24 Nov 2003 09:01:19 -0000	1.6.2.2
***************
*** 100,104 ****
  public class SqlQueryPipelineStage
      extends PipelineStage {
!   /**
     * constants
     */
--- 100,108 ----
  public class SqlQueryPipelineStage
      extends PipelineStage {
! 
! 	private static LogService log =
! 			LogService.getInstance(SqlQueryPipelineStage.class.getName());
! 
! 	/**
     * constants
     */
***************
*** 187,206 ****
      String sql = null;
      try {
!       conn = getConnection();
  
        // Iterate through sqls
        if ((queries != null) && (queries.length > 0)) {
          for (int i = 0; i < queries.length; ++i) {
!           Element queryElement = root.addElement(QUERY);
            String queryName = queries[i].getName();
            queryElement.addAttribute(QUERY_NAME, queryName);
            queryElement.addAttribute(QUERY_NUMBER, Integer.toString(i));
  
            sql = queries[i].getValue();
            stmt = conn.createStatement();
!           LogService.getInstance().logDebug("Executing " + sql);
            rs = stmt.executeQuery(sql);
            handleRows(rs, queryElement);
          }
        }
      } catch (ResourceException e) {
--- 191,216 ----
      String sql = null;
      try {
!     	log.logDebug("Getting connection object");
!     	conn = getConnection();
  
        // Iterate through sqls
        if ((queries != null) && (queries.length > 0)) {
          for (int i = 0; i < queries.length; ++i) {
!         	log.logDebug("Adding query root element");
!         	Element queryElement = root.addElement(QUERY);
            String queryName = queries[i].getName();
+           log.logDebug("Adding query name");
            queryElement.addAttribute(QUERY_NAME, queryName);
+           log.logDebug("Adding query number");
            queryElement.addAttribute(QUERY_NUMBER, Integer.toString(i));
  
            sql = queries[i].getValue();
            stmt = conn.createStatement();
!           log.logDebug("Executing " + sql);
            rs = stmt.executeQuery(sql);
            handleRows(rs, queryElement);
          }
+       } else {
+       	log.logWarn("No queries available for query pipeline stage");
        }
      } catch (ResourceException e) {
***************
*** 254,265 ****
          columnElement.addAttribute(COLUMN_NAME, name);
          columnElement.addAttribute(COLUMN_NUMBER, Integer.toString(j));
! 		columnElement.addAttribute(COLUMN_CLASS, metaData.getColumnClassName(j));
          if(value!=null) {
!           columnElement.setText(value.toString());
          } else {
!         columnElement.setText("");
          }
        }
      }
    }
  
--- 264,276 ----
          columnElement.addAttribute(COLUMN_NAME, name);
          columnElement.addAttribute(COLUMN_NUMBER, Integer.toString(j));
!         columnElement.addAttribute(COLUMN_CLASS, metaData.getColumnClassName(j));
          if(value!=null) {
!         	columnElement.setText(value.toString());
          } else {
!         	columnElement.setText("");
          }
        }
      }
+ 	log.logInfo("Resultset size: " + rs.getRow());
    }