/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 2607

Added by Jing Tao almost 19 years ago

Add code to handle replicate the deleted document.

         public static final String EML200 = "eml200";
         public static final String EML210 = "eml210";
         public static final String EXTERNALSCHEMALOCATIONPROPERTY = "http://apache.org/xml/properties/schema/external-schemaLocation";
         public static final String REVISIONTABLE = "xml_revisions";
         public static final String DOCUMENTTABLE = "xml_documents";
         /*
          * public static final String EXTERNALSCHEMALOCATION =
          * "eml://ecoinformatics.org/eml-2.0.0
-...
                 throws SQLException, AccessionNumberException, Exception
+        {
             DBConnection dbconn = null;
             int serialNumber = -1;
             PreparedStatement pstmt = null;
             //MetaCatUtil util = new MetaCatUtil();
             AccessionNumber ac;
             String action = null;
             try {
                 //dbconn = util.openDBConnection();
                 //check out DBConnection
                 dbconn = DBConnectionPool
                         .getDBConnection("DocumentImpl.registerDocument");
                 serialNumber = dbconn.getCheckOutSerialNumber();
                 String docIdWithoutRev = MetaCatUtil.getDocIdFromString(accnum);
                 int userSpecifyRev = MetaCatUtil.getVersionFromString(accnum);
                 int revInDataBase = getLatestRevisionNumber(docIdWithoutRev);
                 //revIndataBase=-1, there is no record in xml_documents table
                 //the data file is a new one, inert it into table
                 //user specified rev should be great than 0
                 if (revInDataBase == -1 && userSpecifyRev > 0) {
                     ac = new AccessionNumber(accnum, "insert");
                     action = "insert";
+                }
                 //rev is greater the last revsion number and revInDataBase isn't -1
                 // it is a updated data file
                 else if (userSpecifyRev > revInDataBase && revInDataBase > 0) {
                     if (!hasWritePermission(user, groups, accnum)) { throw new Exception(
                        "User " + user
                        + " does not have permission to update the document"
                        + accnum); }
                     //archive the old entry
                     archiveDocRevision(docIdWithoutRev, user);
                     //delete the old entry in xml_documents
                     //deleteXMLDocuments(docIdWithoutRev);
                     ac = new AccessionNumber(accnum, "update");
                     action = "update";
+                }
                 //other situation
                 else {
                     throw new Exception("Revision number couldn't be "
                             + userSpecifyRev);
+                }
                 String docid = ac.getDocid();
                 String rev = ac.getRev();
                 /*
                  * SimpleDateFormat formatter = new SimpleDateFormat ("MM/dd/yy
                  * HH:mm:ss"); Date localtime = new Date(); String dateString =
                  * formatter.format(localtime); String
                  * sqlDateString=dbAdapter.toDate(dateString, "MM/DD/YY
                  * HH24:MI:SS");
                  */
                 String sqlDateString = dbAdapter.getDateTimeFunction();
                 StringBuffer sql = new StringBuffer();
                 if (action != null && action.equals("insert")) {
                     sql.append("insert into xml_documents (docid, docname, " +
                                "doctype, ");
                     sql.append("user_owner, user_updated, server_location, " +
                                "rev,date_created");
                     sql.append(", date_updated, public_access) values ('");
                     sql.append(docid).append("','");
                     sql.append(docname).append("','");
                     sql.append(doctype).append("','");
                     sql.append(user).append("','");
                     sql.append(user).append("','");
                     sql.append(serverCode).append("','");
                     sql.append(rev).append("',");
                     sql.append(sqlDateString).append(",");
                     sql.append(sqlDateString).append(",");
                     sql.append("'0')");
                 } else if (action != null && action.equals("update")) {
                     sql.append("update xml_documents set docname ='");
                     sql.append(docname).append("', ");
                     sql.append("user_updated='");
                     sql.append(user).append("', ");
                     sql.append("server_location='");
                     sql.append(serverCode).append("',");
                     sql.append("rev='");
                     sql.append(rev).append("',");
                     sql.append("date_updated=");
                     sql.append(sqlDateString);
                     sql.append(" where docid='");
                     sql.append(docid).append("'");
+                }
                 pstmt = dbconn.prepareStatement(sql.toString());
                 pstmt.execute();
                 pstmt.close();
                 //dbconn.close();
             } finally {
                 try {
                     if(pstmt != null){
                         pstmt.close();
+                    }
                 } finally {
                     DBConnectionPool.returnDBConnection(dbconn, serialNumber);
+                }
             String docIdWithoutRev = MetaCatUtil.getDocIdFromAccessionNumber(accnum);
             int userSpecifyRev = MetaCatUtil.getRevisionFromAccessionNumber(accnum);
             action = checkRevInXMLDocuments(accnum, userSpecifyRev);
             if (action.equals("UPDATE"))
+            {
                 //archive the old entry
                 if (!hasWritePermission(user, groups, accnum)) { throw new Exception(
                         "User " + user
                         + " does not have permission to update the document"
                         + accnum); }
                 archiveDocRevision(docIdWithoutRev, user);
+            }
             String rev = Integer.toString(userSpecifyRev);
             modifyRecordsInGivenTable(DOCUMENTTABLE, action,docIdWithoutRev, doctype, docname,
                         user, rev, serverCode);
+        }
         /**
-...
          *            resides.
          */
         public static void registerDocumentInReplication(String docname,
                 String doctype, String accnum, String user, int serverCode)
                 String doctype, String accnum, String user, int serverCode, String tableName)
                 throws SQLException, AccessionNumberException, Exception
+        {
             DBConnection dbconn = null;
             int serialNumber = -1;
             //MetaCatUtil util = new MetaCatUtil();
             AccessionNumber ac;
             PreparedStatement pstmt = null;
             String action = null;
             String docIdWithoutRev = MetaCatUtil.getDocIdFromAccessionNumber(accnum);
             int userSpecifyRev = MetaCatUtil.getRevisionFromAccessionNumber(accnum);
             if (tableName.equals(DOCUMENTTABLE))
+            {
                 action = checkRevInXMLDocuments(accnum, userSpecifyRev);
                 if (action.equals("UPDATE"))
+                {
                         //archive the old entry
                         archiveDocRevision(docIdWithoutRev, user);
+                }
+            }
             else if (tableName.equals(REVISIONTABLE))
+            {
                 action = checkXMLRevisionTable(accnum, userSpecifyRev);
+            }
             else
+            {
                 throw new Exception("Couldn't handle this table name "+tableName);
+            }
             String rev = Integer.toString(userSpecifyRev);
             modifyRecordsInGivenTable(tableName, action,docIdWithoutRev, doctype, docname,
                         user, rev, serverCode);
+        }
        /*
         * This method will insert or update xml-documents or xml_revision table
         */
        private static void modifyRecordsInGivenTable(String tableName, String action,
                            String docid, String doctype, String docname, String user,
                            String rev, int serverCode) throws Exception
+       {
           DBConnection dbconn = null;
           PreparedStatement pstmt = null;
           int serialNumber = -1;
           String sqlDateString = dbAdapter.getDateTimeFunction();
           try
+          {
             dbconn = DBConnectionPool.getDBConnection(
               "DocumentImpl.registerDocumentInReplication");
             serialNumber = dbconn.getCheckOutSerialNumber();
             StringBuffer sql = new StringBuffer();
             if (action != null && action.equals("INSERT")) {
                 sql.append("insert into ");
                 sql.append(tableName);
                 sql.append(" (docid, docname, " +
                            "doctype, ");
                 sql.append("user_owner, user_updated, server_location, " +
                            "rev,date_created");
                 sql.append(", date_updated, public_access) values ('");
                 sql.append(docid).append("','");
                 sql.append(docname).append("','");
                 sql.append(doctype).append("','");
                 sql.append(user).append("','");
                 sql.append(user).append("','");
                 sql.append(serverCode).append("','");
                 sql.append(rev).append("',");
                 sql.append(sqlDateString).append(",");
                 sql.append(sqlDateString).append(",");
                 sql.append("'0')");
             } else if (action != null && action.equals("UPDATE")) {
                 sql.append("update xml_documents set docname ='");
                 sql.append(docname).append("', ");
                 sql.append("user_updated='");
                 sql.append(user).append("', ");
                 sql.append("server_location='");
                 sql.append(serverCode).append("',");
                 sql.append("rev='");
                 sql.append(rev).append("',");
                 sql.append("date_updated=");
                 sql.append(sqlDateString);
                 sql.append(" where docid='");
                 sql.append(docid).append("'");
+            }
             pstmt = dbconn.prepareStatement(sql.toString());
             pstmt.execute();
             pstmt.close();
         } finally {
             try {
                 //dbconn = util.openDBConnection();
                 dbconn = DBConnectionPool.getDBConnection(
                         "DocumentImpl.registerDocumentInReplication");
                 serialNumber = dbconn.getCheckOutSerialNumber();
                 String docIdWithoutRev = MetaCatUtil
                         .getDocIdFromAccessionNumber(accnum);
                 int userSpecifyRev = MetaCatUtil
                         .getRevisionFromAccessionNumber(accnum);
                 int revInDataBase = getLatestRevisionNumber(docIdWithoutRev);
                 //revIndataBase=-1, there is no record in xml_documents table
                 //the data file is a new one, inert it into table
                 //user specified rev should be great than 0
                 if (revInDataBase == -1 && userSpecifyRev >= 0) {
                     ac = new AccessionNumber(accnum, "insert");
                     action = "insert";
                 if(pstmt != null){
                     pstmt.close();
+                }
                 //rev is greater the last revsion number and revInDataBase isn't -1
                 // it is a updated data file
                 else if (userSpecifyRev > revInDataBase && revInDataBase >= 0) {
                     //archive the old entry
                     archiveDocRevision(docIdWithoutRev, user);
                     //delete the old entry in xml_documents
                     //deleteXMLDocuments(docIdWithoutRev);
                     ac = new AccessionNumber(accnum, "update");
                     action = "update";
+                }
                 // local server has newer version, then notify the remote server
                 else if (userSpecifyRev < revInDataBase && revInDataBase > 0) {
                     throw new Exception("Local server: "
                             + MetaCatUtil.getOption("server")
                             + " has newer revision of doc: " + docIdWithoutRev
                             + "." + revInDataBase + ". Please notify it.");
+                }
                 //other situation
                 else {
                     throw new Exception("Revision number couldn't be "
                             + userSpecifyRev);
+                }
                 String docid = ac.getDocid();
                 String rev = ac.getRev();
                 /*
                  * SimpleDateFormat formatter = new SimpleDateFormat ("MM/dd/yy
                  * HH:mm:ss"); Date localtime = new Date(); String dateString =
                  * formatter.format(localtime); String
                  * sqlDateString=dbAdapter.toDate(dateString, "MM/DD/YY
                  * HH24:MI:SS");
                  */
                 String sqlDateString = dbAdapter.getDateTimeFunction();
                 StringBuffer sql = new StringBuffer();
                 if (action != null && action.equals("insert")) {
                     sql.append("insert into xml_documents (docid, docname, " +
                                "doctype, ");
                     sql.append("user_owner, user_updated, server_location, " +
                                "rev,date_created");
                     sql.append(", date_updated, public_access) values ('");
                     sql.append(docid).append("','");
                     sql.append(docname).append("','");
                     sql.append(doctype).append("','");
                     sql.append(user).append("','");
                     sql.append(user).append("','");
                     sql.append(serverCode).append("','");
                     sql.append(rev).append("',");
                     sql.append(sqlDateString).append(",");
                     sql.append(sqlDateString).append(",");
                     sql.append("'0')");
                 } else if (action != null && action.equals("update")) {
                     sql.append("update xml_documents set docname ='");
                     sql.append(docname).append("', ");
                     sql.append("user_updated='");
                     sql.append(user).append("', ");
                     sql.append("server_location='");
                     sql.append(serverCode).append("',");
                     sql.append("rev='");
                     sql.append(rev).append("',");
                     sql.append("date_updated=");
                     sql.append(sqlDateString);
                     sql.append(" where docid='");
                     sql.append(docid).append("'");
+                }
                 // Set auto commit fasle
                 dbconn.setAutoCommit(false);
                 pstmt = dbconn.prepareStatement(sql.toString());
                 pstmt.execute();
                 // Commit the insert
                 dbconn.commit();
                 pstmt.close();
                 //dbconn.close();
             } finally {
                 // Set DBConnection auto commit true
                 dbconn.setAutoCommit(true);
                 pstmt.close();
                 DBConnectionPool.returnDBConnection(dbconn, serialNumber);
+            }
+        }
+        }
+       }
         /**
          * This method will register a data file entry in xml_documents and save a
          * data file input Stream into file system.. It is only used in replication
-...
          */
         public static void writeDataFileInReplication(InputStream input,
                 String filePath, String docname, String doctype, String accnum,
                 String user, String docHomeServer, String notificationServer)
                 String user, String docHomeServer, String notificationServer, String tableName, boolean timedReplication)
                 throws SQLException, AccessionNumberException, Exception
+        {
             int serverCode = -2;
-...
             //register data file into xml_documents table
             registerDocumentInReplication(docname, doctype, accnum, user,
                     serverCode);
                     serverCode, tableName);
             //write inputstream into file system.
             File dataDirectory = new File(filePath);
             File newFile = new File(dataDirectory, accnum);
-...
             bis.close();
             outPut.close();
             fos.close();
             // Force replicate data file
             ForceReplicationHandler forceReplication = new ForceReplicationHandler(
             if (!timedReplication)
+            {
               ForceReplicationHandler forceReplication = new ForceReplicationHandler(
                     accnum, false, notificationServer);
+            }
+        }
         /*
          * This method will determine if we need to insert or update xml_document base
          * on given docid, rev and rev in xml_documents table
          */
          private static String checkRevInXMLDocuments(String docid, int userSpecifyRev) throws Exception
+         {
             String action = null;
             MetaCatUtil.debugMessage("The user specifyRev: " + userSpecifyRev, 30);
             // Revision for this docid in current database
             int revInDataBase = getLatestRevisionNumber(docid);
             MetaCatUtil.debugMessage("The rev in data base: " + revInDataBase, 30);
             // String to store the revision
             String rev = null;
             //revIndataBase=-1, there is no record in xml_documents table
             //the document is a new one for local server, inert it into table
             //user specified rev should be great than 0
             if (revInDataBase == -1 && userSpecifyRev >= 0) {
                 // rev equals user specified
                 rev = (new Integer(userSpecifyRev)).toString();
                 // action should be INSERT
                 action = "INSERT";
+            }
             //rev is greater the last revsion number and revInDataBase isn't -1
             // it is a updated file
             else if (userSpecifyRev > revInDataBase && revInDataBase >= 0) {
                 // rev equals user specified
                 rev = (new Integer(userSpecifyRev)).toString();
                 // action should be update
                 action = "UPDATE";
+            }
             // local server has newer version, then notify the remote server
             else if (userSpecifyRev < revInDataBase && revInDataBase > 0) {
                 throw new Exception("Local server: "
                         + MetaCatUtil.getOption("server")
                         + " has newer revision of doc: " + docid + "."
                         + revInDataBase + ". Please notify it.");
+            }
             //other situation
             else {
                 throw new Exception("The docid" + docid
                         + "'s revision number couldn't be " + userSpecifyRev);
+            }
             return action;
+         }
          /*
           * This method will check if the xml_revision table already has the
           * document or not
           */
          private static String checkXMLRevisionTable(String docid, int rev) throws Exception
+         {
              String action = "INSERT";
              Vector localrev = null;
              try
+             {
                localrev = DBUtil.getRevListFromRevisionTable(docid);
+             }
              catch (SQLException e)
+             {
                MetaCatUtil.debugMessage("Local rev for docid "+ docid + " could not "+
                                       " be found because " + e.getMessage(), 45);
                MetacatReplication.replErrorLog("Docid "+ docid + " could not be "+
                        "written because error happend to find it's local revision");
                throw new Exception (e.getMessage());
+             }
              MetaCatUtil.debugMessage("rev list in xml_revision table for docid "+ docid + " is "+
                                      localrev.toString(), 45);
              // if the rev is in the xml_revision, it throws a exception
              if (localrev.contains(new Integer(rev)))
+             {
                 throw new Exception("The docid and rev is already in xml_revision table");
+             }
              return action;
+         }
          /*
+          *
           */
         /**
          * Get a lock for a given document.
          */
-...
                 if (action.equals("INSERT")) {
                     //AccessionNumber ac = new AccessionNumber();
                     //this.docid = ac.generate(docid, "INSERT");
                     pstmt = connection
                             .prepareStatement("INSERT INTO xml_documents "
                             + "(docid, rootnodeid, docname, doctype, user_owner, "
-...
                             + sysdate + ", ?, ?, ?, ?)");
                     // Increase dbconnection usage count
                     connection.increaseUsageCount(1);
                     //note that the server_location is set to 1.
                     //this means that "localhost" in the xml_replication table must
                     //always be the first entry!!!!!
-...
                     pstmt.setString(5, user);
                     pstmt.setString(6, user);
                     //public access is usefulless, so set it to null
                     pstmt.setString(7, null);
                     pstmt.setInt(7, 0);
                     /*
                      * if ( pub == null ) { pstmt.setString(7, null); } else if (
                      * pub.toUpperCase().equals("YES") || pub.equals("1") ) {
-...
                      * pub.toUpperCase().equals("NO") || pub.equals("0") ) {
                      * pstmt.setInt(7, 0); }
                      */
                     pstmt.setString(8, catalogid);
                     pstmt.setInt(8, (new Integer(catalogid)).intValue());
                     pstmt.setInt(9, serverCode);
                     pstmt.setInt(10, Integer.parseInt(updatedVersion));
                 } else if (action.equals("UPDATE")) {
                     // Save the old document publicaccessentry in a backup table
                     thisdoc = new DocumentImpl(docid, false);
                     DocumentImpl.archiveDocRevision(connection, docid, user, thisdoc);
                     MetaCatUtil.debugMessage("after archiveDoc", 40);
                     MetaCatUtil.debugMessage("after archiveDoc", 30);
                     int thisrev = thisdoc.getRev();
                     MetaCatUtil.debugMessage("this revsion is: " + thisrev, 40);
-...
                         MetaCatUtil.debugMessage("after delete", 40);
                         // Increase dbconnection usage count
                         connection.increaseUsageCount(1);
                         pstmt.execute();
                         pstmt.close();
+                    }
-...
                     pstmt.setString(4, user);
                     pstmt.setInt(5, serverCode);
                     pstmt.setInt(6, thisrev);
                     pstmt.setString(7, null);
                     pstmt.setInt(7, 0);
                     /*
                      * if ( pub == null ) { pstmt.setString(7, null); } else if (
                      * pub.toUpperCase().equals("YES") || pub.equals("1") ) { pstmt
                      * .setInt(7, 1); } else if ( pub.toUpperCase().equals("NO") ||
                      * pub.equals("0") ) { pstmt.setInt(7, 0); }
                      */
                     pstmt.setString(8, catalogid);
                     pstmt.setInt(8, (new Integer(catalogid)).intValue());
                     pstmt.setString(9, this.docid);
                 } else {
-...
+                }
                 // 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 "
-...
+                }
             } catch (SQLException sqle) {
                 sqle.printStackTrace();
                 throw sqle;
             } catch (Exception e) {
                 e.printStackTrace();
                 throw e;
+            }
+        }
-...
                 // write to xml_node complete. start the indexing thread.
                 DBSAXHandler dbx = (DBSAXHandler) parser.getContentHandler();
                 System.out.println("here!!!!!!!adf");
                 dbx.runIndexingThread();
                 System.out.println("here!!!!!!!adfadfa");
             } catch (Exception e) {
                 e.printStackTrace();
                 conn.rollback();
                 conn.setAutoCommit(true);
                 //if it is a eml2 document, we need delete online data
-...
         public static String writeReplication(DBConnection conn, Reader xml,
                 String pub, Reader dtd, String action, String accnum, String user,
                 String[] groups, String homeServer, String notifyServer,
                 String ruleBase, boolean needValidation) throws Exception
                 String ruleBase, boolean needValidation, String tableName, boolean timedReplication) throws Exception
+        {
             long rootId;
             MetaCatUtil.debugMessage("user in replication" + user, 30);
             // Docid without revision
             String docid = MetaCatUtil.getDocIdFromAccessionNumber(accnum);
-...
             int revInDataBase = getLatestRevisionNumber(docid);
             MetaCatUtil.debugMessage("The rev in data base: " + revInDataBase, 30);
             // String to store the revision
             String rev = null;
             String rev = (new Integer(userSpecifyRev)).toString();
             //revIndataBase=-1, there is no record in xml_documents table
             //the document is a new one for local server, inert it into table
             //user specified rev should be great than 0
             if (revInDataBase == -1 && userSpecifyRev >= 0) {
                 // rev equals user specified
                 rev = (new Integer(userSpecifyRev)).toString();
                 // action should be INSERT
                 action = "INSERT";
             if (tableName.equals(DOCUMENTTABLE))
+            {
                 action = checkRevInXMLDocuments(docid, userSpecifyRev);
+            }
             //rev is greater the last revsion number and revInDataBase isn't -1
             // it is a updated file
             else if (userSpecifyRev > revInDataBase && revInDataBase >= 0) {
                 // rev equals user specified
                 rev = (new Integer(userSpecifyRev)).toString();
                 // action should be update
                 action = "UPDATE";
             else if (tableName.equals(REVISIONTABLE))
+            {
                 action = checkXMLRevisionTable(docid, userSpecifyRev);
+            }
             // local server has newer version, then notify the remote server
             else if (userSpecifyRev < revInDataBase && revInDataBase > 0) {
                 throw new Exception("Local server: "
                         + MetaCatUtil.getOption("server")
                         + " has newer revision of doc: " + docid + "."
                         + revInDataBase + ". Please notify it.");
             else
+            {
                 throw new Exception("The table name is not support "+tableName);
+            }
             //other situation
             else {
                 throw new Exception("The docid" + docid
                         + "'s revision number couldn't be " + userSpecifyRev);
+            }
             // Variable to store homeserver code
             int serverCode = -2;
-...
                 parser = initializeParser(conn, action, docid, rev, user, groups,
                         pub, serverCode, dtd, ruleBase, needValidation);
                 DBSAXHandler dbx = (DBSAXHandler) parser.getContentHandler();
                 if (tableName.equals(REVISIONTABLE))
+                {
                     dbx.setIsRevisionDoc(true);
+                }
                 conn.setAutoCommit(false);
                 parser.parse(new InputSource(xml));
                 conn.commit();
                 conn.setAutoCommit(true);
                 // write to xml_node complete. start the indexing thread.
                 DBSAXHandler dbx = (DBSAXHandler) parser.getContentHandler();
                 dbx.runIndexingThread();
                 // this only for xml_documents
                 if (!tableName.equals(REVISIONTABLE))
+                {
                     dbx.runIndexingThread();
+                }
                 rootId = dbx.getRootNodeId();
             } catch (Exception e) {
                 conn.rollback();
-...
             // run write into access db base on relation table and access rule
             try {
                 runRelationAndAccessHandler(accnum, user, groups, serverCode);
                 if (!tableName.equals(REVISIONTABLE))
+                {
                    runRelationAndAccessHandler(accnum, user, groups, serverCode);
+                }
                 else
+                {
                    moveNodesToNodesRevision(conn, rootId);
+                }
             } catch (Exception ee) {
                 MetacatReplication.replErrorLog("Failed to " + "create access "
                         + "rule for package: " + accnum + " because "
-...
                         + ee.getMessage(), 30);
+            }
             //Force replication to other server
             ForceReplicationHandler forceReplication = new ForceReplicationHandler(
             if (!timedReplication)
+            {
               ForceReplicationHandler forceReplication = new ForceReplicationHandler(
                     accnum, action, true, notifyServer);
+            }
             return (accnum);
+        }
-...
         private static void archiveDocRevision(DBConnection dbconn, String docid,
                 String user, DocumentImpl doc)
+        {
             String sysdate = dbAdapter.getDateTimeFunction();
             //DBConnection conn = null;
             //int serialNumber = -1;
             PreparedStatement pstmt = null;
             // create a record in xml_revisions table
             // for that document as selected from xml_documents
-...
                 if (doc == null) {
                         doc = new DocumentImpl(docid);
+                }
                 long rootNodeId = doc.getRootNodeID();
                 //check out DBConnection
                 /*
                  * conn=DBConnectionPool.
                  * getDBConnection("DocumentImpl.archiveDocRevision");
                  * serialNumber=conn.getCheckOutSerialNumber();
                  */
                 archiveDocRevison(dbconn, docid, user, rootNodeId);
                 // 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 = ?");
             }catch (Exception e) {
                 MetaCatUtil.debugMessage(
                         "Error in DocumentImpl.archiveDocRevision : "
                                 + e.getMessage(), 30);
+            }
+        }
         private static void archiveDocRevison(DBConnection dbconn, String docid,
                                          String user, long rootNodeId) throws Exception
+        {
             String sysdate = dbAdapter.getDateTimeFunction();
             //DBConnection conn = null;
             //int serialNumber = -1;
             PreparedStatement pstmt = null;
             try
+            {
             // Move the nodes from xml_nodes to xml_nodes_revisions table...
             moveNodesToNodesRevision(dbconn, 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, "
                     + "server_location, rev, public_access, catalog_id) "
                     + "SELECT ?, rootnodeid, docname, doctype, "
                     + "user_owner, ?, " + sysdate + ", " + sysdate + ", "
                     + "server_location, rev, public_access, catalog_id "
                     + "FROM xml_documents " + "WHERE docid = ?");
                 // 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, "
                         + "server_location, rev, public_access, catalog_id) "
                         + "SELECT ?, rootnodeid, docname, doctype, "
                         + "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(1, docid);
             pstmt.setString(2, user);
             pstmt.setString(3, docid);
             pstmt.execute();
             pstmt.close();
                 // Increase dbconnection usage count
                 dbconn.increaseUsageCount(1);
                 // Bind the values to the query and execute it
                 pstmt.setString(1, docid);
                 pstmt.setString(2, user);
                 pstmt.setString(3, docid);
                 pstmt.execute();
           } catch (SQLException e) {
             MetaCatUtil.debugMessage(
                     "Error in DocumentImpl.archiveDocRevision : "
                             + e.getMessage(), 30);
             throw e;
           } catch (Exception e) {
             MetaCatUtil.debugMessage(
                     "Error in DocumentImpl.archiveDocRevision : "
                             + e.getMessage(), 30);
             throw e;
+          }
           finally {
             try {
                 pstmt.close();
             } catch (SQLException e) {
             } catch (SQLException ee) {
                 MetaCatUtil.debugMessage(
                         "Error in DocumentImpl.archiveDocRevision : "
                                 + e.getMessage(), 30);
             } catch (Exception e) {
                 MetaCatUtil.debugMessage(
                         "Error in DocumentImpl.archiveDocRevision : "
                                 + e.getMessage(), 30);
                         "Error in DocumnetImpl.archiveDocRevision: "
                                 + ee.getMessage(), 50);
+            }
             finally {
                 try {
                     pstmt.close();
                 } catch (SQLException ee) {
                     MetaCatUtil.debugMessage(
                             "Error in DocumnetImpl.archiveDocRevision: "
                                     + ee.getMessage(), 50);
+                }
+            }
+          }
+        }
         private static void moveNodesToNodesRevision(DBConnection dbconn,
                                            long rootNodeId) throws Exception
+        {
             PreparedStatement pstmt = null;
             // 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, rootNodeId);
             pstmt.execute();
             pstmt.close();
+        }
         /** Save a document entry in the xml_revisions table */
         private static void archiveDocRevision(String docid, String user)
+        {

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 2607

Added by Jing Tao almost 19 years ago