Add increment and test

Author: mevdschee

README.md

@@ -114,7 +114,7 @@ These features match features in v1 (see branch "v1"):
   - [x] Pagination, seeking, sorting and column selection
   - [x] Relation detection nested results (belongsTo, hasMany and HABTM)
   - [ ] ~~Relation "transforms" (of condensed JSON) for PHP and JavaScript~~
-  - [ ] Atomic increment support via PATCH (for counters)
+  - [x] Atomic increment support via PATCH (for counters)
   - [x] Binary fields supported with base64 encoding
   - [x] Spatial/GIS fields and filters supported with WKT
   - [ ] Unstructured data support through JSON/JSONB

src/Tqdev/PhpCrudApi/Controller/RecordController.php

@@ -1,11 +1,11 @@
 <?php
 namespace Tqdev\PhpCrudApi\Controller;
 
+use Tqdev\PhpCrudApi\Middleware\Router\Router;
 use Tqdev\PhpCrudApi\Record\ErrorCode;
 use Tqdev\PhpCrudApi\Record\RecordService;
 use Tqdev\PhpCrudApi\Request;
 use Tqdev\PhpCrudApi\Response;
-use Tqdev\PhpCrudApi\Middleware\Router\Router;
 
 class RecordController
 {
@@ -130,4 +130,34 @@ public function delete(Request $request): Response
         }
     }
 
+    public function increment(Request $request): Response
+    {
+        $table = $request->getPathSegment(2);
+        $id = $request->getPathSegment(3);
+        $record = $request->getBody();
+        if ($record === null) {
+            return $this->responder->error(ErrorCode::HTTP_MESSAGE_NOT_READABLE, '');
+        }
+        $params = $request->getParams();
+        if (!$this->service->exists($table)) {
+            return $this->responder->error(ErrorCode::TABLE_NOT_FOUND, $table);
+        }
+        $ids = explode(',', $id);
+        if (is_array($record)) {
+            if (count($ids) != count($record)) {
+                return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
+            }
+            $result = array();
+            for ($i = 0; $i < count($ids); $i++) {
+                $result[] = $this->service->increment($table, $ids[$i], $record[$i], $params);
+            }
+            return $this->responder->success($result);
+        } else {
+            if (count($ids) != 1) {
+                return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
+            }
+            return $this->responder->success($this->service->increment($table, $id, $record, $params));
+        }
+    }
+
 }

src/Tqdev/PhpCrudApi/Database/GenericDB.php

@@ -1,9 +1,9 @@
 <?php
 namespace Tqdev\PhpCrudApi\Database;
 
+use Tqdev\PhpCrudApi\Column\Reflection\ReflectedTable;
 use Tqdev\PhpCrudApi\Record\Condition\ColumnCondition;
 use Tqdev\PhpCrudApi\Record\Condition\Condition;
-use Tqdev\PhpCrudApi\Column\Reflection\ReflectedTable;
 
 class GenericDB
 {
@@ -218,6 +218,22 @@ public function deleteSingle(ReflectedTable $table, String $id)
         return $stmt->rowCount();
     }
 
+    public function incrementSingle(ReflectedTable $table, array $columnValues, String $id)
+    {
+        if (count($columnValues) == 0) {
+            return 0;
+        }
+        $this->converter->convertColumnValues($table, $columnValues);
+        $updateColumns = $this->columns->getIncrement($table, $columnValues);
+        $tableName = $table->getName();
+        $condition = new ColumnCondition($table->getPk(), 'eq', $id);
+        $parameters = array_values($columnValues);
+        $whereClause = $this->conditions->getWhereClause($condition, $parameters);
+        $sql = 'UPDATE "' . $tableName . '" SET ' . $updateColumns . $whereClause;
+        $stmt = $this->query($sql, $parameters);
+        return $stmt->rowCount();
+    }
+
     private function query(String $sql, array $parameters): \PDOStatement
     {
         $stmt = $this->pdo->prepare($sql);

src/Tqdev/PhpCrudApi/Record/RecordService.php

@@ -1,9 +1,9 @@
 <?php
 namespace Tqdev\PhpCrudApi\Record;
 
+use Tqdev\PhpCrudApi\Column\ReflectionService;
 use Tqdev\PhpCrudApi\Database\GenericDB;
 use Tqdev\PhpCrudApi\Record\Document\ListDocument;
-use Tqdev\PhpCrudApi\Column\ReflectionService;
 
 class RecordService
 {
@@ -86,6 +86,14 @@ public function delete(String $tableName, String $id, array $params)
         return $this->db->deleteSingle($table, $id);
     }
 
+    public function increment(String $tableName, String $id, /* object */ $record, array $params)
+    {
+        $this->sanitizeRecord($tableName, $record, $id);
+        $table = $this->tables->get($tableName);
+        $columnValues = $this->columns->getValues($table, true, $record, $params);
+        return $this->db->incrementSingle($table, $columnValues, $id);
+    }
+
     public function _list(String $tableName, array $params): ListDocument
     {
         $table = $this->tables->get($tableName);