introduce gateway

src/Connection.php

@@ -23,7 +23,7 @@
  *
  * @package Blast\Orm
  */
-class Connection extends DbalConnection implements MapperFactoryInterface
+class Connection extends DbalConnection implements MapperFactoryInterface, QueryFactoryInterface
 {
 
     use MapperFactoryTrait {
@@ -55,9 +55,9 @@ public function createMapper($entity){
      *
      * @param \Doctrine\DBAL\Query\QueryBuilder $builder
      *
-     * @return Mapper
+     * @return \Blast\Orm\Query
      */
-    public function createQuery($entity, QueryBuilder $builder = null)
+    public function createQuery($entity = null, QueryBuilder $builder = null)
     {
         $query = new Query($this, $entity);
         $query->setBuilder(null === $builder ? parent::createQueryBuilder() : $builder);

src/ConnectionAwareTrait.php

@@ -17,14 +17,14 @@ trait ConnectionAwareTrait
 {
 
     /**
-     * @var \Doctrine\DBAL\Connection
+     * @var \Doctrine\DBAL\Connection|\Blast\Orm\Connection
      */
     private $connection = null;
 
     /**
      * Get current connection
      *
-     * @return \Doctrine\DBAL\Driver\Connection|\Doctrine\DBAL\Connection
+     * @return \Doctrine\DBAL\Driver\Connection|\Doctrine\DBAL\Connection|\Blast\Orm\Connection
      */
     public function getConnection()
     {
@@ -35,7 +35,7 @@ public function getConnection()
     }
 
     /**
-     * @param \Doctrine\DBAL\Driver\Connection|null $connection
+     * @param \Doctrine\DBAL\Driver\Connection|\Blast\Orm\Connection|null $connection
      *
      * @return $this
      */

src/Gateway.php

@@ -0,0 +1,98 @@
+<?php
+/**
+ *
+ * (c) Marco Bunge <marco_bunge@web.de>
+ *
+ * For the full copyright and license information, please view the LICENSE.txt
+ * file that was distributed with this source code.
+ *
+ * Date: 13.04.2016
+ * Time: 17:23
+ *
+ */
+
+namespace Blast\Orm;
+
+
+use Blast\Orm\Relations\RelationInterface;
+use Doctrine\DBAL\Schema\Column;
+use Doctrine\DBAL\Types\Type;
+
+class Gateway implements GatewayInterface, ConnectionAwareInterface
+{
+
+    use ConnectionAwareTrait;
+
+    /**
+     * @var string
+     */
+    private $table;
+
+    /**
+     * Create a new gateway for a single table
+     *
+     * @param $table
+     */
+    public function __construct($table)
+    {
+        $this->table = $table;
+    }
+
+    /**
+     * Prepare insert statement
+     *
+     * @param $data
+     *
+     * @param Column[] $fields
+     * @return $this
+     */
+    public function insert($data, $fields = [])
+    {
+        //cancel if $data has no entries
+        if (count($data) < 1) {
+            return false;
+        }
+
+        //prepare statement
+        $query = $this->getConnection()->createQuery();
+        $query->insert($this->table);
+
+        foreach ($data as $key => $value) {
+            if ($value instanceof RelationInterface) {
+                continue;
+            };
+
+            $query->setValue($key, $query->createPositionalParameter(
+                $value, array_key_exists($key, $fields) ?
+                $fields[$key]->getType()->getName() :
+                Type::STRING));
+        }
+
+        return $query;
+    }
+
+    /**
+     * Prepare update statement
+     *
+     * @param $primaryKey
+     * @param $data
+     *
+     * @return mixed
+     */
+    public function update($primaryKey, $data)
+    {
+        // TODO: Implement update() method.
+    }
+
+    /**
+     * Prepare delete statement
+     *
+     * @param $primaryKey
+     *
+     * @return mixed
+     */
+    public function delete($primaryKey)
+    {
+        // TODO: Implement delete() method.
+    }
+}

src/GatewayInterface.php

@@ -0,0 +1,59 @@
+<?php
+/**
+ *
+ * (c) Marco Bunge <marco_bunge@web.de>
+ *
+ * For the full copyright and license information, please view the LICENSE.txt
+ * file that was distributed with this source code.
+ *
+ * Date: 13.04.2016
+ * Time: 17:08
+ *
+ */
+
+namespace Blast\Orm;
+
+/**
+ * The gateway is accessing a single table or view and interacts with database
+ * 
+ * @package Blast\Orm
+ */
+interface GatewayInterface
+{
+
+    /**
+     * Create a new gateway for a single table
+     * 
+     * @param $table
+     */
+    public function __construct($table);
+
+    /**
+     * Prepare insert statement
+     * 
+     * @param $data
+     * 
+     * @return $this
+     */
+    public function insert($data);
+
+    /**
+     * Prepare update statement
+     * 
+     * @param $primaryKey
+     * @param $data
+     * 
+     * @return mixed
+     */
+    public function update($primaryKey, $data);
+
+    /**
+     * Prepare delete statement
+     * 
+     * @param $primaryKey
+     * 
+     * @return mixed
+     */
+    public function delete($primaryKey);
+
+}

src/Mapper.php

@@ -148,33 +148,14 @@ public function create($entity)
 
         //disallow differing entities
         $this->checkEntity($provider);
-
-        //prepare statement
-        $query = $this->createQuery();
-        $query->insert($provider->getDefinition()->getTableName());
-
+
         //pass data without relations
         $data = $provider->extract();
 
-        //cancel if $data has no entries
-        if (count($data) < 1) {
-            return false;
-        }
-
         $fields = $provider->getDefinition()->getFields();
-
-        foreach ($data as $key => $value) {
-            if ($value instanceof RelationInterface) {
-                continue;
-            };
-
-            $query->setValue($key, $query->createPositionalParameter(
-                $value, array_key_exists($key, $fields) ?
-                $fields[$key]->getType()->getName() :
-                Type::STRING));
-        }
-
-        return $query;
+        $gateway = new Gateway($provider->getDefinition()->getTableName());
+
+        return $gateway->insert($data, $fields);
     }
 
     /**
@@ -192,15 +173,15 @@ public function update($entity)
         $this->checkEntity($provider);
 
         $pkName = $provider->getDefinition()->getPrimaryKeyName();
+        //pass data without relations
+        $data = $provider->extract();
+        $fields = $provider->getDefinition()->getFields();
 
+
         //prepare statement
         $query = $this->createQuery();
         $query->update($provider->getDefinition()->getTableName());
 
-        //pass data without relations
-        $data = $provider->extract();
-
-        $fields = $provider->getDefinition()->getFields();
 
         foreach ($data as $key => $value) {
             if ($value instanceof RelationInterface) {

src/QueryFactoryInterface.php

@@ -23,5 +23,5 @@ interface QueryFactoryInterface
      * 
      * @return Mapper
      */
-    public function createQuery($entity);
+    public function createQuery($entity = null);
 }