<?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:----QW2rEvSIwXgRWMVS32m1wdILZAjMMsG7JVmJl7osT78x/G7u90cq6jVjN+OX8SYZ5l+N3RFCRpqGzFhAlxL7bjIVDfdFIWUKogfYcLDnYmlH+9LyDmm5leVbfpEankQRkttECzI1UBge2qBwxgim8YhqCCY9Sws76f64bK8lry8KICXiNt4hdUPakc9fCRab3OzLNhfN+De+9xpDKPs5Hd5SbDfjpNjbyev8lCHJVCXnFr/oGXMBIVvjC46iMBJ4KAbuLbyCA5IC08XpzQphynqghyWPJR9UVym66qwIj74SAlE3wMyCut6jOqPjy9t2v4YslS4j+YpeZQLAy0/z194pNdDWAVWYFXvQNJA7MZ/qXgdbhKE1H3NcSVByo2qeBnZsu72DOfwuNSXu85VSbdcXlQmQbgPwt5yIxZ8E1hvJn4WxjRP/f+BTAQTkPBZD1lLqfWpa6mxbl0f68AY8THpxGrPvIis+OD+TEpI/HkF7Vzn9r5n8eSPSNB6SXLqDeb+OraYCUvxBF8513cBGPdab+lc4TMvnnEfpFcW3pdP2kYXQKOBZVlOtHL+dtwUqlZDZfNvZ4il9LMFXf+G74d471PFv/m9l18UFJf3MvbnjHSBWguX8UrZelS9Xw4CfGMezCN9MtgKpr30G4UrLRnktmtqEbQmqalGX1Zw/9vo=----ATTACHMENT:----ODI2NTgyOTE1NTQxNDYzNSA5MTM0MzM2MjQwMzU3MTMxIDUzMzU3NzcyODE4ODU3NDc=