Implementação do updatePerformer.

Author: 0x3175633435

src/Db/Gateway/DynamicTableGateway.php

@@ -9,6 +9,7 @@
 use Zend\EntityMapper\Db\Sql\Factory\Select\SelectFactory;
 use Zend\EntityMapper\Db\Sql\Performer\InsertPerformer;
 use Zend\EntityMapper\Db\Sql\Performer\SelectPerformer;
+use Zend\EntityMapper\Db\Sql\Performer\UpdatePerformer;
 
 /**
  * DynamicTableGateway
@@ -91,6 +92,28 @@ public function select(string $entity, $select)
         return $rows;
     }
 
+    /**
+     * @param array $objects
+     * @return array
+     * @throws \Zend\Cache\Exception\ExceptionInterface
+     * @throws \Zend\EntityMapper\Config\Container\Exceptions\ItemNotFoundException
+     */
+    public function insertArray(array $objects): array
+    {
+        $response = [];
+
+        foreach ($objects as $object) {
+            $entity = get_class($object);
+            $this->setUp($entity);
+
+            $insertPerformer = new InsertPerformer(self::$tableGateways[$entity]);
+            $object = $insertPerformer->perform($object);
+            $response[] = $object;
+        }
+
+        return $response;
+    }
+
     /**
      * @param $object
      * @return mixed
@@ -99,12 +122,52 @@ public function select(string $entity, $select)
      */
     public function insert($object)
     {
-        $entity = get_class($object);
-        $this->setUp($entity);
+        $response = $this->insertArray([$object]);
+
+        if (count($response) == 0) {
+            return null;
+        }
+
+        return $response[0];
+    }
+
+    /**
+     * @param array $objects
+     * @return array
+     * @throws \Zend\Cache\Exception\ExceptionInterface
+     * @throws \Zend\EntityMapper\Config\Container\Exceptions\ItemNotFoundException
+     */
+    public function updateArray(array $objects): array
+    {
+        $response = [];
 
-        $insertPerformer = new InsertPerformer(self::$tableGateways[$entity]);
-        $object = $insertPerformer->perform($object);
+        foreach ($objects as $object) {
+            $entity = get_class($object);
+            $this->setUp($entity);
 
-        return $object;
+            $updatePerformer = new UpdatePerformer(self::$tableGateways[$entity]);
+            $object = $updatePerformer->perform($object);
+            $response[] = $object;
+        }
+
+        return $response;
     }
+
+    /**
+     * @param $object
+     * @return mixed|null
+     * @throws \Zend\Cache\Exception\ExceptionInterface
+     * @throws \Zend\EntityMapper\Config\Container\Exceptions\ItemNotFoundException
+     */
+    public function update($object)
+    {
+        $response = $this->updateArray([$object]);
+
+        if (count($response) == 0) {
+            return null;
+        }
+
+        return $response[0];
+    }
+
 }

src/Db/Gateway/TransactionalTableGateway.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Zend\EntityMapper\Db\Gateway;
+
+use Zend\Db\TableGateway\TableGatewayInterface;
+
+class TransactionalTableGateway implements TableGatewayInterface
+{
+
+}

src/Db/Sql/Performer/UpdatePerformer.php

@@ -1,7 +1,60 @@
 <?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
- */
+ * UpdatePerformer
+ *
+ * @package Zend\EntityMapper\Db\Sql\Performer
+ */
+class UpdatePerformer extends AbstractPerformer
+{
+    /**
+     * @var Container
+     */
+    private $container;
+
+    /**
+     * UpdatePerformer 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];
+
+        $extractor = new Extractor();
+        $arrayParsedObject = $extractor->extract($object);
+
+        $this->tableGateway->update($arrayParsedObject, $primaryKeyWhere);
+    }
+}