Metacat

/**

 *    Purpose: A Class that represents an XML node and its contents

 *  Copyright: 2000 Regents of the University of California and the

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Matt Jones

 *     '$Date$'

 * '$Revision$'

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program 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 General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

import java.sql.*;

import java.io.IOException;

import java.util.Hashtable;

import java.util.Enumeration;

 */

  private DBSAXNode	parentNode;

   * @param conn the JDBC Connection to which all information is written

   */

  /**

   * Construct a new node instance for ELEMENT nodes

   *

   * @param conn the JDBC Connection to which all information is written

   * @param tagname the name of the node

   * @param parentNode the parent node for this node being created

   */

                    throws SAXException {

    this.parentNode = parentNode;

    setDocID(docid);

    //updateNodeIndex(docid, doctype);

  public void writeChildNodeToDB(String nodetype, String nodename,

                                 throws SAXException {

      PreparedStatement pstmt;

      if (nodetype == "DOCUMENT") {

        pstmt = conn.prepareStatement(

            "INSERT INTO xml_nodes " +

            "VALUES (?, ?, ?)");

        pstmt = conn.prepareStatement(

            "INSERT INTO xml_nodes " +

      //long nid = generateNodeID();

      //let the db generate it: using identity key or through

      //the db trigger xml_nodes_before_insert using sequence

      //long nid = dbAdapter.getUniqueID(conn, "xml_nodes");

      //pstmt.setLong(1, nid);

      pstmt.setString(1, nodetype);

      pstmt.setString(2, nodename);

      pstmt.setString(3, docid);

        //pstmt.setLong(4, nid);

          pstmt.setLong(5, getParentID());

          pstmt.setString(6, data);

          pstmt.setInt(7, getNodeIndex());

          pstmt.setLong(5, getNodeID());

      // Do the insertion

      pstmt.execute();

      pstmt.close();

      // get the generated unique id afterward

      long nid = dbAdapter.getUniqueID(conn, "xml_nodes");

        // Record the root node id that was generated from the database

        setRootNodeID(nid);

      }

        setNodeID(nid);

        setNodeType(nodetype);

      }

                                                     nodename + ", " +

   */

  public void updateRootNodeID(long nodeid) throws SAXException {

      try {

        PreparedStatement pstmt;

        pstmt = conn.prepareStatement(

              "UPDATE xml_nodes set rootnodeid = ? " +

              "WHERE nodeid = ?");

        // Bind the values to the query

        pstmt.setLong(1, nodeid);

        pstmt.setLong(2, nodeid);

        // Do the update

        pstmt.execute();

        pstmt.close();

      } catch (SQLException e) {

        System.out.println("Error in DBSaxNode.updateRootNodeID: " +

                           e.getMessage());

        throw new SAXException(e.getMessage());

      }

  }

  /**

   * into DB connection

   */

        PreparedStatement pstmt;

        pstmt = conn.prepareStatement(

              "UPDATE xml_nodes set nodename = ? " +

              "WHERE nodeid = ?");

        pstmt.setString(1, nodename);

        pstmt.execute();

        pstmt.close();

      } catch (SQLException e) {

                           e.getMessage());

  }

      try {

        stmt = conn.createStatement();

        boolean tableHasRows = rs.next();

        if (tableHasRows) {

      } catch (SQLException e) {

                            e.getMessage());

              throws SAXException {

      // Enter the attribute in the hash table

      super.setAttribute(attName, attValue);

      System.err.println("Attribute name must not be null!");

  /**

   * test strings that represent all of the relative and absolute

   * paths through the XML tree from document root to this node

   */

               throws SAXException

  {

    boolean atStartingNode = true;

    boolean atRootDocumentNode = false;

    DBSAXNode nodePointer = this;

    StringBuffer currentPath = new StringBuffer();

    // Create a Hashtable of all of the paths to reach this node

    // including absolute paths and relative paths

    while (!atRootDocumentNode) {

      if (atStartingNode) {

        currentPath.insert(0, nodePointer.getTagName());

        pathlist.put(currentPath.toString(), new Long(getNodeID()));

      } else {

        currentPath.insert(0, "/");

        currentPath.insert(0, nodePointer.getTagName());

        pathlist.put(currentPath.toString(), new Long(getNodeID()));

      // advance to the next parent node

      nodePointer = nodePointer.getParentNode();

      // If we're at the DOCUMENT node (root of DOM tree), add

      // the root "/" to make the absolute path

      if (nodePointer.getNodeType().equals("DOCUMENT")) {

        currentPath.insert(0, "/");

        pathlist.put(currentPath.toString(), new Long(getNodeID()));

      }

    }

    try {

      // Create an insert statement to reuse for all of the path insertions

      PreparedStatement pstmt = conn.prepareStatement(

               "parentnodeid) " +

              "VALUES (?, ?, ?, ?, ?)");

      pstmt.setString(4, doctype);

      while (en.hasMoreElements()) {

        String path = (String)en.nextElement();

        Long nodeid = (Long)pathlist.get(path);

        pstmt.setLong(1, nodeid.longValue());

        pstmt.setString(2, path);

        pstmt.executeUpdate();

        //System.out.println(nodeid + " ==> " + path);

      }

      // Close the database statement

      pstmt.close();

    } catch (SQLException sqe) {

                         "DBSAXNode.updateNodeIndex");

      throw new SAXException(sqe.getMessage());

    }

  }

  /**

   * USED FROM SEPARATE THREAD RUNNED from DBSAXHandler on endDocument()

   * Update the node index (xml_index) for this node by generating

   * test strings that represent all of the relative and absolute

   * paths through the XML tree from document root to this node

   */

  public void updateNodeIndex(Connection conn, String docid, String doctype)

               throws SAXException

  {

    Hashtable pathlist = new Hashtable();

    boolean atStartingNode = true;

    boolean atRootDocumentNode = false;

    DBSAXNode nodePointer = this;

    StringBuffer currentPath = new StringBuffer();

    int counter = 0;

    // Create a Hashtable of all of the paths to reach this node

    // including absolute paths and relative paths

    while (!atRootDocumentNode) {

      if (atStartingNode) {

        currentPath.insert(0, nodePointer.getTagName());

        pathlist.put(currentPath.toString(), new Long(getNodeID()));

        counter++;

        atStartingNode = false;

      } else {

        currentPath.insert(0, "/");

        currentPath.insert(0, nodePointer.getTagName());

        pathlist.put(currentPath.toString(), new Long(getNodeID()));

        counter++;

      }

      // advance to the next parent node

      nodePointer = nodePointer.getParentNode();

      // If we're at the DOCUMENT node (root of DOM tree), add

      // the root "/" to make the absolute path

      if (nodePointer.getNodeType().equals("DOCUMENT")) {

        currentPath.insert(0, "/");

        pathlist.put(currentPath.toString(), new Long(getNodeID()));

        counter++;

        atRootDocumentNode = true;

      }

    }

    try {

      // Create an insert statement to reuse for all of the path insertions

      PreparedStatement pstmt = conn.prepareStatement(

              "INSERT INTO xml_index (nodeid, path, docid, doctype, " +

               "parentnodeid) " +

              "VALUES (?, ?, ?, ?, ?)");

      ((OraclePreparedStatement)pstmt).setExecuteBatch(counter);

      pstmt.setString(3, docid);

      pstmt.setString(4, doctype);

      pstmt.setLong(5, getParentID());

      // Step through the hashtable and insert each of the path values

      while (en.hasMoreElements()) {

        String path = (String)en.nextElement();

        Long nodeid = (Long)pathlist.get(path);

        pstmt.setLong(1, nodeid.longValue());

        pstmt.setString(2, path);

        //System.out.println(nodeid + " ==> " + path);

      }

      // Close the database statement

      pstmt.close();

    } catch (SQLException sqe) {

                         "DBSAXNode.updateNodeIndex");

  }

  /** get the parent of this node */

  public DBSAXNode getParentNode() {

    return parentNode;

  }