mindplay\sql\postgres\PostgresDatabase

Complexity

Total Complexity

9

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

91.67%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	bootstrap()	0	12	1
A	createConnection()	0	4	1
A	quoteName()	0	4	1
A	quoteTableName()	0	6	2
A	select()	0	4	1
A	insert()	0	4	1
A	update()	0	4	1
A	delete()	0	4	1

<?php

namespace mindplay\sql\postgres;

use mindplay\sql\model\Database;
use mindplay\sql\model\DatabaseContainer;
use mindplay\sql\model\DatabaseContainerFactory;
use mindplay\sql\model\Driver;
use mindplay\sql\model\schema\Table;
use mindplay\sql\model\types\BoolType;
use mindplay\sql\model\types\FloatType;
use PDO;

class PostgresDatabase extends Database implements Driver
{
    protected function bootstrap(DatabaseContainerFactory $factory)
    {
        $factory->set(Driver::class, $this);
        
        $factory->register(BoolType::class, function () {
            return BoolType::get(true, false);
        });
        
        $factory->alias("scalar.boolean", BoolType::class);

        $factory->register("scalar.double", FloatType::class);
    }

    /**
     * @param PDO $pdo
     *
     * @return PostgresConnection
     */
    public function createConnection(PDO $pdo)
    {
        return $this->container->create(PostgresConnection::class, ['pdo' => $pdo]);
    }

    /**
     * @inheritdoc
     */
    public function quoteName($name)
    {
        return '"' . $name . '"';
    }

    /**
     * @inheritdoc
     */
    public function quoteTableName($schema, $table)
    {
        return $schema
            ? '"' . $schema . '"."' . $table . '"'
            : '"' . $table . '"';
    }

    /**
     * @param Table $from
     *
     * @return PostgresSelectQuery
     */
    public function select(Table $from)
    {
        return $this->container->create(PostgresSelectQuery::class, ['root' => $from]);
    }
    
    /**
     * @param Table $into
     *
     * @return PostgresInsertQuery
     */
    public function insert(Table $into)
    {
        return $this->container->create(PostgresInsertQuery::class, ['table' => $into]);
    }

    /**
     * @param Table $table
     *
     * @return PostgresUpdateQuery
     */
    public function update(Table $table)
    {
        return $this->container->create(PostgresUpdateQuery::class, ['table' => $table]);
    }

    /**
     * @param Table $table
     *
     * @return PostgresDeleteQuery
     */
    public function delete(Table $table)
    {
        return $this->container->create(PostgresDeleteQuery::class, ['table' => $table]);
    }
}