<?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:----QWwbqTARSqGQDkpvb6lzedfnGn5q/FlSOK1O8Z//GQodD/dynd8Kja58i8RF+gmhL1BdCS7a5YbAqHZZh91uEj+z5k6VhG1kpeyeHAJtrPxQBN2FtzKVMzmIx9EiQ5adg2v+T4+iplXwl7TvtWKwgrxQINwbEDT2sQ7nvxhwVWeb+fmfE+oFthp1hFCHWjVUTWesq48tQusNxoKbWcDXh6dS7jCHCllwIeSLMtNWP9OO8K6/NPSy4TiGDDGqjF2ZdgcosXq53jjZ7+JxzKA7dDQngRhIMpu3ZXUS/uCiAw6qzOZFJE5e82kwQIT7H3W0ANFej1Cka861vc4E/84KyKvHgmt2r/VVuq333bON+RqYsa2IzoC7DhD35CCSn+7+M+RcC2jwg7L7w9IfLvhe/MDvk18wme6EpMVkXH+NgILDnHMWQ3NXSd65xNjhUAahAmlPjhgU64ylHS54cKpILvhF3HvI/+INRDfnQHhQaMGIuezmi6ZQKjL2BgLolEfv54qVrryL8UO9kVTGfMcqTw/8WoZ0sPtR3llxL1cID45VIGu80X040g2Yn8eX5FEMc/Ah+EvhsCIRhmnWaiVBPSGhyAjeu563Nb7mVBKmmQexUURd6MvTFSzpfIiZUGFfTUISA6YW7oD4bFzKzPlylz9vXIV/rnxiamswh3f4Eqs=----ATTACHMENT:----MzgyNTA2NTE0MDU1OTMwNCAyNjkxNjQ0MjUwNjM3NjAyIDU3MDU4Mjg5OTA5ODQyODU=