Changeset 8738 for trunk/gsdl3/extensions/gsdl-as/src/org/greenstone/gsdlas/profiles/Subscription.java

Timestamp:

2004-12-06T11:44:03+13:00 (19 years ago)

Author:

schweer

Message:

user authentication works; user information and subscriptions/predicates are stored to thedatabase

File:

• trunk/gsdl3/extensions/gsdl-as/src/org/greenstone/gsdlas/profiles/Subscription.java (modified) (4 diffs)

trunk/gsdl3/extensions/gsdl-as/src/org/greenstone/gsdlas/profiles/Subscription.java

@@ -9 +9 @@
 package org.greenstone.gsdlas.profiles;
 
+import java.sql.*;
+import java.sql.Connection;
+import java.sql.Statement;
 import java.util.*;
 import java.util.Map;
 import java.util.TreeMap;
+
+import org.greenstone.gsdlas.database.DatabaseException;
+import org.greenstone.gsdlas.database.DatabaseManager;
 
 /**
@@ -21 +27 @@
 public class Subscription implements Comparable {
     private Map map;
+    
     private int id;
+    private String username;
+    private String name;
+    private String email;
+    private boolean rssNotification;
+    private boolean eventsSincePageNotification;
+    
     private int numOfNonEqualsPredicates;
     
-    private static int highestId = 0;
-
-    public Subscription(Map valueMap) throws ParseException {
+    public Subscription(Map valueMap) throws DatabaseException, SQLException {
         map = new TreeMap();
         for (Iterator iter = valueMap.keySet().iterator(); iter.hasNext();) {
             String key = (String) iter.next();
-            String value = (String) valueMap.get(key);
-            Predicate predicate = PredicateFactory.createPredicate(key, value); 
-            map.put(key, predicate);
+            Object value = valueMap.get(key);
+            
+            Predicate predicate = null;
+            if (value instanceof String) {
+                predicate = PredicateFactory.createPredicate(key, (String) value);  
+                map.put(key, predicate);
+            } else if (value instanceof List) {
+                List values = (List)value;
+                predicate = PredicateFactory.createPredicate(key, values);  
+                map.put(key, predicate);
+            } 
             
             if (predicate != null && !(predicate instanceof IdEqualsPredicate)) {
@@ -38 +57 @@
             }
         }
-        id = highestId++;
+        
+        System.out.println("finished creating predicates");
+        
+        username = (String) valueMap.get("username");
+        name = (String) valueMap.get("subscription_name");
+        email = (String) valueMap.get("email");
+        rssNotification = valueMap.containsKey("way") && ((List)valueMap.get("way")).contains("rss");
+        eventsSincePageNotification = valueMap.containsKey("way") && ((List)valueMap.get("way")).contains("page");
+        id = saveToDatabase(true);
+        
+        for (Iterator iter = getPredicates().iterator(); iter.hasNext();) {
+            Predicate predicate = (Predicate) iter.next();
+            if (predicate != null) {
+                predicate.addSubscription(id);
+            }
+        }
     }
     
@@ -95 +129 @@
         return new Integer(id).compareTo(new Integer(other.id));
     }
+    
+    private int saveToDatabase(boolean initial) throws DatabaseException, SQLException {
+        Connection conn = DatabaseManager.getInstance().getDatabaseConnection();
+        Statement statement = conn.createStatement();
+        String sqlString;
+        if (initial) {
+            sqlString = "INSERT INTO subscriptions (name, email, rss, page, user) " +
+                    "VALUES ('" + name + "','" + email + "'," + (rssNotification ? 1 : 0) +
+                    "," + (eventsSincePageNotification ? 1: 0)+ ", '" + username + "');";
+        } else {
+            sqlString = "UPDATE subscriptions SET name='" + name + "', email='" +
+                    email + "', rss=" + (rssNotification ? 1 : 0) + ",page=" + 
+                    (eventsSincePageNotification ? 1 : 0)+ "WHERE id=" + id + ";";
+            // cannot change user
+        }
+        System.out.println(sqlString);
+        statement.executeUpdate(sqlString);
+        
+        sqlString = "SELECT id FROM subscriptions WHERE name like '" + name + 
+                    "' AND email like '" + email + "' AND rss=" + (rssNotification ? 1 : 0) 
+                    + " AND page=" + (eventsSincePageNotification ? 1 : 0) + " AND user like '" +
+                    username + "';";
+        System.out.println(sqlString);
+        ResultSet result = statement.executeQuery(sqlString);
+        int id;
+        if (result.next()) {
+            id = result.getInt("id");
+        } else {
+            throw new DatabaseException("Couldn't save subscription");
+        }
+        
+        if (initial) {
+           for (Iterator iter = getPredicates().iterator(); iter.hasNext();) {
+               Predicate predicate = (Predicate) iter.next();
+               sqlString = "INSERT INTO subs_to_predicates (subscription, predicate) " +
+                    "VALUES (" + id + "," + predicate.getID() + ");";
+               statement.executeUpdate(sqlString);
+           }
+        }
+        return id;
+    }
 }