<?php
    class Database {

        private $link;

        public function __construct() {
            // Notice that private connection information is *NOT* part of the source
            // and therefore does not end up in public repos, etc.
            //$connectionString = getenv("MYSQLCONNSTR_localdb");
            $connectionString = "Database=image;Data Source=localhost;User Id=image;Password=image";
            $varsString = str_replace(";","&", $connectionString);
            parse_str($varsString);

            $host = $Data_Source;
            $user = $User_Id;
            $pass = $Password;
            $db = $Database;
            
            try{
                $this->link = new PDO("mysql:host=".$host.";dbname=".$db, $user, $pass);
                $this->link->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            
            }
            catch (PDOException $e){
                echo "Error: Unable to connect to MySQL: ". $e->getMessage();
                die;
            }

            $this->InitializeImageTable();
        }   

        public function __destruct() {
            $this->link = null;
        }

        public function UploadImage($imageName, $imageFP) {
            $sql = $this->link->prepare("INSERT INTO images (name, image) VALUES (:name, :image);");
            $sql->bindParam(":name", $imageName);
            $sql->bindParam(":image", $imageFP, PDO::PARAM_LOB);

            $sql->execute();
        
            return $this->link->lastInsertId();
        }

        public function GetAllImages() {
            $sql = $this->link->prepare("SELECT * FROM images;");
            $sql->execute();
            
            $results = $sql->fetchAll(PDO::FETCH_OBJ);
            
            return $results;
        }

        public function FindImage($id) {
            $sql = $this->link->prepare("SELECT * FROM images WHERE id = :id;");
            $sql->bindParam(":id", $id, PDO::PARAM_INT);
            $sql->execute();
            
            $result = $sql->fetch(PDO::FETCH_OBJ);
            return $result;
        }

        private function InitializeImageTable() {
            // Check to see if the table needs to be created
            $results = $this->link->query("SHOW TABLES LIKE 'images';");
            if ($results == TRUE && $results->rowCount() > 0) {
                return;
            }

            // create table 
            $sql = "CREATE TABLE images (
                id INT(10) NOT NULL AUTO_INCREMENT PRIMARY KEY, 
                name VARCHAR(255) NOT NULL DEFAULT '',
                image LONGBLOB NOT NULL
                );";

            if ($this->link->query($sql) != TRUE) {
                die("Error creating image table: " . $this->link->error);
            }
        } 
    }
?>