Soluble\Japha\Db\DriverManager

Complexity

Total Complexity

11

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	createConnection()	0	21	5
A	getJdbcDsn()	0	12	3
A	getDriverManager()	0	7	2

<?php

declare(strict_types=1);

/*
 * Soluble Japha
 *
 * @link      https://github.com/belgattitude/soluble-japha
 * @copyright Copyright (c) 2013-2020 Vanvelthem Sébastien
 * @license   MIT License https://github.com/belgattitude/soluble-japha/blob/master/LICENSE.md
 */

namespace Soluble\Japha\Db;

use Soluble\Japha\Bridge;
use Soluble\Japha\Bridge\Exception;
use Soluble\Japha\Interfaces;

class DriverManager
{
    /**
     * @var Interfaces\JavaObject DriverManager object ('java.sql.DriverManager')
     */
    protected $driverManager;

    /**
     * @var Bridge\Adapter
     */
    protected $ba;

    /**
     * @param Bridge\Adapter $ba
     */
    public function __construct(Bridge\Adapter $ba)
    {
        $this->ba = $ba;
    }

    /**
     * Create an sql connection to database.
     *
     *
     * @throws Exception\JavaException
     * @throws Exception\ClassNotFoundException
     * @throws Exception\InvalidArgumentException
     * @throws Exception\BrokenConnectionException
     *
     * @param string $dsn
     * @param string $driverClass
     *
     * @return Interfaces\JavaObject Java('java.sql.Connection')
     */
    public function createConnection(string $dsn, string $driverClass = 'com.mysql.jdbc.Driver'): Interfaces\JavaObject
    {
        if (!is_string($dsn) || trim($dsn) == '') {

The condition is_string($dsn) is always true.

            $message = 'DSN param must be a valid (on-empty) string';
            throw new Exception\InvalidArgumentException(__METHOD__.' '.$message);
        }

        $class = $this->ba->javaClass('java.lang.Class');
        try {
            $class->forName($driverClass);

The method forName() does not exist on Soluble\Japha\Interfaces\JavaClass. Since you implemented __call, consider adding a @method annotation.

        } catch (Exception\JavaException $e) {
            throw $e;
        }

        try {
            $conn = $this->getDriverManager()->getConnection($dsn);

The method getConnection() does not exist on Soluble\Japha\Interfaces\JavaObject. Since you implemented __call, consider adding a @method annotation.

        } catch (Exception\JavaExceptionInterface $e) {
            throw $e;
        }

        return $conn;
    }

    /**
     * Return underlying java driver manager.
     *
     * @return Interfaces\JavaObject Java('java.sql.DriverManager')
     */
    public function getDriverManager(): Interfaces\JavaObject
    {
        if ($this->driverManager === null) {
            $this->driverManager = $this->ba->javaClass('java.sql.DriverManager');
        }

        return $this->driverManager;
    }

    /**
     * Return a JDBC DSN formatted string from options.
     *
     * @param string $driver   driver name  (mysql/mariadb/oracle/postgres...)
     * @param string $db       database name
     * @param string $host     server ip or name
     * @param string $user     username to connect
     * @param string $password password to connect
     * @param array  $options  extra options as an associative array
     *
     * @return string
     */
    public static function getJdbcDsn(string $driver, string $db, string $host, string $user, string $password, array $options = []): string
    {
        $extras = '';
        if (count($options) > 0) {
            $tmp = [];
            foreach ($options as $key => $value) {
                $tmp[] = urlencode($key).'='.urlencode($value);
            }
            $extras = '&'.implode('&', $tmp);
        }

        return "jdbc:$driver://$host/$db?user=$user&password=$password".$extras;
    }
}