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

« Previous | Next »

Revision 1217

Added by Jing Tao almost 22 years ago

Merge DBConnection branch to head.

       int serverCheckCode = 1;
       MetaCatUtil util = new MetaCatUtil();
       Hashtable serverList = new Hashtable();
       Connection conn;
       //Connection conn;
       PrintWriter out;
       public ReplicationHandler(PrintWriter o)
-...
         //xml_documents with an update_date > last_checked
         try
+        {
           try
           { //this connection is prone to error for some reason so we
           //try
           //{ //this connection is prone to error for some reason so we
             //try to connect it three times before quiting.
             conn = util.openDBConnection();
+          }
           catch(SQLException sqle)
+          {
             //conn = util.openDBConnection();
           //}
           //catch(SQLException sqle)
           //{
             /*try
+            {
               conn = util.openDBConnection();
-...
+              }
               catch(SQLException sqleee)
               {*/
                 System.out.println("error getting db connection in " +
                                    "ReplicationHandler.run: " +
                                    sqle.getMessage());
                 //System.out.println("error getting db connection in " +
                                    //"ReplicationHandler.run: " +
                                    //sqle.getMessage());
               //}
             //}
+          }
           serverList = buildServerList(conn);
           //}
           serverList = buildServerList();
           //if serverList is null, metacat don't need to replication
           if (serverList==null||serverList.isEmpty())
+          {
-...
+          }
           updateCatalog(serverList);
           update(serverList);
           conn.close();
+        }
           //conn.close();
         }//try
         catch (Exception e)
+        {
           //System.out.println("Error in replicationHandler.run():"+e.getMessage());
+        }
           MetaCatUtil.debugMessage("Error in replicationHandler.run():"
                                                         +e.getMessage(), 30);
         }//catch
+      }
       /**
-...
            should be kept anyway)
         */
         Connection conn = null;
         try
         DBConnection dbConn = null;
         int serialNumber = -1;
         /*try
+        {
           conn = util.getConnection();
+        }
         catch (Exception e)
+        {
           util.debugMessage("There is problem to get conncetion: "+e.getMessage());
+        }
         }*/
         Enumeration keys;
         String server;
-...
         try
+        {
           dbConn=DBConnectionPool.
                       getDBConnection("ReplicationHandler.update");
           serialNumber=dbConn.getCheckOutSerialNumber();
           MetaCatUtil.debugMessage("init parser");
           parser = initParser(message);
           keys = serverList.keys();
-...
               String docServer = (String)w.elementAt(2);
               pstmt = conn.prepareStatement("select rev from xml_documents where "+
              pstmt = dbConn.prepareStatement("select rev from xml_documents where "+
                                             "docid like '" + docid + "'");
               pstmt.execute();
               rs = pstmt.getResultSet();
-...
                 try
+                {
                   String newDocid = DocumentImpl.writeReplication(conn,
                   String newDocid = DocumentImpl.writeReplication(dbConn,
                                   new StringReader(newxmldoc),
                                   (String)docinfoHash.get("public_access"),
                                   null,  /* the dtd text */
-...
                                   null, /* null for groups[] */
                                   docHomeServer,
                                   false /* validate */);
                   //increase usage
                   dbConn.increaseUsageCount(1);
                   MetacatReplication.replLog("wrote doc " + docid + " from " +
                                              docServer);
                   /*System.out.println("wrote doc " + docid + " from " +
-...
             { //delete the deleted documents;
               Vector w = new Vector((Vector)d.elementAt(k));
               String docid = (String)w.elementAt(0);
               if(!alreadyDeleted(docid, conn))
               if(!alreadyDeleted(docid))
+              {
                 //because delete method docid should have rev number
                 //so we just add one for it. This rev number is no sence.
                 String accnum=docid+util.getOption("accNumSeparator")+"1";
                 //System.out.println("accnum: "+accnum);
                 DocumentImpl.delete(conn, accnum, null, null);
                 DocumentImpl.delete(accnum, null, null);
                 MetacatReplication.replLog("doc " + docid + " deleted");
+              }
             }//for delete docs
-...
                 sql.append("server like '").append(server).append("'");
                 //System.out.println("sql: " + sql.toString());
                 pstmt.close();
                 pstmt = conn.prepareStatement(sql.toString());
                 pstmt = dbConn.prepareStatement(sql.toString());
                 //increase usage count
                 dbConn.increaseUsageCount(1);
                 pstmt.executeUpdate();
                 //conn.commit();
                 dbConn.commit();
                 System.out.println("last_checked updated to " + datestr + " on " +
                                 server);
+              }
-...
           try
+          {
             pstmt.close();
             util.returnConnection(conn);
+          }
           catch(Exception ee) {}
           }//try
           catch(Exception ee)
+          {
             MetaCatUtil.debugMessage("Error in ReplicationHandler.update to close"+
                                     " pstmt: "+ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
       }//update
-...
        */
       private void updateCatalog(Hashtable serverList)
+      {
         Connection conn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         try
+        {
           try
           { //this connection is prone to error for some reason so we
             //try to connect it three times before quiting.
           /*try
+          {
             conn = util.openDBConnection();
+          }
           catch(SQLException sqle)
-...
                                    sqleee.getMessage());
+              }
+            }
+          }
           }*/
           dbConn=DBConnectionPool.
                       getDBConnection("ReplicationHandler.updateCatalog");
           serialNumber=dbConn.getCheckOutSerialNumber();
           String server;
           Enumeration keys = serverList.keys();
           while(keys.hasMoreElements())
-...
                 sql.append("target_doctype, public_id, system_id) values (?,?,?,");
                 sql.append("?,?)");
                 //System.out.println("sql: " + sql.toString());
                 PreparedStatement pstmt = conn.prepareStatement(sql.toString());
                 pstmt = dbConn.prepareStatement(sql.toString());
                 //increase usage count 1
                 dbConn.increaseUsageCount(1);
                 pstmt.setString(1, (String)v.elementAt(0));
                 pstmt.setString(2, (String)v.elementAt(1));
                 pstmt.setString(3, (String)v.elementAt(2));
-...
+              }
+            }
+          }
           conn.close();
           //conn.close();
+        }
         catch(Exception e)
+        {
           System.out.println("error in ReplicationHandler.updateCatalog: " +
                               e.getMessage());
           e.printStackTrace(System.out);
         }//catch
         finally
+        {
           try
+          {
             conn.close();
+          }
           catch (Exception ee)
             pstmt.close();
           }//try
           catch (SQLException ee)
+          {
+          }
+        }
             MetaCatUtil.debugMessage("Error in ReplicationHandler.updateCatalog "+
                           "to close pstmt: "+ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finall
+      }
       /**
-...
        *   _             X             TRUE
        *   _             _             TRUE
        */
       private static boolean alreadyDeleted(String docid, Connection conn)
       private static boolean alreadyDeleted(String docid)
+      {
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         try
+        {
           dbConn=DBConnectionPool.
                       getDBConnection("ReplicationHandler.alreadyDeleted");
           serialNumber=dbConn.getCheckOutSerialNumber();
           boolean xml_docs = false;
           boolean xml_revs = false;
           StringBuffer sb = new StringBuffer();
           sb.append("select docid from xml_revisions where docid like '");
           sb.append(docid).append("'");
           PreparedStatement pstmt = conn.prepareStatement(sb.toString());
           pstmt = dbConn.prepareStatement(sb.toString());
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
           boolean tablehasrows = rs.next();
-...
           sb.append("select docid from xml_documents where docid like '");
           sb.append(docid).append("'");
           pstmt.close();
           pstmt = conn.prepareStatement(sb.toString());
           pstmt = dbConn.prepareStatement(sb.toString());
           //increase usage count
           dbConn.increaseUsageCount(1);
           pstmt.execute();
           rs = pstmt.getResultSet();
           tablehasrows = rs.next();
-...
+        }
         finally
+        {
+        }
           try
+          {
             pstmt.close();
           }//try
           catch (SQLException ee)
+          {
             MetaCatUtil.debugMessage("Error in replicationHandler.alreadyDeleted "+
                               "to close pstmt: "+ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
         return false;
+      }
-...
        */
       private static String getAction(String docid)
+      {
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         try
+        {
           MetaCatUtil util = new MetaCatUtil();
           dbConn=DBConnectionPool.
                       getDBConnection("ReplicationHandler.getAction");
           serialNumber=dbConn.getCheckOutSerialNumber();
           //MetaCatUtil util = new MetaCatUtil();
           StringBuffer sql = new StringBuffer();
           sql.append("select docid from xml_documents where docid like '");
           sql.append(docid).append("'");
           Connection conn = util.openDBConnection();
           PreparedStatement pstmt = conn.prepareStatement(sql.toString());
           //Connection conn = util.openDBConnection();
           pstmt = dbConn.prepareStatement(sql.toString());
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
           if(rs.next())
+          {
             pstmt.close();
             conn.close();
             //conn.close();
             return "UPDATE";
+          }
           else
+          {
             pstmt.close();
             conn.close();
             //conn.close();
             return "INSERT";
+          }
+        }
-...
           System.out.println("error in replicationHandler.getAction: " +
                               e.getMessage());
+        }
         finally
+        {
           try
+          {
             pstmt.close();
+          }
           catch (SQLException sqlE)
+          {
             MetaCatUtil.debugMessage("error in replicationHandler.getAction: " +
                          "to close pstmt: "+ sqlE.getMessage(), 30);
+          }
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+          }
         }//finally
         return "";
+      }
-...
        * and it's last update time.
        * @param conn a connection to the database
        */
       public static Hashtable buildServerList(Connection conn)
       public static Hashtable buildServerList()
+      {
         DBConnection dbConn = null;
         int serialNumber = -1;
         Hashtable sl = new Hashtable();
         PreparedStatement pstmt;
         PreparedStatement pstmt = null;
         try
+        {
           pstmt = conn.prepareStatement("select server, last_checked, replicate " +
           dbConn=DBConnectionPool.
                       getDBConnection("ReplicationHandler.buildServerList");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pstmt = dbConn.prepareStatement("select server, last_checked, replicate "+
                                         "from xml_replication");
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
-...
           System.out.println("error in replicationHandler.buildServerList(): " +
                              e.getMessage());
+        }
         finally
+        {
           try
+          {
             pstmt.close();
           }//try
           catch (SQLException sqlE)
+          {
             MetaCatUtil.debugMessage("Error in ReplicationHandler.buildServerList: "
                                     +sqlE.getMessage());
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
         return sl;
+      }
        /**
-...
       public static Hashtable getHomeServer(String docId)
+      {
         Hashtable sl = new Hashtable();
         Connection conn = null;
         MetaCatUtil ut=new MetaCatUtil();
         docId=ut.getDocIdFromString(docId);
         DBConnection dbConn = null;
         int serialNumber = -1;
         //MetaCatUtil ut=new MetaCatUtil();
         docId=MetaCatUtil.getDocIdFromString(docId);
         PreparedStatement pstmt=null;
         int serverLocation;
         try
+        {
           conn=ut.getConnection();
           //get conection
           dbConn=DBConnectionPool.
                       getDBConnection("ReplicationHandler.getHomeServer");
           serialNumber=dbConn.getCheckOutSerialNumber();
           //get a server location from xml_document table
           pstmt = conn.prepareStatement("select server_location from xml_documents "
           pstmt=dbConn.prepareStatement("select server_location from xml_documents "
                                                 +"where docid = ?");
           pstmt.setString(1, docId);
           pstmt.execute();
-...
           else
+          {
             pstmt.close();
             ut.returnConnection(conn);
             //ut.returnConnection(conn);
             return null;
+          }
           pstmt = conn.prepareStatement("select server, last_checked, replicate " +
           pstmt=dbConn.prepareStatement("select server, last_checked, replicate " +
                             "from xml_replication where serverid = ?");
           //increase usage count
           dbConn.increaseUsageCount(1);
           pstmt.setInt(1, serverLocation);
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
-...
           else
+          {
             pstmt.close();
             ut.returnConnection(conn);
             //ut.returnConnection(conn);
             return null;
+          }
           pstmt.close();
+        }
         catch(Exception e)
+        {
           System.out.println("error in replicationHandler.buildServerList(): " +
           System.out.println("error in replicationHandler.getHomeServer(): " +
                              e.getMessage());
+        }
         finally
-...
           try
+          {
             pstmt.close();
             ut.returnConnection(conn);
             //ut.returnConnection(conn);
+          }
           catch (Exception ee)
+          {
             MetaCatUtil.debugMessage("Eror irn rplicationHandler.getHomeServer() "+
                               "to close pstmt: "+ee.getMessage(), 30);
+          }
+        }
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+          }
         }//finally
         return sl;
+      }
-...
        */
       public static int getServerLocation(String accNum) throws Exception
+      {
         Connection conn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         int serverCode = 1;
         MetaCatUtil ut = new MetaCatUtil();
         String docId=ut.getDocIdFromString(accNum);
         //MetaCatUtil ut = new MetaCatUtil();
         String docId=MetaCatUtil.getDocIdFromString(accNum);
         try
+        {
           conn = ut.openDBConnection();
           pstmt = conn.prepareStatement("SELECT server_location FROM xml_documents "
           //conn = ut.openDBConnection();
           //get conection
           dbConn=DBConnectionPool.
                       getDBConnection("ReplicationHandler.getServerLocation");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pstmt=dbConn.prepareStatement("SELECT server_location FROM xml_documents "
                                   + "WHERE docid LIKE '" + docId + "'");
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
-...
+          {
             serverCode = rs.getInt(1);
             pstmt.close();
             conn.close();
             //conn.close();
             return serverCode;
+          }
           //if couldn't find in xml_documents table, we think server code is 1
-...
           else
+          {
             pstmt.close();
             conn.close();
             //conn.close();
             return serverCode;
+          }
-...
           try
+          {
             pstmt.close();
             conn.close();
             return serverCode;
             //conn.close();
+          }
           catch(Exception ee)
+          {
             MetaCatUtil.debugMessage("Erorr in Replication.getServerLocation "+
                          "to close pstmt"+ee.getMessage(), 30);
+          }
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
        //return serverCode;
+      }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 1217

Added by Jing Tao almost 22 years ago