/src/edu/ucsb/nceas/metacat/DBSAXNode.java - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 1217

Added by Jing Tao almost 22 years ago

Merge DBConnection branch to head.

      */
     public class DBSAXNode extends BasicNode {
       private Connection	conn;
       private DBConnection	connection;
       private DBSAXNode	parentNode;
       private static final AbstractDatabase dbAdapter = MetaCatUtil.dbAdapter;
-...
+       *
        * @param conn the JDBC Connection to which all information is written
        */
       public DBSAXNode (Connection conn, String docid) throws SAXException {
       public DBSAXNode (DBConnection conn, String docid) throws SAXException {
         super();
         this.conn = conn;
         this.connection = conn;
         this.parentNode = null;
         writeChildNodeToDB("DOCUMENT", null, null, docid);
         updateRootNodeID(getNodeID());
-...
        * @param tagname the name of the node
        * @param parentNode the parent node for this node being created
        */
       public DBSAXNode (Connection conn, String qName, String lName,
       public DBSAXNode (DBConnection conn, String qName, String lName,
                         DBSAXNode parentNode, long rootnodeid,
                         String docid, String doctype)
                                                    throws SAXException {
         super(lName);
         this.conn = conn;
         this.connection = conn;
         this.parentNode = parentNode;
         setParentID(parentNode.getNodeID());
         setRootNodeID(rootnodeid);
-...
                                      String data, String docid)
                                      throws SAXException {
         try {
           if(conn == null)
           /*if(conn == null)
+          {
             try
+            {
-...
               MetaCatUtil.debug("Error while getting db connection in " +
                                 "DBSAXNode: " + e.getMessage());
+            }
+          }
           }*/
           PreparedStatement pstmt;
           if (nodetype == "DOCUMENT") {
             pstmt = conn.prepareStatement(
             pstmt = connection.prepareStatement(
                 "INSERT INTO xml_nodes " +
                 "(nodetype, nodename, nodeprefix, docid) " +
                 "VALUES (?, ?, ?, ?)");
             // Increase DBConnection usage count
             connection.increaseUsageCount(1);
             MetaCatUtil.debugMessage("INSERTING DOCNAME: " + nodename);
           } else {
             pstmt = conn.prepareStatement(
             pstmt = connection.prepareStatement(
                 "INSERT INTO xml_nodes " +
                 "(nodetype, nodename, nodeprefix, docid, " +
                 "rootnodeid, parentnodeid, nodedata, nodeindex) " +
                 "VALUES (?, ?, ?, ?, ?, ?, ?, ?)");
             // Increase DBConnection usage count
             connection.increaseUsageCount(1);
+          }
           // Bind the values to the query
-...
           pstmt.close();
           // get the generated unique id afterward
           long nid = dbAdapter.getUniqueID(conn, "xml_nodes");
           long 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
-...
       public void updateRootNodeID(long nodeid) throws SAXException {
           try {
             PreparedStatement pstmt;
             pstmt = conn.prepareStatement(
             pstmt = connection.prepareStatement(
                   "UPDATE xml_nodes set rootnodeid = ? " +
                   "WHERE nodeid = ?");
             // Increase DBConnection usage count
             connection.increaseUsageCount(1);
             // Bind the values to the query
             pstmt.setLong(1, nodeid);
-...
       public void writeNodename(String nodename) throws SAXException {
           try {
             PreparedStatement pstmt;
             pstmt = conn.prepareStatement(
             pstmt = connection.prepareStatement(
                   "UPDATE xml_nodes set nodename = ? " +
                   "WHERE nodeid = ?");
             // Increase DBConnection usage count
             connection.increaseUsageCount(1);
             // Bind the values to the query
             pstmt.setString(1, nodename);
-...
       private long generateNodeID() throws SAXException {
           long nid=0;
           Statement stmt;
           DBConnection dbConn = null;
           int serialNumber = -1;
           try {
             stmt = conn.createStatement();
             // Get DBConnection
             dbConn=DBConnectionPool.getDBConnection("DBSAXNode.generateNodeID");
             serialNumber=dbConn.getCheckOutSerialNumber();
             stmt = dbConn.createStatement();
             stmt.execute("SELECT xml_nodes_id_seq.nextval FROM dual");
             ResultSet rs = stmt.getResultSet();
             boolean tableHasRows = rs.next();
-...
                                 e.getMessage());
             throw new SAXException(e.getMessage());
+          }
           finally
+          {
             // Return DBconnection
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
           return nid;
+      }
-...
+        }
+      }
       /**
        * NOT USED
        * 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(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
           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.executeUpdate();
             //System.out.println(nodeid + " ==> " + path);
+          }
           // Close the database statement
           pstmt.close();
         } catch (SQLException sqe) {
           System.err.println("SQL Exception while inserting path to index in " +
                              "DBSAXNode.updateNodeIndex");
           System.err.println(sqe.getMessage());
           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)
       public void updateNodeIndex(DBConnection conn, String docid, String doctype)
                    throws SAXException
+      {
         Hashtable pathlist = new Hashtable();
-...
                   "INSERT INTO xml_index (nodeid, path, docid, doctype, " +
                    "parentnodeid) " +
                   "VALUES (?, ?, ?, ?, ?)");
           // Increase usage count
           conn.increaseUsageCount(1);
           pstmt.setString(3, docid);
           pstmt.setString(4, doctype);

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 1217

Added by Jing Tao almost 22 years ago