<?php

require_once("lekar.php");
require_once("IDB.php");

class DB implements IDB {
    const host = "localhost";
    const username = "root";
    const password = "";
    const dbName = "kol2grupaa";

    public static function vratiLekara() {
        $con = new mysqli(self::host, self::username, self::password, self::dbName);
        if ($con->connect_errno) {
        // u slucaju greske odstampati odgovarajucu poruku
        print ("Connection error (" . $con->connect_errno . "): $con->connect_error");
        }
        else {
            // $res je rezultat izvrsenja upita
            $res = $con->query("SELECT * FROM lekar");
            $lekar = null;
            if ($res) {
                $row = array();
                // fetch_assoc() pribavlja jedan po jedan red iz rezulata
            // u redosledu u kom ga je vratio db server
                if ($row = $res->fetch_assoc()) {
                    $lekar = new Lekar($row["faksimil"],$row["ime"],$row["prezime"]);
                }
                // zatvaranje objekta koji cuva rezultat
                $res->close();

                $rezzz = $con->query("SELECT * from pacijent WHERE lekar_id = $lekar->faksimil;");
                if ($rezzz) {
                    $red = array();
                    while ($red = $rezzz->fetch_assoc()) {
                        $pacijent = new Pacijent($red["jmbg"],$red["ime"],$red["prezime"],$red["pol"],$red["dete"]);
                        $lekar->dodaj($pacijent);
                    }
                }
                else
                {
                    print ("Query failed");
                }
            }
            else
            {
                print ("Query failed");
            }
            $con->close();
            return $lekar;
        }
    }

    public static function izmeniPacijenta(Pacijent $pacijent) {
        $con = new mysqli(self::host, self::username, self::password, self::dbName);
        if ($con->connect_errno) {
        // u slucaju greske odstampati odgovarajucu poruku
        print ("Connection error (" . $con->connect_errno . "): $con->connect_error");
        }
        else {
            // $res je rezultat izvrsenja upita
            if ($pacijent->dete)
                $d = 1;
            else
                $d = 0;

            $res = $con->query("UPDATE pacijent SET ime='$pacijent->ime',"
                    . " prezime='$pacijent->prezime', pol='$pacijent->pol',"
                    . " dete=$d WHERE jmbg='$pacijent->jmbg';");

            if (!$res) {
                print ("Query failed");
            }
            $con->close();
        }
    }
}

?>