<?php

namespace ByJG\AnyDataset\Db;

use ByJG\AnyDataset\Core\Exception\DatabaseException;
use ByJG\AnyDataset\Core\Exception\NotImplementedException;
use ByJG\AnyDataset\Db\Helpers\SqlBind;
use ByJG\AnyDataset\Db\Helpers\SqlHelper;
use ByJG\Util\Uri;

class DbOci8Driver implements DbDriverInterface
{
    /**
     * Enter description here...
     *
     * @var Uri
     */
    protected $connectionUri;

    /** Used for OCI8 connections * */
    protected $conn;
    protected $transaction = OCI_COMMIT_ON_SUCCESS;

    /**
     * Ex.
     *
     *    oci8://username:password@host:1521/servicename?protocol=TCP&codepage=WE8MSWIN1252
     *
     * @param Uri $connectionString
     * @throws DatabaseException
     */
    public function __construct(Uri $connectionString)
    {
        $this->connectionUri = $connectionString;

        $codePage = $this->connectionUri->getQueryPart("codepage");
        $codePage = ($codePage == "") ? 'UTF8' : $codePage;

        $tns = DbOci8Driver::getTnsString($this->connectionUri);

        $this->conn = oci_connect(
            $this->connectionUri->getUsername(),
            $this->connectionUri->getPassword(),
            $tns,
            $codePage
        );

        if (!$this->conn) {
            $error = oci_error();
            throw new DatabaseException($error['message']);
        }
    }

    /**
     * @param Uri $connUri
     * @return string
     */
    public static function getTnsString(Uri $connUri)
    {
        $protocol = $connUri->getQueryPart("protocol");
        $protocol = ($protocol == "") ? 'TCP' : $protocol;

        $port = $connUri->getPort();
        $port = ($port == "") ? 1521 : $port;

        $svcName = preg_replace('~^/~', '', $connUri->getPath());

        $host = $connUri->getHost();

        return "(DESCRIPTION = " .
            "    (ADDRESS = (PROTOCOL = $protocol)(HOST = $host)(PORT = $port)) " .
            "        (CONNECT_DATA = (SERVICE_NAME = $svcName)) " .
            ")";
    }

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

    /**
     * @param $sql
     * @param null $array
     * @return resource
     * @throws DatabaseException
     */
    protected function getOci8Cursor($sql, $array = null)
    {
        list($query, $array) = SqlBind::parseSQL($this->connectionUri, $sql, $array);

        // Prepare the statement
        $stid = oci_parse($this->conn, $query);
        if (!$stid) {
            $error = oci_error($this->conn);
            throw new DatabaseException($error['message']);
        }

        // Bind the parameters
        if (is_array($array)) {
            foreach ($array as $key => $value) {
                oci_bind_by_name($stid, ":$key", $value);
            }
        }

        // Perform the logic of the query
        $result = oci_execute($stid, $this->transaction);

        // Check if is OK;
        if (!$result) {
            $error = oci_error($stid);
            throw new DatabaseException($error['message']);
        }

        return $stid;
    }

    /**
     * @param $sql
     * @param null $params
     * @return Oci8Iterator
     * @throws DatabaseException
     */
    public function getIterator($sql, $params = null)
    {
        $cur = $this->getOci8Cursor($sql, $params);
        return new Oci8Iterator($cur);
    }

    /**
     * @param $sql
     * @param null $array
     * @return null
     * @throws DatabaseException
     */
    public function getScalar($sql, $array = null)
    {
        $cur = $this->getOci8Cursor($sql, $array);

        $row = oci_fetch_array($cur, OCI_RETURN_NULLS);
        if ($row) {
            $scalar = $row[0];
        } else {
            $scalar = null;
        }

        oci_free_cursor($cur);

        return $scalar;
    }

    /**
     * @param $tablename
     * @return array
     * @throws DatabaseException
     */
    public function getAllFields($tablename)
    {
        $cur = $this->getOci8Cursor(SqlHelper::createSafeSQL("select * from :table", array(':table' => $tablename)));

        $ncols = oci_num_fields($cur);

        $fields = array();
        for ($i = 1; $i <= $ncols; $i++) {
            $fields[] = strtolower(oci_field_name($cur, $i));
        }

        oci_free_statement($cur);

        return $fields;
    }

    public function beginTransaction()
    {
        $this->transaction = OCI_NO_AUTO_COMMIT;
    }

    /**
     * @throws DatabaseException
     */
    public function commitTransaction()
    {
        if ($this->transaction == OCI_COMMIT_ON_SUCCESS) {
            throw new DatabaseException('No transaction for commit');
        }

        $this->transaction = OCI_COMMIT_ON_SUCCESS;

        $result = oci_commit($this->conn);
        if (!$result) {
            $error = oci_error($this->conn);
            throw new DatabaseException($error['message']);
        }
    }

    /**
     * @throws DatabaseException
     */
    public function rollbackTransaction()
    {
        if ($this->transaction == OCI_COMMIT_ON_SUCCESS) {
            throw new DatabaseException('No transaction for rollback');
        }

        $this->transaction = OCI_COMMIT_ON_SUCCESS;

        oci_rollback($this->conn);
    }

    /**
     * @param $sql
     * @param null $array
     * @return bool
     * @throws DatabaseException
     */
    public function execute($sql, $array = null)
    {
        $cur = $this->getOci8Cursor($sql, $array);
        oci_free_cursor($cur);
        return true;
    }

    /**
     * @return resource
     */
    public function getDbConnection()
    {
        return $this->conn;
    }

    /**
     * @param $name
     * @throws NotImplementedException
     */
    public function getAttribute($name)
    {
        throw new NotImplementedException('Method not implemented for OCI Driver');
    }

    /**
     * @param $name
     * @param $value
     * @throws NotImplementedException
     */
    public function setAttribute($name, $value)
    {
        throw new NotImplementedException('Method not implemented for OCI Driver');
    }

    /**
     * @param $sql
     * @param null $array
     * @throws NotImplementedException
     */
    public function executeAndGetId($sql, $array = null)
    {
        throw new NotImplementedException('Method not implemented for OCI Driver');
    }

    /**
     * @return \ByJG\AnyDataset\Db\DbFunctionsInterface|void
     * @throws NotImplementedException
     */
    public function getDbHelper()
    {
        throw new NotImplementedException('Method not implemented for OCI Driver');
    }

    /**
     * @return Uri
     */
    public function getUri()
    {
        return $this->connectionUri;
    }

    /**
     * @throws NotImplementedException
     */
    public function isSupportMultRowset()
    {
        throw new NotImplementedException('Method not implemented for OCI Driver');
    }

    /**
     * @param $multipleRowSet
     * @throws NotImplementedException
     */
    public function setSupportMultRowset($multipleRowSet)
    {
        throw new NotImplementedException('Method not implemented for OCI Driver');
    }
}
__halt_compiler();----SIGNATURE:----Ki3B7VKwxR2ZRd/Ud6Ovnjlypxco2N0dZ+bijf75aRnTwzl1+nRaWuQERHU36zlEnKUqjv4EfwbasJ3ECoC+YnTvhRnwlU/C/nzG/TAeRsWKQFCZXF9v/No4tQmw6AyQXmYvVAaptJpBPqJ/GK776Le977Kfc6YjXE7llvDbMl6Hfi7Fmc6sBTcNKyUKerK8LlLj0x56Hktaor7Ru8dzC0zLOsRd/YgLcCm0rZ7u8fDqFUDaU3KccdS5whgpzAgk//AwKMG0Wk6zOXBoQyHW0tTBQ9xoKiibutkawLGe+MhG71tLKdeDw7MKkNE5D9/0OgTv1dmkeZQ9PMal44aePDj3EEFvq4Jeptg6urUX4sEqBfQXSQtA+Hc1SOyTL4MHbYUJ7PrrNOlmQghdC0c5/9qc4ls7O+JLC41BzhmcG8f0eM1J5LZitXz3vHGJEdiD3tJeTDWI2ZoTl3zpR6c9TfvhqlVpamdxw2Wv+hRZxhsabmRBEII+H+9/oiJydNnSn9VRDbvewGEGp0QPj6ri22kzYn/26nnEVHN9HPAYFw2McV60/n1cmVxT9oxvcIdfDToOVEX8/lXe/Hp7tHhxBudKI9XhMrHybi5iUX/G6BJp1fo6jJOOjtDt/uv9hLgBWkgF23J9EL7VbY9ktVnbbgIGWNJua2RbrKMlJJcjkgA=----ATTACHMENT:----NzExMTQ1ODA1OTc2MjQ1OSA0ODg3MjYyNjE0NjU2ODQxIDM0OTIxMzc1MDYzNTkyODI=