loaderjobattrreader.java

数据仓库工具

/**
  LoaderJobAttrReader - Class used for reading attributes from  tag.
    Copyright (C) 2002-2003  Together
    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Lesser General Public
    License as published by the Free Software Foundation; either
    version 2.1 of the License, or (at your option) any later version.
    This library is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
    Lesser General Public License for more details.
    You should have received a copy of the GNU Lesser General Public
    License along with this library; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 LoaderJobAttrReader.java
 Date: 20.5.2003.
 @version 1.0.0
 @author: Zoran Milakovic [e-mail]
 */

package org.webdocwf.util.loader;

import java.io.IOException;
import java.io.InputStream;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;

import org.w3c.dom.Document;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.webdocwf.util.loader.logging.Logger;

/**
 * Class used for reading attribute values from tags in XML file.
 *
 * @author     Zoran Milakovic
 * @version    1.1
 */
public class LoaderJobAttrReader {

//parametri loaderJob elementa
  boolean bDefaultOnErrorContinue = false;
  boolean bDefaultCommit = true;
  String strDefaultUserID = "";
  String strDefaultLogDir = "";
  String strDefaultLogFile = "default";
  String strDefaultVendorConfig = "OctopusDBVendors.xml";
  boolean bDefaultObjectIDAutoCreate = false;
  int iDefaultObjectIDStartValue = 1;
  int iDefaultCommitCount = 100;
  int iLoaderJobCommitCount = 0;
  boolean bDefaultOidLogic = true;

  String strDefaultLogMode = "normal";
  int iDefaultObjectIDIncrement = 20;
  String strDefaultObjectIDTableName = "objectid";
  String strDefaultObjectIDColumnName = "next";
  String strDefaultObjectIDNameColumnName = "";
  String strDefaultObjectIDNameColumnValue = "";
  String strDefaultTableMode = "Query";

  //rale
  String strDefaultDataCutOff = "";
  String strLogTableName = "";
  String strLogTable = "";
  String strLogColumnName = "";
  String strLogRowNumber = "";
  String strLogOriginalValue = "";
  String strLogNewValue = "";
  String strLogImportDefinitionName = "";
  String strLogOperationName = "";
  String strLogTypeName = "";

  private Logger logger;
  String strLogClassName = "";
  String strPathToLoggerConf = "";
  String setFetchSize = "";
  String setCursorName = "";

  /**
   * Method importLoaderJobAttributes is used to analyse import XML file
       * about attributes of root element(loaderJob). Values of these attributes puts in global variables.
   * @param inputStream Data from inputXML file which is converted into InputStream.
   * @throws LoaderException
   */
  public void importLoaderJobAttributes(InputStream inputStream) throws LoaderException {
    Document doc = null;
    this.logger.write("full", "\timportLoaderJobAttributes method is started.");
    try {
      DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
      DocumentBuilder db = null;
      db = dbf.newDocumentBuilder();
      doc = db.parse(inputStream);
    }
    catch (Exception e) {
      this.logger.write("normal", "Sorry, an error occurred: " + e);
      LoaderException le = new LoaderException("Exception: ",
                           (Throwable)e);
      throw le;
//            System.exit(1);
    }
    if (doc != null) {
      NodeList tagRestartCounter = doc.getElementsByTagName("loaderJob");
      if (tagRestartCounter.getLength() != 0) {
        NamedNodeMap attrs = tagRestartCounter.item(0).getAttributes();
        Node nodeResult = attrs.getNamedItem("logMode");
        if (nodeResult != null)
          this.strDefaultLogMode = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("objectIDIncrement");
        String strIncrement = "";
        if (nodeResult != null)
          strIncrement = nodeResult.getNodeValue();
        if (!strIncrement.equals(""))
          this.iDefaultObjectIDIncrement = Integer.parseInt(strIncrement);

        nodeResult = attrs.getNamedItem("objectIDTableName");
        if (nodeResult != null)
          this.strDefaultObjectIDTableName = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("objectIDColumnName");
        if (nodeResult != null)
          this.strDefaultObjectIDColumnName = nodeResult.getNodeValue();

        //log table
        nodeResult = attrs.getNamedItem("dataCutOff");
        if (nodeResult != null)
          this.strDefaultDataCutOff = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logTableName");
        if (nodeResult != null)
          this.strLogTableName = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logTable");
        if (nodeResult != null)
          this.strLogTable = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logColumnName");
        if (nodeResult != null)
          this.strLogColumnName = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logRowNumber");
        if (nodeResult != null)
          this.strLogRowNumber = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logOriginalValue");
        if (nodeResult != null)
          this.strLogOriginalValue = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logNewValue");
        if (nodeResult != null)
          this.strLogNewValue = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logImportDefinitionName");
        if (nodeResult != null)
          this.strLogImportDefinitionName = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logOperationName");
        if (nodeResult != null)
          this.strLogOperationName = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logTypeName");
        if (nodeResult != null)
          this.strLogTypeName = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("objectIDNameColumnName");
        if (nodeResult != null)
          this.strDefaultObjectIDNameColumnName = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("objectIDNameColumnValue");
        if (nodeResult != null)
          this.strDefaultObjectIDNameColumnValue = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("onErrorContinue");
        if (nodeResult != null)
          this.bDefaultOnErrorContinue = (new Boolean(nodeResult.getNodeValue())).booleanValue();

        nodeResult = attrs.getNamedItem("commit");
        if (nodeResult != null)
          this.bDefaultCommit = (new Boolean(nodeResult.getNodeValue())).booleanValue();

        nodeResult = attrs.getNamedItem("userID");
        if (nodeResult != null)
          this.strDefaultUserID = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logDir");
        if (nodeResult != null)
          this.strDefaultLogDir = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("logFile");
        if (nodeResult != null)
          this.strDefaultLogFile = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("vendorConfig");
        if (nodeResult != null)
          this.strDefaultVendorConfig = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("objectIDAutoCreate");
        if (nodeResult != null)
          this.bDefaultObjectIDAutoCreate = (new Boolean(nodeResult.getNodeValue())).booleanValue();

        nodeResult = attrs.getNamedItem("objectIDStartValue");
        if (nodeResult != null)
          this.iDefaultObjectIDStartValue = Integer.parseInt(nodeResult.getNodeValue());

        nodeResult = attrs.getNamedItem("commitCount");
        if (nodeResult != null)
          this.iLoaderJobCommitCount = Integer.parseInt(nodeResult.getNodeValue());

        nodeResult = attrs.getNamedItem("oidLogic");
        if (nodeResult != null)
          this.bDefaultOidLogic = (new Boolean(nodeResult.getNodeValue())).booleanValue();

        nodeResult = attrs.getNamedItem("tableMode");
        if (nodeResult != null)
          this.strDefaultTableMode = nodeResult.getNodeValue();

//        nodeResult = attrs.getNamedItem("logClassName");
//        if (nodeResult != null)
//          this.strLogClassName = nodeResult.getNodeValue();

//        nodeResult = attrs.getNamedItem("pathToLoggerConf");
//        if (nodeResult != null)
//          this.strPathToLoggerConf = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("returnCode");
        if (nodeResult != null) {
          if (!ReturnCode.isParameter)
            ReturnCode.setDefaultErrorReturnCode(Integer.parseInt(nodeResult.getNodeValue()));
        }

        nodeResult = attrs.getNamedItem("setFetchSize");
        if (nodeResult != null)
          this.setFetchSize = nodeResult.getNodeValue();

        nodeResult = attrs.getNamedItem("setCursorName");
        if (nodeResult != null)
          this.setCursorName = nodeResult.getNodeValue();

      }
    }
    try {
      inputStream.reset();
    }
    catch (IOException e) {
      this.logger.write("normal", "Sorry, an error occurred: " + e);
      LoaderException le = new LoaderException("IOException: ",
                           (Throwable)e);
      throw le;
    }
    this.logger.write("full", "\timportLoaderJobAttributes method is finished.");
  }

  /**
   * This method set setCursorName parameter
   * @param setCursorName is value of parameter
   */
  public void setSetCursorName(String setCursorName) {
    this.setCursorName = setCursorName;
  }

  /**
   * This method read value from setCursorName parameter
   * @return value attribute.
   */