Changeset 9848 for branches/ant-install-branch

Timestamp:

2005-05-10T15:49:29+12:00 (19 years ago)

Author:

kjdon

Message:

indented the code properly, and closed off the statement

File:

• branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/notifier/NotifierManager.java (modified) (5 diffs)

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/notifier/NotifierManager.java

@@ -12 +12 @@
 public class NotifierManager {
 
-    public NotifierManager() {
-    }
+    public NotifierManager() {
+    }
+    
+    public void detectEvents(CollectionManager collManager) {
+    String notifyHost = collManager.getNotifyHost();
+    if (notifyHost == null)
+        return;
     
-    public void detectEvents(CollectionManager collManager) {
-        String notifyHost = collManager.getNotifyHost();
-        if (notifyHost == null)
-            return;
-        
-        System.out.println("detecting events");
-        
-        String collectionName = collManager.getCollectionName();
-        String host = "http://localhost:8080/soap/servlet/rpcrouter";
-        
-        String lastBuild = dateToSqlString(collManager.getBuildDate());
-        System.out.println("last build was " + lastBuild);
-        Statement statement = collManager.getDatabase().createStatement();
+    System.out.println("detecting events");
+    
+    String collectionName = collManager.getCollectionName();
+    String host = "http://localhost:8080/soap/servlet/rpcrouter";
+    
+    String lastBuild = dateToSqlString(collManager.getBuildDate());
+    System.out.println("last build was " + lastBuild);
+    Statement statement = collManager.getDatabase().createStatement();
         try {
             // detect all new documents. A document is new if and only if
             // AccessionDate >= CollectionLastRebuiltDate
-            ResultSet results = statement.executeQuery("SELECT DocID FROM document WHERE DocType != 'GSMETADATA' AND AccessionDate >= " + lastBuild);
-            notify(collectionName, host, notifyHost, results, collManager.getDatabase(), collManager.getBuildDate(), "new_document");
-            
-            // detect modified documents. A document is modified if and only if
-            // AccessionDate < CollectionLastRebuiltDate (ie, it is not new) and 
-            // IndexedDate >= CollectionLastRebuiltDate 
-            results = statement.executeQuery("SELECT DocID FROM document WHERE DocType != 'GSMETADATA' AND AccessionDate < " + lastBuild + " AND IndexedDate >= " + lastBuild);
-            notify(collectionName, host, notifyHost, results, collManager.getDatabase(), collManager.getBuildDate(), "document_modified");
-            
-            // TODO deleted docs?
+        ResultSet results = statement.executeQuery("SELECT DocID FROM document WHERE DocType != 'GSMETADATA' AND AccessionDate >= " + lastBuild);
+        notify(collectionName, host, notifyHost, results, collManager.getDatabase(), collManager.getBuildDate(), "new_document");
+        
+        // detect modified documents. A document is modified if and only if
+        // AccessionDate < CollectionLastRebuiltDate (ie, it is not new) and 
+        // IndexedDate >= CollectionLastRebuiltDate 
+        results = statement.executeQuery("SELECT DocID FROM document WHERE DocType != 'GSMETADATA' AND AccessionDate < " + lastBuild + " AND IndexedDate >= " + lastBuild);
+        notify(collectionName, host, notifyHost, results, collManager.getDatabase(), collManager.getBuildDate(), "document_modified");
+        
+        statement.close();
+        // TODO deleted docs?
         } catch (SQLException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
+        // TODO Auto-generated catch block
+        e.printStackTrace();
         }
-    }
-
+    }
+    
     /**
      * @param collName
@@ -58 +59 @@
      * @throws SQLException
      */
-    private void notify(String collName, String hostURL, String notifyHost, ResultSet results, GS3SQLConnection database, Date date, String eventType) {
-        try {
-            System.out.println("notifyHost is " + notifyHost);
-            URL url = new URL("http://" + notifyHost + "/alerting/service");
-            System.out.println("trying to send to " + url);
-            
-            while(results.next()) {
-                System.out.println(eventType + ": " + results.getString("DocID"));
+    private void notify(String collName, String hostURL, String notifyHost, ResultSet results, GS3SQLConnection database, Date date, String eventType) {
+    try {
+        System.out.println("notifyHost is " + notifyHost);
+        URL url = new URL("http://" + notifyHost + "/alerting/service");
+        System.out.println("trying to send to " + url);
+        
+        while(results.next()) {
+        System.out.println(eventType + ": " + results.getString("DocID"));
                 
                 String documentID = results.getString("DocID");
                 
-                try {
+        try {
                     HttpURLConnection conn = (HttpURLConnection) url.openConnection(); // TODO what about proxies?
                     conn.setUseCaches(false);
@@ -112 +113 @@
                     e1.printStackTrace();
                 }
-            }
-        } catch (SQLException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        } catch (MalformedURLException e) {
+        }
+    } catch (SQLException e) {
+        // TODO Auto-generated catch block
+        e.printStackTrace();
+    } catch (MalformedURLException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
-    }
+    }
 
     /**
@@ -134 +135 @@
         try {
             String sqlString = "SELECT mdvalues.value " +
-                    "FROM structure s JOIN divisions d ON (s.structureref = d.parentref) " +
-                    "                 JOIN divisionmetarefs USING (divisionref) " + 
-                    "                 JOIN metadata m USING (metaid) " +
-                    "                 JOIN namespaces USING (metadataref) " + 
-                    "                 JOIN mdvalues USING (namespaceref) " +
-                    "  WHERE mdvalues.label = 'Title' AND s.docid = '" + documentID + "'" + 
-                    "                                 AND s.structureType = 'Whole Document' " +
-                    "                                 AND d.parenttype = 'Structure' " + 
-                    "                                 AND m.docID = s.docid;";
+        "FROM structure s JOIN divisions d ON (s.structureref = d.parentref) " +
+        "                 JOIN divisionmetarefs USING (divisionref) " + 
+        "                 JOIN metadata m USING (metaid) " +
+        "                 JOIN namespaces USING (metadataref) " + 
+        "                 JOIN mdvalues USING (namespaceref) " +
+        "  WHERE mdvalues.label = 'Title' AND s.docid = '" + documentID + "'" + 
+        "                                 AND s.structureType = 'Whole Document' " +
+        "                                 AND d.parenttype = 'Structure' " + 
+        "                                 AND m.docID = s.docid;";
             results = statement.executeQuery(sqlString);
             if (results.next()) {
@@ -149 +150 @@
                 return title;
             }
+        statement.close();
         } catch (SQLException e) {
             e.printStackTrace();