[Cobricks-cvscommit] cobricks2/src/org/cobricks/core/db DBAccess.java DBAccessImpl.java

[Michael K. <ko...@us...>]

Update of /cvsroot/cobricks/cobricks2/src/org/cobricks/core/db
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv25347/db

Modified Files:
	DBAccess.java DBAccessImpl.java 
Log Message:


Index: DBAccessImpl.java
===================================================================
RCS file: /cvsroot/cobricks/cobricks2/src/org/cobricks/core/db/DBAccessImpl.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -d -r1.9 -r1.10
--- DBAccessImpl.java	5 Jul 2004 07:58:01 -0000	1.9
+++ DBAccessImpl.java	16 Jul 2004 08:18:56 -0000	1.10
@@ -576,6 +576,35 @@
 
     
     /**
+     * Delete rows from the given table.
+     */
+    public void sqlDelete(String tablename, String where) 
+    {
+        logger.debug("sqlDelete("+tablename+","+where+")");
+
+        StringBuffer sb = new StringBuffer("delete from ");
+        sb.append(tablename);
+        sb.append(" where ");
+        sb.append(where);
+
+        Connection conn = null;
+        PreparedStatement pstmt = null;
+        try {
+            conn = dataSource.getConnection();
+            pstmt = conn.prepareStatement(sb.toString());
+            pstmt.execute();
+            pstmt.close();
+        } catch(Exception e) {
+            logger.error(LogUtil.ex("Failed executing sql statement: "
+                                    +sb.toString(), e));
+        } finally {
+            try { pstmt.close(); } catch (Exception e) { }
+            try { conn.close(); } catch (Exception e) { }
+        }
+    }
+
+    
+    /**
      * Update a row in the given table.This method constructs an attribute 
      * name list and calls the sqlUpdate() function with the additional 
      * parameter.

Index: DBAccess.java
===================================================================
RCS file: /cvsroot/cobricks/cobricks2/src/org/cobricks/core/db/DBAccess.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -d -r1.6 -r1.7
--- DBAccess.java	5 Jul 2004 07:58:01 -0000	1.6
+++ DBAccess.java	16 Jul 2004 08:18:56 -0000	1.7
@@ -51,6 +51,7 @@
 
     public void sqlDelete(String tablename, int primaryKey);
     public void sqlDelete(String tablename, Map attrs);
+    public void sqlDelete(String tablename, String where);
 
     public void sqlUpdate(String tablename, List attrnames, Map attrs, 
 			  String where);