/ - Diff - Metacat - Ecoinformatics Redmine

        */
       public static String getServer(int serverCode)
+      {
         //System.out.println("serverid: " + serverCode);
         try
+        {
           Connection conn = util.openDBConnection();
           PreparedStatement pstmt = conn.prepareStatement("select server from " +
           String sql = new String("select server from " +
                                   "xml_replication where serverid = " +
                                   serverCode);
           PreparedStatement pstmt = conn.prepareStatement(sql);
           //System.out.println("getserver sql: " + sql);
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
           boolean tablehasrows = rs.next();
           if(tablehasrows)
+          {
             conn.close();
             //System.out.println("server: " + rs.getString(1));
             return rs.getString(1);
+          }
           conn.close();
-...
         return null;
           //return null if the server does not exist
+      }
       /**
        * Returns a server code given a server name
        * @param server the name of the server
        * @return integer > 0 representing the code of the server, 0 if the server
        *  does not exist.
        */
       public static int getServerCode(String server) throws Exception
+      {
         try
+        {
           Connection conn = util.openDBConnection();
           PreparedStatement pstmt = conn.prepareStatement("select serverid from " +
                                              "xml_replication where server " +
                                              "like '" + server + "'");
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
           boolean tablehasrows = rs.next();
           int serverCode = 0;
           if(tablehasrows)
+          {
              return rs.getInt(1);
+          }
           else
+          {
             return 0;
+          }
+        }
         catch(Exception e)
+        {
           throw e;
+        }
+      }
       /**
        * This method returns the content of a url
        * @param u the url to return the content from
        * @return a string representing the content of the url
        * @throws java.io.IOException
        */
       public static String getURLContent(URL u) throws java.io.IOException
+      {
         //System.out.println("url: " + u.toString());
         char istreamChar;
         int istreamInt;
         InputStreamReader istream = new InputStreamReader(u.openStream());
         StringBuffer serverResponse = new StringBuffer();
         while((istreamInt = istream.read()) != -1)
+        {
           istreamChar = (char)istreamInt;
           serverResponse.append(istreamChar);
+        }
         return serverResponse.toString();
+      }
+    }

                                   String action, String docid, String user,
                                   String group, int serverCode )
                     throws Exception {
     System.out.println("action: " + action + " servercode: " +
                         serverCode);
         System.out.println("action: " + action + " servercode: " +
                             serverCode);
         if(serverCode != 1 && action.equals("UPDATE"))
         { //if this document being written is not a resident of this server then
           //we need to try to get a lock from it's resident server.  If the
-...
           update = update.replace(' ', '+');
           URL u = new URL("http://" + server + "?action=getlock&updatedate=" +
                           update + "&docid=" + docid);
           //System.out.println("url: " + u.toString());
           InputStreamReader istream = new InputStreamReader(u.openStream());
           StringBuffer serverResponse = new StringBuffer();
           while((istreamInt = istream.read()) != -1)
+          {
             istreamChar = (char)istreamInt;
             serverResponse.append(istreamChar);
+          }
           String serverResStr = serverResponse.toString();
           String serverResStr = MetacatReplication.getURLContent(u);
           System.out.println("serverResStr: " + serverResStr);
           String openingtag = serverResStr.substring(0, serverResStr.indexOf(">")+1);
           //System.out.println("openingtag: " + openingtag);

             update = update.replace(' ', '+');
             u = new URL("http://" + server + "?action=update&date=" + update);
             istream = new InputStreamReader(u.openStream());
             serverResponse = new StringBuffer();
             while((istreamInt = istream.read()) != -1)
+            {
               istreamChar = (char)istreamInt;
               serverResponse.append(istreamChar);
+            }
             responses.add(serverResponse.toString()); //list of updates
             responses.add(MetacatReplication.getURLContent(u)); //list of updates
+          }
           //initialize the parser
-...
               //send a message to the server requesting each document
               URL getDocURL = new URL("http://" + docServer +
                                       "?action=read&docid="+ docid);
               InputStreamReader getDocIstream = new InputStreamReader(
                                                     getDocURL.openStream());
               //the following while loop should not be needed.  see the note
               //below before the DocumentImpl.write() call.
               serverResponse = new StringBuffer();
               while((istreamInt = getDocIstream.read()) != -1)
+              {
                 istreamChar = (char)istreamInt;
                 serverResponse.append(istreamChar);
+              }
               String srvrResponseStr = MetacatReplication.getURLContent(getDocURL);
               //System.out.println("<<<<<<document>>>>>");
               //System.out.println(serverResponse.toString());
               //System.out.println("<<<<<<end document>>>>>");
               pstmt = conn.prepareStatement("select serverid from " +
                                              "xml_replication where server " +
                                              "like '" + docServer + "'");
               pstmt.execute();
               ResultSet rs = pstmt.getResultSet();
               boolean tablehasrows = rs.next();
               int serverCode = 0;
               if(tablehasrows)
+              {
                 serverCode = rs.getInt(1);
                 //System.out.println("servercode: " + serverCode);
+              }
               else
+              {
                 System.out.println("error: server not registered");
+              }
               int serverCode = MetacatReplication.getServerCode(docServer);
               if(serverCode != 0)
+              {
                 //update the document into the DB
                 String action = getAction(docid);
                 //System.out.println("action: " + action + " docid: " + docid);
                 //note that getDocIstream is commented out below.  This should
                 //work as a param to this method but it doesn'.  I don't know why
                 //but putting a string reader there works but not an
                 //inputStreamReader.
                 DocInfoHandler dih = new DocInfoHandler();
                 XMLReader docinfoParser = initParser(dih);
                 URL docinfoUrl = new URL("http://" + docServer +
-...
                                                     docInfoBuffer.toString())));
                 Hashtable docinfoHash = dih.getDocInfo();
                 String newDocid = DocumentImpl.write(conn,
                                    new StringReader(serverResponse.toString())
                                    /*getDocIstream*/,
                                    new StringReader(srvrResponseStr),
                                    action,
                                    docid, (String)docinfoHash.get("user_owner"),
                                    (String)docinfoHash.get("user_owner"),

Project

General

Profile

Metacat

Revision 569

Added by berkley about 24 years ago