initial commit

2022-10-25 13:47:30 +02:00 · 2022-10-25 13:47:30 +02:00 · 4665e1706f
commit 4665e1706f
parent 8189abfd29
1 changed files with 170 additions and 0 deletions
--- a/src/Repository/AddressRepository.php
+++ b/src/Repository/AddressRepository.php
@ -0,0 +1,170 @@
+<?php
+/*
+ * Copyright (c) 2022. Micha Espey <tracer@24unix.net>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ *
+ */
+
+namespace App\Repository;
+
+use App\Entity\AddressBookEntry;
+use App\Service\DatabaseConnection;
+use App\Entity\User;
+use PDO;
+use PDOException;
+
+/**
+ * Handles CRUD of Addresses class.
+ */
+class AddressRepository
+{
+    public function __construct(private readonly DatabaseConnection $databaseConnection)
+    {
+        // empty body
+    }
+
+    public function findAll(string $orderBy = 'last'): array
+    {
+        $users = [];
+        $sql = "
+            SELECT id, owner, first, last, street, zip, city, phone 
+            FROM " . DatabaseConnection::TABLE_ADDRESSES . "
+            ORDER BY :order";
+
+        try {
+            $statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+            $statement->bindParam(param: ':order', var: $orderBy);
+
+            $statement->execute();
+            $addresses = [];
+            while ($result = $statement->fetch(mode: PDO::FETCH_ASSOC)) {
+                $address = new AddressBookEntry(owner: $result['owner'], first: $result['first'], last: $result['last'], street: $result['street'], zip: $result['zip'], city: $result['city'], phone: $result['phone'], id: $result['id']);
+                $addresses[] = $address;
+            }
+            return $addresses;
+        } catch (PDOException $e) {
+            exit($e->getMessage());
+        }
+    }
+
+
+    public function findByID(int $id): ?AddressBookEntry
+    {
+        $sql = "
+            SELECT id, owner, first, last, street, zip, city, phone 
+            FROM " . DatabaseConnection::TABLE_USERS . "
+            WHERE id = :id";
+
+        try {
+            $statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+            $statement->bindParam(param: ':id', var: $id);
+            $statement->execute();
+            if ($result = $statement->fetch(mode: PDO::FETCH_ASSOC)) {
+                return new AddressBookEntry(owner: $result['owner'], first: $result['first'], last: $result['last'], street: $result['street'], zip: $result['zip'], city: $result['city'], phone: $result['phone'], id: $result['id']);
+            } else {
+                return null;
+            }
+        } catch (PDOException $e) {
+            exit($e->getMessage());
+        }
+    }
+
+
+    public function insert(AddressBookEntry $address): bool|string
+    {
+        $sql = "
+            INSERT INTO " . DatabaseConnection::TABLE_ADDRESSES . " (owner, first, last, city, zip, street, phone)
+            VALUES (:owner, :first, :last, :city, :zip, :street, :phone)";
+
+        try {
+            $owner = $address->getOwner();
+            $first = $address->getFirst();
+            $last = $address->getLast();
+            $city = $address->getCity();
+            $zip = $address->getZip();
+            $street = $address->getStreet();
+            $phone = $address->getPhone();
+
+            $statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+            $statement->bindParam(param: ':owner', var: $owner);
+            $statement->bindParam(param: ':first', var: $first);
+            $statement->bindParam(param: ':last', var: $last);
+            $statement->bindParam(param: ':city', var: $city);
+            $statement->bindParam(param: ':zip', var: $zip);
+            $statement->bindParam(param: ':street', var: $street);
+            $statement->bindParam(param: ':phone', var: $phone);
+            $statement->execute();
+
+            return $this->databaseConnection->getConnection()->lastInsertId();
+        } catch (PDOException $e) {
+            exit($e->getMessage());
+        }
+    }
+
+
+    public function update(Address $address): bool|int
+    {
+        /*
+        $id = $user->getId();
+        $nick = $user->getNick();
+        $first = $user->getFirst();
+        $last = $user->getLast();
+        $isAdmin = $user->isAdmin() ? 1 : 0;
+
+        if ($user->getPassword()) {
+            $password = $user->getPassword();
+        } else {
+            $current = $this->findByID(id: $id);
+            $password = $current->getPassword();
+        }
+
+        $sql = "
+			UPDATE " . DatabaseConnection::TABLE_USERS . " SET
+				nick = :nick,
+				password = :password,
+				first = :first,
+				last = :last,
+				is_admin = :is_admin
+            WHERE id = :id";
+
+        try {
+            $statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+            $statement->bindParam(param: 'id', var: $id);
+            $statement->bindParam(param: 'nick', var: $nick);
+            $statement->bindParam(param: 'password', var: $password);
+            $statement->bindParam(param: 'first', var: $first);
+            $statement->bindParam(param: 'last', var: $last);
+            $statement->bindParam(param: 'is_admin', var: $isAdmin);
+            $statement->execute();
+
+            return $statement->rowCount();
+        } catch (PDOException $e) {
+            echo $e->getMessage();
+            return false;
+        }
+        */
+        return false;
+    }
+
+
+    public function delete(AddressBookEntry $addressBookEntry): int
+    {
+        $sql = "
+            DELETE FROM " . DatabaseConnection::TABLE_ADDRESSES . "
+            WHERE id = :id";
+
+        try {
+            $statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+            $id = $addressBookEntry->getId();
+            $statement->bindParam(param: 'id', var: $id);
+            $statement->execute();
+
+            return $statement->rowCount();
+        } catch (PDOException $e) {
+            exit($e->getMessage());
+        }
+    }
+
+}