build fix for #744

api.include.php

@@ -4525,18 +4525,58 @@ namespace Tqdev\PhpCrudApi\Controller {
 
     class JsonResponder implements Responder
     {
+        private $debug;
+
+        public function __construct(bool $debug)
+        {
+            $this->debug = $debug;
+        }
+
         public function error(int $error, string $argument, $details = null): ResponseInterface
         {
-            $errorCode = new ErrorCode($error);
-            $status = $errorCode->getStatus();
-            $document = new ErrorDocument($errorCode, $argument, $details);
-            return ResponseFactory::fromObject($status, $document);
+            $document = new ErrorDocument(new ErrorCode($error), $argument, $details);
+            return ResponseFactory::fromObject($document->getStatus(), $document);
         }
 
         public function success($result): ResponseInterface
         {
             return ResponseFactory::fromObject(ResponseFactory::OK, $result);
         }
+
+        public function exception($exception): ResponseInterface
+        {
+            $document = ErrorDocument::fromException($exception);
+            $response = ResponseFactory::fromObject($document->getStatus(), $document);
+            if ($this->debug) {
+                $response = ResponseUtils::addExceptionHeaders($response, $exception);
+            }
+            return $response;
+        }
+
+        public function multi($results): ResponseInterface
+        {
+            $document = array();
+            $success = true;
+            foreach ($results as $i=>$result) {
+                if ($result instanceof \Throwable) {
+                    $document[$i] = ErrorDocument::fromException($result);
+                    $success = false;
+                } else {
+                    $document[$i] = $result;
+                }
+            }
+            $status = $success ? ResponseFactory::OK : ResponseFactory::FAILED_DEPENDENCY;
+            $response = ResponseFactory::fromObject($status, $document);
+            foreach ($results as $i=>$result) {
+                if ($result instanceof \Throwable) {
+                    if ($this->debug) {
+                        $response = ResponseUtils::addExceptionHeaders($response, $result);
+                    }
+                }
+            }
+            return $response;
+        }
+
     }
 }
 
@@ -4614,11 +4654,11 @@ namespace Tqdev\PhpCrudApi\Controller {
             $params = RequestUtils::getParams($request);
             if (strpos($id, ',') !== false) {
                 $ids = explode(',', $id);
-                $result = [];
+                $argumentLists = array();
                 for ($i = 0; $i < count($ids); $i++) {
-                    array_push($result, $this->service->read($table, $ids[$i], $params));
+                    $argumentLists[] = array($table, $ids[$i], $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'read'], $argumentLists));
             } else {
                 $response = $this->service->read($table, $id, $params);
                 if ($response === null) {
@@ -4628,6 +4668,27 @@ namespace Tqdev\PhpCrudApi\Controller {
             }
         }
 
+        private function multiCall(callable $method, array $argumentLists): array
+        {
+            $result = array();
+            $success = true;
+            $this->service->beginTransaction();
+            foreach ($argumentLists as $arguments) {
+                try {
+                    $result[] = call_user_func_array($method, $arguments);
+                } catch (\Throwable $e) {
+                    $success = false;
+                    $result[] = $e;
+                }
+            }
+            if ($success) {
+                $this->service->commitTransaction();
+            } else {
+                $this->service->rollBackTransaction();
+            }
+            return $result;
+        }
+
         public function create(ServerRequestInterface $request): ResponseInterface
         {
             $table = RequestUtils::getPathSegment($request, 2);
@@ -4643,11 +4704,11 @@ namespace Tqdev\PhpCrudApi\Controller {
             }
             $params = RequestUtils::getParams($request);
             if (is_array($record)) {
-                $result = array();
+                $argumentLists = array();
                 foreach ($record as $r) {
-                    $result[] = $this->service->create($table, $r, $params);
+                    $argumentLists[] = array($table, $r, $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'create'], $argumentLists));
             } else {
                 return $this->responder->success($this->service->create($table, $record, $params));
             }
@@ -4673,11 +4734,11 @@ namespace Tqdev\PhpCrudApi\Controller {
                 if (count($ids) != count($record)) {
                     return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
                 }
-                $result = array();
+                $argumentLists = array();
                 for ($i = 0; $i < count($ids); $i++) {
-                    $result[] = $this->service->update($table, $ids[$i], $record[$i], $params);
+                    $argumentLists[] = array($table, $ids[$i], $record[$i], $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'update'], $argumentLists));
             } else {
                 if (count($ids) != 1) {
                     return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
@@ -4699,11 +4760,11 @@ namespace Tqdev\PhpCrudApi\Controller {
             $params = RequestUtils::getParams($request);
             $ids = explode(',', $id);
             if (count($ids) > 1) {
-                $result = array();
+                $argumentLists = array();
                 for ($i = 0; $i < count($ids); $i++) {
-                    $result[] = $this->service->delete($table, $ids[$i], $params);
+                    $argumentLists[] = array($table, $ids[$i], $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'delete'], $argumentLists));
             } else {
                 return $this->responder->success($this->service->delete($table, $id, $params));
             }
@@ -4729,11 +4790,11 @@ namespace Tqdev\PhpCrudApi\Controller {
                 if (count($ids) != count($record)) {
                     return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
                 }
-                $result = array();
+                $argumentLists = array();
                 for ($i = 0; $i < count($ids); $i++) {
-                    $result[] = $this->service->increment($table, $ids[$i], $record[$i], $params);
+                    $argumentLists[] = array($table, $ids[$i], $record[$i], $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'increment'], $argumentLists));
             } else {
                 if (count($ids) != 1) {
                     return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
@@ -5435,6 +5496,21 @@ namespace Tqdev\PhpCrudApi\Database {
             return $this->definition;
         }
 
+        public function beginTransaction() /*: void*/
+        {
+            $this->pdo->beginTransaction();
+        }
+
+        public function commitTransaction() /*: void*/
+        {
+            $this->pdo->commit();
+        }
+
+        public function rollBackTransaction() /*: void*/
+        {
+            $this->pdo->rollBack();
+        }
+
         private function addMiddlewareConditions(string $tableName, Condition $condition): Condition
         {
             $condition1 = VariableStore::get("authorization.conditions.$tableName");
@@ -5609,7 +5685,7 @@ namespace Tqdev\PhpCrudApi\Database {
                 $this->port,
                 $this->database,
                 $this->tables,
-                $this->username
+                $this->username,
             ]));
         }
     }
@@ -6979,19 +7055,17 @@ namespace Tqdev\PhpCrudApi\Middleware\Router {
         private $responder;
         private $cache;
         private $ttl;
-        private $debug;
         private $registration;
         private $routes;
         private $routeHandlers;
         private $middlewares;
 
-        public function __construct(string $basePath, Responder $responder, Cache $cache, int $ttl, bool $debug)
+        public function __construct(string $basePath, Responder $responder, Cache $cache, int $ttl)
         {
             $this->basePath = rtrim($this->detectBasePath($basePath), '/');
             $this->responder = $responder;
             $this->cache = $cache;
             $this->ttl = $ttl;
-            $this->debug = $debug;
             $this->registration = true;
             $this->routes = $this->loadPathTree();
             $this->routeHandlers = [];
@@ -7102,23 +7176,8 @@ namespace Tqdev\PhpCrudApi\Middleware\Router {
             }
             try {
                 $response = call_user_func($this->routeHandlers[$routeNumbers[0]], $request);
-            } catch (\PDOException $e) {
-                if (strpos(strtolower($e->getMessage()), 'duplicate') !== false) {
-                    $response = $this->responder->error(ErrorCode::DUPLICATE_KEY_EXCEPTION, '');
-                } elseif (strpos(strtolower($e->getMessage()), 'unique constraint') !== false) {
-                    $response = $this->responder->error(ErrorCode::DUPLICATE_KEY_EXCEPTION, '');
-                } elseif (strpos(strtolower($e->getMessage()), 'default value') !== false) {
-                    $response = $this->responder->error(ErrorCode::DATA_INTEGRITY_VIOLATION, '');
-                } elseif (strpos(strtolower($e->getMessage()), 'allow nulls') !== false) {
-                    $response = $this->responder->error(ErrorCode::DATA_INTEGRITY_VIOLATION, '');
-                } elseif (strpos(strtolower($e->getMessage()), 'constraint') !== false) {
-                    $response = $this->responder->error(ErrorCode::DATA_INTEGRITY_VIOLATION, '');
-                } else {
-                    $response = $this->responder->error(ErrorCode::ERROR_NOT_FOUND, '');
-                }
-                if ($this->debug) {
-                    $response = ResponseUtils::addExceptionHeaders($response, $e);
-                }
+            } catch (\Throwable $exception) {
+                $response = $this->responder->exception($exception);
             }
             return $response;
         }
@@ -9790,32 +9849,37 @@ namespace Tqdev\PhpCrudApi\Record\Document {
 
     class ErrorDocument implements \JsonSerializable
     {
-        public $code;
-        public $message;
+        public $errorCode;
+        public $argument;
         public $details;
 
         public function __construct(ErrorCode $errorCode, string $argument, $details)
         {
-            $this->code = $errorCode->getCode();
-            $this->message = $errorCode->getMessage($argument);
+            $this->errorCode = $errorCode;
+            $this->argument = $argument;
             $this->details = $details;
         }
 
+        public function getStatus(): int
+        {
+            return $this->errorCode->getStatus();
+        }
+
         public function getCode(): int
         {
-            return $this->code;
+            return $this->errorCode->getCode();
         }
 
         public function getMessage(): string
         {
-            return $this->message;
+            return $this->errorCode->getMessage($this->argument);
         }
 
         public function serialize()
         {
             return [
-                'code' => $this->code,
-                'message' => $this->message,
+                'code' => $this->getCode(),
+                'message' => $this->getMessage(),
                 'details' => $this->details,
             ];
         }
@@ -9824,6 +9888,27 @@ namespace Tqdev\PhpCrudApi\Record\Document {
         {
             return array_filter($this->serialize());
         }
+
+        public static function fromException(\Throwable $exception)
+        {
+            $document = new ErrorDocument(new ErrorCode(ErrorCode::ERROR_NOT_FOUND), $exception->getMessage(), null);
+            if ($exception instanceof \PDOException) {
+                if (strpos(strtolower($exception->getMessage()), 'duplicate') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DUPLICATE_KEY_EXCEPTION), '', null);
+                } elseif (strpos(strtolower($exception->getMessage()), 'unique constraint') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DUPLICATE_KEY_EXCEPTION), '', null);
+                } elseif (strpos(strtolower($exception->getMessage()), 'default value') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DATA_INTEGRITY_VIOLATION), '', null);
+                } elseif (strpos(strtolower($exception->getMessage()), 'allow nulls') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DATA_INTEGRITY_VIOLATION), '', null);
+                } elseif (strpos(strtolower($exception->getMessage()), 'constraint') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DATA_INTEGRITY_VIOLATION), '', null);
+                } else {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::ERROR_NOT_FOUND), '', null);
+                }
+            }
+            return $document;
+        }
     }
 }
 
@@ -10349,6 +10434,21 @@ namespace Tqdev\PhpCrudApi\Record {
             return $this->reflection->getType($table);
         }
 
+        public function beginTransaction() /*: void*/
+        {
+            $this->db->beginTransaction();
+        }
+
+        public function commitTransaction() /*: void*/
+        {
+            $this->db->commitTransaction();
+        }
+
+        public function rollBackTransaction() /*: void*/
+        {
+            $this->db->rollBackTransaction();
+        }
+
         public function create(string $tableName, /* object */ $record, array $params) /*: ?int*/
         {
             $this->sanitizeRecord($tableName, $record, '');
@@ -10773,8 +10873,8 @@ namespace Tqdev\PhpCrudApi {
             $prefix = sprintf('phpcrudapi-%s-', substr(md5(__FILE__), 0, 8));
             $cache = CacheFactory::create($config->getCacheType(), $prefix, $config->getCachePath());
             $reflection = new ReflectionService($db, $cache, $config->getCacheTime());
-            $responder = new JsonResponder();
-            $router = new SimpleRouter($config->getBasePath(), $responder, $cache, $config->getCacheTime(), $config->getDebug());
+            $responder = new JsonResponder($config->getDebug());
+            $router = new SimpleRouter($config->getBasePath(), $responder, $cache, $config->getCacheTime());
             foreach ($config->getMiddlewares() as $middleware => $properties) {
                 switch ($middleware) {
                     case 'sslRedirect':
@@ -11297,6 +11397,7 @@ namespace Tqdev\PhpCrudApi {
         const METHOD_NOT_ALLOWED = 405;
         const CONFLICT = 409;
         const UNPROCESSABLE_ENTITY = 422;
+        const FAILED_DEPENDENCY = 424;
         const INTERNAL_SERVER_ERROR = 500;
 
         public static function fromXml(int $status, string $xml): ResponseInterface

api.php

@@ -4525,18 +4525,58 @@ namespace Tqdev\PhpCrudApi\Controller {
 
     class JsonResponder implements Responder
     {
+        private $debug;
+
+        public function __construct(bool $debug)
+        {
+            $this->debug = $debug;
+        }
+
         public function error(int $error, string $argument, $details = null): ResponseInterface
         {
-            $errorCode = new ErrorCode($error);
-            $status = $errorCode->getStatus();
-            $document = new ErrorDocument($errorCode, $argument, $details);
-            return ResponseFactory::fromObject($status, $document);
+            $document = new ErrorDocument(new ErrorCode($error), $argument, $details);
+            return ResponseFactory::fromObject($document->getStatus(), $document);
         }
 
         public function success($result): ResponseInterface
         {
             return ResponseFactory::fromObject(ResponseFactory::OK, $result);
         }
+
+        public function exception($exception): ResponseInterface
+        {
+            $document = ErrorDocument::fromException($exception);
+            $response = ResponseFactory::fromObject($document->getStatus(), $document);
+            if ($this->debug) {
+                $response = ResponseUtils::addExceptionHeaders($response, $exception);
+            }
+            return $response;
+        }
+
+        public function multi($results): ResponseInterface
+        {
+            $document = array();
+            $success = true;
+            foreach ($results as $i=>$result) {
+                if ($result instanceof \Throwable) {
+                    $document[$i] = ErrorDocument::fromException($result);
+                    $success = false;
+                } else {
+                    $document[$i] = $result;
+                }
+            }
+            $status = $success ? ResponseFactory::OK : ResponseFactory::FAILED_DEPENDENCY;
+            $response = ResponseFactory::fromObject($status, $document);
+            foreach ($results as $i=>$result) {
+                if ($result instanceof \Throwable) {
+                    if ($this->debug) {
+                        $response = ResponseUtils::addExceptionHeaders($response, $result);
+                    }
+                }
+            }
+            return $response;
+        }
+
     }
 }
 
@@ -4614,11 +4654,11 @@ namespace Tqdev\PhpCrudApi\Controller {
             $params = RequestUtils::getParams($request);
             if (strpos($id, ',') !== false) {
                 $ids = explode(',', $id);
-                $result = [];
+                $argumentLists = array();
                 for ($i = 0; $i < count($ids); $i++) {
-                    array_push($result, $this->service->read($table, $ids[$i], $params));
+                    $argumentLists[] = array($table, $ids[$i], $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'read'], $argumentLists));
             } else {
                 $response = $this->service->read($table, $id, $params);
                 if ($response === null) {
@@ -4628,6 +4668,27 @@ namespace Tqdev\PhpCrudApi\Controller {
             }
         }
 
+        private function multiCall(callable $method, array $argumentLists): array
+        {
+            $result = array();
+            $success = true;
+            $this->service->beginTransaction();
+            foreach ($argumentLists as $arguments) {
+                try {
+                    $result[] = call_user_func_array($method, $arguments);
+                } catch (\Throwable $e) {
+                    $success = false;
+                    $result[] = $e;
+                }
+            }
+            if ($success) {
+                $this->service->commitTransaction();
+            } else {
+                $this->service->rollBackTransaction();
+            }
+            return $result;
+        }
+
         public function create(ServerRequestInterface $request): ResponseInterface
         {
             $table = RequestUtils::getPathSegment($request, 2);
@@ -4643,11 +4704,11 @@ namespace Tqdev\PhpCrudApi\Controller {
             }
             $params = RequestUtils::getParams($request);
             if (is_array($record)) {
-                $result = array();
+                $argumentLists = array();
                 foreach ($record as $r) {
-                    $result[] = $this->service->create($table, $r, $params);
+                    $argumentLists[] = array($table, $r, $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'create'], $argumentLists));
             } else {
                 return $this->responder->success($this->service->create($table, $record, $params));
             }
@@ -4673,11 +4734,11 @@ namespace Tqdev\PhpCrudApi\Controller {
                 if (count($ids) != count($record)) {
                     return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
                 }
-                $result = array();
+                $argumentLists = array();
                 for ($i = 0; $i < count($ids); $i++) {
-                    $result[] = $this->service->update($table, $ids[$i], $record[$i], $params);
+                    $argumentLists[] = array($table, $ids[$i], $record[$i], $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'update'], $argumentLists));
             } else {
                 if (count($ids) != 1) {
                     return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
@@ -4699,11 +4760,11 @@ namespace Tqdev\PhpCrudApi\Controller {
             $params = RequestUtils::getParams($request);
             $ids = explode(',', $id);
             if (count($ids) > 1) {
-                $result = array();
+                $argumentLists = array();
                 for ($i = 0; $i < count($ids); $i++) {
-                    $result[] = $this->service->delete($table, $ids[$i], $params);
+                    $argumentLists[] = array($table, $ids[$i], $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'delete'], $argumentLists));
             } else {
                 return $this->responder->success($this->service->delete($table, $id, $params));
             }
@@ -4729,11 +4790,11 @@ namespace Tqdev\PhpCrudApi\Controller {
                 if (count($ids) != count($record)) {
                     return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
                 }
-                $result = array();
+                $argumentLists = array();
                 for ($i = 0; $i < count($ids); $i++) {
-                    $result[] = $this->service->increment($table, $ids[$i], $record[$i], $params);
+                    $argumentLists[] = array($table, $ids[$i], $record[$i], $params);
                 }
-                return $this->responder->success($result);
+                return $this->responder->multi($this->multiCall([$this->service, 'increment'], $argumentLists));
             } else {
                 if (count($ids) != 1) {
                     return $this->responder->error(ErrorCode::ARGUMENT_COUNT_MISMATCH, $id);
@@ -5435,6 +5496,21 @@ namespace Tqdev\PhpCrudApi\Database {
             return $this->definition;
         }
 
+        public function beginTransaction() /*: void*/
+        {
+            $this->pdo->beginTransaction();
+        }
+
+        public function commitTransaction() /*: void*/
+        {
+            $this->pdo->commit();
+        }
+
+        public function rollBackTransaction() /*: void*/
+        {
+            $this->pdo->rollBack();
+        }
+
         private function addMiddlewareConditions(string $tableName, Condition $condition): Condition
         {
             $condition1 = VariableStore::get("authorization.conditions.$tableName");
@@ -5609,7 +5685,7 @@ namespace Tqdev\PhpCrudApi\Database {
                 $this->port,
                 $this->database,
                 $this->tables,
-                $this->username
+                $this->username,
             ]));
         }
     }
@@ -6979,19 +7055,17 @@ namespace Tqdev\PhpCrudApi\Middleware\Router {
         private $responder;
         private $cache;
         private $ttl;
-        private $debug;
         private $registration;
         private $routes;
         private $routeHandlers;
         private $middlewares;
 
-        public function __construct(string $basePath, Responder $responder, Cache $cache, int $ttl, bool $debug)
+        public function __construct(string $basePath, Responder $responder, Cache $cache, int $ttl)
         {
             $this->basePath = rtrim($this->detectBasePath($basePath), '/');
             $this->responder = $responder;
             $this->cache = $cache;
             $this->ttl = $ttl;
-            $this->debug = $debug;
             $this->registration = true;
             $this->routes = $this->loadPathTree();
             $this->routeHandlers = [];
@@ -7102,23 +7176,8 @@ namespace Tqdev\PhpCrudApi\Middleware\Router {
             }
             try {
                 $response = call_user_func($this->routeHandlers[$routeNumbers[0]], $request);
-            } catch (\PDOException $e) {
-                if (strpos(strtolower($e->getMessage()), 'duplicate') !== false) {
-                    $response = $this->responder->error(ErrorCode::DUPLICATE_KEY_EXCEPTION, '');
-                } elseif (strpos(strtolower($e->getMessage()), 'unique constraint') !== false) {
-                    $response = $this->responder->error(ErrorCode::DUPLICATE_KEY_EXCEPTION, '');
-                } elseif (strpos(strtolower($e->getMessage()), 'default value') !== false) {
-                    $response = $this->responder->error(ErrorCode::DATA_INTEGRITY_VIOLATION, '');
-                } elseif (strpos(strtolower($e->getMessage()), 'allow nulls') !== false) {
-                    $response = $this->responder->error(ErrorCode::DATA_INTEGRITY_VIOLATION, '');
-                } elseif (strpos(strtolower($e->getMessage()), 'constraint') !== false) {
-                    $response = $this->responder->error(ErrorCode::DATA_INTEGRITY_VIOLATION, '');
-                } else {
-                    $response = $this->responder->error(ErrorCode::ERROR_NOT_FOUND, '');
-                }
-                if ($this->debug) {
-                    $response = ResponseUtils::addExceptionHeaders($response, $e);
-                }
+            } catch (\Throwable $exception) {
+                $response = $this->responder->exception($exception);
             }
             return $response;
         }
@@ -9790,32 +9849,37 @@ namespace Tqdev\PhpCrudApi\Record\Document {
 
     class ErrorDocument implements \JsonSerializable
     {
-        public $code;
-        public $message;
+        public $errorCode;
+        public $argument;
         public $details;
 
         public function __construct(ErrorCode $errorCode, string $argument, $details)
         {
-            $this->code = $errorCode->getCode();
-            $this->message = $errorCode->getMessage($argument);
+            $this->errorCode = $errorCode;
+            $this->argument = $argument;
             $this->details = $details;
         }
 
+        public function getStatus(): int
+        {
+            return $this->errorCode->getStatus();
+        }
+
         public function getCode(): int
         {
-            return $this->code;
+            return $this->errorCode->getCode();
         }
 
         public function getMessage(): string
         {
-            return $this->message;
+            return $this->errorCode->getMessage($this->argument);
         }
 
         public function serialize()
         {
             return [
-                'code' => $this->code,
-                'message' => $this->message,
+                'code' => $this->getCode(),
+                'message' => $this->getMessage(),
                 'details' => $this->details,
             ];
         }
@@ -9824,6 +9888,27 @@ namespace Tqdev\PhpCrudApi\Record\Document {
         {
             return array_filter($this->serialize());
         }
+
+        public static function fromException(\Throwable $exception)
+        {
+            $document = new ErrorDocument(new ErrorCode(ErrorCode::ERROR_NOT_FOUND), $exception->getMessage(), null);
+            if ($exception instanceof \PDOException) {
+                if (strpos(strtolower($exception->getMessage()), 'duplicate') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DUPLICATE_KEY_EXCEPTION), '', null);
+                } elseif (strpos(strtolower($exception->getMessage()), 'unique constraint') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DUPLICATE_KEY_EXCEPTION), '', null);
+                } elseif (strpos(strtolower($exception->getMessage()), 'default value') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DATA_INTEGRITY_VIOLATION), '', null);
+                } elseif (strpos(strtolower($exception->getMessage()), 'allow nulls') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DATA_INTEGRITY_VIOLATION), '', null);
+                } elseif (strpos(strtolower($exception->getMessage()), 'constraint') !== false) {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::DATA_INTEGRITY_VIOLATION), '', null);
+                } else {
+                    $document = new ErrorDocument(new ErrorCode(ErrorCode::ERROR_NOT_FOUND), '', null);
+                }
+            }
+            return $document;
+        }
     }
 }
 
@@ -10349,6 +10434,21 @@ namespace Tqdev\PhpCrudApi\Record {
             return $this->reflection->getType($table);
         }
 
+        public function beginTransaction() /*: void*/
+        {
+            $this->db->beginTransaction();
+        }
+
+        public function commitTransaction() /*: void*/
+        {
+            $this->db->commitTransaction();
+        }
+
+        public function rollBackTransaction() /*: void*/
+        {
+            $this->db->rollBackTransaction();
+        }
+
         public function create(string $tableName, /* object */ $record, array $params) /*: ?int*/
         {
             $this->sanitizeRecord($tableName, $record, '');
@@ -10773,8 +10873,8 @@ namespace Tqdev\PhpCrudApi {
             $prefix = sprintf('phpcrudapi-%s-', substr(md5(__FILE__), 0, 8));
             $cache = CacheFactory::create($config->getCacheType(), $prefix, $config->getCachePath());
             $reflection = new ReflectionService($db, $cache, $config->getCacheTime());
-            $responder = new JsonResponder();
-            $router = new SimpleRouter($config->getBasePath(), $responder, $cache, $config->getCacheTime(), $config->getDebug());
+            $responder = new JsonResponder($config->getDebug());
+            $router = new SimpleRouter($config->getBasePath(), $responder, $cache, $config->getCacheTime());
             foreach ($config->getMiddlewares() as $middleware => $properties) {
                 switch ($middleware) {
                     case 'sslRedirect':
@@ -11297,6 +11397,7 @@ namespace Tqdev\PhpCrudApi {
         const METHOD_NOT_ALLOWED = 405;
         const CONFLICT = 409;
         const UNPROCESSABLE_ENTITY = 422;
+        const FAILED_DEPENDENCY = 424;
         const INTERNAL_SERVER_ERROR = 500;
 
         public static function fromXml(int $status, string $xml): ResponseInterface