PHPPackage\PDOWrapper\Database

Complexity

Total Complexity

7

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	create()	0	11	2
A	name()	0	8	2
A	all()	0	10	2

<?php
declare(strict_types=1);

/*
 +-----------------------------------------------------------------------------+
 | PHPPackage - PDO Wrapper
 +-----------------------------------------------------------------------------+
 | Copyright (c)2018 (http://github.com/phppackage/pdo-wrapper)
 +-----------------------------------------------------------------------------+
 | This source file is subject to MIT License
 | that is bundled with this package in the file LICENSE.
 |
 | If you did not receive a copy of the license and are unable to
 | obtain it through the world-wide-web, please send an email
 | to lawrence@cherone.co.uk so we can send you a copy immediately.
 +-----------------------------------------------------------------------------+
 | Authors:
 |   Lawrence Cherone <lawrence@cherone.co.uk>
 +-----------------------------------------------------------------------------+
 */

namespace PHPPackage\PDOWrapper;

class Database
{
    /**
     * @var PHPPackage\PDOWrapper\PDO

The type PHPPackage\PDOWrapper\PHPPackage\PDOWrapper\PDO was not found. Did you mean PHPPackage\PDOWrapper\PDO? If so, make sure to prefix the type with \.

     */
    private $pdo;

    /**
     * 
     */
    public function __construct(PDO $pdo)
    {
        $this->pdo = $pdo;

It seems like $pdo of type PHPPackage\PDOWrapper\PDO is incompatible with the declared type PHPPackage\PDOWrapper\PHPPackage\PDOWrapper\PDO of property $pdo.

    }

    /**
     * Get database name from dsn
     *
     * @throws RuntimeException
     * @return string
     */
    public function name(string $dsn): string
    {
        // match database from dsn & set working vars
        if (!preg_match('/dbname=(\w+);/', $dsn, $results)) {
            throw new \RuntimeException('Could not match database name from dsn');
        }

        return $results[1];
    }

    /**
     * Create database
     *
     * @return bool
     */
    public function create(string $name, $username, $password): bool
    {
        if (!in_array($name, $this->all())) {
            return (bool) $this->pdo->exec("
                CREATE DATABASE `$name`;
                CREATE USER '{$username}'@'%' IDENTIFIED BY '{$password}';
                GRANT ALL ON `$name`.* TO '{$username}'@'%';
                FLUSH PRIVILEGES;
            ");
        }
        return false;
    }

    /**
     * Returns an array of databases
     * @return mixed
     */
    public function all(): array
    {
        $stmt = $this->pdo->query("SHOW DATABASES");

        $result = [];
        while ($row = $stmt->fetchColumn(0)) {
            $result[] = $row;
        }

        return $result;
    }

}