Graze\DataDb\Dialect\MysqlDialect

Complexity

Total Complexity

17

Size/Duplication

Total Lines	204
Duplicated Lines	19.61 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	getIdentifierQuote()	0	4	1
A	getCreateTableLike()	10	10	1
B	getDeleteTableJoinSoftDelete()	0	30	3
A	getDeleteTableJoin()	23	23	2
A	getDeleteFromTableSoftDelete()	0	19	3
A	getCreateTable()	0	15	1
A	getColumnDefinition()	7	7	2
A	getPrimaryKeyDefinition()	0	4	1
A	getIndexDefinition()	0	4	1
A	getDescribeTable()	0	4	1
A	getCreateSyntax()	0	7	1

<?php

namespace Graze\DataDb\Dialect;

use Graze\DataDb\TableNodeInterface;

class MysqlDialect extends AbstractDialect
{
    /**
     * @return string
     */
    public function getIdentifierQuote()
    {
        return '`';
    }

    /**
     * @param TableNodeInterface $old
     * @param TableNodeInterface $new
     *
     * @return array
     */
    public function getCreateTableLike(TableNodeInterface $old, TableNodeInterface $new)

This method seems to be duplicated in your project.

    {
        return [
            $this->format(
                'CREATE TABLE {new:schema|q}.{new:table|q} LIKE {old:schema|q}.{old:table|q}',
                ['old' => $old, 'new' => $new,]
            ),
            [],
        ];
    }

    /**
     * @param TableNodeInterface $source
     * @param TableNodeInterface $join
     * @param string             $on
     * @param string|null        $where
     *
     * @return array
     */
    public function getDeleteTableJoinSoftDelete(
        TableNodeInterface $source,
        TableNodeInterface $join,
        $on,
        $where = null
    ) {
        return [
            $this->format(
                'UPDATE {source:schema|q}.{source:table|q}
                JOIN {join:schema|q}.{join:table|q}
                ON {on}
                SET{softUpdated}
                    {source:softDeleted|q} = CURRENT_TIMESTAMP
                {where}',
                [
                    'source'      => $source,
                    'join'        => $join,
                    'on'          => $on,
                    'softUpdated' => ($source->getSoftUpdated() ?
                        $this->format(
                            ' {source:softUpdated|q} = CURRENT_TIMESTAMP,',
                            ['source' => $source]
                        ) : ''
                    ),
                    'where'       => ($where ? 'WHERE ' . $where : ''),
                ]
            ),
            [],
        ];
    }

    /**
     * @param TableNodeInterface $source
     * @param TableNodeInterface $join
     * @param string             $on
     * @param string|null        $where
     *
     * @return array
     */
    public function getDeleteTableJoin(

This method seems to be duplicated in your project.

        TableNodeInterface $source,
        TableNodeInterface $join,
        $on,
        $where = null
    ) {
        return [
            $this->format(
                'DELETE {source:schema|q}.{source:table|q}
                FROM {source:schema|q}.{source:table|q}
                JOIN {join:schema|q}.{join:table|q}
                ON {on}
                {where}',
                [
                    'source' => $source,
                    'join'   => $join,
                    'on'     => $on,
                    'where'  => ($where ? 'WHERE ' . $where : ''),
                ]
            ),
            [],
        ];
    }

    /**
     * @param TableNodeInterface $table
     * @param string|null        $where
     *
     * @return array [sql, bind]
     */
    public function getDeleteFromTableSoftDelete(TableNodeInterface $table, $where = null)
    {
        return [
            $this->format(
                'UPDATE {table:schema|q}.{table:table|q}
                    SET{softUpdated}
                        {table:softDeleted|q} = CURRENT_TIMESTAMP
                    {where}',
                [
                    'table'       => $table,
                    'softUpdated' => ($table->getSoftUpdated() ?
                        $this->format(' {table:softUpdated|q} = CURRENT_TIMESTAMP,', ['table' => $table]) :
                        ''),
                    'where'       => ($where ? 'WHERE ' . $where : ''),
                ]
            ),
            [],
        ];
    }

    /**
     * @param TableNodeInterface $table
     * @param array              $columns
     * @param array              $primary
     * @param array              $index
     *
     * @return array
     */
    public function getCreateTable(TableNodeInterface $table, array $columns, array $primary, array $index)
    {
        $allColumns = array_merge($columns, $primary, $index);

        return [
            $this->format(
                "CREATE TABLE {table:schema|q}.{table:table|q} (\n  {allColumns}\n)",
                [
                    'table'      => $table,
                    'allColumns' => implode(",\n  ", $allColumns),
                ]
            ),
            [],
        ];
    }

    /**
     * @param array $column
     *
     * @return string
     */
    public function getColumnDefinition(array $column)

This method seems to be duplicated in your project.

    {
        return $this->format(
            '{column|q} {type} {notnull}',
            array_merge($column, ['notnull' => $column['nullable'] ? 'NULL' : 'NOT NULL'])
        );
    }

    /**
     * @param array $key
     *
     * @return string
     */
    public function getPrimaryKeyDefinition(array $key)
    {
        return $this->format('PRIMARY KEY ({column|q})', $key);
    }

    /**
     * @param array $index
     *
     * @return string
     */
    public function getIndexDefinition(array $index)
    {
        return $this->format('KEY {column|q} ({column|q})', $index);
    }

    /**
     * @param TableNodeInterface $table
     *
     * @return array [sql, bind]
     */
    public function getDescribeTable(TableNodeInterface $table)
    {
        return [$this->format('DESCRIBE {table:schema|q}.{table:table|q}', ['table' => $table]), []];
    }

    /**
     * @param TableNodeInterface $table
     *
     * @return array [sql, bind]
     */
    public function getCreateSyntax(TableNodeInterface $table)
    {
        return [
            $this->format('SHOW CREATE TABLE {table:schema|q}.{table:table|q}', ['table' => $table]),
            [],
        ];
    }
}