dbTransactions.php

<?php

namespace Database\Transactions;

include_once "db.php";
include_once "Log.php";
include_once "utils.php";

abstract class Transaction
{
	private $committed;
    private $properties;
	protected function __construct()
	{
		$this->committed=false;
    $this->properties=array();
	}
	public function __set($property,$value)
	{
		if($property!='committed' && array_key_exists($property,$this->properties))
		{
			if(is_array($this->properties[$property]) && !is_array($value))
			{
					array_push($this->properties[$property],$value);
			}
			else
			{
					$this->properties[$property]=$value;
			}
		}
	}
	public function __get($property)
	{
			if($property!='committed' && array_key_exists($property,$this->properties))
			{
				return $this->properties[$property];
			}
			return null;
	}
	public function commit()
	{
		if(!$this->committed)
		{
      $this->exec_commit();
			$this->committed=true;
		}
	}
	public function rollback()
	{
		if($this->committed)
		{
      $this->exec_rollback();
			$this->committed=false;
		}
	}
	abstract protected function exec_commit();
	abstract protected function exec_rollback();
  protected function create_prop($name,$value)
  {
      $this->properties[$name]=$value;
  }
}

class CreateBook extends Transaction
{
    public function __construct()
    {
        parent::__construct();
        $this->create_prop('filename',null);
        $this->create_prop('bookid',null);
        $this->create_prop('hash',null);
        $this->create_prop('size',null);
        $this->create_prop('descr',null);
        $this->create_prop('year',null);
        $this->create_prop('title',null);
        $this->create_prop('author',null);
        $this->create_prop('img',null);
        $this->create_prop('vendor',null);
        $this->create_prop('subjects',array());
        $this->create_prop('file_id',null);
        $this->create_prop('file_size',null);
    }
    protected function exec_commit()
    {
        $dbase = \Database\odbc()->connect();
        if($dbase)
        {
						$con = $dbase->con();
            $title=mysqli_real_escape_string($con,$this->title);
            $descr=mysqli_real_escape_string($con,$this->descr);
            $author=mysqli_real_escape_string($con,$this->author);
            $size=$this->size;
            $year=$this->year;
            $hash=$this->hash;
            $img=mysqli_real_escape_string($con,$this->img);
            $file_id=$this->file_id;
            $file_size=$this->file_size;
            $vendor=$this->vendor;
            $filename=mysqli_real_escape_string($con,$this->filename);
						
						$sql="INSERT INTO BOOKS (TITLE,DESCR,AUTHORS,SIZE,YEAR,HASH,IMG_PATH) VALUES ('$title','$descr','$author',$size,'$year','$hash','$img')";
            $res=$dbase->query($sql);
            if(!$res)
            {
                $dbase->close();
                throw new \Exception('database error: '.$sql);
            }
            $id=$this->bookid = $res;

            foreach($this->subjects as $subject)
            {
							if(strlen($subject)>0)
							{
								$subject_id=\utils\selectOrCreateSubject($dbase,$subject);
								if($subject_id>0)
								{
	                $dbase->query("INSERT INTO BOOKS_SUBJECTS_ASSOC (SUBJECT_ID,BOOK_ID) VALUES ($subject_id,$id)");								
								}
								else
								{
									\Logs\logDebug('cannot get subjects id for \'' . $subject . '\'');
								}	
							}
            }

            $res=$dbase->query("SELECT ID FROM FILE_STORE WHERE VENDOR_CODE='$vendor'");
            $store_id=null;
            if($res->next())
            {
                $store_id=$res->field_value('ID');
            }
            else
            {
                $dbase->close();
                throw new \Exception('cannot get file store id.');
            }
            $dbase->query("INSERT BOOKS_LINKS(BOOK_ID,STORE_ID,FILE_ID,FILE_SIZE,FILE_NAME) VALUES($id,$store_id,'$file_id',$file_size,'$filename')");

            $dbase->close();
        }
    }
	public function exec_rollback()
    {
    }
}

class DeleteBook extends Transaction
{
    public function __construct()
    {
        parent::__construct();
        $this->create_prop('bookid',null);
    }
    protected function exec_commit()
    {
         $dbase = \Database\odbc()->connect();
         if($dbase)
         {
             $bookid=$this->bookid;
             $dbase->query("DELETE FROM BOOKS WHERE ID=$bookid");
             $dbase->query("DELETE FROM BOOKS_LINKS WHERE BOOK_ID=$bookid");
             $dbase->query("DELETE FROM BOOKS_SUBJECTS_ASSOC WHERE BOOK_ID=$bookid");
					 	 $dbase->query("DELETE FROM IT_SUBJECT WHERE ID NOT IN (SELECT SUBJECT_ID FROM BOOKS_SUBJECTS_ASSOC) AND PERMANENT=0");
             $dbase->close();
         }
    }
    public function exec_rollback()
    {
    }
}

?>