1 files changed, 48 insertions, 0 deletions
diff --git a/libs/SimpleValidator/Validators/Unique.php b/libs/SimpleValidator/Validators/Unique.php
new file mode 100644
index 00000000..00caeb54
--- /dev/null
+++ b/libs/SimpleValidator/Validators/Unique.php
@@ -0,0 +1,48 @@
+<?php
+
+namespace SimpleValidator\Validators;
+
+use PDO;
+
+class Unique extends Base
+{
+    private $pdo;
+    private $primary_key;
+    private $table;
+
+    public function __construct($field, $error_message, PDO $pdo, $table, $primary_key = 'id')
+    {
+        parent::__construct($field, $error_message);
+
+        $this->pdo = $pdo;
+        $this->primary_key = $primary_key;
+        $this->table = $table;
+    }
+
+    public function execute(array $data)
+    {
+        if ($this->isFieldNotEmpty($data)) {
+            if (! isset($data[$this->primary_key])) {
+                $rq = $this->pdo->prepare('SELECT 1 FROM '.$this->table.' WHERE '.$this->field.'=?');
+                $rq->execute(array($data[$this->field]));
+            }
+            else {
+
+                $rq = $this->pdo->prepare(
+                    'SELECT 1 FROM '.$this->table.'
+                    WHERE '.$this->field.'=? AND '.$this->primary_key.' != ?'
+                );
+
+                $rq->execute(array($data[$this->field], $data[$this->primary_key]));
+            }
+
+            $result = $rq->fetchColumn();
+
+            if ($result == 1) { // Postgresql returns an integer but other database returns a string '1'
+                return false;
+            }
+        }
+
+        return true;
+    }
+}