mass remove implemented

Author: nekufa

src/Mapper.php

@@ -106,9 +106,14 @@ public function getSchema()
         return $this->schema ?: $this->schema = new Schema($this);
     }
 
-    public function remove(Entity $instance)
+    public function remove($space, $params = [])
     {
-        $this->findRepository($instance)->remove($instance);
+        if($space instanceof Entity) {
+            $this->findRepository($space)->removeEntity($space);
+
+        } else {
+            $this->getRepository($space)->remove($params);
+        }
     }
 
     public function save(Entity $instance)

src/Repository.php

@@ -179,7 +179,30 @@ public function update(Entity $instance, $operations)
         }
     }
 
-    public function remove($instance)
+    public function truncate()
+    {
+        $this->cache = [];
+        $this->results = [];
+        $id = $this->space->getId();
+        $this->space->getMapper()->getClient()->evaluate("box.space[$id]:truncate()");
+    }
+
+    public function remove($params = [])
+    {
+        if($params instanceof Entity) {
+            return $this->removeEntity($params);
+        }
+
+        if(!count($params)) {
+            throw new Exception("Use truncate to flush space");
+        }
+
+        foreach($this->find($params) as $entity) {
+            $this->removeEntity($entity);
+        }
+    }
+
+    public function removeEntity(Entity $instance)
     {
         $key = $this->space->getInstanceKey($instance);
 
@@ -202,12 +225,12 @@ public function remove($instance)
             $this->space->getMapper()->getClient()
                 ->getSpace($this->space->getId())
                 ->delete($pk);
-
         }
 
         unset($this->original[$key]);
 
         $this->results = [];
+        $this->cache = [];
     }
 
     public function save($instance)

tests/MapperTest.php

@@ -6,6 +6,31 @@
 
 class MapperTest extends TestCase
 {
+    public function testRemove()
+    {
+        $mapper = $this->createMapper();
+        $this->clean($mapper);
+
+        $mapper->getSchema()->createSpace('sector_parent')
+            ->addProperties([
+                'id' => 'unsigned',
+                'parent' => 'unsigned',
+            ])
+            ->addIndex(['id', 'parent']);
+
+        $mapper->create('sector_parent', ['id' => 1, 'parent' => 2]);
+        $mapper->create('sector_parent', ['id' => 1, 'parent' => 3]);
+        $mapper->create('sector_parent', ['id' => 2, 'parent' => 3]);
+
+        $this->assertCount(3, $mapper->find('sector_parent'));
+
+        $mapper->remove('sector_parent', ['id' => 1]);
+        $this->assertCount(1, $mapper->find('sector_parent'));
+
+        $mapper->getRepository('sector_parent')->truncate();
+        $this->assertCount(0, $mapper->find('sector_parent'));
+    }
+
     public function testCompositeKeys()
     {
         $mapper = $this->createMapper();