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

« Previous | Next »

Revision 471

Added by bojilova over 23 years ago

Separate thread used for writing into xml_index table.
This cut the time of the response on insert almost in half.
The tread is started afterwards
(on end of document parsing and inserting into xml_nodes) from
DBSAXHandler and uses new(separate) db connection.
But I did not find a good way to show the work done of that thread.

         this.conn = conn;
         this.parentNode = parentNode;
         writeChildNodeToDB("ELEMENT", getTagName(), null, docid);
         updateNodeIndex(docid, doctype);
         //No writing XML Index from here. New Thread used instead.
         //updateNodeIndex(docid, doctype);
+      }
       /** creates SQL code and inserts new node into DB connection */
-...
+          }
+      }
       /**
        * creates SQL code to put doc ID for the document node and for
        * comment/PI nodes under document node into DB connection
        */
     /*
       public void writeDocID(String doc_id) {
           try {
             PreparedStatement pstmt;
             pstmt = conn.prepareStatement(
                   "UPDATE xml_nodes set docid = ? " +
                   "WHERE nodeid = ?");
             // Bind the values to the query
             pstmt.setString(1, doc_id);
             pstmt.setLong(2, getNodeID());
             // 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
             pstmt.setString(1, doc_id);
             pstmt.setLong(2, getNodeID());
             // Do the insertion
             pstmt.execute();
             pstmt.close();
           } catch (SQLException e) {
             System.out.println(e.getMessage());
+          }
+      }
     */
       /** get next node id from DB connection */
       private long generateNodeID() throws SAXException {
           long nid=0;
-...
+      }
       /**
        * 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
-...
           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.");
           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)
                    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();

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 471

Added by bojilova over 23 years ago