X-Git-Url: http://erislabs.net/gitweb/?a=blobdiff_plain;f=source%2Fmircoders%2Fstorage%2FDatabaseContentToTopics.java;h=f1d4633ba035b91a154825c8937e1a12a0511065;hb=95c2e3a74f492f6f61d4dbe8bb47996f43af0627;hp=7201f94765258430e63908232689c7d56f0fa7df;hpb=991a8eeb9f18ef922985d79bf2c4ac300fbee4a3;p=mir.git

diff --git a/source/mircoders/storage/DatabaseContentToTopics.java b/source/mircoders/storage/DatabaseContentToTopics.java
index 7201f947..f1d4633b 100755
--- a/source/mircoders/storage/DatabaseContentToTopics.java
+++ b/source/mircoders/storage/DatabaseContentToTopics.java
@@ -1,154 +1,237 @@
-package mircoders.storage;
-
-import java.lang.*;
-import java.sql.*;
-import java.io.*;
-import java.util.*;
+/*
+ * Copyright (C) 2001, 2002 The Mir-coders group
+ *
+ * This file is part of Mir.
+ *
+ * Mir is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * Mir is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Mir; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ *
+ * In addition, as a special exception, The Mir-coders gives permission to link
+ * the code of this program with  any library licensed under the Apache Software License,
+ * The Sun (tm) Java Advanced Imaging library (JAI), The Sun JIMI library
+ * (or with modified versions of the above that use the same license as the above),
+ * and distribute linked combinations including the two.  You must obey the
+ * GNU General Public License in all respects for all of the code used other than
+ * the above mentioned libraries.  If you modify this file, you may extend this
+ * exception to your version of the file, but you are not obligated to do so.
+ * If you do not wish to do so, delete this exception statement from your version.
+ */
 
-import freemarker.template.*;
+package mircoders.storage;
 
-import mir.storage.*;
-import mir.entity.*;
-import mir.misc.*;
+import mir.entity.EntityList;
+import mir.log.LoggerWrapper;
+import mir.storage.Database;
+import mir.storage.DatabaseFailure;
+import mircoders.entity.EntityContent;
+import mircoders.entity.EntityTopics;
 
-import mircoders.entity.*;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Iterator;
+import java.util.List;
 
 /**
- * <b>Diese Klasse implementiert die Datenbankverbindung zur MetaObjekt-Tabelle
- *
+ * <b>This class implements the 1-n-relation between
+ * content and topic
  *
  */
 
-public class DatabaseContentToTopics extends Database implements StorageObject{
+public class DatabaseContentToTopics extends Database {
 
   private static DatabaseContentToTopics instance;
 
-  public static DatabaseContentToTopics getInstance()
-    throws StorageObjectException {
+  public synchronized static DatabaseContentToTopics getInstance() {
     if (instance == null) {
       instance = new DatabaseContentToTopics();
-      instance.myselfDatabase = instance;
     }
     return instance;
   }
 
-  private DatabaseContentToTopics()
-    throws StorageObjectException {
-
+  private DatabaseContentToTopics() {
     super();
-    this.hasTimestamp = false;
-    this.theTable="content_x_topic";
-  }
 
+    logger = new LoggerWrapper("Database.ContentToTopics");
+    mainTable="content_x_topic";
+    entityClass = mir.entity.GenericEntity.class;
+  }
 
+  /**
+   * This class return an EntityList of Topics
+   */
   public EntityList getTopics(EntityContent content) {
     EntityList returnList=null;
     if (content != null) {
-      // get all to_topic from content_x_topic
-      String id = content.getId();
-      String subselect = "id in (select topic_id from " + theTable + " where content_id=" + id+")";
 
+      String id = content.getId();
       try {
-        returnList = DatabaseTopics.getInstance().selectByWhereClause(subselect,-1);
-      } catch (Exception e) {
-        theLog.printDebugInfo("-- get topics failed " + e.toString());
+        ArrayList extraTables = new ArrayList();
+        extraTables.add(mainTable+" cxt");
+        returnList = DatabaseTopics.getInstance()
+      	               .selectByWhereClauseWithExtraTables("t",extraTables,
+			                       "t.id=cxt.topic_id and  cxt.content_id="+id );
+      }
+      catch (Exception e) {
+        logger.error("-- get topics failed " + e.toString());
       }
     }
     return returnList;
   }
 
+  /**
+   * Returns a List of String-Objects from a content-id.
+   */
+  public List getTopicsOfContent(String contentId)
+    throws DatabaseFailure {
+    ArrayList returnList = new ArrayList();
 
-  public void setTopics(String contentId, String[] topicId) {
-    if (contentId == null){
-      return;
-    }
-    if (topicId==null || topicId[0]==null) {
-      return;
-    }
-    //first delete all row with content_id=contentId
-    String sql = "delete from "+ theTable +" where content_id=" + contentId;
-
-    Connection con=null;Statement stmt=null;
-    try {
-      con = getPooledCon();
-      // should be a preparedStatement because is faster
-      stmt = con.createStatement();
-      ResultSet rs = executeSql(stmt,sql);
-    } catch (Exception e) {
-      theLog.printDebugInfo("-- set topics failed -- delete");
-    } finally {
-      freeConnection(con,stmt);
-    }
-
-    //now insert
-    //first delete all row with content_id=contentId
-    for (int i=0;i<topicId.length;i++) {
-      sql = "insert into "+ theTable +" (content_id,topic_id) values ("
-            + contentId + "," + topicId[i] + ")";
+    if (contentId != null) {
+      String sql = "select topic_id from " + mainTable + " where content_id=" + contentId;
+      Connection con=null;Statement stmt=null;
       try {
-        con = getPooledCon();
+        con = obtainConnection();
+
         // should be a preparedStatement because is faster
         stmt = con.createStatement();
         ResultSet rs = executeSql(stmt,sql);
-      } catch (Exception e) {
-        theLog.printDebugInfo("-- set topics failed -- insert laenge topicId" + topicId.length);
-      } finally {
+        if(rs!=null){
+          while(rs.next()){
+            returnList.add(Integer.toString(rs.getInt("topic_id")));
+          }
+        }
+      }
+      catch (Exception e) {
+        logger.error("DatabaseContentToTopics.getTopicsOfContent: " + e.getMessage());
+      }
+      finally {
         freeConnection(con,stmt);
       }
     }
+    return returnList;
   }
 
+  private String getIdListExpression(List aList) {
+    String result = "";
 
-  public void setTopics(String contentId, String topicId) {
-    if (contentId == null && topicId == null) {
-      return;
+    Iterator i = aList.iterator();
+
+    while (i.hasNext()) {
+      result = result + i.next().toString();
+      if (i.hasNext())
+        result = result + ", ";
     }
-    //first delete all row with content_id=contentId
-    String sql = "delete from "+ theTable +" where content_id=" + contentId;
+    return result;
+  }
 
-    Connection con=null;Statement stmt=null;
-    try {
-      con = getPooledCon();
-      // should be a preparedStatement because is faster
-      stmt = con.createStatement();
-      int rs = executeUpdate(stmt,sql);
-    } catch (Exception e) {
-      theLog.printDebugInfo("-- set topics failed -- delete");
-    } finally {
-      freeConnection(con,stmt);
+  public void setTopics(String anArticleId, String [] aTopics) throws DatabaseFailure {
+    if (aTopics==null)
+      setTopics(anArticleId, (List) null);
+    else
+      setTopics(anArticleId, Arrays.asList(aTopics));
+  }
+
+  public void setTopics(String anArticleId, List aTopics) throws DatabaseFailure {
+    List newTopics = new ArrayList();
+    if (aTopics!=null) {
+      Iterator i = aTopics.iterator();
+
+      while (i.hasNext()) {
+        newTopics.add(new Integer(Integer.parseInt((String) i.next())));
+      }
     }
 
-    //now insert
-    //first delete all row with content_id=contentId
+    List currentTopics = getTopicsOfContent(anArticleId);
+    logger.debug("New topics = " + newTopics.toString());
+    logger.debug("Current topics = " + currentTopics.toString());
+    List topicsToDelete = new ArrayList(currentTopics);
+    topicsToDelete.removeAll(newTopics);
+    List topicsToAdd = new ArrayList(newTopics);
+    topicsToAdd.removeAll(currentTopics);
+    logger.debug("to delete = " + topicsToDelete.toString());
+    logger.debug("to add = " + topicsToAdd.toString());
 
-    sql = "insert into "+ theTable +" (content_id,topic_id) values ("
-          + contentId + "," + topicId + ")";
-    try {
-      con = getPooledCon();
-      // should be a preparedStatement because is faster
-      stmt = con.createStatement();
-      int rs = executeUpdate(stmt,sql);
-    } catch (Exception e) {
-      theLog.printDebugInfo("-- set topics failed -- insert");
-    } finally {
-      freeConnection(con,stmt);
+
+    if (!topicsToDelete.isEmpty()) {
+      String sql =
+          "delete from " + mainTable + " " +
+          "where content_id=" + anArticleId +
+          "        and topic_id in (" + getIdListExpression(topicsToDelete) + ")";
+
+      Connection connection=null;
+      Statement statement=null;
+      try {
+        connection = obtainConnection();
+        statement = connection.createStatement();
+        executeUpdate(statement, sql);
+      }
+      catch (Exception e) {
+        logger.error("-- deleting topics failed");
+      }
+      finally {
+        try {
+          freeConnection(connection, statement);
+        }
+        catch (Throwable t) {
+        }
+      }
+    }
+
+    Iterator i = topicsToAdd.iterator();
+    while (i.hasNext()) {
+      Integer topicId = (Integer) i.next();
+      String sql =
+          "insert into " + mainTable + " (content_id, topic_id) "+
+          "values (" + anArticleId + "," + topicId + ")";
+      Connection connection=null;
+      Statement statement=null;
+      try {
+        connection = obtainConnection();
+        // should be a preparedStatement because is faster
+        statement = connection.createStatement();
+        executeUpdate(statement, sql);
+      }
+      catch (Exception e) {
+        logger.error("-- adding topics failed");
+      }
+      finally {
+        try {
+          freeConnection(connection, statement);
+        }
+        catch (Throwable t) {
+        }
+      }
     }
   }
 
-  public void deleteByContentId(String contentId) {
+  public void deleteByContentId(String contentId)
+    throws DatabaseFailure {
     if (contentId == null) {
       //theLog.printDebugInfo("-- delete topics failed -- no content id");
       return;
     }
     //delete all row with content_id=contentId
-    String sql = "delete from "+ theTable +" where content_id=" + contentId;
+    String sql = "delete from "+ mainTable +" where content_id=" + contentId;
 
     Connection con=null;Statement stmt=null;
     try {
-      con = getPooledCon();
+      con = obtainConnection();
       // should be a preparedStatement because is faster
       stmt = con.createStatement();
-      ResultSet rs = executeSql(stmt,sql);
+      executeSql(stmt,sql);
     } catch (Exception e) {
       //theLog.printDebugInfo("-- delete topics failed  ");
     } finally {
@@ -156,58 +239,52 @@ public class DatabaseContentToTopics extends Database implements StorageObject{
     }
   }
 
-  public void deleteByTopicId(String topicId) {
+  public void deleteByTopicId(String topicId)
+    throws DatabaseFailure {
     if (topicId == null) {
       //theLog.printDebugInfo("-- delete topics failed -- no topic id");
       return;
     }
     //delete all row with content_id=contentId
-    String sql = "delete from "+ theTable +" where topic_id=" + topicId;
+    String sql = "delete from "+ mainTable +" where topic_id=" + topicId;
 
     Connection con=null;Statement stmt=null;
     try {
-      con = getPooledCon();
+      con = obtainConnection();
       // should be a preparedStatement because is faster
       stmt = con.createStatement();
-      ResultSet rs = executeSql(stmt,sql);
-    } catch (Exception e) {
-      theLog.printDebugInfo("-- delete topics failed ");
-    } finally {
+      executeSql(stmt,sql);
+    }
+    catch (Exception e) {
+      logger.error("-- delete topics failed ");
+    }
+    finally {
       freeConnection(con,stmt);
     }
   }
 
-
-  public EntityList getContent(EntityTopics topic) {
+/**
+ * Returns list of Content for a specific topic
+ * @param topic
+ * @return EntityList
+ * @throws DatabaseFailure
+ */
+  public EntityList getContent(EntityTopics topic)
+    throws DatabaseFailure {
     EntityList returnList=null;
     if (topic != null) {
       String id = topic.getId();
-      String select = "select content_id from " + theTable + " where topic_id=" + id;
-
-      // execute select statement
-      Connection con=null;Statement stmt=null;
       try {
-        con = getPooledCon();
-        // should be a preparedStatement because is faster
-        stmt = con.createStatement();
-        ResultSet rs = executeSql(stmt,select);
-        if (rs!=null) {
-          String topicSelect= "id IN (";
-          boolean first=true;
-          while (rs.next()) {
-            if (first==false) topicSelect+=",";
-            topicSelect += rs.getString(1);
-            first=false;
-          }
-          topicSelect+=")";
-          if (first==false)
-            returnList = DatabaseContent.getInstance().selectByWhereClause(topicSelect,-1);
-        }
+        ArrayList extraTables = new ArrayList();
+        extraTables.add(mainTable+" cxt");
+        returnList = DatabaseContent.getInstance()
+                      .selectByWhereClauseWithExtraTables("c",extraTables,
+                          "c.id=cxt.content_id and cxt.topic_id="+id );
+      }
+      catch (Exception e) {
+        logger.error("-- get content failed");
       }
-      catch (Exception e) {theLog.printDebugInfo("-- get contetn failed");}
-      finally { freeConnection(con,stmt);}
     }
     return returnList;
   }
-
 }