cleanup / abuse system fix / prepping for a release

[mir.git] / source / mir / producer / EntityDeletingProducerNode.java

diff --git a/source/mir/producer/EntityDeletingProducerNode.java b/source/mir/producer/EntityDeletingProducerNode.java
index 055e182..ea9fb42 100755 (executable)
--- a/source/mir/producer/EntityDeletingProducerNode.java
+++ b/source/mir/producer/EntityDeletingProducerNode.java
@@ -30,15 +30,12 @@
 package mir.producer;
 
 import java.util.Map;
-import java.util.Vector;
 
 import mir.entity.adapter.EntityAdapterModel;
-import mir.entity.adapter.EntityIteratorAdapter;
 import mir.log.LoggerWrapper;
-import mir.util.CachingRewindableIterator;
 import mir.util.ParameterExpander;
 
-public class EntityDeletingProducerNode implements ProducerNode {
+public class EntityDeletingProducerNode extends AbstractProducerNode {
   private String whereClause;
   private EntityAdapterModel model;
   private String definition;
@@ -54,11 +51,11 @@ public class EntityDeletingProducerNode implements ProducerNode {
     try {
       EntityAdapterModel.Mapping mapping = model.getMappingForName(definition);
 
-      mapping.getStorage().deleteByWhereClause(ParameterExpander.expandExpression( aValueMap, whereClause ));
+      mapping.getDatabase().deleteByWhereClause(ParameterExpander.expandExpression( aValueMap, whereClause ));
     }
     catch (Throwable t) {
       aLogger.error("Error while deleting entities: " + t.toString());
     }
-  };
+  }
 
 }