The validation class was written and included in the DB layer.

Author: muhammetsafak

composer.json

@@ -24,8 +24,7 @@
     "minimum-stability": "stable",
     "require": {
         "php": ">=7.4",
-        "ext-pdo": "*",
-        "initphp/validation": "^1.0"
+        "ext-pdo": "*"
     },
     "require-dev": {
         "phpunit/phpunit": "9.5"

src/DB.php

@@ -15,7 +15,7 @@
 
 namespace InitPHP\Database;
 
-use InitPHP\Database\Exceptions\DatabaseInvalidArgumentException;
+use InitPHP\Database\Validation\Validation;
 use \PDO;
 use \InitPHP\Database\Connection\{Connection, ConnectionInterface};
 use \InitPHP\Database\DataMapper\{DataMapper, DataMapperInterface};
@@ -57,10 +57,19 @@ class DB
         'updatedField'      => null,
         'deletedField'      => null,
         'timestampFormat'   => 'c',
+        'validation'        => [
+            'methods'   => [],
+            'messages'  => [],
+            'labels'    => [],
+        ],
     ];
 
     private bool $isOnlyDeletes = false;
 
+    private Validation $_validation;
+
+    private array $errors = [];
+
     public function __construct(array $configurations)
     {
         $this->configurations = \array_merge($this->configurations, $configurations);
@@ -85,6 +94,7 @@ public function __construct(array $configurations)
             'schema'            => ($this->configurations['tableSchema'] ?? null),
             'schemaID'          => ($this->configurations['tableSchemaID'] ?? null),
         ]);
+        $this->_validation = new Validation($this->configurations['validation']['methods'], $this->configurations['validation']['messages'], $this->configurations['validation']['labels'], $this);
     }
 
     public function __call($name, $arguments)
@@ -153,6 +163,18 @@ public function getSchemaID()
         return $this->configurations['tableSchemaID'];
     }
 
+    public function isError(): bool
+    {
+        $this->get_error_merge();
+        return !empty($this->errors);
+    }
+
+    public function getError(): array
+    {
+        $this->get_error_merge();
+        return $this->errors;
+    }
+
     /**
      * @return ConnectionInterface
      */
@@ -174,34 +196,55 @@ public function getDataMapper(): DataMapperInterface
      */
     public function getQueryBuilder(): QueryBuilderInterface
     {
-        $this->is_get_execute = false;
         return $this->_queryBuilder;
     }
 
+    public function getValidation(): Validation
+    {
+        return $this->_validation;
+    }
+
     /**
      * @param array $fields
      * @return bool
+     * @throws Exceptions\ValidationException
      */
     public function create(array $fields)
     {
         $data = []; $parameters = [];
         $isCreatedField = !empty($this->configurations['createdField']);
         if(\count($fields) === \count($fields, \COUNT_RECURSIVE)){
+            $this->getValidation()->setData($fields);
             foreach ($fields as $column => $value) {
+                if($this->getValidation()->validation($column, null) === FALSE){
+                    $this->errors[] = $this->getValidation()->getError();
+                    return false;
+                }
                 $data[$column] = ':'.$column;
                 $parameters[':' . $column] = $value;
             }
+            if(empty($data)){
+                return false;
+            }
             if($isCreatedField){
                 $data[$this->configurations['createdField']] = ':' . $this->configurations['createdField'];
             }
         }else{
             $i = 0;
             foreach ($fields as $row) {
                 $data[$i] = [];
+                $this->getValidation()->setData($row);
                 foreach ($row as $column => $value) {
+                    if($this->getValidation()->validation($column, null) === FALSE){
+                        $this->errors[] = $this->getValidation()->getError();
+                        return false;
+                    }
                     $data[$i][$column] = ':' . $column . '_' . $i;
                     $parameters[':' . $column . '_' . $i] = $value;
                 }
+                if(empty($data)){
+                    continue;
+                }
                 if($isCreatedField){
                     $data[$i][$this->configurations['createdField']] = ':' . $this->configurations['createdField'];
                 }
@@ -250,16 +293,23 @@ public function readOne(array $selector = [], array $conditions = [], array $par
      */
     public function update(array $fields)
     {
+        $schemaID = null;
         if(!empty($this->getSchemaID()) && isset($fields[$this->getSchemaID()])){
+            $schemaID = $fields[$this->getSchemaID()];
             $this->getQueryBuilder()->where($this->getSchemaID(), ':' . $this->getSchemaID());
-            $this->getDataMapper()->setParameter(':' . $this->getSchemaID(), $fields[$this->getSchemaID()]);
+            $this->getDataMapper()->setParameter(':' . $this->getSchemaID(), $schemaID);
             unset($fields[$this->getSchemaID()]);
         }
         if(empty($fields)){
             return false;
         }
+        $this->getValidation()->setData($fields);
         $data = [];
         foreach ($fields as $column => $value) {
+            if($this->getValidation()->validation($column, $schemaID) === FALSE){
+                $this->errors[] = $this->getValidation()->getError();
+                return false;
+            }
             $data[$column] = ':' . $column;
             $this->getDataMapper()->setParameter(':' . $column, $value);
         }
@@ -430,4 +480,12 @@ private function deletedFieldBuild(bool $reset = true): void
         }
     }
 
+    private function get_error_merge(): void
+    {
+        $error = $this->getDataMapper()->lastError();
+        if(!empty($error) && !\in_array($error, $this->errors)){
+            $this->errors[] = $error;
+        }
+    }
+
 }

src/Exceptions/ValidationException.php

@@ -0,0 +1,20 @@
+<?php
+/**
+ * ValidationException.php
+ *
+ * This file is part of Database.
+ *
+ * @author     Muhammet ŞAFAK <info@muhammetsafak.com.tr>
+ * @copyright  Copyright © 2022 Muhammet ŞAFAK
+ * @license    ./LICENSE  MIT
+ * @version    1.1.7
+ * @link       https://www.muhammetsafak.com.tr
+ */
+
+declare(strict_types=1);
+
+namespace InitPHP\Database\Exceptions;
+
+class ValidationException extends \Exception
+{
+}

src/Helper.php

@@ -104,7 +104,7 @@ public static function isSQLParameterOrFunction($value): bool
         }
         return ($value === '?'
             || (bool)\preg_match('/^:[\w]+$/', $value)
-            || (bool)\preg_match('/^[a-zA-Z\_]+\(\)$/', $value));
+            || (bool)\preg_match('/^[a-zA-Z_]+\(\)$/', $value));
     }
 
     public static function queryBindParameter($value, string $syntax = '{value}'): string