/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 1217

Added by Jing Tao almost 22 years ago

Merge DBConnection branch to head.

+      }
       /** Construct a new validation object using a database entity resolver */
       public DBValidate(String parserName, Connection conn) {
       public DBValidate(String parserName, DBConnection conn) {
         this(parserName);
         DBEntityResolver dbresolver = new DBEntityResolver(conn);
-...
         String doc = args[0];
         MetaCatUtil util = new MetaCatUtil();
         DBConnection conn = null;
         int serailNumber = -1;
         try {
           Connection conn = util.openDBConnection();
           conn = DBConnectionPool.getDBConnection("DBValidate.main");
           serailNumber = conn.getCheckOutSerialNumber();
           DBValidate gxv = new DBValidate(util.getOption("saxparser"), conn);
           if (gxv.validate(doc)) {
-...
+          }
         } catch (SQLException e) {
           System.out.println("<error>Couldn't open database connection.</error>");
         } catch (ClassNotFoundException e) {
           System.out.println("<error>Couldn't open database connection.</error>");
+        }
+        }
         finally
+        {
           DBConnectionPool.returnDBConnection(conn, serailNumber);
         }//finally
+      }

       final static long CYCLETIMEOFDBCONNECTION =
                    Long.parseLong(MetaCatUtil.getOption("cycleTimeOfDBConnection"));
       //the number for trying to check out a connection in the pool in
       //getDBConnection method
       final static int LIMIT = 2;
       final static int FREE = 0; //status of a connection
       final static int BUSY = 1; //statis of a connection
-...
                                                     throws SQLException
+      {
         DBConnection db = null;
         MetaCatUtil.debugMessage("Try to checking out connection...", 10);
         //try every DBConnection in the pool
           for (int i=0; i<connectionPool.size(); i++)
         int random = 0; //random number
         int index = 0; //index
         int size = 0; //size of connection pool
         MetaCatUtil.debugMessage("Try to checking out connection...", 45);
         size = connectionPool.size();
         MetaCatUtil.debugMessage("size of connection pool: "+size, 45);
          //try every DBConnection in the pool
         //every DBConnection will be try LIMITE times
         for (int j=0 ; j<LIMIT; j++)
+        {
            //create a random number as the started index for connection pool
           //So that the connection ofindex of 0 wouldn't be a the heaviest user
           random = (new Double (Math.random()*100)).intValue();
           for (int i=0; i<size; i++)
+          {
             db = (DBConnection) connectionPool.elementAt(i);
             index =(i+random)%size;
             db = (DBConnection) connectionPool.elementAt(index);
             MetaCatUtil.debugMessage("Index: "+index, 45);
             MetaCatUtil.debugMessage("Tag: "+db.getTag(), 45);
             MetaCatUtil.debugMessage("Status: "+db.getStatus(), 45);
             //check if the connection is free
             if (db.getStatus()==FREE)
+            {
-...
                 db.setCheckOutMethodName(methodName);
                 //debug message
                 MetaCatUtil.debugMessage("The connection is checked out: "
                                            +db.getTag(), 20);
                 MetaCatUtil.debugMessage("The age is "+db.getAge(), 25);
                 MetaCatUtil.debugMessage("The usage is "+db.getUsageCount(), 25);
                                            +db.getTag(), 35);
                 MetaCatUtil.debugMessage("The method for checking is: "
                                                   +db.getCheckOutMethodName(), 35);
                 MetaCatUtil.debugMessage("The age is "+db.getAge(), 40);
                 MetaCatUtil.debugMessage("The usage is "+db.getUsageCount(), 40);
                 MetaCatUtil.debugMessage("The conection time it has: "
                                                     +db.getConnectionTime(), 25);
                                                     +db.getConnectionTime(), 40);
                 //set check out time
                 db.setCheckOutTime(System.currentTimeMillis());
                 //check it out
-...
                 //close this DBConnection
                 db.close();
                 //remove it form connection pool
                 connectionPool.remove(i);
                 connectionPool.remove(index);
                 //insert a new DBConnection to same palace
                 db = new DBConnection();
                 connectionPool.insertElementAt(db, i);
                 connectionPool.insertElementAt(db, index);
               }//else
             }//if
           }//for
         }//for
         //if couldn't get a connection, we should increase DBConnection pool
         //if the connection pool size is less than maximum connection number
         int poolSize = connectionPool.size();
         if ( poolSize < MAXIMUMCONNECTIONNUMBER )
         if ( size < MAXIMUMCONNECTIONNUMBER )
+        {
            if ((poolSize+INCREASECONNECTIONNUMBER) < MAXIMUMCONNECTIONNUMBER)
            if ((size+INCREASECONNECTIONNUMBER) < MAXIMUMCONNECTIONNUMBER)
+           {
              //if we can create INCREASECONNECTIONNUMBER of new DBConnection
              //add to connection pool
-...
+           {
              //There is no enough room to increase INCREASECONNECTIONNUMBER
              //we create new DBCoonection to Maximum connection number
              for (int i= poolSize+1; i<= MAXIMUMCONNECTIONNUMBER; i++)
              for (int i= size+1; i<= MAXIMUMCONNECTIONNUMBER; i++)
+             {
                DBConnection dbConn = new DBConnection();
                connectionPool.add(dbConn);
-...
         }//if
         else
+        {
           throw new SQLException("The maximum of " +MAXIMUMCONNECTIONNUMBER +
           /*throw new SQLException("The maximum of " +MAXIMUMCONNECTIONNUMBER +
                                 " open db connections is reached." +
                                 " New db connection to MetaCat" +
                                 " cannot be established.");
         }//else
         //recursive to get new connection
         return getDBConnection();
       }//getDBConnection
       /**
        * Method to get a DBConnection in connection pool
        * 1) try to get a DBConnection from DBConnection pool
        * 2) if 1) failed, then check the size of pool. If the size reach the
        *    maximum number of connection, throw a exception: couldn't get one
        * 3) If the size is less than the maximum number of connectio, create some
        *    new connections and recursive get one
        */
       public static synchronized DBConnection getDBConnection() throws SQLException
+      {
         DBConnection db = null;
         MetaCatUtil.debugMessage("Try to checking out connection...", 10);
         //try every DBConnection in the pool
           for (int i=0; i<connectionPool.size(); i++)
+          {
             db = (DBConnection) connectionPool.elementAt(i);
             //check if the connection is free
             if (db.getStatus()==FREE)
+            {
               //If this connection is good, return this DBConnection
               if (validateDBConnection(db))
+              {
                 //set this DBConnection status
                 db.setStatus(BUSY);
                 //increase checkout serial number
                 db.increaseCheckOutSerialNumber(1);
                 //increase one usageCount
                 db.increaseUsageCount(1);
                 //debug message
                 MetaCatUtil.debugMessage("The connection is checked out: "
                                            +db.getTag(), 25);
                 MetaCatUtil.debugMessage("The age is "+db.getAge(), 25);
                 MetaCatUtil.debugMessage("The usage is "+db.getUsageCount(), 25);
                 MetaCatUtil.debugMessage("The conection time it has: "
                                                     +db.getConnectionTime(), 25);
                 //set check out time
                 db.setCheckOutTime(System.currentTimeMillis());
                 //check it out
                 return db;
               }//if
               else//The DBConnection has some problem
+              {
                 //close this DBConnection
                 db.close();
                 //remove it form connection pool
                 connectionPool.remove(i);
                 //insert a new DBConnection to same palace
                 db = new DBConnection();
                 connectionPool.insertElementAt(db, i);
               }//else
             }//if
           }//for
         //if couldn't get a connection, we should increase DBConnection pool
         //if the connection pool size is less than maximum connection number
         int poolSize = connectionPool.size();
         if ( poolSize < MAXIMUMCONNECTIONNUMBER )
+        {
            if ((poolSize+INCREASECONNECTIONNUMBER) < MAXIMUMCONNECTIONNUMBER)
+           {
              //if we can create INCREASECONNECTIONNUMBER of new DBConnection
              //add to connection pool
              for ( int i=0; i<INCREASECONNECTIONNUMBER; i++)
+             {
                DBConnection dbConn = new DBConnection();
                connectionPool.add(dbConn);
              }//for
            }//if
            else
+           {
              //There is no enough room to increase INCREASECONNECTIONNUMBER
              //we create new DBCoonection to Maximum connection number
              for (int i= poolSize+1; i<= MAXIMUMCONNECTIONNUMBER; i++)
+             {
                DBConnection dbConn = new DBConnection();
                connectionPool.add(dbConn);
              }//for
            }//else
         }//if
         else
+        {
           throw new SQLException("The maximum of " +MAXIMUMCONNECTIONNUMBER +
                                 " cannot be established.");*/
            MetaCatUtil.debugMessage("The maximum of " +MAXIMUMCONNECTIONNUMBER +
                                 " open db connections is reached." +
                                 " New db connection to MetaCat" +
                                 " cannot be established.");
                                 " cannot be established.", 1);
            return null;
            //if couldn't get a connection, sleep 20 seconds and try again.
            /*try
+           {
              System.out.println("sleep");
              Thread.sleep(2000);
+           }
            catch (Exception e)
+           {
            }*/
         }//else
         //recursive to get new connection
         return getDBConnection();
         return getDBConnection(methodName);
       }//getDBConnection
       /**
        * Method to check if a db connection works fine or not
        * Check points include:
-...
        */
       private static boolean validateDBConnection (DBConnection dbConn)
+      {
         Connection conn = null;
         //Check if the DBConnection usageCount if it is too many
         if (dbConn.getUsageCount() >= MAXIMUMUSAGENUMBER )
+        {
-...
+        }
         //Try to run a simple query
         conn = dbConn.getConnections();
         try
+        {
           long startTime=System.currentTimeMillis();
           conn.getMetaData();
           DatabaseMetaData metaData = dbConn.getMetaData();
           long stopTime=System.currentTimeMillis();
           //increase one usagecount
           dbConn.increaseUsageCount(1);
-...
+        {
           MetaCatUtil.debugMessage("Couldn't find a DBConnection in the pool"
                                       +" which have same tag to the returned"
                                       +" DBConnetion object");
                                       +" DBConnetion object", 30);
           return;
         }//if
-...
             //set check out time to 0
             dbConn.setCheckOutTime(0);
             MetaCatUtil.debugMessage("Connection: "+dbConn.getTag()+" checked in.",
 );
 );
              MetaCatUtil.debugMessage("Connection: "+dbConn.getTag()+"'s status: "
                                                         +dbConn.getStatus(), 35);
           }//if
           else
+          {
             MetaCatUtil.debugMessage("This DBConnection couldn't return", 30);
           }//else
         }//else
-...
+      {
         int index = -1;
         String info = null;
         //if conn is null return -1 too
         if (conn==null)
+        {
           return -1;
+        }
         //get tag of this returned DBConnection
         info = conn.getTag();
         //if the tag is null or empty, -1 will be returned
-...
         }//while
       }//run
       /**
        * Method to get the number of free DBConnection in DBConnection pool
        */
       public int getFreeDBConnectionNumber()
+      {
         int numberOfFreeDBConnetion = 0; //return number
         DBConnection db = null; //single DBconnection
         int poolSize = 0; //size of connection pool
         //get the size of DBConnection pool
         poolSize = connectionPool.size();
         //Check every DBConnection in the pool
         for ( int i=0; i<poolSize; i++)
+        {
           db = (DBConnection) connectionPool.elementAt(i);
           //check the status of db. If it is free, count it
           if (db.getStatus() == FREE)
+          {
             numberOfFreeDBConnetion++;
           }//if
         }//for
         //return the count result
         return numberOfFreeDBConnetion;
       }//getFreeDBConnectionNumber
        /**
        * Method to print out the method name which have busy DBconnection
        */
       public void printMethodNameHavingBusyDBConnection()
+      {
         DBConnection db = null; //single DBconnection
         int poolSize = 0; //size of connection pool
         //get the size of DBConnection pool
         poolSize = connectionPool.size();
         //Check every DBConnection in the pool
         for ( int i=0; i<poolSize; i++)
+        {
           db = (DBConnection) connectionPool.elementAt(i);
           //check the status of db. If it is free, count it
           if (db.getStatus() == BUSY)
+          {
             MetaCatUtil.debugMessage("This method having a busy DBConnection: "
                                         +db.getCheckOutMethodName(), 30);
             MetaCatUtil.debugMessage("The busy DBConnection tag is: "
                                         +db.getTag(), 30);
           }//if
         }//for
       }//printMethodNameHavingBusyDBConnection
     }//DBConnectionPool

         conn.commit();
       }//commit
       /**
        * Method to set commit mode
        * @param autocommit, true of false to auto commit
        */
       public void setAutoCommit( boolean autoCommit) throws SQLException
+      {
         conn.setAutoCommit(autoCommit);
       }//setAutoCommit
       /**
        * Method to roll back
        */
       public void rollback() throws SQLException
+      {
         conn.rollback();
       }//rollback
       /**
        * Method to get meta data
        */
       public DatabaseMetaData getMetaData() throws SQLException
+      {
         return conn.getMetaData();
       }//getMetaData
     }//DBConnection class

                                               HttpServletResponse response)
+      {
         String subaction = ((String[])params.get("subaction"))[0];
         Connection conn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         try {
           conn = util.openDBConnection();
           PreparedStatement pstmt = null;
           //conn = util.openDBConnection();
           dbConn=DBConnectionPool.
                    getDBConnection("MetacatReplication.handleServerControlRequest");
           serialNumber=dbConn.getCheckOutSerialNumber();
           // add server to server list
           if ( subaction.equals("add") ) {
             String replicate = ((String[])params.get("replicate"))[0];
             String server = ((String[])params.get("server"))[0];
             pstmt = conn.prepareStatement("INSERT INTO xml_replication " +
             pstmt = dbConn.prepareStatement("INSERT INTO xml_replication " +
                                           "(server, last_checked, replicate) " +
                                           "VALUES ('" + server + "', to_date(" +
                                           "'01/01/00', 'MM/DD/YY'), '" +
                                           replicate + "')");
             pstmt.execute();
             pstmt.close();
             conn.commit();
             dbConn.commit();
             out.println("Server " + server + " added");
             response.setContentType("text/html");
             out.println("<html><body><table border=\"1\">");
             out.println("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
             out.println("<b>replicate</b></td></tr>");
             pstmt = conn.prepareStatement("SELECT * FROM xml_replication");
             pstmt = dbConn.prepareStatement("SELECT * FROM xml_replication");
             //increase dbconnection usage
             dbConn.increaseUsageCount(1);
             pstmt.execute();
             ResultSet rs = pstmt.getResultSet();
             boolean tablehasrows = rs.next();
-...
           // delete server from server list
           } else if ( subaction.equals("delete") ) {
             String server = ((String[])params.get("server"))[0];
             pstmt = conn.prepareStatement("DELETE FROM xml_replication " +
             pstmt = dbConn.prepareStatement("DELETE FROM xml_replication " +
                                           "WHERE server LIKE '" + server + "'");
             pstmt.execute();
             pstmt.close();
             conn.commit();
             dbConn.commit();
             out.println("Server " + server + " deleted");
             response.setContentType("text/html");
             out.println("<html><body><table border=\"1\">");
             out.println("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
             out.println("<b>replicate</b></td></tr>");
             pstmt = conn.prepareStatement("SELECT * FROM xml_replication");
             pstmt = dbConn.prepareStatement("SELECT * FROM xml_replication");
             //increase dbconnection usage
             dbConn.increaseUsageCount(1);
             pstmt.execute();
             ResultSet rs = pstmt.getResultSet();
             boolean tablehasrows = rs.next();
-...
             out.println("<html><body><table border=\"1\">");
             out.println("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
             out.println("<b>replicate</b></td></tr>");
             pstmt = conn.prepareStatement("SELECT * FROM xml_replication");
             pstmt = dbConn.prepareStatement("SELECT * FROM xml_replication");
             pstmt.execute();
             ResultSet rs = pstmt.getResultSet();
             boolean tablehasrows = rs.next();
-...
             out.println("</table></body></html>");
+          }
           pstmt.close();
           conn.close();
           //conn.close();
         } catch(Exception e) {
           System.out.println("Error in " +
-...
                              e.getMessage());
           e.printStackTrace(System.out);
+        }
         finally
+        {
           try
+          {
             pstmt.close();
           }//try
           catch (SQLException ee)
+          {
             MetaCatUtil.debugMessage("Error in " +
                     "MetacatReplication.handleServerControlRequest to close pstmt "
                      + ee.getMessage());
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
+      }
       // download certificate with the public key from certURL and
-...
         String dbaction = "UPDATE"; // the default action is UPDATE
         boolean override = false;
         int serverCode = 1;
         DBConnection dbConn = null;
         int serialNumber = -1;
         try {
           //if the url contains a dbaction then the default action is overridden
-...
           String homeServer=(String)docinfoHash.get("home_server");
           util.debugMessage("homeServer: "+homeServer,20);
           // write the document here
           Connection conn = util.openDBConnection();
           DocumentImpl.writeReplication(conn, new StringReader(xmldoc), null, null,
                   dbaction, docid, user, null, homeServer, false);
           //Connection conn = util.openDBConnection();
           dbConn=DBConnectionPool.
                   getDBConnection("MetacatReplication.handleForceReplicateRequest");
           serialNumber=dbConn.getCheckOutSerialNumber();
           DocumentImpl.writeReplication(dbConn,
                       new StringReader(xmldoc), null, null, dbaction, docid, user,
                       null, homeServer, false);
           conn.close();
           //conn.close();
           MetacatReplication.replLog("document " + docid + " added to DB with " +
                                      "action " + dbaction);
-...
                              "Request(): " + e.getMessage());
            e.printStackTrace();
+        }
         finally
+        {
           DBConnectionPool.returnDBConnection(dbConn, serialNumber);
         }//finally
+      }
       /**
-...
         boolean override = false;
         int serverCode = 1;
         String dbaction=null;
         Connection conn=null;
         //Connection conn=null;
         try
+        {
-...
           //the xml_documents
           if (dbaction.equals("delete"))
+          {
             conn = util.getConnection();
             DocumentImpl.delete(conn,docid,user,null);
             util.returnConnection(conn);
             //conn = util.getConnection();
             DocumentImpl.delete(docid,user,null);
             //util.returnConnection(conn);
+          }
           //To data file insert or update is same
           else if (dbaction.equals("insert")||dbaction.equals("update"))
-...
         } catch(Exception e)
+        {
           util.returnConnection(conn);
           //util.returnConnection(conn);
           util.debugMessage("ERROR in MetacatReplication.handleForceReplicate" +
                              "Request(): " + e.getMessage(), 30);
+        }
-...
       private void handleGetLockRequest(PrintWriter out, Hashtable params,
                                         HttpServletResponse response)
+      {
         Connection conn = null;
         //Connection conn = null;
         try
+        {
           conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleGetLockRequest");
           /*conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleGetLockRequest");*/
           String docid = ((String[])params.get("docid"))[0];
           String remoteRev = ((String[])params.get("updaterev"))[0];
           DocumentImpl requestDoc = new DocumentImpl(conn, docid);
           DocumentImpl requestDoc = new DocumentImpl(docid);
           MetacatReplication.replLog("lock request for " + docid);
           int localRevInt = requestDoc.getRev();
           int remoteRevInt = Integer.parseInt(remoteRev);
-...
             MetacatReplication.replLog("lock denied for " + docid +
                                        "reason: client has outdated file");
+          }
           conn.close();
           //conn.close();
+        }
         catch(Exception e)
+        {
-...
+      {
         String docid = ((String[])(params.get("docid")))[0];
         StringBuffer sb = new StringBuffer();
         Connection conn = null;
         //Connection conn = null;
         try
+        {
           conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleGetDocumentInfoRequest");
           DocumentImpl doc = new DocumentImpl(conn, docid);
           /*conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                   "handleGetDocumentInfoRequest");*/
           DocumentImpl doc = new DocumentImpl(docid);
           sb.append("<documentinfo><docid>").append(docid);
           sb.append("</docid><docname>").append(doc.getDocname());
           sb.append("</docname><doctype>").append(doc.getDoctype());
-...
           sb.append("</rev></documentinfo>");
           response.setContentType("text/xml");
           out.println(sb.toString());
           conn.close();
           //conn.close();
+        }
         catch (Exception e)
+        {
-...
       private void handleGetDocumentRequest(PrintWriter out, Hashtable params,
                                             HttpServletResponse response)
+      {
         Connection conn = null;
         //Connection dbConn = null;
         try
+        {
           //try to open a https stream to test if the request server's public key
-...
+          }
           String docid = ((String[])(params.get("docid")))[0];
           conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleGetDocumentRequest");
           DocumentImpl di = new DocumentImpl(conn, docid);
           /*conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleGetDocumentRequest");*/
           DocumentImpl di = new DocumentImpl(docid);
           response.setContentType("text/xml");
           out.print(di.toString());
           conn.close();
           //conn.close();
           MetacatReplication.replLog("document " + docid + " sent");
+        }
-...
       private void handleUpdateRequest(PrintWriter out, Hashtable params,
                                         HttpServletResponse response)
+      {
         Connection conn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         try
+        {
           //try to open a https stream to test if the request server's public key
-...
             delsql.append("and server_location = 1");
+          }
           conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleUpdateRequest");
           PreparedStatement pstmt = conn.prepareStatement(docsql.toString());
           /*conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleUpdateRequest");*/
           dbConn=DBConnectionPool.
                       getDBConnection("MetacatReplication.handleUpdateRequest");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pstmt = dbConn.prepareStatement(docsql.toString());
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
           boolean tablehasrows = rs.next();
-...
             }//while
           }//else
           pstmt = conn.prepareStatement(delsql.toString());
           pstmt = dbConn.prepareStatement(delsql.toString());
           //usage count should increas 1
           dbConn.increaseUsageCount(1);
           pstmt.execute();
           rs = pstmt.getResultSet();
           tablehasrows = rs.next();
-...
           doclist.append("</updates></replication>");
           MetaCatUtil.debugMessage("doclist: " + doclist.toString());
           pstmt.close();
           conn.close();
           //conn.close();
           response.setContentType("text/xml");
           out.println(doclist.toString());
-...
           response.setContentType("text/xml");
           out.println("<error>e.getMessage()</error>");
+        }
         finally
+        {
           try
+          {
             pstmt.close();
           }//try
           catch (SQLException ee)
+          {
             MetaCatUtil.debugMessage("Error in MetacatReplication." +
                     "handleUpdaterequest to close pstmt: "+ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
+      }
-...
                                                     HttpServletResponse response,
                                                     boolean printFlag)
+      {
         Connection conn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         try
+        {
           conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleGetCatalogRequest");
           pstmt = conn.prepareStatement("select entry_type, " +
           /*conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "handleGetCatalogRequest");*/
           dbConn=DBConnectionPool.
                      getDBConnection("MetacatReplication.handleGetCatalogRequest");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pstmt = dbConn.prepareStatement("select entry_type, " +
                                   "source_doctype, target_doctype, public_id, " +
                                   "system_id from xml_catalog");
           pstmt.execute();
-...
             tablehasrows = rs.next();
+          }
           sb.append("</xml_catalog>");
           conn.close();
           //conn.close();
           if(printFlag)
+          {
             response.setContentType("text/xml");
-...
+        }
         catch(Exception e)
+        {
           try
+          {
             pstmt.close();
             conn.close();
+          }
           catch(Exception ee)
           {}
           System.out.println("error in MetacatReplication.handleGetCatalogRequest:"+
                               e.getMessage());
           e.printStackTrace(System.out);
+        }
         finally
+        {
           try
+          {
             pstmt.close();
           }//try
           catch (SQLException ee)
+          {
             MetaCatUtil.
                debugMessage("Error in MetacatReplication.handleGetCatalogRequest: "
                +ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
         return null;
+      }
-...
       public static String getServer(int serverCode)
+      {
         //System.out.println("serverid: " + serverCode);
         Connection conn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         try
+        {
           conn = MetacatReplication.getDBConnection("MetacatReplication." +
                                                     "getServer");
           dbConn=DBConnectionPool.
                       getDBConnection("MetacatReplication.getServer");
           serialNumber=dbConn.getCheckOutSerialNumber();
           String sql = new String("select server from " +
                                   "xml_replication where serverid = " +
                                   serverCode);
           PreparedStatement pstmt = conn.prepareStatement(sql);
           pstmt = dbConn.prepareStatement(sql);
           //System.out.println("getserver sql: " + sql);
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
-...
             //System.out.println("server: " + rs.getString(1));
             return rs.getString(1);
+          }
           pstmt.close();
           conn.close();
           //conn.close();
+        }
         catch(Exception e)
+        {
           System.out.println("Error in MetacatReplication.getServer: " +
                               e.getMessage());
+        }
         finally
+        {
           try
+          {
             pstmt.close();
           }//try
           catch (SQLException ee)
+          {
             MetaCatUtil.debugMessage("Error in MetacactReplication.getserver: "+
                                         ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//fianlly
         }//finally
         return null;
           //return null if the server does not exist
+      }
-...
        */
       public static int getServerCode(String server) throws Exception
+      {
         Connection conn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         int serverCode = 0;
         try {
           conn = util.openDBConnection();
           pstmt = conn.prepareStatement("SELECT serverid FROM xml_replication " +
           //conn = util.openDBConnection();
           dbConn=DBConnectionPool.
                       getDBConnection("MetacatReplication.getServerCode");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pstmt = dbConn.prepareStatement("SELECT serverid FROM xml_replication " +
                                         "WHERE server LIKE '" + server + "'");
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
-...
           if ( tablehasrows ) {
             serverCode = rs.getInt(1);
             pstmt.close();
             conn.close();
             //conn.close();
             return serverCode;
+          }
-...
           throw e;
         } finally {
           try {
           try
+          {
             pstmt.close();
             conn.close();
           } catch(Exception ee) {}
+        }
             //conn.close();
            }//try
            catch(Exception ee)
+           {
              MetaCatUtil.debugMessage("Error in MetacatReplicatio.getServerCode: "
                                       +ee.getMessage(), 30);
            }//catch
            finally
+           {
              DBConnectionPool.returnDBConnection(dbConn, serialNumber);
            }//finally
         }//finally
         return serverCode;
+      }
-...
        */
       public static boolean replToServer(String server)
+      {
         Connection conn = null;
         DBConnection dbConn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         try
+        {
           conn = MetacatReplication.getDBConnection("MetacatReplication.replToServer");
           pstmt = conn.prepareStatement("select replicate from " +
           dbConn=DBConnectionPool.
                       getDBConnection("MetacatReplication.repltoServer");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pstmt = dbConn.prepareStatement("select replicate from " +
                                         "xml_replication where server like '" +
                                          server + "'");
           pstmt.execute();
-...
             if(i == 1)
+            {
               pstmt.close();
               conn.close();
               //conn.close();
               return true;
+            }
             else
+            {
               pstmt.close();
               conn.close();
               //conn.close();
               return false;
+            }
+          }
-...
           try
+          {
             pstmt.close();
             conn.close();
+          }
             //conn.close();
           }//try
           catch(Exception ee)
           {}
+        }
+          {
             MetaCatUtil.debugMessage("Error in MetacatReplication.replToServer: "
                                       +ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
         return false;
         //the default if this server does not exist is to not replicate to it.
+      }
       /**
        * A method for redundantly trying to connect.  this method will attempt to
        * connect to the DB 3 times before failing.
        * @param methodname the methodname from which this method is called.
        */
       public static Connection getDBConnection(String methodname) throws Exception
+      {
         Connection conn = null;
         try
+        {
           try
           { //this connection is prone to error for some reason so we
             //try to connect it three times before quiting.
             conn = util.openDBConnection();
             return conn;
+          }
           catch(SQLException sqle)
+          {
             try
+            {
               conn = util.openDBConnection();
               return conn;
+            }
             catch(SQLException sqlee)
+            {
               try
+              {
                 conn = util.openDBConnection();
                 return conn;
+              }
               catch(SQLException sqleee)
+              {
                 System.out.println("error getting db connection in " +
                                    methodname +  ": " +
                                    sqleee.getMessage());
                 return conn;
+              }
+            }
+          }
+        }
         catch(Exception e)
+        {
           throw new java.lang.Exception("error in " + methodname + ": " +
                               e.getMessage());
+        }
+      }
+    }

       static final int WRITE = 2;
       static final int READ = 4;
       private Connection  conn = null;
       //private Connection  conn = null;
       private String  parserName = null;
       private MetaCatUtil util = new MetaCatUtil();
       /**
-...
               // Open a connection to the database
               MetaCatUtil   util = new MetaCatUtil();
               Connection dbconn = util.openDBConnection();
               //Connection dbconn = util.openDBConnection();
               double connTime = System.currentTimeMillis();
               // Execute the query
               DBQuery queryobj = new DBQuery(dbconn, util.getOption("saxparser"));
               DBQuery queryobj = new DBQuery(util.getOption("saxparser"));
               FileReader xml = new FileReader(new File(xmlfile));
               Hashtable nodelist = null;
               nodelist = queryobj.findDocuments(xml, null, null, useXMLIndex);
-...
        * @param parserName the fully qualified name of a Java class implementing
        *                   the org.xml.sax.XMLReader interface
        */
       public DBQuery( Connection conn, String parserName )
       public DBQuery(String parserName )
                       throws IOException,
                              SQLException,
                              ClassNotFoundException {
         this.conn = conn;
         //this.conn = conn;
         this.parserName = parserName;
+      }
-...
           String fieldname = null;
           String fielddata = null;
           String relation = null;
           Connection dbconn = null;
           Connection dbconn2 = null;
           //Connection dbconn = null;
           //Connection dbconn2 = null;
           int rev = 0;
           StringBuffer document = null;
           StringBuffer document = null;
           DBConnection dbconn = null;
           int serialNumber = -1;
           try {
             if (conn == null || conn.isClosed()) {
             /*if (conn == null || conn.isClosed()) {
               dbconn = util.openDBConnection();
             } else {
               dbconn = conn;
+            }
             }*/
             dbconn=DBConnectionPool.getDBConnection("DBQuery.findDocuments");
             serialNumber=dbconn.getCheckOutSerialNumber();
             // problem with ODBC driver multi-threading
          //   dbconn2 = util.openDBConnection(); // for use by AccessControlList
-...
             while (tableHasRows)
+            {
               docid = rs.getString(1).trim();
               if ( !hasPermission(dbconn, user, groups, docid) ) {
               if ( !hasPermission(user, groups, docid) ) {
                 // Advance to the next record in the cursor
                 tableHasRows = rs.next();
                 continue;
-...
                 PreparedStatement npstmt = dbconn.
                                            prepareStatement(btBuf.toString());
                 //should incease usage count
                 dbconn.increaseUsageCount(1);
                 npstmt.execute();
                 ResultSet btrs = npstmt.getResultSet();
                 boolean hasBtRows = btrs.next();
-...
                     // xmldoc = new DocumentImpl(dbconn, packageDocid);
                     //  thus use the following to get the doc info only
                     //  xmldoc = new DocumentImpl(dbconn);
                     xmldoc = new DocumentImpl(dbconn, packageDocid, false);
                     xmldoc = new DocumentImpl(packageDocid, false);
                     if (xmldoc == null) {
                       util.debugMessage("Document was null for: "+packageDocid, 50);
+                    }
-...
                 //pstmt.close();
                 pstmt = dbconn.prepareStatement(qspec.printExtendedSQL(
                                             doclist.toString()));
                 //increase dbconnection usage count
                 dbconn.increaseUsageCount(1);
                 pstmt.execute();
                 rs = pstmt.getResultSet();
                 tableHasRows = rs.next();
                 while(tableHasRows)
+                {
                   docid = rs.getString(1).trim();
                   if ( !hasPermission(dbconn, user, groups, docid) ) {
                   if ( !hasPermission(user, groups, docid) ) {
                     // Advance to the next record in the cursor
                     tableHasRows = rs.next();
                     continue;
-...
                                ee.getMessage());
             ee.printStackTrace(System.err);
+          }
           finally {
           finally
+          {
             try
+            {
               dbconn.close();
             //  dbconn2.close();
+            }
             catch(SQLException sqle)
               pstmt.close();
             }//try
             catch (SQLException sqlE)
+            {
               System.out.println("error closing conn in DBQuery.findDocuments");
+            }
+          }
               MetaCatUtil.debugMessage("Error in DBQuery.findDocuments: "
                                           +sqlE.getMessage(), 30);
             }//catch
             finally
+            {
               DBConnectionPool.returnDBConnection(dbconn, serialNumber);
             }//finally
           }//finally
         //System.out.println("docListResult: ");
         //System.out.println(docListResult.toString());
         return docListResult;
-...
        * in the order in which they appearred in the document.
        * @param nodename the name or path of the particular node.
        * @param docid the docid of the document you want the node from.
        * @param conn a database connection-this allows this method to be static
        */
       public static Object[] getNodeContent(String nodename, String docid,
                                             Connection conn)
       public static Object[] getNodeContent(String nodename, String docid)
+      {
         DBConnection dbconn = null;
         int serialNumber = -1;
         StringBuffer query = new StringBuffer();
         Vector result = new Vector();
         PreparedStatement pstmt = null;
-...
         query.append("' and docid like '").append(docid).append("')");
         try
+        {
           pstmt = conn.prepareStatement(query.toString());
           dbconn=DBConnectionPool.getDBConnection("DBQuery.getNodeContent");
             serialNumber=dbconn.getCheckOutSerialNumber();
           pstmt = dbconn.prepareStatement(query.toString());
           // Execute the SQL query using the JDBC connection
           pstmt.execute();
-...
+          {
             pstmt.close();
+          }
           catch(SQLException sqle) {}
           catch(SQLException sqle)
           {}
           finally
+          {
             DBConnectionPool.returnDBConnection(dbconn, serialNumber);
+          }
+        }
         return result.toArray();
+      }
-...
         * Check for "READ" permission on @docid for @user and/or @group
         * from DB connection
         */
       private boolean hasPermission ( Connection conn, String user,
       private boolean hasPermission (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();
         //return aclobj.hasPermission("READ", user, groups, docid);
         return AccessControlList.hasPermission("READ", user, groups, docid);
+      }
       /**
-...
         */
       private Vector getCurrentDocidListForDataPackage(String dataPackageDocid)
+      {
         DBConnection dbConn = null;
         int serialNumber = -1;
         Vector docIdList=new Vector();//return value
         PreparedStatement pStmt;
         PreparedStatement pStmt = null;
         ResultSet rs=null;
         String docIdInSubjectField=null;
         String docIdInObjectField=null;
-...
         String query="SELECT subject, object from xml_relation where docId = ?";
         try
+        {
           pStmt=conn.prepareStatement(query);
           dbConn=DBConnectionPool.
                       getDBConnection("DBQuery.getCurrentDocidListForDataPackage");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pStmt=dbConn.prepareStatement(query);
           //bind the value to query
           pStmt.setString(1, dataPackageDocid);
-...
           util.debugMessage("Error in getDocidListForDataPackage: "
                                 +e.getMessage(), 30);
         }//catch
         finally
+        {
           try
+          {
             pStmt.close();
           }//try
           catch (SQLException ee)
+          {
             util.debugMessage("Error in getDocidListForDataPackage: "
                                 +ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//fianlly
         }//finally
         return docIdList;
       }//getCurrentDocidListForDataPackadge()
-...
         Vector docIdList=new Vector();//return value
         Vector tripleList=null;
         String xml=null;
         Connection dbConn=null;
           //initial a documentImpl object
           DocumentImpl packageDocument =
                       new DocumentImpl(dataPackageDocid);
           //transfer to documentImpl object to string
           xml=packageDocument.toString();
         if (conn == null || conn.isClosed())
+        {
           dbConn = util.openDBConnection();
+        }
         else
+        {
           dbConn=conn;
+        }
         //initial a documentImpl object
         DocumentImpl packageDocument = new DocumentImpl(dbConn, dataPackageDocid);
         //transfer to documentImpl object to string
         xml=packageDocument.toString();
         //create a tripcollection object
         TripleCollection tripleForPackage = new
           //create a tripcollection object
           TripleCollection tripleForPackage = new
                                          TripleCollection(new StringReader(xml));
         //get the vetor of triples
         tripleList=tripleForPackage.getCollection();
           //get the vetor of triples
           tripleList=tripleForPackage.getCollection();
         for (int i= 0; i<tripleList.size(); i++)
+        {
           //put subject docid  into docIdlist without duplicate
           if (!docIdList.contains(((Triple)tripleList.elementAt(i)).getSubject()))
           for (int i= 0; i<tripleList.size(); i++)
+          {
             //put subject docid  into docIdlist
              docIdList.add(((Triple)tripleList.get(i)).getSubject());
+          }
           //put object docid into docIdlist without duplicate
           if (!docIdList.contains(((Triple)tripleList.elementAt(i)).getObject()))
+          {
              docIdList.add(((Triple)(tripleList.get(i))).getObject());
+          }
         }//for
             //put subject docid  into docIdlist without duplicate
             if (!docIdList.contains(((Triple)tripleList.elementAt(i)).getSubject()))
+            {
               //put subject docid  into docIdlist
               docIdList.add(((Triple)tripleList.get(i)).getSubject());
+            }
             //put object docid into docIdlist without duplicate
             if (!docIdList.contains(((Triple)tripleList.elementAt(i)).getObject()))
+            {
               docIdList.add(((Triple)(tripleList.get(i))).getObject());
+            }
           }//for
         return docIdList;
       }//getDocidListForPackageInXMLRevisions()
-...
       private boolean isDataPackageId(String docId)
+      {
         boolean result=false;
         PreparedStatement pStmt;
         PreparedStatement pStmt = null;
         ResultSet rs=null;
         String query="SELECT docId from xml_relation where docId = ?";
         DBConnection dbConn = null;
         int serialNumber = -1;
         try
+        {
           pStmt=conn.prepareStatement(query);
           dbConn=DBConnectionPool.
                       getDBConnection("DBQuery.isDataPackageId");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pStmt=dbConn.prepareStatement(query);
           //bind the value to query
           pStmt.setString(1, docId);
           //execute the query
-...
         }//try
         catch (SQLException e)
+        {
           util.debugMessage("Error in getDocidListForDataPackadge: "
           util.debugMessage("Error in isDataPackageId: "
                                 +e.getMessage(), 30);
+        }
         finally
+        {
           try
+          {
             pStmt.close();
           }//try
           catch (SQLException ee)
+          {
             MetaCatUtil.debugMessage("Error in isDataPackageId: "
                                                             + ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
         return result;
       }//isDataPackageId()
-...
        * @param user, the name of user
        * @param groups, the user's group
        */
        private boolean hasPermissionToExportPackage(Connection conn, String docId,
        private boolean hasPermissionToExportPackage(String docId,
                                             String user, String[] groups)
                        throws Exception
+       {
          DocumentImpl doc=new DocumentImpl(conn,docId);
          return doc.hasReadPermission(conn, user, groups,docId);
          //DocumentImpl doc=new DocumentImpl(conn,docId);
          return DocumentImpl.hasReadPermission(user, groups,docId);
+       }
       /**
-...
       private int getCurrentRevFromXMLDoumentsTable(String docId)
+      {
         int rev=-5;
         PreparedStatement pStmt;
         PreparedStatement pStmt = null;
         ResultSet rs=null;
         String query="SELECT rev from xml_documents where docId = ?";
         DBConnection dbConn=null;
         int serialNumber = -1;
         try
+        {
           pStmt=conn.prepareStatement(query);
           dbConn=DBConnectionPool.
                       getDBConnection("DBQuery.getCurrentRevFromXMLDocumentsTable");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pStmt=dbConn.prepareStatement(query);
           //bind the value to query
           pStmt.setString(1, docId);
           //execute the query
-...
         }//try
         catch (SQLException e)
+        {
           util.debugMessage("Error in getDocidListForDataPackadge: "
           util.debugMessage("Error in getCurrentRevFromXMLDoumentsTable: "
                                 +e.getMessage(), 30);
+        }
         }//catch
         finally
+        {
           try
+          {
             pStmt.close();
           }//try
           catch (SQLException ee)
+          {
             MetaCatUtil.debugMessage("Error in getCurrentRevFromXMLDoumentsTable: "
                                       +ee.getMessage(), 30);
           }//catch
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
           }//finally
         }//finally
         return rev;
       }//getCurrentRevFromXMLDoumentsTable
-...
       private Vector getCurrentAllDocumentImpl( Vector docIdList)
                                   throws McdbException,Exception

... 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