Changeset 8867 for trunk/greenstone3-extensions/gsdl-as/src/org/greenstone/gsdlas/profiles/Predicate.java

Timestamp:

2004-12-21T12:11:00+13:00 (19 years ago)

Author:

schweer

Message:

fixed BTS 12: restore subscriptions/predicates from database

File:

• trunk/greenstone3-extensions/gsdl-as/src/org/greenstone/gsdlas/profiles/Predicate.java (modified) (3 diffs)

trunk/greenstone3-extensions/gsdl-as/src/org/greenstone/gsdlas/profiles/Predicate.java

@@ -119 +119 @@
         String query = "SELECT id FROM predicates " +
                 "WHERE field = '" + field + 
-                "' AND value = '" + value + "';";
+                "' AND value = '" + value + 
+                "' AND type = '" + this.getClass().getName() + "';";
         Statement statement = DatabaseManager.getInstance().getDatabaseConnection().createStatement();
         System.out.println(query);
         ResultSet result = statement.executeQuery(query);
         if (result.next()) { // predicate already exists in database
-            System.out.println("predicate " + id + " already exists");
-            return result.getInt("id");
+            int id = result.getInt("id"); 
+            System.out.println("predicate already exists with id " + id);
+            return id;
         }
         // predicate has been newly created
-        String insert = "INSERT INTO predicates (field, value) " +
-        "VALUES ('" + field + "', '" + value + "');";
+        String insert = "INSERT INTO predicates (field, type, value) " +
+        "VALUES ('" + field + "', '" + this.getClass().getName() + "', '" + value + "');";
         System.out.println(insert);
         statement.execute(insert);
@@ -141 +143 @@
 
     /**
-     * @return
-     */
-    public List getValueList() {
-        throw new UnsupportedOperationException("you can only call this method for multi-valued predicates");
-    }
-
-    /**
      * @param key
      * @return
@@ -154 +149 @@
         return ArrayHelper.contains(singleValueFields, key) || ArrayHelper.contains(multiValueFields, key);
     }
+
+    /**
+     * @param subID
+     * @throws DatabaseException
+     * @throws SQLException
+     */
+    public void removeSubscription(Integer subID) throws SQLException, DatabaseException {
+        subscriptions.remove(subID);
+
+        Statement statement = DatabaseManager.getInstance().getDatabaseConnection().createStatement();
+        String sqlString = "DELETE FROM subs_to_predicates " +
+            "WHERE subscription = " + subID + 
+            " AND predicate = " + id;
+        statement.executeUpdate(sqlString);
+        
+        if (subscriptions.isEmpty()) {
+            PredicateFactory.deletePredicate(this);
+            sqlString = "DELETE FROM predicates WHERE id = " + id;
+            statement.executeUpdate(sqlString);
+        }
+    }
     
 }