/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 2524

Added by sgarg over 19 years ago

Modified code to enter/remove data from xml_path_index and enter data into xml_nodes_revision when action=insert, update and delete are performed.

          */
         public void buildIndex() throws McdbException
+        {
             MetaCatUtil util = new MetaCatUtil();
             TreeSet nodeRecordLists = getNodeRecordList(rootnodeid);
             Stack openElements = new Stack();
             boolean atRootElement = true;
             long rootNodeId = -1;
-...
                 pstmt.close();
                 dbConn.increaseUsageCount(1);
                 // Delete all the entries in xml_queryresult
                 pstmt = dbConn.prepareStatement(
                         "DELETE FROM xml_path_index WHERE docid = ?");
                 pstmt.setString(1, docid);
                 pstmt.execute();
                 pstmt.close();
                 dbConn.increaseUsageCount(1);
                 // Step through all of the node records we were given
                 // and build the new index and update the database
                 it = nodeRecordLists.iterator();
-...
                         updateNodeIndex(dbConn, pathList);
+                    }
+                }
                 dbConn.commit();
             } catch (SQLException e) {
                 MetaCatUtil.debugMessage(
                     "SQL Exception while inserting path index in " +
                     "DocumentImpl.buildIndex for document " + docid, 10);
           		MetaCatUtil.debugMessage(e.getMessage(), 10);
                 e.printStackTrace();
                 try {
                     dbConn.rollback();
                 } catch (SQLException sqle) {
                 	MetaCatUtil.debugMessage(
     					"Error while rolling back commit in DocumentImpl.buildIndex"
                         + "\n" + sqle.getMessage(), 10);
+                }
             } finally {
     			DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+            }
                 ResultSet rs = null;
                 PreparedStatement pstmt1 = null;
                 for (int i = 0; i < MetaCatUtil.pathsForIndexing.size(); i++) {
                   MetaCatUtil.formattedDebugMessage("Indexing the path '"
                                                     + (String) MetaCatUtil
                                                     .pathsForIndexing.elementAt(i)
                                                     + "' for docid " + docid
                                                     + "... ", 30, false, true);
                   pstmt = dbConn.prepareStatement("SELECT DISTINCT n.docid, "
                                                   + "n.nodedata, n.nodedatanumerical, n.parentnodeid"
                                                   + " FROM xml_nodes n, xml_index i WHERE"
                                                   + " i.path = ? and n.parentnodeid=i.nodeid and"
                                                   + " n.nodetype LIKE 'TEXT' and n.docid = ?");
                   pstmt.setString(1, (String) MetaCatUtil.
                                   pathsForIndexing.elementAt(i));
                   pstmt.setString(2, docid);
                   pstmt.execute();
                   rs = pstmt.getResultSet();
                   int count = 0;
                   MetaCatUtil.debugMessage("Executed the select statement for: "
                                            + (String) MetaCatUtil.pathsForIndexing
                                            .elementAt(i), 60);
                   try {
                       while (rs.next()) {
                           String docid = rs.getString(1);
                           String nodedata = rs.getString(2);
                           float nodedatanumerical = rs.getFloat(3);
                           int parentnodeid = rs.getInt(4);
                           if (!nodedata.trim().equals("")) {
                               pstmt1 = dbConn.prepareStatement("INSERT INTO "
                                           + "xml_path_index (docid, path, nodedata, "
                                           + "nodedatanumerical, parentnodeid)"
                                           + " VALUES (?, ?, ?, ?, ?)");
                               pstmt1.setString(1, docid);
                               pstmt1.setString(2, (String) MetaCatUtil.
                                                pathsForIndexing.elementAt(i));
                               pstmt1.setString(3, nodedata);
                               pstmt1.setFloat(4, nodedatanumerical);
                               pstmt1.setFloat(5, parentnodeid);
                               pstmt1.execute();
                               pstmt1.close();
                               count++;
+                          }
+                      }
+                  }
                   catch (Exception e) {
                       System.out.println("Exception:" + e.getMessage());
                       e.printStackTrace();
+                  }
                   rs.close();
                   pstmt.close();
                   dbConn.increaseUsageCount(1);
                   MetaCatUtil.formattedDebugMessage("indexed " + count
                                            + " records from xml_nodes",
 , true, false);
+              }
               dbConn.commit();
           } catch (SQLException e) {
               MetaCatUtil.debugMessage("SQL Exception while inserting path index "
                                        + "in DocumentImpl.buildIndex for "
                                        + "document " + docid, 10);
               MetaCatUtil.debugMessage(e.getMessage(), 10);
               e.printStackTrace();
               try {
                   dbConn.rollback();
               } catch (SQLException sqle) {
                   MetaCatUtil.debugMessage("Error while rolling back "
                                            + "commit in DocumentImpl"
                                            + ".buildIndex" + "\n"
                                            + sqle.getMessage(), 10);
+              }
           } finally {
               DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+          }
+        }
         /**
-...
             PreparedStatement pstmt = null;
             String rev = docid.getRev();
             String newid = docid.getIdentifier();
             try {
                 dbconn = DBConnectionPool
                         .getDBConnection("DocumentImpl.isRevisionOnly");
-...
             String nodeprefix = null;
             String nodedata = null;
             String quotechar = dbAdapter.getStringDelimiter();
             String table = "xml_nodes";
             try {
                 if (isRevisionOnly(new DocumentIdentifier(docid))) { //pull the document from xml_revisions
                     // instead of from xml_documents;
                     table = "xml_nodes_revisions";
+                }
             }  catch (McdbDocNotFoundException notFound) {
                 throw notFound;
             } catch (Exception e) {
                 MetaCatUtil.debugMessage("error in DocumentImpl.getDocumentInfo: "
                         + e.getMessage(), 30);
+            }
             try {
                 dbconn = DBConnectionPool
                         .getDBConnection("DocumentImpl.getNodeRecordList");
                 serialNumber = dbconn.getCheckOutSerialNumber();
                 pstmt = dbconn
                         .prepareStatement("SELECT nodeid,parentnodeid,nodeindex, "
                                 + "nodetype,nodename,nodeprefix,nodedata "
                                 + "FROM xml_nodes WHERE rootnodeid = ?");
                                 + "FROM " + table + " WHERE rootnodeid = ?");
                 // Bind the values to the query
                 pstmt.setLong(1, rootnodeid);
-...
                 String catalogid, int serverCode) throws SQLException, Exception
+        {
             String sysdate = dbAdapter.getDateTimeFunction();
             DocumentImpl thisdoc = null;
             try {
                 PreparedStatement pstmt = null;
-...
                 } else if (action.equals("UPDATE")) {
                     // Save the old document publicaccessentry in a backup table
                     DocumentImpl.archiveDocRevision(connection, docid, user);
                     thisdoc = new DocumentImpl(docid, false);
                     DocumentImpl.archiveDocRevision(connection, docid, user, thisdoc);
                     MetaCatUtil.debugMessage("after archiveDoc", 40);
                     DocumentImpl thisdoc = new DocumentImpl(docid, false);
                     int thisrev = thisdoc.getRev();
                     MetaCatUtil.debugMessage("this revsion is: " + thisrev, 40);
                     //if the updated vesion is not greater than current one,
-...
                 // Do the insertion
                 pstmt.execute();
                 pstmt.close();
                 if(action.equals("UPDATE")){
                     // Delete the old nodes in xml_nodes table...
                     pstmt = connection.prepareStatement("DELETE FROM xml_nodes "
                                                     + "WHERE rootnodeid = ?");
                     // Increase dbconnection usage count
                     connection.increaseUsageCount(1);
                     // Bind the values to the query and execute it
                     pstmt.setLong(1, thisdoc.getRootNodeID());
                     pstmt.execute();
                     pstmt.close();
+                }
             } catch (SQLException sqle) {
                 throw sqle;
             } catch (Exception e) {
-...
                 ResultSet rs = pstmt.getResultSet();
                 if(!rs.next()){
                     rs.close();
                     pstmt.close();
                     conn.increaseUsageCount(1);
                     throw new Exception("Docid " + accnum + " does not exsist. "
                                         + "Please check that you have specified the"
                                         + " revision number of the document also.");
-...
                 conn.setAutoCommit(false);
                 // Copy the record to the xml_revisions table
                 DocumentImpl.archiveDocRevision(conn, docid, user);
                 DocumentImpl.archiveDocRevision(conn, docid, user, null);
                 // Now delete it from the xml_index table
                 boolean useXMLIndex = (new Boolean(MetaCatUtil
                         .getOption("usexmlindex"))).booleanValue();
                //if (useXMLIndex) {
                 pstmt = conn
                         .prepareStatement("DELETE FROM xml_index WHERE docid = ?");
-...
                 pstmt = conn.prepareStatement(
                         "DELETE FROM xml_relation WHERE docid = ?");
                 //increase usage count
                 pstmt.setString(1, docid);
                 pstmt.execute();
                 pstmt.close();
                 conn.increaseUsageCount(1);
                 // Delete it from xml_path_index table
                 pstmt = conn.prepareStatement(
                         "DELETE FROM xml_path_index WHERE docid = ?");
                 //increase usage count
                 pstmt.setString(1, docid);
                 pstmt.execute();
                 pstmt.close();
                 conn.increaseUsageCount(1);
                 // Delete it from xml_accesssubtree table
                 pstmt = conn.prepareStatement(
                         "DELETE FROM xml_accesssubtree WHERE docid = ?");
                 //increase usage count
                 conn.increaseUsageCount(1);
                 pstmt.setString(1, docid);
                 pstmt.execute();
                 pstmt.close();
                 conn.increaseUsageCount(1);
                 // Delete it from xml_documents table
                 pstmt = conn.prepareStatement(
-...
                 //Usaga count increase 1
                 conn.increaseUsageCount(1);
                 // Delete the old nodes in xml_nodes table...
                        pstmt = conn.prepareStatement("DELETE FROM xml_nodes "
                                                        + "WHERE docid = ?");
                        // Increase dbconnection usage count
                        conn.increaseUsageCount(1);
                        // Bind the values to the query and execute it
                        pstmt.setString(1, docid);
                        pstmt.execute();
                        pstmt.close();
                 conn.commit();
                 conn.setAutoCommit(true);
             } catch (Exception e) {
                 MetaCatUtil.debugMessage("error in DocumentImpl.delete: "
                         + e.getMessage(), 30);
         e.printStackTrace();
                 throw e;
             } finally {
-...
          * paramter is in order to rollback feature
          */
         private static void archiveDocRevision(DBConnection dbconn, String docid,
                 String user)
                 String user, DocumentImpl doc)
+        {
             String sysdate = dbAdapter.getDateTimeFunction();
             //DBConnection conn = null;
-...
             // for that document as selected from xml_documents
             try {
                 if (doc == null) {
                         doc = new DocumentImpl(docid);
+                }
                 //check out DBConnection
                 /*
                  * conn=DBConnectionPool.
                  * getDBConnection("DocumentImpl.archiveDocRevision");
                  * serialNumber=conn.getCheckOutSerialNumber();
                  */
                 // Move the nodes from xml_nodes to xml_revisions table...
                 pstmt = dbconn.prepareStatement("INSERT INTO xml_nodes_revisions "
                         + "(nodeid, nodeindex, nodetype, nodename, nodeprefix, "
                         + "nodedata, parentnodeid, rootnodeid, docid, date_created,"
                         + " date_updated, nodedatanumerical) "
                         + "SELECT * FROM xml_nodes " + "WHERE rootnodeid = ?");
                 // Increase dbconnection usage count
                 dbconn.increaseUsageCount(1);
                 // Bind the values to the query and execute it
                 pstmt.setLong(1, doc.getRootNodeID());
                 pstmt.execute();
                 pstmt.close();
                 // Move the document information to xml_revisions table...
                 pstmt = dbconn.prepareStatement("INSERT INTO xml_revisions "
                         + "(docid, rootnodeid, docname, doctype, "
                         + "user_owner, user_updated, date_created, date_updated, "
-...
                         + "user_owner, ?, " + sysdate + ", " + sysdate + ", "
                         + "server_location, rev, public_access, catalog_id "
                         + "FROM xml_documents " + "WHERE docid = ?");
                 // Increase dbconnection usage count
                 dbconn.increaseUsageCount(1);
                 // Bind the values to the query and execute it
-...
                 pstmt.setString(3, docid);
                 pstmt.execute();
                 pstmt.close();
             } catch (SQLException e) {
                 MetaCatUtil.debugMessage(
                         "Error in DocumentImpl.archiveDocRevision : "
                                 + e.getMessage(), 30);
             } finally {
             } catch (Exception e) {
                 MetaCatUtil.debugMessage(
                         "Error in DocumentImpl.archiveDocRevision : "
                                 + e.getMessage(), 30);
+            }
             finally {
                 try {
                     pstmt.close();
                 } catch (SQLException ee) {

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 2524

Added by sgarg over 19 years ago