/ - Diff - Metacat - Ecoinformatics Redmine

         try
+        {
           Connection conn = util.openDBConnection();
           PreparedStatement pstmt;
           PreparedStatement pstmt = null;
           if(subaction.equals("add"))
+          {
             String replicate = ((String[])params.get("replicate"))[0];
-...
+            }
             out.println("</table></body></html>");
+          }
           pstmt.close();
           conn.close();
+        }
         catch(Exception e)
-...
           doclist.append("</updates></replication>");
           MetaCatUtil.debugMessage("doclist: " + doclist.toString());
           pstmt.close();
           conn.close();
           response.setContentType("text/xml");
           out.println(doclist.toString());
-...
                                                     HttpServletResponse response,
                                                     boolean printFlag)
+      {
         Connection conn = null;
         PreparedStatement pstmt = null;
         try
+        {
           Connection conn = util.openDBConnection();
           PreparedStatement pstmt = conn.prepareStatement("select entry_type, " +
           conn = util.openDBConnection();
           pstmt = conn.prepareStatement("select entry_type, " +
                                   "source_doctype, target_doctype, public_id, " +
                                   "system_id from xml_catalog");
           pstmt.execute();
-...
             response.setContentType("text/xml");
             out.println(sb.toString());
+          }
           pstmt.close();
           return sb.toString();
+        }
         catch(Exception e)
+        {
           try
+          {
             pstmt.close();
             conn.close();
+          }
           catch(Exception ee)
           {}
           System.out.println("error in handleGetCatalogRequest: " + e.getMessage());
           e.printStackTrace(System.out);
+        }
-...
             //System.out.println("server: " + rs.getString(1));
             return rs.getString(1);
+          }
           pstmt.close();
           conn.close();
+        }
         catch(Exception e)
-...
        */
       public static int getServerCode(String server) throws Exception
+      {
         Connection conn = null;
         PreparedStatement pstmt = null;
         try
+        {
           Connection conn = util.openDBConnection();
           PreparedStatement pstmt = conn.prepareStatement("select serverid from " +
           conn = util.openDBConnection();
           pstmt = conn.prepareStatement("select serverid from " +
                                              "xml_replication where server " +
                                              "like '" + server + "'");
           pstmt.execute();
-...
           boolean tablehasrows = rs.next();
           int serverCode = 0;
           if(tablehasrows)
+          {
              return rs.getInt(1);
+          {
             int ret = rs.getInt(1);
             pstmt.close();
             conn.close();
             return ret;
+          }
           else
+          {
             pstmt.close();
             conn.close();
             return 0;
+          }
+        }
-...
+        {
           throw e;
+        }
         finally
+        {
            try
+           {
              pstmt.close();
              conn.close();
+           }
            catch(Exception ee) {}
+        }
+      }
       /**
-...
        */
       public static boolean replToServer(String server)
+      {
         Connection conn = null;
         PreparedStatement pstmt = null;
         try
+        {
           Connection conn = util.openDBConnection();
           PreparedStatement pstmt = conn.prepareStatement("select replicate from " +
                                     "xml_replication where server like '" +
                                     server + "'");
           conn = util.openDBConnection();
           pstmt = conn.prepareStatement("select replicate from " +
                                         "xml_replication where server like '" +
                                          server + "'");
           pstmt.execute();
           ResultSet rs = pstmt.getResultSet();
           boolean tablehasrows = rs.next();
-...
             int i = rs.getInt(1);
             if(i == 1)
+            {
               pstmt.close();
               conn.close();
               return true;
+            }
             else
+            {
               pstmt.close();
               conn.close();
               return false;
+            }
+          }
-...
+        {
           System.out.println("error in replToServer: " + e.getMessage());
+        }
         finally
+        {
           try
+          {
             pstmt.close();
             conn.close();
+          }
           catch(Exception ee)
           {}
+        }
         return false;
         //the default if this server does not exist is to not replicate to it.
+      }

+      {
         //System.out.println("in finddocuments");
           Hashtable   docListResult = new Hashtable();
           PreparedStatement pstmt;
           PreparedStatement pstmt = null;
           String docid = null;
           String docname = null;
           String doctype = null;
-...
           String fieldname = null;
           String fielddata = null;
           String relation = null;
           Connection dbconn = null;
           int rev = 0;
           StringBuffer document = null;
           Vector returndocVec = new Vector();
-...
+          }
           try {
             dbconn = util.openDBConnection();
             // Get the XML query and covert it into a SQL statment
             QuerySpecification qspec = new QuerySpecification(xmlquery,
                                        parserName,
                                        util.getOption("accNumSeparator"));
            // System.out.println(qspec.printSQL());
             pstmt = conn.prepareStatement( qspec.printSQL() );
             pstmt = dbconn.prepareStatement( qspec.printSQL() );
             // Execute the SQL query using the JDBC connection
             pstmt.execute();
             ResultSet rs = pstmt.getResultSet();
             boolean tableHasRows = rs.next();
             while (tableHasRows) {
             while (tableHasRows)
+            {
               docid = rs.getString(1);
               if ( !hasPermission(conn, user, group, docid) ) {
               if ( !hasPermission(dbconn, user, group, docid) ) {
                 // Advance to the next record in the cursor
                 tableHasRows = rs.next();
                 continue;
-...
               createDate = rs.getString(5);
               updateDate = rs.getString(6);
               rev = rs.getInt(7);
               //System.out.println("vec.size = " + returndocVec.size());
               if(returndocVec.size() != 0 && !returndocVec.contains(doctype))
               { //there are returndocs to match (backtracking can now be performed).
-...
                 //btBuf.append("?docid=").append(docid).append("'");
                 btBuf.append("%docid=").append(docid).append("'");
                 //System.out.println("sql: " + btBuf.toString());
                 pstmt = conn.prepareStatement(btBuf.toString());
                 pstmt = dbconn.prepareStatement(btBuf.toString());
                 pstmt.execute();
                 ResultSet btrs = pstmt.getResultSet();
                 boolean hasBtRows = btrs.next();
-...
                   MetacatURL objURL = new MetacatURL(btrs.getString(1));
                   try
+                  {
                     xmldoc = new DocumentImpl(conn, objURL.getParam(0)[1]);
                     xmldoc = new DocumentImpl(dbconn, objURL.getParam(0)[1]);
+                  }
                   catch(Exception e)
+                  {
-...
               // Advance to the next record in the cursor
               tableHasRows = rs.next();
               System.out.println("next1");
+            }
             System.out.println("rs1.close");
             rs.close();
             if(qspec.containsExtendedSQL())
+            {
-...
                 doclist.append("',");
+              }
               doclist.deleteCharAt(doclist.length()-1); //remove the last comma
               pstmt = conn.prepareStatement(qspec.printExtendedSQL(
               pstmt.close();
               pstmt = dbconn.prepareStatement(qspec.printExtendedSQL(
                                             doclist.toString()));
               pstmt.execute();
               rs = pstmt.getResultSet();
-...
               while(tableHasRows)
+              {
                 docid = rs.getString(1);
                 if ( !hasPermission(conn, user, group, docid) ) {continue;}
                 if ( !hasPermission(dbconn, user, group, docid) ) {continue;}
                 fieldname = rs.getString(2);
                 fielddata = rs.getString(3);
-...
                 document.append("</param>");
                 tableHasRows = rs.next();
                 System.out.println("next2");
                 if(docListResult.containsKey(docid))
+                {
                   String removedelement = (String)docListResult.remove(docid);
-...
                   docListResult.put(docid, document.toString());
+                }
+              }
               System.out.println("rs2.close");
               rs.close();
+            }
             //this loop adds the relation data to the resultdoc
-...
               String docidkey = (String)docidkeys.nextElement();
               //System.out.println("relationsql: " + qspec.printRelationSQL(
               //                                           connstring + docidkey));
               pstmt = conn.prepareStatement(
               pstmt.close();
               pstmt = dbconn.prepareStatement(
                       qspec.printRelationSQL(connstring + docidkey));
               pstmt.execute();
               rs = pstmt.getResultSet();
-...
+                  }
+                }
                 tableHasRows = rs.next();
                 System.out.println("next3");
+              }
               rs.close();
               System.out.println("rs3.close");
               System.out.println("pstmt.close()");
               pstmt.close();
+            }
             pstmt.close();
           } catch (SQLException e) {
             System.err.println("Error getting id: " + e.getMessage());
             System.err.println("SQL Error in DBQuery.findDocuments: " +
                                e.getMessage());
           } catch (IOException ioe) {
             System.err.println("Error printing qspec:");
             System.err.println(ioe.getMessage());
           } catch (Exception ee) {
             System.out.println("error in DBQuery.findDocuments: " +
                                ee.getMessage());
+          }
           finally {
             try
+            {
               dbconn.close();
+            }
             catch(SQLException sqle)
+            {
               System.out.println("error closing conn in DBQuery.findDocuments");
+            }
+          }
         //System.out.println("docListResult: ");
         //System.out.println(docListResult.toString());
         return docListResult;
-...
+      {
         StringBuffer query = new StringBuffer();
         Vector result = new Vector();
         PreparedStatement pstmt;
         PreparedStatement pstmt = null;
         query.append("select nodedata from xml_nodes where parentnodeid in ");
         query.append("(select nodeid from xml_index where path like '");
         query.append(nodename);
-...
         catch (SQLException e)
+        {
           System.err.println("Error getting id: " + e.getMessage());
+        }
         } finally {
           try
+          {
             pstmt.close();
+          }
           catch(SQLException sqle) {}
+        }
         return result.toArray();
+      }

src/edu/ucsb/nceas/metacat/MetaCatServlet.java
1036	1036	}
1037	1037
1038	1038	fin.close();
	1039	pstmt.close();
1039	1040	conn.close();
1040	1041	}
1041	1042	catch(Exception e)

src/edu/ucsb/nceas/metacat/DataFileUploadInterface.java
136	136	Connection conn = util.openDBConnection();
137	137	PreparedStatement pstmt = conn.prepareStatement(sql.toString());
138	138	pstmt.execute();
	139	pstmt.close();
139	140	conn.close();
140	141	}
141	142	catch(Exception e)

         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");
-...
           parser = XMLReaderFactory.createXMLReader(parserName);
           // Turn on validation
           parser.setFeature("http://xml.org/sax/features/validation", true);
           parser.setFeature("http://xml.org/sax/features/validation", false);
           // Turn off Including all external parameter entities
           // (the external DTD subset also)
           // Doesn't work well, probably the feature name is not correct

         String update;
         ReplMessageHandler message = new ReplMessageHandler();
         Vector responses = new Vector();
         PreparedStatement pstmt;
         PreparedStatement pstmt = null;
         ResultSet rs;
         boolean tablehasrows;
         boolean flag=false;
-...
               sql.append(datestr).append("', 'YY-MM-DD HH24:MI:SS') where ");
               sql.append("server like '").append(server).append("'");
               //System.out.println("sql: " + sql.toString());
               pstmt.close();
               pstmt = conn.prepareStatement(sql.toString());
               pstmt.executeUpdate();
               //conn.commit();
-...
           System.out.println("error in update2: " + e.getMessage());
           e.printStackTrace(System.out);
+        }
         finally
+        {
           try
+          {
             pstmt.close();
+          }
           catch(Exception ee) {}
+        }
+      }
       /**
-...
                 pstmt.setString(4, (String)v.elementAt(3));
                 pstmt.setString(5, (String)v.elementAt(4));
                 pstmt.execute();
                 pstmt.close();
+              }
+            }
+          }
-...
           sb = new StringBuffer();
           sb.append("select docid from xml_documents where docid like '");
           sb.append(docid).append("'");
           pstmt.close();
           pstmt = conn.prepareStatement(sb.toString());
           pstmt.execute();
           rs = pstmt.getResultSet();
           tablehasrows = rs.next();
           pstmt.close();
           if(tablehasrows)
+          {
             xml_docs = true;
-...
           System.out.println("error in alreadyDeleted: " + e.getMessage());
           e.printStackTrace(System.out);
+        }
         finally
+        {
+        }
         return false;
+      }
-...
           if(rs.next())
+          {
             pstmt.close();
             conn.close();
             return "UPDATE";
+          }
           else
+          {
             pstmt.close();
             conn.close();
             return "INSERT";
+          }
-...
+            }
             tableHasRows = rs.next();
+          }
           pstmt.close();
+        }
         catch(Exception e)
+        {

src/edu/ucsb/nceas/metacat/RelationHandler.java
102	102	String object = rs.getString(3);
103	103
104	104	//compare r to each relation in xml_relation
	105	pstmt.close();
105	106	pstmt = conn.prepareStatement("select subject, subdoctype, " +
106	107	"relationship, object, objdoctype " +
107	108	"from xml_relation");

src/edu/ucsb/nceas/metacat/DocumentIdentifier.java
104	104	if(tablehasrows)
105	105	{
106	106	String retStr = rs.getString(1);
	107	pstmt.close();
107	108	conn.close();
108	109	return retStr;
109	110	}

       private void insertPermissions( String permType )
               throws SQLException
+      {
         PreparedStatement pstmt;
         PreparedStatement pstmt = null;
         try {
           pstmt = conn.prepareStatement(
-...
         } catch (SQLException e) {
           throw new
           SQLException("AccessControlList.insertPermissions(): " + e.getMessage());
         } finally {
           pstmt.close();
+        }
+      }

Project

General

Profile

Metacat

Revision 667

Added by berkley almost 24 years ago