readerthread.java

pl/sql中记log的函数

package log4plsql.backgroundProcess;


/*
 * Copyright (C) LOG4PLSQL project team. All rights reserved.
 *
 * This software is published under the terms of the The LOG4PLSQL 
 * Software License, a copy of which has been included with this
 * distribution in the LICENSE.txt file.  
 * see: <http://log4plsql.sourceforge.net>  */
 
 
import oracle.xml.parser.v2.XMLNode;
import org.apache.log4j.Logger;



/**
 * Thread to drive a database pooling
 * @author 	guillaume Moulard 
 * @version 	1.0   
 * @since       LOG4PLSQL V3.1.2
 */
class ReaderThread extends Thread {

  private  XmlConfig lxmlConfig;
  private  Logger ldbLogger;
  private  ReaderLogDataBase readerDB;


/**
* Drive a connection to database
*/
public ReaderThread (XMLNode xmlNodeConfig,
                        Logger dbLogger ) {
    lxmlConfig = new XmlConfig(xmlNodeConfig); 
 
    ldbLogger = ldbLogger.getLogger("backgroundProcess.ReaderLogDataBase.ReaderDBThread");

    ldbLogger.debug("ReaderLogDataBase : Connect");
    readerDB = new ReaderLogDataBase( 
            lxmlConfig.getXpathParam("database/source/connection/dburl/text()", "NotExiste"),
            lxmlConfig.getXpathParam("database/source/connection/username/text()", "NotExiste"),
            lxmlConfig.getXpathParam("database/source/connection/password/text()", "NotExiste"),
            lxmlConfig.getXpathParam("database/source/pipename/text()", "NotExiste"),
            lxmlConfig.getXpathParam("@name", "noName")
            );
}


/**
* in loop, write a message in database to log4j logger 
*/
  public void run() {
      while (true) {
          readerDB.readlog(ldbLogger); 
          try {
              sleep(1000);
          } catch(InterruptedException e) {
              ldbLogger.error(e);  
          }
      }
  }
}