Implementação do parser para joins do select.

Author: 0x3175633435

src/Db/Select/Parsing/SelectParser.php

@@ -5,6 +5,7 @@
 use Zend\Db\Sql\Select;
 use Zend\EntityMapper\Config\Container\Container;
 use Zend\EntityMapper\Config\Entity;
+use Zend\EntityMapper\Db\Select\Reflection\JoinReflector;
 use Zend\EntityMapper\Db\Select\Reflection\OperatorReflector;
 use Zend\EntityMapper\Db\Select\Reflection\SelectReflector;
 
@@ -169,6 +170,56 @@ public function parseOrder(): Select
         $order->setValue($select, $parsedOrders);
 
         return $select;
+    }
+
+    /**
+     * @return Select
+     * @throws \Zend\EntityMapper\Config\Container\Exceptions\ItemNotFoundException
+     */
+    public function parseJoin(): Select
+    {
+        $joins = $this->reflector->getProperty('joins');
+        $joinReflector = new JoinReflector($joins);
+        $joinClauses = $joinReflector->getJoinClauses();
+        $parsedJoinClauses = [];
+
+        foreach ($joinClauses as $joinClause) {
+
+            $tableName = null;
+            $rawObjectName = $joinClause['name'];
+
+            if(is_array($rawObjectName)) {
+                foreach ($rawObjectName as $alias => $class) {
+                    $config = $this->container->get($class);
+                    $joinClause['name'] = [$alias => $config->getTable()];
+                    $fields = $config->getFields();
+                }
+            }
+            else {
+                $config = $this->container->get($rawObjectName);
+                $fields = $config->getFields();
+            }
 
+            foreach ($fields as $field) {
+                $joinClause['on'] = str_replace($field->getProperty(), $field->getAlias(), $joinClause['on']);
+
+                foreach ($joinClause['columns'] as $key => $column) {
+                    $joinClause['columns'][$key] = str_replace($field->getProperty(), $field->getAlias(), $joinClause['columns'][$key]);
+                }
+            }
+
+            $parsedJoinClauses[] = $joinClause;
+
+        }
+
+        $joinsReflection = new \ReflectionObject($joins);
+        $joinsReflectorJoinsProperty = $joinsReflection->getProperty('joins');
+        $joinsReflectorJoinsProperty->setAccessible(true);
+        $joinsReflectorJoinsProperty->setValue($joins, $parsedJoinClauses);
+
+        $this->reflector->setProperty('joins', $joins);
+        $select = $this->reflector->getSelect();
+
+        return $select;
     }
 }

src/Db/Select/Reflection/HavingReflector.php

@@ -0,0 +1,7 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Lucas A. de Araújo
+ * Date: 05/07/2018
+ * Time: 08:18
+ */

src/Db/Select/Reflection/JoinReflector.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace Zend\EntityMapper\Db\Select\Reflection;
+
+use Zend\Db\Sql\Join;
+
+class JoinReflector
+{
+    private $join;
+
+    /**
+     * JoinReflector constructor.
+     *
+     * @param Join $join
+     */
+    public function __construct(Join $join)
+    {
+        $this->join = $join;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getJoinClauses()
+    {
+        $joinReflection = new \ReflectionObject($this->join);
+        $joinsPropertyReflection = $joinReflection->getProperty('joins');
+        $joinsPropertyReflection->setAccessible(true);
+        $joinClauses = $joinsPropertyReflection->getValue($this->join);
+
+        return $joinClauses;
+    }
+}

src/Db/Select/Reflection/SelectReflector.php

@@ -45,13 +45,24 @@ public function getSelect(): Select
      * @param string $name
      * @return mixed
      */
-    private function getProperty(string $name)
+    public function getProperty(string $name)
     {
         $property = $this->reflection->getProperty($name);
         $property->setAccessible(true);
         return $property->getValue($this->select);
     }
 
+    /**
+     * @param string $name
+     * @param $value
+     */
+    public function setProperty(string $name, $value): void
+    {
+        $property = $this->reflection->getProperty($name);
+        $property->setAccessible(true);
+        $property->setValue($this->select, $value);
+    }
+
     /**
      * @return string|array|TableIdentifier
      */

tests/Db/Select/Parsing/SelectParsingTest.php

@@ -39,7 +39,7 @@ public function setUp()
         $sql = new Select();
         $sql->columns(['hpower' => 'horsepower', 'pistons'])
             ->from(['a' => Engine::class])
-            ->join(['b' => Engine::class], 'a.id = b.id', [])
+            ->join(['b' => Engine::class], 'a.horsepower = b.horsepower', ['horsepower'])
             ->where
                 ->greaterThan('horsepower', 200)
                 ->and->lessThan('cm3', 2.0);
@@ -151,4 +151,31 @@ public function testParsingOrderColumns()
 
         $this->assertEquals($order[0], 'hp DESC');
     }
+
+    public function testParsingJoinClauses()
+    {
+        $parser = new SelectParser($this->select);
+        $parser->parseFrom();
+        $parser->parseColumns();
+        $parser->parseWhere();
+        $parser->parseFrom();
+
+        $select = $parser->parseJoin();
+
+        $selectReflection = new \ReflectionObject($select);
+        $joinsProperty = $selectReflection->getProperty('joins');
+        $joinsProperty->setAccessible(true);
+        $joins = $joinsProperty->getValue($select);
+
+        $joinsReflection = new \ReflectionObject($joins);
+        $joinsProperty = $joinsReflection->getProperty('joins');
+        $joinsProperty->setAccessible(true);
+        $joinsArray = $joinsProperty->getValue($joins);
+
+        $clause = $joinsArray[0];
+        $on = $clause['on'];
+
+        $this->assertNotEmpty($joinsArray);
+        $this->assertEquals($on, 'a.hp = b.hp');
+    }
 }