X-Git-Url: http://erislabs.net/gitweb/?a=blobdiff_plain;f=source%2Fmircoders%2Fstorage%2FDatabaseComment.java;h=8561eb451b8a091595a9fb7893a3dae809e5eb8f;hb=95c2e3a74f492f6f61d4dbe8bb47996f43af0627;hp=56f3e336d694a6cf1ca7fb9c5b2d766685bbdf60;hpb=8297c34c7a424107fd7d1980b6e8e5a3ae26494b;p=mir.git diff --git a/source/mircoders/storage/DatabaseComment.java b/source/mircoders/storage/DatabaseComment.java index 56f3e336..8561eb45 100755 --- a/source/mircoders/storage/DatabaseComment.java +++ b/source/mircoders/storage/DatabaseComment.java @@ -30,23 +30,15 @@ package mircoders.storage; -import java.sql.Connection; -import java.sql.SQLException; -import java.sql.Statement; - -import mir.log.LoggerWrapper; -import mir.storage.Database; -import mir.storage.StorageObject; -import mir.storage.StorageObjectFailure; +import java.sql.Connection; +import java.sql.SQLException; +import java.sql.Statement; -/** - * This class implements the access to the comment-table for the - * media table. - * - * - */ +import mir.log.LoggerWrapper; +import mir.storage.Database; +import mir.storage.DatabaseFailure; -public class DatabaseComment extends Database implements StorageObject{ +public class DatabaseComment extends Database { private static DatabaseComment instance; @@ -59,30 +51,28 @@ public class DatabaseComment extends Database implements StorageObject{ private DatabaseComment() { super(); - hasTimestamp = false; - theTable = "comment"; + mainTable = "comment"; logger = new LoggerWrapper("Database.Comment"); - this.theEntityClass = mircoders.entity.EntityComment.class; + entityClass = mircoders.entity.EntityComment.class; } - public boolean deleteByContentId(String id) throws StorageObjectFailure { + public boolean deleteByContentId(String id) throws DatabaseFailure { Statement stmt = null; Connection con = null; String sql; - int res = 0; - /** @todo comments and topics should be deleted */ - sql = "delete from " + theTable + " where to_media=" + id; + /** todo comments and topics should be deleted */ + sql = "delete from " + mainTable + " where to_media=" + id; logger.info("DELETE "+ sql); try { - con = getPooledCon(); + con = obtainConnection(); stmt = con.createStatement(); - res = stmt.executeUpdate(sql); + stmt.executeUpdate(sql); } catch (SQLException sqe) { - new StorageObjectFailure(sqe); + new DatabaseFailure(sqe); return false; } finally {