From 9688b6bf00ab1c66868609a86d1d2fce0aad2d7e Mon Sep 17 00:00:00 2001
From: Jesse Morgan <jesse@jesterpm.net>
Date: Mon, 18 Nov 2013 23:16:22 -0800
Subject: Adding a resource to delete an assessment.

---
 .../p4square/grow/backend/db/CassandraDatabase.java  | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

(limited to 'src/com/p4square/grow/backend/db')

diff --git a/src/com/p4square/grow/backend/db/CassandraDatabase.java b/src/com/p4square/grow/backend/db/CassandraDatabase.java
index e40c251..b8cb6df 100644
--- a/src/com/p4square/grow/backend/db/CassandraDatabase.java
+++ b/src/com/p4square/grow/backend/db/CassandraDatabase.java
@@ -16,6 +16,7 @@ import com.netflix.astyanax.ColumnMutation;
 import com.netflix.astyanax.model.Column;
 import com.netflix.astyanax.model.ColumnFamily;
 import com.netflix.astyanax.model.ColumnList;
+import com.netflix.astyanax.ColumnListMutation;
 import com.netflix.astyanax.MutationBatch;
 import com.netflix.astyanax.serializers.StringSerializer;
 import com.netflix.astyanax.thrift.ThriftFamilyFactory;
@@ -189,4 +190,23 @@ public class CassandraDatabase {
             throw new RuntimeException(e);
         }
     }
+
+    /**
+     * Remove a row
+     */
+    public void deleteRow(final String cfName, final String key) {
+        ColumnFamily<String, String> cf = new ColumnFamily(cfName,
+            StringSerializer.get(),
+            StringSerializer.get());
+
+        try {
+            MutationBatch batch = mKeyspace.prepareMutationBatch();
+            ColumnListMutation<String> cfm = batch.withRow(cf, key).delete();
+            batch.execute();
+
+        } catch (ConnectionException e) {
+            cLog.error("deleteRow failed due to Connection Exception", e);
+            throw new RuntimeException(e);
+        }
+    }
 }
-- 
cgit v1.2.3