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$'

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

    this.conn = conn;

  /**

   * 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

   */

                    DBSAXNode rootNode, DBSAXDocument currentDocument) {

    setParentID(parentNode.getNodeID());

    setDocID(currentDocument.getDocID());

  public void writeChildNodeToDB(String nodetype, String nodename,

      PreparedStatement pstmt;

      if (nodetype == "DOCUMENT") {

        pstmt = conn.prepareStatement(

            "INSERT INTO xml_nodes " +

            "(nodeid, nodetype, nodename) " +

        pstmt = conn.prepareStatement(

            "INSERT INTO xml_nodes " +

            "(nodeid, nodetype, nodename, " +

      pstmt.setString(2, nodetype);

      pstmt.setString(3, nodename);

        if (nodetype == "ELEMENT") {

          pstmt.setLong(5, getRootNodeID());

          pstmt.setString(6, getDocID());

          pstmt.setString(7, data);

          pstmt.setInt(8, getNodeIndex());

          pstmt.setLong(5, getRootNodeID());

          pstmt.setString(6, getDocID());

          pstmt.setString(7, data);

          pstmt.setInt(8, incChildNum());

      // Do the insertion

      pstmt.execute();

      pstmt.close();

        setNodeID(nid);

        setNodeType(nodetype);

      }

      System.err.println("Error inserting node: (" + nodetype + ", " +

                                                     nodename + ", " +

   * creates SQL code to put nodename for the document node

   * into DB connection

   */

  public void writeNodename(String nodename) {

      try {

        PreparedStatement pstmt;

        pstmt = conn.prepareStatement(

              "UPDATE xml_nodes set nodename = ? " +

              "WHERE nodeid = ?");

        pstmt.setString(1, nodename);

        pstmt.execute();

        pstmt.close();

      } catch (SQLException e) {

        System.out.println(e.getMessage());

      }

  }

   * creates SQL code to put root node id for the document node

   * into DB connection

   */

  public void writeRootNodeID(long rootnode_id) {

      try {

        PreparedStatement pstmt;

        pstmt = conn.prepareStatement(

              "UPDATE xml_nodes set rootnodeid = ? " +

              "WHERE nodeid = ?");

        // Bind the values to the query

        pstmt.setLong(1, rootnode_id);

        pstmt.setLong(2, getNodeID());

        // Do the insertion

        pstmt.execute();

        pstmt.close();

      } catch (SQLException e) {

        System.out.println(e.getMessage());

      }

  }

  /**

   * comment/PI nodes under document node into DB connection

        PreparedStatement pstmt;

        pstmt = conn.prepareStatement(

              "UPDATE xml_nodes set docid = ? " +

              "WHERE nodeid = ?");

        // Bind the values to the query

        // Do the insertion

        pstmt.execute();

        pstmt.close();

        // for comments and PI on the top

        pstmt = conn.prepareStatement(

              "UPDATE xml_nodes set docid = ? " +

              "WHERE parentnodeid = ?");

        // Bind the values to the query

        // Do the insertion

        pstmt.execute();

        pstmt.close();

      } catch (SQLException e) {

        System.out.println(e.getMessage());

      try {

        stmt = conn.createStatement();

        boolean tableHasRows = rs.next();

        if (tableHasRows) {

      } catch (SQLException e) {

        System.out.println("Error getting id: " + e.getMessage());

    if (attName != null) {

      // Enter the attribute in the hash table

      super.setAttribute(attName, attValue);

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

  /**

   * 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

   */

  private void updateNodeIndex() {

    Hashtable pathlist = new Hashtable();

    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()));

        atStartingNode = false;

      } 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()));

        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) VALUES (?, ?)");

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

      Enumeration en = pathlist.keys();

      while (en.hasMoreElements()) {

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

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

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

        pstmt.setString(2, path);

        pstmt.execute();

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

      }

      // Close the database statement

      pstmt.close();

    } catch (SQLException sqe) {

      System.err.println("SQL Exception while inserting path to index.");

      System.err.println(sqe.getMessage());

    }

  }

  /** get the parent of this node */

  public DBSAXNode getParentNode() {

    return parentNode;

  }

/**

 * '$Log$

 * 'Merged in substantial changes to DBWriter and associated classes and to

 * 'the MetaCatServlet in order to accomodate the new UPDATE and DELETE

 * 'functions.  The command line tools and the parameters for the

 * 'servlet have changed substantially.

 * '

 * 'Added RCSfile keyword

 * '

 * 'Revision 1.30.2.1  2000/06/25 23:34:17  jones

 * 'Changed documentation formatting, added log entries at bottom of source files

 * ''

 */