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

« Previous | Next »

Revision 1217

Added by Jing Tao almost 22 years ago

Merge DBConnection branch to head.

       static final int READ = 4;
       private static final AbstractDatabase dbAdapter = MetaCatUtil.dbAdapter;
       private Connection conn = null;
       private DBConnection connection = null;
       private String docid = null;
       private String updatedVersion=null;
       private String docname = null;
-...
        * @param docid the identifier of the document to be created
        * @param readNodes flag indicating whether the xmlnodes should be read
        */
       public DocumentImpl(Connection conn, String docid, boolean readNodes)
       public DocumentImpl(String docid, boolean readNodes)
              throws McdbException
+      {
         try {
           this.conn = conn;
           //this.conn = conn;
           this.docid = docid;
           // Look up the document information
           getDocumentInfo(docid);
           if (readNodes) {
             // Download all of the document nodes using a single SQL query
             // The sort order of the records is determined by the NodeComparator
             // class, and needs to represent a depth-first traversal for the
             // toXml() method to work properly
             nodeRecordList = getNodeRecordList(rootnodeid);
+          }
         } catch (McdbException ex) {
-...
        * @param conn the database connection from which to read the document
        * @param docid the identifier of the document to be created
        */
       public DocumentImpl(Connection conn, String docid) throws McdbException
       public DocumentImpl(String docid) throws McdbException
+      {
         this(conn, docid, true);
         this(docid, true);
+      }
       /**
-...
        *        resides.
+       *
        */
       public DocumentImpl(Connection conn, long rootnodeid, String docname,
       /*public DocumentImpl(Connection conn, long rootnodeid, String docname,
                           String doctype, String docid, String action, String user,
                           String pub, String catalogid, int serverCode)
                           throws SQLException, Exception
-...
         this.doctype = doctype;
         this.docid = docid;
         writeDocumentToDB(action, user, pub, catalogid, serverCode);
+      }
       }*/
       /**
        * Construct a new document instance, writing the contents to the database.
-...
        *        resides.
+       *
        */
       public DocumentImpl(Connection conn, long rootNodeId, String docName,
       public DocumentImpl(DBConnection conn, long rootNodeId, String docName,
                           String docType, String docId, String newRevision,
                           String action, String user,
                           String pub, String catalogId, int serverCode)
                           throws SQLException, Exception
+      {
         this.conn = conn;
         this.connection = conn;
         this.rootnodeid = rootNodeId;
         this.docname = docName;
         this.doctype = docType;
-...
                          String docname, String doctype, String accnum, String user)
                          throws SQLException, AccessionNumberException, Exception
+      {
         Connection dbConn = null;
         MetaCatUtil ut = new MetaCatUtil();
         try
+        {
           dbConn = ut.openDBConnection();
           // get server location for this doc
           int serverLocation=getServerLocationNumber(dbConn,accnum);
           dbConn.close();
            // get server location for this doc
           int serverLocation=getServerLocationNumber(accnum);
           registerDocument(docname, doctype,accnum, user, serverLocation);
+        }
         catch (Exception e)
+        {
           throw e;
+        }
         finally
+        {
           try
+          {
             dbConn.close();
+          }
           catch (Exception ee)
           {}
+        }
+      }
       /**
-...
                          String user, int serverCode)
                          throws SQLException, AccessionNumberException, Exception
+      {
         Connection dbconn = null;
         MetaCatUtil util = new MetaCatUtil();
         DBConnection dbconn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         //MetaCatUtil util = new MetaCatUtil();
         AccessionNumber ac;
         try {
           dbconn = util.openDBConnection();
           //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(dbconn, docIdWithoutRev);
           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(dbconn, accnum, "insert");
             ac = new AccessionNumber(accnum, "insert");
+          }
           //rev is greater the last revsion number and revInDataBase isn't -1
           // it is a updated data file
-...
+          {
             //archive the old entry
             archiveDocRevision(dbconn, docIdWithoutRev, user);
             archiveDocRevision(docIdWithoutRev, user);
             //delete the old entry in xml_documents
             deleteXMLDocuments(dbconn, docIdWithoutRev);
             ac = new AccessionNumber(dbconn, accnum, "update");
             deleteXMLDocuments(docIdWithoutRev);
             ac = new AccessionNumber(accnum, "update");
+          }
           //other situation
           else
-...
           sql.append(sqlDateString).append(",");
           sql.append(sqlDateString).append(",");
           sql.append("'0')");
           PreparedStatement pstmt = dbconn.prepareStatement(sql.toString());
           pstmt = dbconn.prepareStatement(sql.toString());
           pstmt.execute();
           pstmt.close();
           dbconn.close();
           //dbconn.close();
+        }
         finally
+        {
           try
+          {
             dbconn.close();
             pstmt.close();
+          }
           catch (SQLException sqlE)
           finally
+          {
             util.debugMessage("Error in DocumentImpl.registerDocument:" +
                                     sqlE.getMessage(), 30);
             DBConnectionPool.returnDBConnection(dbconn, serialNumber);
+          }
+        }
+      }
-...
                          String user, int serverCode)
                          throws SQLException, AccessionNumberException, Exception
+      {
         Connection dbconn = null;
         MetaCatUtil util = new MetaCatUtil();
         DBConnection dbconn = null;
         int serialNumber = -1;
         //MetaCatUtil util = new MetaCatUtil();
         AccessionNumber ac;
         PreparedStatement pstmt = null;
         try {
           dbconn = util.openDBConnection();
           //dbconn = util.openDBConnection();
            dbconn=DBConnectionPool.
                       getDBConnection("DocumentImpl.registerDocumentInReplication");
           serialNumber=dbconn.getCheckOutSerialNumber();
           String docIdWithoutRev=MetaCatUtil.getDocIdFromString(accnum);
           int userSpecifyRev=MetaCatUtil.getVersionFromString(accnum);
           int revInDataBase=getLatestRevisionNumber(dbconn, docIdWithoutRev);
           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(dbconn, accnum, "insert");
             ac = new AccessionNumber(accnum, "insert");
+          }
           //rev is greater the last revsion number and revInDataBase isn't -1
           // it is a updated data file
-...
+          {
             //archive the old entry
             archiveDocRevision(dbconn, docIdWithoutRev, user);
             archiveDocRevision(docIdWithoutRev, user);
             //delete the old entry in xml_documents
             deleteXMLDocuments(dbconn, docIdWithoutRev);
             ac = new AccessionNumber(dbconn, accnum, "update");
             deleteXMLDocuments(docIdWithoutRev);
             ac = new AccessionNumber(accnum, "update");
+          }
           //other situation
           else
-...
           sql.append(sqlDateString).append(",");
           sql.append(sqlDateString).append(",");
           sql.append("'0')");
           PreparedStatement pstmt = dbconn.prepareStatement(sql.toString());
           pstmt = dbconn.prepareStatement(sql.toString());
           pstmt.execute();
           pstmt.close();
           dbconn.close();
           //dbconn.close();
+        }
         finally
+        {
           try
+          {
             dbconn.close();
+          }
           catch (SQLException sqlE)
+          {
             util.debugMessage("Error in DocumentImpl.registerDocument:" +
                                     sqlE.getMessage());
+          }
           pstmt.close();
           DBConnectionPool.returnDBConnection(dbconn, serialNumber);
+        }
+      }
-...
       public static boolean getDataFileLockGrant(String accnum)
                                                       throws Exception
+      {
         Connection dbConn = null;
         MetaCatUtil ut= new MetaCatUtil();
         try
+        {
           dbConn = ut.openDBConnection();
           int serverLocation=getServerLocationNumber(dbConn,accnum);
           dbConn.close();
           int serverLocation=getServerLocationNumber(accnum);
           return getDataFileLockGrant(accnum,serverLocation);
+        }
         catch (Exception e)
+        {
           try
+          {
             dbConn.close();
+          }
           catch (Exception ee)
           {}
           throw e;
+        }
+      }
-...
                                               throws Exception
+      {
         boolean flag=true;
         MetaCatUtil util = new MetaCatUtil();
         String docid = util.getDocIdFromString(accnum);
         int rev = util.getVersionFromString(accnum);
         //MetaCatUtil util = new MetaCatUtil();
         String docid = MetaCatUtil.getDocIdFromString(accnum);
         int rev = MetaCatUtil.getVersionFromString(accnum);
         if (serverCode == 1)
+        {
-...
           String server = MetacatReplication.getServer(serverCode);
           MetacatReplication.replLog("attempting to lock " + accnum);
           URL u = new URL("https://" + server + "?server="
                +util.getLocalReplicationServerName()+"&action=getlock&updaterev="
           URL u = new URL("https://" + server + "?server=" +
             MetaCatUtil.getLocalReplicationServerName()+"&action=getlock&updaterev="
                +rev + "&docid=" + docid);
           //System.out.println("sending message: " + u.toString());
           String serverResStr = MetacatReplication.getURLContent(u);
-...
       private boolean isRevisionOnly(DocumentIdentifier docid) throws Exception
+      {
         //System.out.println("inRevisionOnly");
         PreparedStatement pstmt;
         DBConnection dbconn = null;
         int serialNumber = -1;
         PreparedStatement pstmt =null;
         String rev = docid.getRev();
         String newid = docid.getIdentifier();
         pstmt = conn.prepareStatement("select rev from xml_documents " +
         try
+        {
           dbconn=DBConnectionPool.
                         getDBConnection("DocumentImpl.isRevisionOnly");
           serialNumber=dbconn.getCheckOutSerialNumber();
           pstmt = dbconn.prepareStatement("select rev from xml_documents " +
                                       "where docid like '" + newid + "'");
         pstmt.execute();
         ResultSet rs = pstmt.getResultSet();
         boolean tablehasrows = rs.next();
         if(rev.equals("newest") || rev.equals("all"))
+        {
           return false;
+        }
         if(tablehasrows)
+        {
           int r = rs.getInt(1);
           pstmt.close();
           if(new Integer(rev).intValue() == r)
           { //the current revision in in xml_documents
             //System.out.println("returning false");
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
           boolean tablehasrows = rs.next();
           if(rev.equals("newest") || rev.equals("all"))
+          {
             return false;
+          }
           else if(new Integer(rev).intValue() < r)
           { //the current revision is in xml_revisions.
             //System.out.println("returning true");
             return true;
+          }
           else if(new Integer(rev).intValue() > r)
           { //error, rev cannot be greater than r
             throw new Exception("requested revision cannot be greater than " +
           if(tablehasrows)
+          {
             int r = rs.getInt(1);
             pstmt.close();
             if(new Integer(rev).intValue() == r)
             { //the current revision in in xml_documents
               //System.out.println("returning false");
               return false;
+            }
             else if(new Integer(rev).intValue() < r)
             { //the current revision is in xml_revisions.
               //System.out.println("returning true");
               return true;
+            }
             else if(new Integer(rev).intValue() > r)
             { //error, rev cannot be greater than r
               throw new Exception("requested revision cannot be greater than " +
                                 "the latest revision number.");
+            }
+          }
+        }
         throw new Exception("the requested docid '" + docid.toString() +
           throw new Exception("the requested docid '" + docid.toString() +
                             "' does not exist");
         }//try
         finally
+        {
           pstmt.close();
           DBConnectionPool.returnDBConnection(dbconn, serialNumber);
         }//finally
+      }
       private void getDocumentInfo(String docid) throws McdbException,
-...
        */
       private void getDocumentInfo(DocumentIdentifier docid) throws McdbException
+      {
         PreparedStatement pstmt;
         DBConnection dbconn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         String table = "xml_documents";
         try
-...
+        }
         try {
         try
+        {
           dbconn=DBConnectionPool.getDBConnection("DocumentImpl.getDocumentInfo");
           serialNumber=dbconn.getCheckOutSerialNumber();
           StringBuffer sql = new StringBuffer();
     // DOCTITLE attr cleared from the db
     //      sql.append("SELECT docname, doctype, rootnodeid, doctitle, ");
-...
           sql.append("' and rev like '").append(docid.getRev()).append("'");
           //System.out.println(sql.toString());
           pstmt =
             conn.prepareStatement(sql.toString());
             dbconn.prepareStatement(sql.toString());
           // Bind the values to the query
           //pstmt.setString(1, docid.getIdentifier());
           //pstmt.setString(2, docid.getRev());
-...
           //get doc  home server name
           pstmt = conn.prepareStatement("select server " +
           pstmt = dbconn.prepareStatement("select server " +
                             "from xml_replication where serverid = ?");
           //because connection use twise here, so we need to increase one
           dbconn.increaseUsageCount(1);
           pstmt.setInt(1, serverlocation);
           pstmt.execute();
           rs = pstmt.getResultSet();
-...
           pstmt.close();
           if (this.doctype != null) {
             pstmt =
               conn.prepareStatement("SELECT system_id " +
               dbconn.prepareStatement("SELECT system_id " +
                                       "FROM xml_catalog " +
                                      "WHERE public_id = ?");
             //should increase usage count again
             dbconn.increaseUsageCount(1);
             // Bind the values to the query
             pstmt.setString(1, doctype);
-...
           throw new McdbException("Error accessing database connection in " +
                                   "DocumentImpl.getDocumentInfo: ", e);
+        }
         finally
+        {
           try
+          {
             pstmt.close();
+          }
           catch (SQLException ee)
+          {
             MetaCatUtil.debugMessage("error in DocumentImple.getDocumentInfo: "
                                         +ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbconn, serialNumber);
+          }
+        }
         if (this.docname == null) {
           throw new McdbDocNotFoundException("Document not found: " + docid);
-...
+       *
        * @param rootnodeid the id of the root node of the node tree to look up
        */
       private TreeSet getNodeRecordList(long rootnodeid) throws McdbException
       private TreeSet getNodeRecordList(long rootnodeid) throws McdbException
+      {
         PreparedStatement pstmt;
         PreparedStatement pstmt = null;
         DBConnection dbconn = null;
         int serialNumber = -1;
         TreeSet nodeRecordList = new TreeSet(new NodeComparator());
         long nodeid = 0;
         long parentnodeid = 0;
-...
         String quotechar = dbAdapter.getStringDelimiter();
         try {
           dbconn=DBConnectionPool.
                         getDBConnection("DocumentImpl.getNodeRecordList");
           serialNumber=dbconn.getCheckOutSerialNumber();
           pstmt =
           conn.prepareStatement("SELECT nodeid,parentnodeid,nodeindex, " +
           dbconn.prepareStatement("SELECT nodeid,parentnodeid,nodeindex, " +
                "nodetype,nodename,nodeprefix,nodedata " +
                "FROM xml_nodes WHERE rootnodeid = ?");
-...
           throw new McdbException("Error in DocumentImpl.getNodeRecordList " +
                                   e.getMessage());
+        }
         finally
+        {
           try
+          {
             pstmt.close();
+          }
           catch (SQLException ee)
+          {
             MetaCatUtil.debugMessage("error in DocumentImpl.getNodeRecordList: "
                                         +ee.getMessage(), 30);
+          }
           finally
+          {
             DBConnectionPool.returnDBConnection(dbconn, serialNumber);
+          }
+        }
         if (nodeRecordList != null) {
           return nodeRecordList;
-...
           if (action.equals("INSERT")) {
             //AccessionNumber ac = new AccessionNumber();
             //this.docid = ac.generate(docid, "INSERT");
             System.out.println("before pstmt");
             pstmt = conn.prepareStatement(
             pstmt = connection.prepareStatement(
                     "INSERT INTO xml_documents " +
                     "(docid, rootnodeid, docname, doctype, " +
                     "user_owner, user_updated, date_created, date_updated, " +
                     "public_access, catalog_id, server_location, rev) " +
                     "VALUES (?, ?, ?, ?, ?, ?, " + sysdate + ", " + 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!!!!!
-...
           } else if (action.equals("UPDATE")) {
             // Save the old document publicaccessentry in a backup table
             DocumentImpl.archiveDocRevision( conn, docid, user );
             DocumentImpl thisdoc = new DocumentImpl(conn, docid);
             DocumentImpl.archiveDocRevision(connection, docid, user );
             DocumentImpl thisdoc = new DocumentImpl(docid);
             int thisrev = thisdoc.getRev();
             //if the updated vesion is not greater than current one,
-...
             // Delete index for the old version of docid
             // The new index is inserting on the next calls to DBSAXNode
             pstmt = conn.prepareStatement(
             pstmt = connection.prepareStatement(
                     "DELETE FROM xml_index WHERE docid='" + this.docid + "'");
             // Increase dbconnection usage count
             connection.increaseUsageCount(1);
             pstmt.execute();
             pstmt.close();
             // Update the new document to reflect the new node tree
             pstmt = conn.prepareStatement(
             pstmt = connection.prepareStatement(
                 "UPDATE xml_documents " +
                 "SET rootnodeid = ?, docname = ?, doctype = ?, " +
                 "user_updated = ?, date_updated = " + sysdate + ", " +
                 "server_location = ?, rev = ?, public_access = ?, catalog_id = ? " +
                 "WHERE docid = ?");
             // Increase dbconnection usage count
             connection.increaseUsageCount(1);
             // Bind the values to the query
             pstmt.setLong(1, rootnodeid);
             pstmt.setString(2, docname);
-...
           // Do the insertion
           pstmt.execute();
           System.out.println("after excecute");
           pstmt.close();
         } catch (SQLException sqle) {
-...
        * @param user the user that owns the document
        * @param groups the groups to which user belongs
        */
       public static String write(Connection conn,String filename,
       public static String write(DBConnection conn,String filename,
                                  String pub, String dtdfilename,
                                  String action, String docid, String user,
                                  String[] groups )
-...
                        pub, dtd, action, docid, user, groups, false);
+      }
       public static String write(Connection conn,Reader xml,String pub,Reader dtd,
       public static String write(DBConnection conn,Reader xml,String pub,Reader dtd,
                                  String action, String docid, String user,
                                  String[] groups, boolean validate)
                     throws Exception {
         //this method will be called in handleUpdateOrInsert method
         //in MetacatServlet class
         // get server location for this doc
         int serverLocation=getServerLocationNumber(conn,docid);
         int serverLocation=getServerLocationNumber(docid);
         //System.out.println("server location: "+serverLocation);
         return write(conn,xml,pub,dtd,action,docid,user,groups,serverLocation,false,
                      validate);
+      }
       public static String write(Connection conn, Reader xml, String pub,
       public static String write(DBConnection conn, Reader xml, String pub,
                                  String action, String docid, String user,
                                  String[] groups )
                     throws Exception {
         if(action.equals("UPDATE"))
         {//if the document is being updated then use the servercode from the
          //originally inserted document.
           DocumentImpl doc = new DocumentImpl(conn, docid);
           DocumentImpl doc = new DocumentImpl(docid);
           int servercode = doc.getServerlocation();
           return write(conn, xml, pub, action, docid, user, groups, servercode);
+        }
-...
+        }
+      }
       public static String write( Connection conn, Reader xml,
       public static String write(DBConnection conn, Reader xml,
                                   String action, String docid, String user,
                                   String[] groups, int serverCode )
                     throws Exception
-...
         return write(conn,xml,null,action,docid,user,groups,serverCode);
+      }
       public static String write( Connection conn, Reader xml, String pub,
       public static String write(DBConnection conn, Reader xml, String pub,
                                   String action, String docid, String user,
                                   String[] groups, int serverCode)
                     throws Exception
-...
                      serverCode,false,false);
+      }
       public static String write( Connection conn, Reader xml, String pub,
       public static String write(DBConnection conn, Reader xml, String pub,
                                   String action, String docid, String user,
                                   String[] groups, int serverCode, boolean override)
                     throws Exception
-...
        *        update will be locked and version checked.
        */
       public static String write( Connection conn,Reader xml,String pub,Reader dtd,
                                   String action, String accnum, String user,
                                   String[] groups, int serverCode, boolean override,
                                   boolean validate)
       public static String write(DBConnection conn, Reader xml,String pub,
                              Reader dtd, String action, String accnum, String user,
                              String[] groups, int serverCode, boolean override,
                              boolean validate)
                     throws Exception
+      {
         // NEW - WHEN CLIENT ALWAYS PROVIDE ACCESSION NUMBER INCLUDING REV IN IT
         MetaCatUtil util = new MetaCatUtil();
         AccessionNumber ac = new AccessionNumber(conn, accnum, action);
         //MetaCatUtil util = new MetaCatUtil();
         MetaCatUtil.debugMessage("conn usage count before writting: "
                                           +conn.getUsageCount(), 50);
         AccessionNumber ac = new AccessionNumber(accnum, action);
         String docid = ac.getDocid();
         String rev = ac.getRev();
         MetaCatUtil.debugMessage("action: " + action + " servercode: " +
-...
           char istreamChar;
           // check for 'write' permission for 'user' to update this document
           if ( !hasPermission(conn, user, groups, docid) ) {
           if ( !hasPermission(user, groups, docid) ) {
             throw new Exception("User " + user +
                   " does not have permission to update XML Document #" + accnum);
+          }
-...
           String updaterev = id.getRev();
           String server = MetacatReplication.getServer(serverCode);
           MetacatReplication.replLog("attempting to lock " + accnum);
           URL u = new URL("https://" + server + "?server="
                +util.getLocalReplicationServerName()+"&action=getlock&updaterev="
           URL u = new URL("https://" + server + "?server="+
             MetaCatUtil.getLocalReplicationServerName()+"&action=getlock&updaterev="
                +updaterev + "&docid=" + docid);
           //System.out.println("sending message: " + u.toString());
           String serverResStr = MetacatReplication.getURLContent(u);
-...
             //If Metacat is super hub, tell all servers in its server list to get
             //the new document, ture mean it is xml document
             if ((util.getOption("hub")).equals("super"))
             if ((MetaCatUtil.getOption("hub")).equals("super"))
+            {
               ForceReplicationHandler frh = new ForceReplicationHandler(accnum,
                     true, ReplicationHandler.buildServerList(conn));
                     true, ReplicationHandler.buildServerList());
+            }
             else
+            {
-...
         if ( action.equals("UPDATE") ) {
           // check for 'write' permission for 'user' to update this document
           if ( !hasPermission(conn, user, groups, docid) ) {
           if ( !hasPermission(user, groups, docid) ) {
             throw new Exception("User " + user +
                   " does not have permission to update XML Document #" + accnum);
+          }
-...
           XMLReader parser = initializeParser(conn, action, docid, rev, validate,
                                               user, groups, pub, serverCode, dtd);
           conn.setAutoCommit(false);
           parser.parse(new InputSource(xml));
           conn.commit();
-...
           //start the thread to replicate this new document out to the other servers
           //true mean it is xml document
           ForceReplicationHandler frh = new ForceReplicationHandler
                     (accnum, action, true,ReplicationHandler.buildServerList(conn));
                     (accnum, action, true,ReplicationHandler.buildServerList());
+        }
         MetaCatUtil.debugMessage("Conn Usage count after writting: "
                                                           +conn.getUsageCount(),50);
         return(accnum);
+      }
-...
        * @param validate, if the xml document is valid or not
        */
       public static String writeReplication( Connection conn,Reader xml,String pub,
                     Reader dtd, String action, String accnum, String user,
                                 String[] groups,String homeServer, boolean validate)
       public static String writeReplication(DBConnection conn, Reader xml,
                 String pub, Reader dtd, String action, String accnum, String user,
                 String[] groups,String homeServer, boolean validate)
                     throws Exception
+      {
         // NEW - WHEN CLIENT ALWAYS PROVIDE ACCESSION NUMBER INCLUDING REV IN IT
         MetaCatUtil util = new MetaCatUtil();
         //AccessionNumber ac = new AccessionNumber(conn, accnum, action);
         //String docid = ac.getDocid();
         // String rev = ac.getRev();
         String docid=util.getDocIdFromString(accnum);
         String rev=(new Integer(util.getVersionFromString(accnum))).toString();
         String docid=MetaCatUtil.getDocIdFromString(accnum);
         String rev=(new Integer(MetaCatUtil.getVersionFromString(accnum))).
                                                                         toString();
         //check if xml_documents table has the document or not
         //if not, set action to insert
         if (getLatestRevisionNumber(conn,docid)==-1)
         if (getLatestRevisionNumber(docid)==-1)
+        {
           action="INSERT";
+        }
-...
         MetaCatUtil.debugMessage("action: " + action + " servercode: " +
                                  serverCode, 10);
         /*if((serverCode != 1 && action.equals("UPDATE")) )
+        {
           int istreamInt;
           char istreamChar;
           DocumentIdentifier id = new DocumentIdentifier(accnum);
           String updaterev = id.getRev();
           String server = MetacatReplication.getServer(serverCode);
           MetacatReplication.replLog("attempting to lock " + accnum);
           URL u = new URL("https://" + server + "?server="
                +util.getLocalReplicationServerName()+"&action=getlock&updaterev="
                +updaterev + "&docid=" + docid);
           String serverResStr = MetacatReplication.getURLContent(u);
           String openingtag =serverResStr.substring(0, serverResStr.indexOf(">")+1);
           if(openingtag.equals("<lockgranted>"))
+          {
             try
+            {
               MetacatReplication.replLog("lock granted for " + accnum + " from " +
                                           server);
               XMLReader parser = initializeParser(conn, action, docid, updaterev,
                                       validate, user, groups, pub, serverCode, dtd);
               conn.setAutoCommit(false);
               parser.parse(new InputSource(xml));
               conn.commit();
               conn.setAutoCommit(true);
+            }
             catch (Exception e)
+            {
               conn.rollback();
               conn.setAutoCommit(true);
               throw e;
+            }
             return (accnum);
+          }
           else if(openingtag.equals("<filelocked>"))
+          {
             MetacatReplication.replLog("lock denied for " + accnum + " on " +
                                        server + " reason: file already locked");
             throw new Exception("The file specified is already locked by another " +
                                 "user.  Please wait 30 seconds, checkout the " +
                                 "newer document, merge your changes and try " +
                                 "again.");
+          }
           else if(openingtag.equals("<outdatedfile>"))
+          {
             MetacatReplication.replLog("lock denied for " + accnum + " on " +
                                         server + " reason: local file outdated");
             throw new Exception("The file you are trying to update is an outdated" +
                                 " version.  Please checkout the newest document, " +
                                 "merge your changes and try again.");
+          }
         }*/
         /*if ( action.equals("UPDATE") ) {
           if ( !hasPermission(conn, user, groups, docid) ) {
             throw new Exception("User " + user +
                   " does not have permission to update XML Document #" + accnum);
+          }
         }*/
         try
+        {
-...
+       *
        * @param docid the ID of the document to be deleted from the database
        */
       public static void delete( Connection conn, String accnum,
       public static void delete(String accnum,
                                      String user, String[] groups )
                     throws Exception
+      {
-...
         // Determine if the docid,rev are OK for DELETE
         //AccessionNumber ac = new AccessionNumber(conn);
         //docid = ac.generate(docid, rev, "DELETE");
         DBConnection conn = null;
         int serialNumber = -1;
         PreparedStatement pstmt =null;
         try
+        {
           //check out DBConnection
           conn=DBConnectionPool.
                         getDBConnection("DocumentImpl.delete");
           serialNumber=conn.getCheckOutSerialNumber();
         // NEW - WHEN CLIENT ALWAYS PROVIDE ACCESSION NUMBER INCLUDING REV IN IT
         AccessionNumber ac = new AccessionNumber(conn, accnum, "DELETE");
         String docid = ac.getDocid();
         String rev = ac.getRev();
           // NEW - WHEN CLIENT ALWAYS PROVIDE ACCESSION NUMBER INCLUDING REV IN IT
           AccessionNumber ac = new AccessionNumber(accnum, "DELETE");
           String docid = ac.getDocid();
           String rev = ac.getRev();
         // check for 'write' permission for 'user' to delete this document
         if ( !hasPermission(conn, user, groups, docid) ) {
           throw new Exception("User " + user +
           if ( !hasPermission(user, groups, docid) ) {
             throw new Exception("User " + user +
                   " does not have permission to delete XML Document #" + accnum);
+        }
+          }
         conn.setAutoCommit(false);
         // Copy the record to the xml_revisions table
         DocumentImpl.archiveDocRevision( conn, docid, user );
           conn.setAutoCommit(false);
           // Copy the record to the xml_revisions table
           DocumentImpl.archiveDocRevision(conn, docid, user );
         // Now delete it from the xml_documents table
         Statement stmt = conn.createStatement();
         stmt.execute("DELETE FROM xml_index WHERE docid = '" + docid + "'");
         //stmt.execute("DELETE FROM xml_access WHERE docid = '" + docid + "'");
         stmt.execute("DELETE FROM xml_access WHERE accessfileid = '" + docid + "'");
         stmt.execute("DELETE FROM xml_relation WHERE docid = '" + docid + "'");
         stmt.execute("DELETE FROM xml_documents WHERE docid = '" + docid + "'");
         stmt.close();
         conn.commit();
         conn.setAutoCommit(true);
           // Now delete it from the xml_index table
           pstmt = conn.prepareStatement("DELETE FROM xml_index WHERE docid = ?");
           pstmt.setString(1,docid);
           pstmt.execute();
           pstmt.close();
           conn.increaseUsageCount(1);
           //stmt.execute("DELETE FROM xml_access WHERE docid = '" + docid + "'");
           // Now delete it from xml_access table
           pstmt = conn.
                   prepareStatement("DELETE FROM xml_access WHERE accessfileid = ?");
           pstmt.setString(1, docid);
           pstmt.execute();
           pstmt.close();
           conn.increaseUsageCount(1);
           // Delete it from relation table
           pstmt = conn.
                    prepareStatement("DELETE FROM xml_relation WHERE docid = ?");
           //increase usage count
           conn.increaseUsageCount(1);
           pstmt.setString(1, docid);
           pstmt.execute();
           pstmt.close();
           // Delete it from xml_doucments table
           pstmt =conn.prepareStatement("DELETE FROM xml_documents WHERE docid = ?");
           pstmt.setString(1, docid);
           pstmt.execute();
           pstmt.close();
           //Usaga count increase 1
           conn.increaseUsageCount(1);
           conn.commit();
           conn.setAutoCommit(true);
         }//try
         finally
+        {
           try
+          {
             // close preparedStatement
             pstmt.close();
           }//try
           finally
+          {
             //check in DBonnection
             DBConnectionPool.returnDBConnection(conn, serialNumber);
           }//finally
         }//finally
         //IF this is a package document:
         //delete all of the relations that this document created.
         //if the deleted document is a package document its relations should
-...
         * Check for "WRITE" permission on @docid for @user and/or @groups
         * from DB connection
         */
       private static boolean hasPermission ( Connection conn, String user,
       private static boolean hasPermission (String user,
                                       String[] groups, String docid )
                       throws SQLException, Exception
+      {
         // Check for WRITE permission on @docid for @user and/or @groups
         AccessControlList aclobj = new AccessControlList(conn);
         return aclobj.hasPermission("WRITE", user, groups, docid);
         //AccessControlList aclobj = new AccessControlList(dbconn);
         return AccessControlList.hasPermission("WRITE", user, groups, docid);
         //return aclobj.hasPermission("WRITE", user, groups, docid);
+      }
       /**
-...
         *@group, user's group
+        *
         */
       public boolean hasReadPermission ( Connection conn, String user,
       public static boolean hasReadPermission (String user,
                                       String[] groups, String docId )
                       throws SQLException, Exception
+      {
         // Check for READ permission on @docid for @user and/or @groups
         AccessControlList aclObj = new AccessControlList(conn);
         return aclObj.hasPermission("READ", user, groups, docId);
         //AccessControlList aclObj = new AccessControlList(conn);
         //return aclObj.hasPermission("READ", user, groups, docId);
         return AccessControlList.hasPermission("READ", user, groups, docId);
+      }
       /**
        * Set up the parser handlers for writing the document to the database
        */
       private static XMLReader initializeParser(Connection conn, String action,
       private static XMLReader initializeParser(DBConnection dbconn, String action,
                                    String docid, String rev, boolean validate,
                                        String user, String[] groups, String pub,
                                        int serverCode, Reader dtd)
                                throws Exception
+      {
         XMLReader parser = null;
         //DBConnection conn = null;
         //int serialNumber = -1;
         //
         // Set up the SAX document handlers for parsing
         //
         try {
            //check out DBConnection
           /*conn=DBConnectionPool.
                         getDBConnection("DocumentImpl.initializeParse");
           serialNumber=conn.getCheckOutSerialNumber();*/
           //create a DBSAXHandler object which has the revision specification
           ContentHandler chandler = new DBSAXHandler(conn, action, docid, rev,
                                                      user, groups, pub, serverCode);
           EntityResolver eresolver= new DBEntityResolver(conn,
           ContentHandler chandler = new DBSAXHandler(dbconn, action,
                                         docid, rev, user, groups, pub, serverCode);
           EntityResolver eresolver= new DBEntityResolver(dbconn,
                                                      (DBSAXHandler)chandler, dtd);
           DTDHandler dtdhandler   = new DBDTDHandler(conn);
           DTDHandler dtdhandler   = new DBDTDHandler(dbconn);
           // Get an instance of the parser
           String parserName = MetaCatUtil.getOption("saxparser");
-...
         } catch (Exception e) {
           throw e;
+        }
         //finally
         //{
           //DBConnectionPool.returnDBConnection(conn, serialNumber);
         //}
         return parser;
+      }
       /**
        * Save a document entry in the xml_revisions table
        * Connection use as a paramter is in order to rollback feature
        */
       private static void archiveDocRevision(DBConnection dbconn, String docid,
                                                         String user)
+     {
         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
        try
+       {
          //check out DBConnection
          /*conn=DBConnectionPool.
                         getDBConnection("DocumentImpl.archiveDocRevision");
          serialNumber=conn.getCheckOutSerialNumber();*/
          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();
        }//try
        catch (SQLException e)
+       {
          MetaCatUtil.debugMessage("Error in DocumentImpl.archiveDocRevision : "+
                                     e.getMessage(), 30);
        }//catch
        finally
+       {
          try
+         {
            pstmt.close();
          }//try
          catch (SQLException ee)
+         {
            MetaCatUtil.debugMessage("Error in DocumnetImpl.archiveDocRevision: "+
                                       ee.getMessage(), 50);
          }//catch
          //finally
          //{
            //check in DBConnection
            //DBConnectionPool.returnDBConnection(conn, serialNumber);
          //}//finally
        }//finnally
       }//achiveDocRevision
       /** Save a document entry in the xml_revisions table */
       private static void archiveDocRevision(Connection conn, String docid,
                                              String user)
       private static void archiveDocRevision(String docid, String user)
+     {
         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
        try
+       {
          PreparedStatement pstmt = conn.prepareStatement(
          //check out DBConnection
          conn=DBConnectionPool.
                         getDBConnection("DocumentImpl.archiveDocRevision");
          serialNumber=conn.getCheckOutSerialNumber();
          pstmt = conn.prepareStatement(
           "INSERT INTO xml_revisions " +
             "(docid, rootnodeid, docname, doctype, " +
             "user_owner, user_updated, date_created, date_updated, " +
-...
           pstmt.setString(3, docid);
           pstmt.execute();
           pstmt.close();
+       }
        }//try
        catch (SQLException e)
+       {
+       }
          MetaCatUtil.debugMessage("Error in DocumentImpl.archiveDocRevision : "+
                                     e.getMessage(), 30);
        }//catch
        finally
+       {
          try
+         {
            pstmt.close();
          }//try
          catch (SQLException ee)
+         {
            MetaCatUtil.debugMessage("Error in DocumnetImpl.archiveDocRevision: "+
                                       ee.getMessage(), 50);
          }//catch
          finally
+         {
            //check in DBConnection
            DBConnectionPool.returnDBConnection(conn, serialNumber);
          }//finally
        }//finnally
+      }
       }//achiveDocRevision
       /**
         * delete a entry in xml_table for given docid
         * @param docId, the id of the document need to be delete
         */
       private static void deleteXMLDocuments(Connection conn, String docId)
       private static void deleteXMLDocuments(String docId)
                                              throws SQLException
+      {
         //delete a record
         PreparedStatement pStmt =
         DBConnection conn = null;
         int serialNumber = -1;
         PreparedStatement pStmt = null;
         try
+        {
           //check out DBConnection
           conn=DBConnectionPool.
                         getDBConnection("DocumentImpl.deleteXMLDocuments");
           serialNumber=conn.getCheckOutSerialNumber();
           //delete a record
           pStmt =
                  conn.prepareStatement("DELETE FROM xml_documents WHERE docid = '"
                                                   + docId + "'");
         pStmt.execute();
         pStmt.close();
         }//try
         finally
+        {
           try
+          {
             pStmt.close();
           }//try
           catch (SQLException e)
+          {
             MetaCatUtil.debugMessage("error in DocumentImpl.deleteXMLDocuments: "+
                                       e.getMessage(), 50);
           }//catch
           finally
+          {
             //return back DBconnection
             DBConnectionPool.returnDBConnection(conn, serialNumber);
           }//finally
         }//finally
       }//deleteXMLDocuments
-...
         * The return value is integer because we want compare it to there new one
         * @param docid <sitecode>.<uniqueid> part of Accession Number
         */
       private static int getLatestRevisionNumber(Connection conn, String docId)
       private static int getLatestRevisionNumber(String docId)
                                           throws SQLException
+      {
         int rev = 1;
         PreparedStatement pStmt;
         PreparedStatement pStmt = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         try
+        {
           //check out DBConnection
           dbConn=DBConnectionPool.
                         getDBConnection("DocumentImpl.getLatestRevisionNumber");
           serialNumber=dbConn.getCheckOutSerialNumber();
         pStmt = conn.prepareStatement
           pStmt = dbConn.prepareStatement
                   ("SELECT rev FROM xml_documents WHERE docid='" + docId + "'");
         pStmt.execute();
           pStmt.execute();
         ResultSet rs = pStmt.getResultSet();
         boolean hasRow = rs.next();
         if (hasRow)
           ResultSet rs = pStmt.getResultSet();
           boolean hasRow = rs.next();
           if (hasRow)
+          {
             rev = rs.getInt(1);
             pStmt.close();
+          }
           else
+          {
             rev=-1;
             pStmt.close();
+          }
         }//try
         finally
+        {
           rev = rs.getInt(1);
           pStmt.close();
+        }
         else
+        {
           rev=-1;
           pStmt.close();
+        }
           try
+          {
             pStmt.close();
+          }
           catch (Exception ee)
+          {
             MetaCatUtil.debugMessage("Error in DocumentImpl."+
                             "getLatestRevisionNumber: "+ee.getMessage(), 50);
+          }
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+          }
         }//finally
         return rev;
       }//getLatestRevisionNumber
-...
+       *
        * @param accum <sitecode>.<uniqueid>.<rev>
        */
       private static int getServerLocationNumber(Connection conn, String accNum)
       private static int getServerLocationNumber(String accNum)
                                                 throws SQLException
+      {
         //get rid of revNum part
         String docId=MetaCatUtil.getDocIdFromString(accNum);
         PreparedStatement pStmt;
         int serverLocation;
         PreparedStatement pStmt = null;
         int serverLocation = 1;
         DBConnection conn = null;
         int serialNumber = -1;
         try
+        {
           //check out DBConnection
           conn=DBConnectionPool.
                         getDBConnection("DocumentImpl.getServerLocationNumber");
           serialNumber=conn.getCheckOutSerialNumber();
         pStmt = conn.prepareStatement
           pStmt = conn.prepareStatement
           ("SELECT server_location FROM xml_documents WHERE docid='" + docId + "'");
         pStmt.execute();
           pStmt.execute();
         ResultSet rs = pStmt.getResultSet();
         boolean hasRow = rs.next();
         //if there is entry in xml_documents, get the serverlocation
         if (hasRow)
           ResultSet rs = pStmt.getResultSet();
           boolean hasRow = rs.next();
           //if there is entry in xml_documents, get the serverlocation
           if (hasRow)
+          {
             serverLocation = rs.getInt(1);
             pStmt.close();
+          }
           else
+          {
             //if htere is no entry in xml_documents, we consider it is new document
             //the server location is local host and value is 1
             serverLocation=1;
             pStmt.close();
+          }
         }//try
         finally
+        {
           serverLocation = rs.getInt(1);
           pStmt.close();
+        }
         else
+        {
           // if htere is no entry in xml_documents, we consider it is new document
           // the server location is local host and value is 1
           serverLocation=1;
           pStmt.close();
+        }
           try
+          {
             pStmt.close();
           }//try
           catch (Exception ee)
+          {
             MetaCatUtil.debugMessage("Error in DocumentImpl.getServerLocationNu(): "
                                         +ee.getMessage(), 50);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(conn, serialNumber);
           }//finally
         }//finally
         return serverLocation;
+      }
-...
+      {
         PreparedStatement pStmt=null;
         int serverLocation=-2;
         Connection dbConn = null;
         MetaCatUtil util = new MetaCatUtil();
         DBConnection dbConn = null;
         int serialNumber = -1;
         //MetaCatUtil util = new MetaCatUtil();
         //we should consider about local host too
         if (serverName.equals(util.getLocalReplicationServerName()))
         if (serverName.equals(MetaCatUtil.getLocalReplicationServerName()))
+        {
           serverLocation=1;
           return serverLocation;
-...
         try
+        {
           //check xml_replication table
           dbConn=util.openDBConnection();
           //dbConn=util.openDBConnection();
           //check out DBConnection
           dbConn=DBConnectionPool.getDBConnection("DocumentImpl.getServerCode");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pStmt = dbConn.prepareStatement
           ("SELECT serverid FROM xml_replication WHERE server='" + serverName +"'");
           pStmt.execute();
-...
+        }
         catch (Exception e)
+        {
           util.debugMessage("Error in DocumentImpl.getServerCode(): "
           MetaCatUtil.debugMessage("Error in DocumentImpl.getServerCode(): "
                                         +e.getMessage(), 30);
+        }
         finally
+        {
           try
+          {
             dbConn.close();
             pStmt.close();
+          }
           catch (Exception ee)
           {}
+          {
             MetaCatUtil.debugMessage("Error in DocumentImpl.getServerCode(): "
                                         +ee.getMessage(), 50);
+          }
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+          }
+        }
-...
       private static void  insertServerIntoReplicationTable(String server)
+      {
         PreparedStatement pStmt=null;
         Connection dbConn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         int replicate = 1;
         MetaCatUtil util = new MetaCatUtil();
         //MetaCatUtil util = new MetaCatUtil();
         try
+        {
            dbConn=util.openDBConnection();
            //dbConn=util.openDBConnection();
            //check out DBConnection
            dbConn=DBConnectionPool.
                     getDBConnection("DocumentImpl.insertServIntoReplicationTable");
            serialNumber=dbConn.getCheckOutSerialNumber();
            pStmt = dbConn.prepareStatement("INSERT INTO xml_replication " +
                                           "(server, last_checked, replicate) " +
                                           "VALUES ('" + server + "', to_date(" +
-...
             pStmt.execute();
             pStmt.close();
             dbConn.commit();
+        }
         }//try
         catch (Exception e)
+        {
           util.debugMessage("Error in DocumentImpl.getServerCode(): "
           MetaCatUtil.debugMessage("Error in DocumentImpl.insertServerIntoRepli(): "
                                         +e.getMessage(), 30);
+        }
         }//catch
         finally
+        {
           try
+          {
             pStmt.close();
             dbConn.close();
           }//try
           catch (Exception ee)
+          {
             MetaCatUtil.debugMessage("Error in DocumentImpl.insetServerIntoRepl(): "
                                         +ee.getMessage(), 50);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+          }
           catch (Exception ee)
           {}
+        }
         }//finally
+      }

... This diff was truncated because it exceeds the maximum size that can be displayed.

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 1217

Added by Jing Tao almost 22 years ago