Metacat

import edu.ucsb.nceas.dbadapter.AbstractDatabase;

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

 * can write its own representation to a database connection

 */

  private DBSAXNode	parentNode;

  private static final AbstractDatabase dbAdapter = MetaCatUtil.dbAdapter;

   * Construct a new node instance for DOCUMENT nodes

   *

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

    updateRootNodeID(getNodeID());

  }

   * Construct a new node instance for ELEMENT nodes

   *

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

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

   */

  public DBSAXNode (DBConnection conn, String qName, String lName,

                                               throws SAXException {

    super(lName);

    //No writing XML Index from here. New Thread used instead.

    //updateNodeIndex(docid, doctype);

  }

   * Construct a new node instance for DTD nodes

   * This Node will write docname, publicId and systemId into db. Only

   * handle systemid  existed.(external dtd)

   * @param tagname the name of the node

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

   */

  {

    super();

      writeDTDNodeToDB(DocumentImpl.SYSTEMID, systemId, docid);

    }

  }

  /** creates SQL code and inserts new node into DB connection */

  public long writeChildNodeToDB(String nodetype, String nodename,

  {

    long nid = -1;

    {

      PreparedStatement pstmt;

      if (nodetype == "DOCUMENT") {

        pstmt = connection.prepareStatement(

            "INSERT INTO xml_nodes " +

            "(nodetype, nodename, nodeprefix, docid) " +

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

        // Increase DBConnection usage count

        connection.increaseUsageCount(1);

        MetaCatUtil.debugMessage("INSERTING DOCNAME: " + nodename, 35);

      } else {

        // Increase DBConnection usage count

        connection.increaseUsageCount(1);

      }

      // get the generated unique id afterward

      nid = dbAdapter.getUniqueID(connection.getConnections(), "xml_nodes");

      //should incease connection usage!!!!!!

      if (nodetype.equals("DOCUMENT")) {

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

        setRootNodeID(nid);

    } catch (SQLException e) {

      System.out.println("Error in DBSaxNode.writeChildNodeToDB");

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

                                                     data + ")" );

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

      e.printStackTrace(System.err);

    return nid;

  }

   * update rootnodeid=nodeid for 'DOCUMENT' type of nodes only

   */

  public void updateRootNodeID(long nodeid) throws SAXException {

        pstmt.execute();

        pstmt.close();

      } catch (SQLException e) {

                           e.getMessage());

        throw new SAXException(e.getMessage());

      }

  }

   */

  public void writeNodename(String nodename) throws SAXException {

      try {

        pstmt.execute();

        pstmt.close();

      } catch (SQLException e) {

                           e.getMessage());

        throw new SAXException(e.getMessage());

      }

  }

 /** creates SQL code and inserts new node into DB connection */

  {

    long nid = -1;

    {

      PreparedStatement pstmt;

      MetaCatUtil.debugMessage("Insert dtd into db: "+nodename +" "+data, 45);

       // Increase DBConnection usage count

      connection.increaseUsageCount(1);

      // Bind the values to the query

      pstmt.setString(1, DocumentImpl.DTD);

      pstmt.setString(2, nodename);

      pstmt.setLong(5, getParentID());

      pstmt.setString(6, data);

      pstmt.setInt(7, getNodeIndex());

      // Do the insertion

      pstmt.execute();

      pstmt.close();

      // get the generated unique id afterward

      nid = dbAdapter.getUniqueID(connection.getConnections(), "xml_nodes");

      //should incease connection usage!!!!!!

    } catch (SQLException e) {

      System.out.println("Error in DBSaxNode.writeDTDNodeToDB");

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

                                                     data + ")" );

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

      e.printStackTrace(System.err);

    }

    return nid;

  }

  /** get next node id from DB connection */

  private long generateNodeID() throws SAXException {

      long nid=0;

        }

        stmt.close();

      } catch (SQLException e) {

                            e.getMessage());

        throw new SAXException(e.getMessage());

      }

  /** Add a new attribute to this node, or set its value */

  public long setAttribute(String attName, String attValue, String docid)

  {

    long nodeId = -1;

    {

      // Enter the attribute in the hash table

      super.setAttribute(attName, attValue);

      // And enter the attribute in the database

      nodeId = writeChildNodeToDB("ATTRIBUTE", attName, attValue, docid);

    {

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

      throw new SAXException("Attribute name must not be null!");

  /** Add a namespace to this node */

  public long setNamespace(String prefix, String uri, String docid)

  {

    long nodeId = -1;

    {

      // Enter the namespace in a hash table

      super.setNamespace(prefix, uri);

      // And enter the namespace in the database

      nodeId = writeChildNodeToDB("NAMESPACE", prefix, uri, docid);

    {

      System.err.println("Namespace prefix must not be null!");

      throw new SAXException("Namespace prefix must not be null!");

    return nodeId;

  }

   * 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

   */

               throws SAXException

  {

    Hashtable pathlist = new Hashtable();

        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(

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

      // Increase usage count

      conn.increaseUsageCount(1);

      pstmt.setString(3, docid);

      pstmt.setString(4, doctype);

      pstmt.setLong(5, getParentID());

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

      Enumeration en = pathlist.keys();

      while (en.hasMoreElements()) {

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

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

        pstmt.setString(2, path);

        pstmt.executeUpdate();

      }

      // Close the database statement

      throw new SAXException(sqe.getMessage());

    }

  }

  /** get the parent of this node */

  public DBSAXNode getParentNode() {

    return parentNode;