Implementação do updatePerformer.

Author: 0x3175633435

src/Db/Gateway/DynamicTableGateway.php

@@ -7,6 +7,7 @@
 use Zend\Db\TableGateway\TableGateway;
 use Zend\EntityMapper\Config\Container\Container;
 use Zend\EntityMapper\Db\Sql\Factory\Select\SelectFactory;
+use Zend\EntityMapper\Db\Sql\Performer\DeletePerformer;
 use Zend\EntityMapper\Db\Sql\Performer\InsertPerformer;
 use Zend\EntityMapper\Db\Sql\Performer\SelectPerformer;
 use Zend\EntityMapper\Db\Sql\Performer\UpdatePerformer;
@@ -170,4 +171,34 @@ public function update($object)
         return $response[0];
     }
 
+    /**
+     * @param array $objects
+     * @return bool
+     * @throws \Zend\Cache\Exception\ExceptionInterface
+     * @throws \Zend\EntityMapper\Config\Container\Exceptions\ItemNotFoundException
+     */
+    public function deleteArray(array $objects): bool
+    {
+        foreach ($objects as $object) {
+            $entity = get_class($object);
+            $this->setUp($entity);
+
+            $deletePerformer = new DeletePerformer(self::$tableGateways[$entity]);
+            $deletePerformer->perform($object);
+        }
+
+        return true;
+    }
+
+    /**
+     * @param $object
+     * @return bool
+     * @throws \Zend\Cache\Exception\ExceptionInterface
+     * @throws \Zend\EntityMapper\Config\Container\Exceptions\ItemNotFoundException
+     */
+    public function delete($object): bool
+    {
+        return $this->deleteArray([$object]);
+    }
+
 }

src/Db/Sql/Performer/DeletePerformer.php

@@ -1,7 +1,57 @@
 <?php
+
+namespace Zend\EntityMapper\Db\Sql\Performer;
+
+use Zend\Db\TableGateway\TableGateway;
+use Zend\EntityMapper\Config\Container\Container;
+use Zend\EntityMapper\Db\Sql\Performer\Base\AbstractPerformer;
+use Zend\EntityMapper\Mapping\Extraction\Extractor;
+
 /**
- * Created by PhpStorm.
- * User: Lucas A. de Araújo
- * Date: 13/07/2018
- * Time: 09:20
- */
+ * DeletePerformer
+ *
+ * @package Zend\EntityMapper\Db\Sql\Performer
+ */
+class DeletePerformer extends AbstractPerformer
+{
+    /**
+     * @var Container
+     */
+    private $container;
+
+    /**
+     * DeletePerformer constructor.
+     *
+     * @param TableGateway $tableGateway
+     * @throws \Zend\Cache\Exception\ExceptionInterface
+     */
+    public function __construct(TableGateway $tableGateway)
+    {
+        $this->tableGateway = $tableGateway;
+        $this->container = new Container();
+    }
+
+    /**
+     * @param $object
+     * @throws \Zend\Cache\Exception\ExceptionInterface
+     * @throws \Zend\EntityMapper\Config\Container\Exceptions\ItemNotFoundException
+     */
+    public function perform($object)
+    {
+        $entityName = get_class($object);
+        $entityConf = $this->container->get($entityName);
+        $primaryKey = null;
+        $reflection = new \ReflectionObject($object);
+
+        foreach ($entityConf->getFields() as $field) {
+            if ($field->isPrimaryKey()) {
+                $primaryKey = $field;
+            }
+        }
+
+        $primaryKeyValue = $reflection->getProperty($primaryKey->getProperty())->getValue($object);
+        $primaryKeyWhere = [$primaryKey->getAlias() => $primaryKeyValue];
+
+        $this->tableGateway->delete($primaryKeyWhere);
+    }
+}