<?php

namespace ByJG\AnyDataset\Db;

use ByJG\Util\Uri;

class PdoOci extends PdoLiteral
{
    public static function schema(): array
    {
        return ['oracle'];
    }

    public function __construct(Uri $connUri)
    {
        parent::__construct($this->createPdoConnStr($connUri), $connUri->getUsername(), $connUri->getPassword(), [], []);
    }

    protected function createPdoConnStr(Uri $connUri): string
    {
        return $connUri->getScheme(). ":dbname=" . self::getTnsString($connUri);
    }

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

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

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

        $host = $connUri->getHost();

        return "(DESCRIPTION = " .
            "    (ADDRESS = (PROTOCOL = $protocol)(HOST = $host)(PORT = $port)) " .
            "        (CONNECT_DATA = (SERVICE_NAME = $svcName)) " .
            ")";
    }
}__halt_compiler();----SIGNATURE:----JhAMXek4l5Hg87agyWravIHH2CABTY+lR9cUmzPirU8tS0/0vFjo2RiVFDuGwE8LuGdY3mCexeG+AMEPrbrAbWh56OVtOt6DUBfMsXrHDKo4jNkK2FacQKqTBrKAg05waqRfI+vXhjmVbz3nKnhXxvdO4jK0uGBFG9O/BfRm+/Vw2VYzcKAqcfVl7WCiCGb7DFj0ZeKLPEVzI+udfzbMH3Qp4V+/3RZyXshE7t8JhfdHq822t+7+njMcKjjnUoE/TEhH8OPjGexurAaudXQT3oXN1nULjVVliN897d0k5y9aS6MKtbUR0ATWs3G3qrfiw3xpse8oiRcTlGXWucWnuMaN4BVBNBgvIF8R82gVCaSN0HfzgWPvcZVG4eZiXSdi/GsLi2rr3Mqi6pIyJWBi7XpLvC2Flye4ENnNU/Dt4Ym2h1yil3R2SVt7wSIcYcH1cJk03G/EDIT4f9JzY0fZGTTZEIy6rxDrGjh481HKAEyTbq92HeR1ZH+4VNZIG5BKmX1bGfTRJ3KpBAFZnaWrad6j927s2cKj4gJBu/xShFJPM56tYk+NuCihMWH92x09uj5DX9VHeLQ1GMCNT+8pbYLOylpGIFEJa87hW6Ki1EhvQ+p6jCp1YBET3e640yiuDBXT98R+cJSC3olIHJJukC1uy1YpfEnNIjZzO9o8HiM=----ATTACHMENT:----NDg5ODE0NDE5NDc0Mjc3MSA3NDQ2MDExMjg3MTQ5NDc3IDY1NTYzMzcwNjQ3ODUwMDA=