<?php

namespace ByJG\AnyDataset\Db;

use ByJG\Util\Uri;

class Factory
{
    /**
     * @param $connectionString
     * @param $schemesAlternative
     * @return \ByJG\AnyDataset\Db\DbDriverInterface
     */
    public static function getDbRelationalInstance($connectionString, $schemesAlternative = null)
    {
        return self::getDbInstance(new Uri($connectionString), $schemesAlternative);
    }

    /**
     * @param $connectionUri Uri
     * @param $schemesAlternative
     * @return mixed
     */
    public static function getDbInstance($connectionUri, $schemesAlternative = null)
    {
        $scheme = $connectionUri->getScheme();

        $prefix = '\\ByJG\\AnyDataset\\Db\\';
        $validSchemes =  array_merge(
            [
                "oci8" => $prefix . "DbOci8Driver",
                "dblib" => $prefix . "PdoDblib",
                "sqlsrv" => $prefix . "PdoSqlsrv",
                "mysql" => $prefix . "PdoMysql",
                "pgsql" => $prefix . "PdoPgsql",
                "oci" => $prefix . "PdoOci",
                "odbc" => $prefix . "PdoOdbc",
                "sqlite" => $prefix . "PdoSqlite",
                "pdo" => $prefix . "PdoPdo"
            ],
            (array)$schemesAlternative
        );

        if (!isset($validSchemes[$scheme])) {
            throw new \InvalidArgumentException("The '$scheme' scheme does not exist. Check the scheme name or use the Generic PDO scheme");
        }

        $class = $validSchemes[$scheme];

        $instance = new $class($connectionUri);

        if (!($instance instanceof DbDriverInterface)) {
            throw new \InvalidArgumentException(
                "The class '$class' is not a instance of DbDriverInterface"
            );
        }

        return $instance;
    }

    /**
     * Get a IDbFunctions class to execute Database specific operations.
     *
     * @param \ByJG\Util\Uri $connectionUri
     * @return \ByJG\AnyDataset\Db\DbFunctionsInterface
     */
    public static function getDbFunctions(Uri $connectionUri)
    {
        $dbFunc = "\\ByJG\\AnyDataset\\Db\\Helpers\\Db"
            . ucfirst($connectionUri->getScheme())
            . "Functions";
        return new $dbFunc();
    }
}
__halt_compiler();----SIGNATURE:----FFH6PuzUkBG0gy1CnHPkrWnj9YrW5sZjl6J0ycUhsfXFAFNuZT//jZTNSyNQjJvAKbYyUHO5ZOMbgC5KwEXst+LbU37W3UIAOzKgQ6slBASY7lhUTgOe53OATl2I0TlGAmXzjgwbdOWJ4HLlPRX3tMeqTCmNKrvh0abjEAG/9u+HZyEjmBp2gF+XdIrPJQMzWIHDEKcdZnJkC2VBDLrpIKAHzChUz70276ner51LCAkJGqSD88RnUrxDHh7/28RdfeFDgBhK5fBcdubDsKi6hz9U3frwI2E+PuK6txDdxMx1KRgipSXWLdV1xES465o2XSVxkg0OG4xuUYj1yLXWAAc2dHiDJlX64k67IDfEKN7MHxsZZ4/FrE+A9/d646p40VQ9t7lrMHU7QabBiqHZZqzhWP0c+jIbwV7lsrm8blGNTeJ8riCUFQ3ZkUYk1sC11uv8YEfHPSWXJlZAaijfthqXfLiI4ohpK88bNwzxYjRZJigLjA1zkFnqMnzuHIEyWoRgyA7+cWYugkj3BipYIUF4vf9zSLJhMMFt1JKEXO1rKp4/aQZMLrXO9PINMPDOW7GZWf2/+8fwja1h6WZcbXuWbTmE60qHwNy7ZzavYm2c5P7umoC1EWh2vWtLOyvcdBGmwwa3/Xf4VNXtpQQiFSd4vWgsh8g2BInqgtNdLbE=----ATTACHMENT:----MTk0MzIzNTg2NTk5NDUzMyAzOTMwOTUwODMzOTQzMzg4IDcxNDgzOTI4OTkwODY3NTU=