Introduce expression language in UPDATE queries

Author: dantleech

features/all/phpcr_query_update.feature

@@ -153,3 +153,30 @@ Feature: Execute a a raw UPDATE query in JCR_SQL2
             | UPDATE [nt:unstructured] mixin_foo('bar') |
             | UPDATE [nt:unstructured] APPLY mixin_foo('bar') |
             | UPDATE [nt:unstructured] mixin_foo'bar') |
+
+    Scenario Outline: Execute update query with expressions
+        Given I execute the "<query>" command
+        Then the command should not fail
+        And I save the session
+        And the node at "<path>" should have the property "<property>" with value "<expectedValue>"
+        And I should see the following:
+        """
+        1 row(s) affected
+        """
+        Examples:
+            | query | path | property | expectedValue |
+            | UPDATE [nt:unstructured] AS a SET a.title = expr('row.getNode().getName()') WHERE localname() = 'article1' | /cms/articles/article1 | title | article1 |
+            | UPDATE [nt:unstructured] AS a SET a.title = expr('row.getPath()') WHERE localname() = 'article1' | /cms/articles/article1 | title |  /cms/articles/article1 |
+
+    Scenario: Execute an update with a quoted expression (can't do this in Examples above)
+        Given I execute the following command:
+        """
+        UPDATE [nt:unstructured] AS a SET a.weight = expr('row.getNode().getPropertyValue("weight") * 2') WHERE a.name = 'Product One'
+        """
+        And the command should not fail
+        And I save the session
+        And the node at "/cms/products/product1" should have the property "weight" with value "20"
+        And I should see the following:
+        """
+        1 row(s) affected
+        """

features/fixtures/cms.xml

@@ -113,6 +113,9 @@
             <sv:property sv:name="title" sv:type="String">
                 <sv:value>Article 1</sv:value>
             </sv:property>
+            <sv:property sv:name="number" sv:type="Long">
+                <sv:value>2</sv:value>
+            </sv:property>
             <sv:property sv:name="tags" sv:type="String" sv:multiple="true">
                 <sv:value>Planes</sv:value>
                 <sv:value>Trains</sv:value>

src/PHPCR/Shell/Console/Command/Phpcr/QueryUpdateCommand.php

@@ -90,7 +90,7 @@ public function execute(InputInterface $input, OutputInterface $output)
         $result = $query->execute();
         $rows = 0;
 
-        $updateProcessor = new UpdateProcessor();
+        $updateProcessor = $this->get('query.update.processor');
 
         foreach ($result as $row) {
             $rows++;

src/PHPCR/Shell/DependencyInjection/Container.php

@@ -40,6 +40,7 @@ public function __construct($mode = PhpcrShell::MODE_STANDALONE)
         $this->registerPhpcr();
         $this->registerEvent();
         $this->registerConsole();
+        $this->registerQuery();
     }
 
     public function registerHelpers()
@@ -167,6 +168,13 @@ public function registerConsole()
             ->addArgument(new Reference('phpcr.session'));
     }
 
+    public function registerQuery()
+    {
+        $this->register('query.update.expression_language', 'Symfony\Component\ExpressionLanguage\ExpressionLanguage');
+        $this->register('query.update.processor', 'PHPCR\Shell\Query\UpdateProcessor')
+            ->addArgument(new Reference('query.update.expression_language'));
+    }
+
     public function getMode()
     {
         return $this->mode;

src/PHPCR/Shell/Query/UpdateProcessor.php

@@ -12,6 +12,7 @@
 namespace PHPCR\Shell\Query;
 
 use PHPCR\Query\RowInterface;
+use Symfony\Component\ExpressionLanguage\ExpressionLanguage;
 
 /**
  * Processor for node updates
@@ -25,8 +26,9 @@ class UpdateProcessor
      */
     private $functionMap = array();
 
-    public function __construct()
+    public function __construct(ExpressionLanguage $expressionLanguage)
     {
+
         $this->functionMapApply = array(
             'mixin_add' => function ($operand, $row, $mixinName) {
                 $node = $row->getNode();
@@ -42,6 +44,14 @@ public function __construct()
         );
 
         $this->functionMapSet = array(
+            'expr' => function ($operand, $row, $expression) use ($expressionLanguage) {
+                return $expressionLanguage->evaluate(
+                    $expression,
+                    array(
+                        'row' => $row,
+                    )
+                );
+            },
             'array_replace' => function ($operand, $row, $v, $x, $y) {
                 $operand->validateScalarArray($v);
                 foreach ($v as $key => $value) {

src/PHPCR/Shell/Test/ContextBase.php

@@ -151,6 +151,14 @@ public function iExecuteTheCommand($args)
         $this->executeCommand($args);
     }
 
+    /**
+     * @Given I execute the following command:
+     */
+    public function iExecuteTheFollowingCommand(PyStringNode $command)
+    {
+        $this->executeCommand($command);
+    }
+
     /**
      * @Given /^I execute the following commands:$/
      */