Lechimp\Dicto\App\IndexDB

Complexity

Total Complexity

16

Size/Duplication

Total Lines	258
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

98.98%

Importance

Changes	1
Bugs	0	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	builder()	0	3	1
A	source_file()	0	20	2
A	entity()	0	23	1
A	reference()	0	20	1
A	relation()	0	16	1
A	source_file_table()	0	3	1
A	entity_table()	0	3	1
A	reference_table()	0	3	1
A	relations_table()	0	3	1
A	init_sqlite_regexp()	0	10	2
A	maybe_init_database_schema()	0	11	2
B	init_database_schema()	0	95	1

<?php
/******************************************************************************
 * An implementation of dicto (scg.unibe.ch/dicto) in and for PHP.
 *
 * Copyright (c) 2016, 2015 Richard Klees <richard.klees@rwth-aachen.de>
 *
 * This software is licensed under The MIT License. You should have received
 * a copy of the license along with the code.
 */

namespace Lechimp\Dicto\App;

use Lechimp\Dicto\Variables\Variable;
use Lechimp\Dicto\Analysis\Query;
use Lechimp\Dicto\Analysis\CompilesVars;
use Lechimp\Dicto\Indexer\Insert;
use Lechimp\Dicto\Indexer\CachesReferences;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema;
use Doctrine\DBAL\Types\Type;
use Doctrine\DBAL\Schema\Synchronizer\SingleDatabaseSynchronizer;

class IndexDB implements Insert, Query {
    use CachesReferences;

    /**
     * @var Connection
     */
    protected $connection;

    public function __construct(Connection $connection) {
        $this->connection = $connection;
    }

    /**
     * @return \Doctrine\DBAL\Query\Builder
     */
    public function builder() {
        return $this->connection->createQueryBuilder();
    }

    // Implementation of Insert interface.

    /**
     * @inheritdoc
     */
    public function source_file($name, $content) {
        assert('is_string($name)');
        assert('is_string($content)');
        $stmt = $this->builder()
            ->insert($this->source_file_table())
            ->values(array
                ( "name" => "?"
                , "line" => "?"
                , "source" => "?"
                ))
            ->setParameter(0, $name);
        $line = 1;
        foreach (explode("\n", $content) as $source) {
            $stmt
                ->setParameter(1, $line)
                ->setParameter(2, $source)
                ->execute();
            $line++;
        }
    }

    /**
     * @inheritdoc
     */
    public function entity($type, $name, $file, $start_line, $end_line) {
        assert('\\Lechimp\\Dicto\\Variables\\Variable::is_type($type)');
        assert('is_string($name)');
        assert('is_string($file)');
        assert('is_int($start_line)');
        assert('is_int($end_line)');
        $this->builder()
            ->insert($this->entity_table())
            ->values(array
                ( "type" => "?"
                , "name" => "?"
                , "file" => "?"
                , "start_line" => "?"
                , "end_line" => "?"
                ))
            ->setParameter(0, $type)
            ->setParameter(1, $name)
            ->setParameter(2, $file)
            ->setParameter(3, $start_line)
            ->setParameter(4, $end_line)
            ->execute();
        return (int)$this->connection->lastInsertId();
    }

    /**
     * @inheritdoc
     */
    public function reference($type, $name, $file, $line) {
        assert('\\Lechimp\\Dicto\\Variables\\Variable::is_type($type)');
        assert('is_string($name)');
        assert('is_string($file)');
        assert('is_int($line)');
        $this->builder()
            ->insert($this->reference_table())
            ->values(array
                ( "type" => "?"
                , "name" => "?"
                , "file" => "?"
                , "line" => "?"
                ))
            ->setParameter(0, $type)
            ->setParameter(1, $name)
            ->setParameter(2, $file)
            ->setParameter(3, $line)
            ->execute();
        return (int)$this->connection->lastInsertId();
    }

    /**
     * @inheritdoc
     */
    public function relation($name, $entity_id, $reference_id) {
        assert('is_string($name)');
        assert('is_int($entity_id)');
        assert('is_int($reference_id)');
        $this->builder()
            ->insert($this->relations_table())
            ->values(array
                ( "name" => "?"
                , "entity_id" => "?"
                , "reference_id" => "?"
                ))
            ->setParameter(0, $name)
            ->setParameter(1, $entity_id)
            ->setParameter(2, $reference_id)
            ->execute();
    }

    // Naming

    public function source_file_table() {
        return "files";
    }

    public function entity_table() {
        return "entities";
    } 

    public function reference_table() {
        return "refs";
    }

    public function relations_table() {
        return "relations";
    }

    /**
     * Initialize REGEXP for sqlite.
     */
    public function init_sqlite_regexp() {
        $pdo = $this->connection->getWrappedConnection();
        if (!($pdo instanceof \PDO)) {
            throw new \RuntimeException(
                "Expected wrapped connection to be PDO-object.");
        }
        $pdo->sqliteCreateFunction("regexp", function($pattern, $data) {
            return preg_match("%$pattern%", $data) > 0;
        });
    }

    // Creation of database.

    public function maybe_init_database_schema() {
        $res = $this->builder()
            ->select("COUNT(*)")
            ->from("sqlite_master")
            ->where("type = 'table'")
            ->execute()
            ->fetchColumn();
        if ($res == 0) {
            $this->init_database_schema();
        }
    }

    public function init_database_schema() {
        $schema = new Schema\Schema();

        $file_table = $schema->createTable($this->source_file_table());
        $file_table->addColumn
            ( "name", "string"
            , array("notnull" => true)
            );
        $file_table->addColumn
            ( "line", "integer"
            , array("notnull" => true, "unsigned" => true)
            );
        $file_table->addColumn
            ( "source", "string"
            , array("notnull" => true)
            );
        $file_table->setPrimaryKey(array("name", "line"));

        $entity_table = $schema->createTable($this->entity_table());
        $entity_table->addColumn
            ("id", "integer"
            , array("notnull" => true, "unsigned" => true, "autoincrement" => true)
            );
        $entity_table->addColumn
            ("type", "string"
            , array("notnull" => true)
            );
        $entity_table->addColumn
            ("name", "string"
            , array("notnull" => true)
            );
        $entity_table->addColumn
            ("file", "string"
            , array("notnull" => true)
            );
        $entity_table->addColumn
            ("start_line", "integer"
            , array("notnull" => true, "unsigned" => true)
            );
        $entity_table->addColumn
            ("end_line", "integer"
            , array("notnull" => true, "unsigned" => true)
            );
        $entity_table->setPrimaryKey(array("id"));

        $reference_table = $schema->createTable($this->reference_table());
        $reference_table->addColumn
            ( "id", "integer"
            , array("notnull" => true, "unsigned" => true, "autoincrement" => true)
            );
        $reference_table->addColumn
            ("type", "string"
            , array("notnull" => true)
            );
        $reference_table->addColumn
            ("name", "string"
            , array("notnull" => true)
            );
        $reference_table->addColumn
            ("file", "string"
            , array("notnull" => true)
            );
        $reference_table->addColumn
            ("line", "integer"
            , array("notnull" => true, "unsigned" => true)
            );
        $reference_table->setPrimaryKey(array("id"));

        $relations_table = $schema->createTable($this->relations_table());
        $relations_table->addColumn
            ("name", "string"
            , array("notnull" => true)
            );
        $relations_table->addColumn
            ( "entity_id", "integer"
            , array("notnull" => true, "unsigned" => true)
            );
        $relations_table->addColumn
            ( "reference_id", "integer"
            , array("notnull" => true, "unsigned" => true)
            );
        $relations_table->addForeignKeyConstraint
            ( $entity_table
            , array("entity_id")
            , array("id")
            );
        $relations_table->addForeignKeyConstraint
            ( $reference_table
            , array("reference_id")
            , array("id")
            );

        $sync = new SingleDatabaseSynchronizer($this->connection);
        $sync->createSchema($schema);
    }
}