Issues in DrizzlePlatform.php - All Issues - Inspection of "Merge pull request #2855 from lcobucci/bc-break/fi..." - doctrine/dbal - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( c7757e...39cb21 )

by Luís

created 2017-11-18 21:31 UTC

lib/Doctrine/DBAL/Platforms/DrizzlePlatform.php (8 issues)

Labels

Duplication 8

Severity

Informational 8

Kim Hemsø Rasmussen 8

<?php
/*
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * This software consists of voluntary contributions made by many individuals
 * and is licensed under the MIT license. For more information, see
 * <http://www.doctrine-project.org>.
 */

namespace Doctrine\DBAL\Platforms;

use Doctrine\DBAL\Schema\Identifier;
use Doctrine\DBAL\Schema\Index;
use Doctrine\DBAL\Schema\Table;
use Doctrine\DBAL\Schema\TableDiff;
use Doctrine\DBAL\Types\BinaryType;

/**
 * Drizzle platform
 *
 * @author Kim Hemsø Rasmussen <[email protected]>
 */
class DrizzlePlatform extends AbstractPlatform
{
    /**
     * {@inheritDoc}
     */
    public function getName()
    {
        return 'drizzle';
    }

    /**
     * {@inheritDoc}
     */
    public function getIdentifierQuoteCharacter()
    {
        return '`';
    }

    /**
     * {@inheritDoc}
     */
    public function getConcatExpression()
    {
        $args = func_get_args();

        return 'CONCAT(' . join(', ', (array) $args) . ')';
    }

    /**
     * {@inheritdoc}
     */
    protected function getDateArithmeticIntervalExpression($date, $operator, $interval, $unit)
    {
        $function = '+' === $operator ? 'DATE_ADD' : 'DATE_SUB';

        return $function . '(' . $date . ', INTERVAL ' . $interval . ' ' . $unit . ')';
    }

    /**
     * {@inheritDoc}
     */
    public function getDateDiffExpression($date1, $date2)
    {
        return 'DATEDIFF(' . $date1 . ', ' . $date2 . ')';
    }

    /**
     * {@inheritDoc}
     */
    public function getBooleanTypeDeclarationSQL(array $field)
    {
        return 'BOOLEAN';
    }

    /**
     * {@inheritDoc}
     */
    public function getIntegerTypeDeclarationSQL(array $field)
    {
        return 'INT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
    }

    /**
     * {@inheritDoc}
     */
    protected function _getCommonIntegerTypeDeclarationSQL(array $columnDef)
    {
        $autoinc = '';
        if ( ! empty($columnDef['autoincrement'])) {
            $autoinc = ' AUTO_INCREMENT';
        }

        return $autoinc;
    }

    /**
     * {@inheritDoc}
     */
    public function getBigIntTypeDeclarationSQL(array $field)
    {
        return 'BIGINT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
    }

    /**
     * {@inheritDoc}
     */
    public function getSmallIntTypeDeclarationSQL(array $field)
    {
        return 'INT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
    }

    /**
     * {@inheritDoc}
     */
    protected function getVarcharTypeDeclarationSQLSnippet($length, $fixed)
    {
        return $length ? 'VARCHAR(' . $length . ')' : 'VARCHAR(255)';
    }

    /**
     * {@inheritdoc}
     */
    protected function getBinaryTypeDeclarationSQLSnippet($length, $fixed)
    {
        return 'VARBINARY(' . ($length ?: 255) . ')';
    }

    /**
     * {@inheritDoc}
     */
    protected function initializeDoctrineTypeMappings()
    {
        $this->doctrineTypeMapping = [
            'boolean'       => 'boolean',
            'varchar'       => 'string',
            'varbinary'     => 'binary',
            'integer'       => 'integer',
            'blob'          => 'blob',
            'decimal'       => 'decimal',
            'datetime'      => 'datetime',
            'date'          => 'date',
            'time'          => 'time',
            'text'          => 'text',
            'timestamp'     => 'datetime',
            'double'        => 'float',
            'bigint'        => 'bigint',
        ];
    }

    /**
     * {@inheritDoc}
     */
    public function getClobTypeDeclarationSQL(array $field)
    {
        return 'TEXT';
    }

    /**
     * {@inheritDoc}
     */
    public function getBlobTypeDeclarationSQL(array $field)
    {
        return 'BLOB';
    }

    /**
     * {@inheritDoc}
     */
    public function getCreateDatabaseSQL($name)
    {
        return 'CREATE DATABASE ' . $name;
    }

    /**
     * {@inheritDoc}
     */
    public function getDropDatabaseSQL($name)
    {
        return 'DROP DATABASE ' . $name;
    }

    /**
     * {@inheritDoc}
     */
    protected function _getCreateTableSQL($tableName, array $columns, array $options = [])
    {
        $queryFields = $this->getColumnDeclarationListSQL($columns);

        if (isset($options['uniqueConstraints']) && ! empty($options['uniqueConstraints'])) {
            foreach ($options['uniqueConstraints'] as $index => $definition) {
                $queryFields .= ', ' . $this->getUniqueConstraintDeclarationSQL($index, $definition);
            }
        }

        // add all indexes
        if (isset($options['indexes']) && ! empty($options['indexes'])) {
            foreach ($options['indexes'] as $index => $definition) {
                $queryFields .= ', ' . $this->getIndexDeclarationSQL($index, $definition);
            }
        }

        // attach all primary keys
        if (isset($options['primary']) && ! empty($options['primary'])) {
            $keyColumns = array_unique(array_values($options['primary']));
            $queryFields .= ', PRIMARY KEY(' . implode(', ', $keyColumns) . ')';
        }

        $query = 'CREATE ';

        if (!empty($options['temporary'])) {
            $query .= 'TEMPORARY ';
        }

        $query .= 'TABLE ' . $tableName . ' (' . $queryFields . ') ';
        $query .= $this->buildTableOptions($options);
        $query .= $this->buildPartitionOptions($options);

        $sql[] = $query;

        if (isset($options['foreignKeys'])) {
            foreach ((array) $options['foreignKeys'] as $definition) {
                $sql[] = $this->getCreateForeignKeySQL($definition, $tableName);
            }
        }

        return $sql;
    }

    /**
     * Build SQL for table options
     *
     * @param array $options
     *
     * @return string
     */
    private function buildTableOptions(array $options)
    {
        if (isset($options['table_options'])) {
            return $options['table_options'];
        }

        $tableOptions = [];

        // Collate
        if ( ! isset($options['collate'])) {
            $options['collate'] = 'utf8_unicode_ci';
        }

        $tableOptions[] = sprintf('COLLATE %s', $options['collate']);

        // Engine
        if ( ! isset($options['engine'])) {
            $options['engine'] = 'InnoDB';
        }

        $tableOptions[] = sprintf('ENGINE = %s', $options['engine']);

        // Auto increment
        if (isset($options['auto_increment'])) {
            $tableOptions[] = sprintf('AUTO_INCREMENT = %s', $options['auto_increment']);
        }

        // Comment
        if (isset($options['comment'])) {
            $comment = trim($options['comment'], " '");

            $tableOptions[] = sprintf("COMMENT = %s ", $this->quoteStringLiteral($comment));
        }

        // Row format
        if (isset($options['row_format'])) {
            $tableOptions[] = sprintf('ROW_FORMAT = %s', $options['row_format']);
        }

        return implode(' ', $tableOptions);
    }

    /**
     * Build SQL for partition options.
     *
     * @param array $options
     *
     * @return string
     */
    private function buildPartitionOptions(array $options)
    {
        return (isset($options['partition_options']))
            ? ' ' . $options['partition_options']
            : '';
    }

    /**
     * {@inheritDoc}
     */
    public function getListDatabasesSQL()
    {
        return "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE CATALOG_NAME='LOCAL'";
    }

    /**
     * {@inheritDoc}
     */
    protected function getReservedKeywordsClass()
    {
        return Keywords\DrizzleKeywords::class;
    }

    /**
     * {@inheritDoc}
     */
    public function getListTablesSQL()
    {
        return "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE='BASE' AND TABLE_SCHEMA=DATABASE()";
    }

    /**
     * {@inheritDoc}
     */
    public function getListTableColumnsSQL($table, $database = null)

    {
        if ($database) {
            $database = "'" . $database . "'";
        } else {
            $database = 'DATABASE()';
        }

        return "SELECT COLUMN_NAME, DATA_TYPE, COLUMN_COMMENT, IS_NULLABLE, IS_AUTO_INCREMENT, CHARACTER_MAXIMUM_LENGTH, COLUMN_DEFAULT," .
               " NUMERIC_PRECISION, NUMERIC_SCALE, COLLATION_NAME" .
               " FROM DATA_DICTIONARY.COLUMNS" .
               " WHERE TABLE_SCHEMA=" . $database . " AND TABLE_NAME = '" . $table . "'";
    }

    /**
     * {@inheritDoc}
     */
    public function getListTableForeignKeysSQL($table, $database = null)

    {
        if ($database) {
            $database = "'" . $database . "'";
        } else {
            $database = 'DATABASE()';
        }

        return "SELECT CONSTRAINT_NAME, CONSTRAINT_COLUMNS, REFERENCED_TABLE_NAME, REFERENCED_TABLE_COLUMNS, UPDATE_RULE, DELETE_RULE" .
               " FROM DATA_DICTIONARY.FOREIGN_KEYS" .
               " WHERE CONSTRAINT_SCHEMA=" . $database . " AND CONSTRAINT_TABLE='" . $table . "'";
    }

    /**
     * {@inheritDoc}
     */
    public function getListTableIndexesSQL($table, $database = null)

    {
        if ($database) {
            $database = "'" . $database . "'";
        } else {
            $database = 'DATABASE()';
        }

        return "SELECT INDEX_NAME AS 'key_name', COLUMN_NAME AS 'column_name', IS_USED_IN_PRIMARY AS 'primary', IS_UNIQUE=0 AS 'non_unique'" .
               " FROM DATA_DICTIONARY.INDEX_PARTS" .
               " WHERE TABLE_SCHEMA=" . $database . " AND TABLE_NAME='" . $table . "'";
    }

    /**
     * {@inheritDoc}
     */
    public function prefersIdentityColumns()
    {
        return true;
    }

    /**
     * {@inheritDoc}
     */
    public function supportsIdentityColumns()
    {
        return true;
    }

    /**
     * {@inheritDoc}
     */
    public function supportsInlineColumnComments()
    {
        return true;
    }

    /**
     * {@inheritDoc}
     */
    public function supportsViews()
    {
        return false;
    }

    /**
     * {@inheritdoc}
     */
    public function supportsColumnCollation()
    {
        return true;
    }

    /**
     * {@inheritDoc}
     */
    public function getDropIndexSQL($index, $table=null)

    {
        if ($index instanceof Index) {
            $indexName = $index->getQuotedName($this);
        } elseif (is_string($index)) {
            $indexName = $index;
        } else {
            throw new \InvalidArgumentException('DrizzlePlatform::getDropIndexSQL() expects $index parameter to be string or \Doctrine\DBAL\Schema\Index.');
        }

        if ($table instanceof Table) {
            $table = $table->getQuotedName($this);
        } elseif (!is_string($table)) {
            throw new \InvalidArgumentException('DrizzlePlatform::getDropIndexSQL() expects $table parameter to be string or \Doctrine\DBAL\Schema\Table.');
        }

        if ($index instanceof Index && $index->isPrimary()) {
            // drizzle primary keys are always named "PRIMARY",
            // so we cannot use them in statements because of them being keyword.
            return $this->getDropPrimaryKeySQL($table);
        }

        return 'DROP INDEX ' . $indexName . ' ON ' . $table;
    }

    /**
     * {@inheritDoc}
     */
    protected function getDropPrimaryKeySQL($table)
    {
        return 'ALTER TABLE ' . $table . ' DROP PRIMARY KEY';
    }

    /**
     * {@inheritDoc}
     */
    public function getDateTimeTypeDeclarationSQL(array $fieldDeclaration)

    {
        if (isset($fieldDeclaration['version']) && $fieldDeclaration['version'] == true) {
            return 'TIMESTAMP';
        }

        return 'DATETIME';
    }

    /**
     * {@inheritDoc}
     */
    public function getTimeTypeDeclarationSQL(array $fieldDeclaration)
    {
        return 'TIME';
    }

    /**
     * {@inheritDoc}
     */
    public function getDateTypeDeclarationSQL(array $fieldDeclaration)
    {
        return 'DATE';
    }

    /**
     * {@inheritDoc}
     */
    public function getAlterTableSQL(TableDiff $diff)
    {
        $columnSql = [];
        $queryParts = [];

        if ($diff->newName !== false) {
            $queryParts[] =  'RENAME TO ' . $diff->getNewName()->getQuotedName($this);
        }

        foreach ($diff->addedColumns as $column) {
            if ($this->onSchemaAlterTableAddColumn($column, $diff, $columnSql)) {
                continue;
            }

            $columnArray = $column->toArray();
            $columnArray['comment'] = $this->getColumnComment($column);
            $queryParts[] = 'ADD ' . $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnArray);
        }

        foreach ($diff->removedColumns as $column) {
            if ($this->onSchemaAlterTableRemoveColumn($column, $diff, $columnSql)) {
                continue;
            }

            $queryParts[] =  'DROP ' . $column->getQuotedName($this);
        }

        foreach ($diff->changedColumns as $columnDiff) {
            if ($this->onSchemaAlterTableChangeColumn($columnDiff, $diff, $columnSql)) {
                continue;
            }

            /* @var $columnDiff \Doctrine\DBAL\Schema\ColumnDiff */
            $column = $columnDiff->column;
            $columnArray = $column->toArray();

            // Do not generate column alteration clause if type is binary and only fixed property has changed.
            // Drizzle only supports binary type columns with variable length.
            // Avoids unnecessary table alteration statements.
            if ($columnArray['type'] instanceof BinaryType &&
                $columnDiff->hasChanged('fixed') &&
                count($columnDiff->changedProperties) === 1
            ) {
                continue;
            }

            $columnArray['comment'] = $this->getColumnComment($column);
            $queryParts[] =  'CHANGE ' . ($columnDiff->getOldColumnName()->getQuotedName($this)) . ' '
                    . $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnArray);
        }

        foreach ($diff->renamedColumns as $oldColumnName => $column) {
            if ($this->onSchemaAlterTableRenameColumn($oldColumnName, $column, $diff, $columnSql)) {
                continue;
            }

            $oldColumnName = new Identifier($oldColumnName);

            $columnArray = $column->toArray();
            $columnArray['comment'] = $this->getColumnComment($column);
            $queryParts[] =  'CHANGE ' . $oldColumnName->getQuotedName($this) . ' '
                    . $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnArray);
        }

        $sql = [];
        $tableSql = [];

        if ( ! $this->onSchemaAlterTable($diff, $tableSql)) {
            if (count($queryParts) > 0) {
                $sql[] = 'ALTER TABLE ' . $diff->getName($this)->getQuotedName($this) . ' ' . implode(", ", $queryParts);
            }
            $sql = array_merge(
                $this->getPreAlterTableIndexForeignKeySQL($diff),
                $sql,
                $this->getPostAlterTableIndexForeignKeySQL($diff)
            );
        }

        return array_merge($sql, $tableSql, $columnSql);
    }

    /**
     * {@inheritDoc}
     */
    public function getDropTemporaryTableSQL($table)

    {
        if ($table instanceof Table) {
            $table = $table->getQuotedName($this);
        } elseif (!is_string($table)) {
            throw new \InvalidArgumentException('getDropTableSQL() expects $table parameter to be string or \Doctrine\DBAL\Schema\Table.');
        }

        return 'DROP TEMPORARY TABLE ' . $table;
    }

    /**
     * {@inheritDoc}
     */
    public function convertBooleans($item)

    {
        if (is_array($item)) {
            foreach ($item as $key => $value) {
                if (is_bool($value) || is_numeric($item)) {
                    $item[$key] = ($value) ? 'true' : 'false';
                }
            }
        } elseif (is_bool($item) || is_numeric($item)) {
           $item = ($item) ? 'true' : 'false';
        }

        return $item;
    }

    /**
     * {@inheritDoc}
     */
    public function getLocateExpression($str, $substr, $startPos = false)

    {
        if ($startPos == false) {
            return 'LOCATE(' . $substr . ', ' . $str . ')';
        }

        return 'LOCATE(' . $substr . ', ' . $str . ', '.$startPos.')';
    }

    /**
     * {@inheritDoc}
     */
    public function getGuidExpression()
    {
        return 'UUID()';
    }

    /**
     * {@inheritDoc}
     */
    public function getRegexpExpression()
    {
        return 'RLIKE';
    }
}


1		<?php
2		/*
3		* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
4		* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
5		* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
6		* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
7		* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
8		* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
9		* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
10		* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
11		* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
12		* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
13		* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
14		*
15		* This software consists of voluntary contributions made by many individuals
16		* and is licensed under the MIT license. For more information, see
17		* <http://www.doctrine-project.org>.
18		*/
19
20		namespace Doctrine\DBAL\Platforms;
21
22		use Doctrine\DBAL\Schema\Identifier;
23		use Doctrine\DBAL\Schema\Index;
24		use Doctrine\DBAL\Schema\Table;
25		use Doctrine\DBAL\Schema\TableDiff;
26		use Doctrine\DBAL\Types\BinaryType;
27
28		/**
29		* Drizzle platform
30		*
31		* @author Kim Hemsø Rasmussen <[email protected]>
32		*/
33		class DrizzlePlatform extends AbstractPlatform
34		{
35		/**
36		* {@inheritDoc}
37		*/
38		public function getName()
39		{
40		return 'drizzle';
41		}
42
43		/**
44		* {@inheritDoc}
45		*/
46		public function getIdentifierQuoteCharacter()
47		{
48		return '`';
49		}
50
51		/**
52		* {@inheritDoc}
53		*/
54		public function getConcatExpression()
55		{
56		$args = func_get_args();
57
58		return 'CONCAT(' . join(', ', (array) $args) . ')';
59		}
60
61		/**
62		* {@inheritdoc}
63		*/
64		protected function getDateArithmeticIntervalExpression($date, $operator, $interval, $unit)
65		{
66		$function = '+' === $operator ? 'DATE_ADD' : 'DATE_SUB';
67
68		return $function . '(' . $date . ', INTERVAL ' . $interval . ' ' . $unit . ')';
69		}
70
71		/**
72		* {@inheritDoc}
73		*/
74		public function getDateDiffExpression($date1, $date2)
75		{
76		return 'DATEDIFF(' . $date1 . ', ' . $date2 . ')';
77		}
78
79		/**
80		* {@inheritDoc}
81		*/
82		public function getBooleanTypeDeclarationSQL(array $field)
83		{
84		return 'BOOLEAN';
85		}
86
87		/**
88		* {@inheritDoc}
89		*/
90		public function getIntegerTypeDeclarationSQL(array $field)
91		{
92		return 'INT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
93		}
94
95		/**
96		* {@inheritDoc}
97		*/
98		protected function _getCommonIntegerTypeDeclarationSQL(array $columnDef)
99		{
100		$autoinc = '';
101		if ( ! empty($columnDef['autoincrement'])) {
102		$autoinc = ' AUTO_INCREMENT';
103		}
104
105		return $autoinc;
106		}
107
108		/**
109		* {@inheritDoc}
110		*/
111		public function getBigIntTypeDeclarationSQL(array $field)
112		{
113		return 'BIGINT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
114		}
115
116		/**
117		* {@inheritDoc}
118		*/
119		public function getSmallIntTypeDeclarationSQL(array $field)
120		{
121		return 'INT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
122		}
123
124		/**
125		* {@inheritDoc}
126		*/
127		protected function getVarcharTypeDeclarationSQLSnippet($length, $fixed)
128		{
129		return $length ? 'VARCHAR(' . $length . ')' : 'VARCHAR(255)';
130		}
131
132		/**
133		* {@inheritdoc}
134		*/
135		protected function getBinaryTypeDeclarationSQLSnippet($length, $fixed)
136		{
137		return 'VARBINARY(' . ($length ?: 255) . ')';
138		}
139
140		/**
141		* {@inheritDoc}
142		*/
143		protected function initializeDoctrineTypeMappings()
144		{
145		$this->doctrineTypeMapping = [
146		'boolean' => 'boolean',
147		'varchar' => 'string',
148		'varbinary' => 'binary',
149		'integer' => 'integer',
150		'blob' => 'blob',
151		'decimal' => 'decimal',
152		'datetime' => 'datetime',
153		'date' => 'date',
154		'time' => 'time',
155		'text' => 'text',
156		'timestamp' => 'datetime',
157		'double' => 'float',
158		'bigint' => 'bigint',
159		];
160		}
161
162		/**
163		* {@inheritDoc}
164		*/
165		public function getClobTypeDeclarationSQL(array $field)
166		{
167		return 'TEXT';
168		}
169
170		/**
171		* {@inheritDoc}
172		*/
173		public function getBlobTypeDeclarationSQL(array $field)
174		{
175		return 'BLOB';
176		}
177
178		/**
179		* {@inheritDoc}
180		*/
181		public function getCreateDatabaseSQL($name)
182		{
183		return 'CREATE DATABASE ' . $name;
184		}
185
186		/**
187		* {@inheritDoc}
188		*/
189		public function getDropDatabaseSQL($name)
190		{
191		return 'DROP DATABASE ' . $name;
192		}
193
194		/**
195		* {@inheritDoc}
196		*/
197		protected function _getCreateTableSQL($tableName, array $columns, array $options = [])
198		{
199		$queryFields = $this->getColumnDeclarationListSQL($columns);
200
201		if (isset($options['uniqueConstraints']) && ! empty($options['uniqueConstraints'])) {
202		foreach ($options['uniqueConstraints'] as $index => $definition) {
203		$queryFields .= ', ' . $this->getUniqueConstraintDeclarationSQL($index, $definition);
204		}
205		}
206
207		// add all indexes
208		if (isset($options['indexes']) && ! empty($options['indexes'])) {
209		foreach ($options['indexes'] as $index => $definition) {
210		$queryFields .= ', ' . $this->getIndexDeclarationSQL($index, $definition);
211		}
212		}
213
214		// attach all primary keys
215	View Code Duplication	if (isset($options['primary']) && ! empty($options['primary'])) {
216		$keyColumns = array_unique(array_values($options['primary']));
217		$queryFields .= ', PRIMARY KEY(' . implode(', ', $keyColumns) . ')';
218		}
219
220		$query = 'CREATE ';
221
222		if (!empty($options['temporary'])) {
223		$query .= 'TEMPORARY ';
224		}
225
226		$query .= 'TABLE ' . $tableName . ' (' . $queryFields . ') ';
227		$query .= $this->buildTableOptions($options);
228		$query .= $this->buildPartitionOptions($options);
229
230		$sql[] = $query;
231
232	View Code Duplication	if (isset($options['foreignKeys'])) {
233		foreach ((array) $options['foreignKeys'] as $definition) {
234		$sql[] = $this->getCreateForeignKeySQL($definition, $tableName);
235		}
236		}
237
238		return $sql;
239		}
240
241		/**
242		* Build SQL for table options
243		*
244		* @param array $options
245		*
246		* @return string
247		*/
248		private function buildTableOptions(array $options)
249		{
250		if (isset($options['table_options'])) {
251		return $options['table_options'];
252		}
253
254		$tableOptions = [];
255
256		// Collate
257		if ( ! isset($options['collate'])) {
258		$options['collate'] = 'utf8_unicode_ci';
259		}
260
261		$tableOptions[] = sprintf('COLLATE %s', $options['collate']);
262
263		// Engine
264		if ( ! isset($options['engine'])) {
265		$options['engine'] = 'InnoDB';
266		}
267
268		$tableOptions[] = sprintf('ENGINE = %s', $options['engine']);
269
270		// Auto increment
271		if (isset($options['auto_increment'])) {
272		$tableOptions[] = sprintf('AUTO_INCREMENT = %s', $options['auto_increment']);
273		}
274
275		// Comment
276	View Code Duplication	if (isset($options['comment'])) {
277		$comment = trim($options['comment'], " '");
278
279		$tableOptions[] = sprintf("COMMENT = %s ", $this->quoteStringLiteral($comment));
280		}
281
282		// Row format
283		if (isset($options['row_format'])) {
284		$tableOptions[] = sprintf('ROW_FORMAT = %s', $options['row_format']);
285		}
286
287		return implode(' ', $tableOptions);
288		}
289
290		/**
291		* Build SQL for partition options.
292		*
293		* @param array $options
294		*
295		* @return string
296		*/
297		private function buildPartitionOptions(array $options)
298		{
299		return (isset($options['partition_options']))
300		? ' ' . $options['partition_options']
301		: '';
302		}
303
304		/**
305		* {@inheritDoc}
306		*/
307		public function getListDatabasesSQL()
308		{
309		return "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE CATALOG_NAME='LOCAL'";
310		}
311
312		/**
313		* {@inheritDoc}
314		*/
315		protected function getReservedKeywordsClass()
316		{
317		return Keywords\DrizzleKeywords::class;
318		}
319
320		/**
321		* {@inheritDoc}
322		*/
323		public function getListTablesSQL()
324		{
325		return "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE='BASE' AND TABLE_SCHEMA=DATABASE()";
326		}
327
328		/**
329		* {@inheritDoc}
330		*/
331	View Code Duplication	public function getListTableColumnsSQL($table, $database = null)
		0 ignored issues – show Duplication introduced 2017-07-31 14:44 UTC by Report Bug Copy Issue Report Show Similar Issues like this This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
332		{
333		if ($database) {
334		$database = "'" . $database . "'";
335		} else {
336		$database = 'DATABASE()';
337		}
338
339		return "SELECT COLUMN_NAME, DATA_TYPE, COLUMN_COMMENT, IS_NULLABLE, IS_AUTO_INCREMENT, CHARACTER_MAXIMUM_LENGTH, COLUMN_DEFAULT," .
340		" NUMERIC_PRECISION, NUMERIC_SCALE, COLLATION_NAME" .
341		" FROM DATA_DICTIONARY.COLUMNS" .
342		" WHERE TABLE_SCHEMA=" . $database . " AND TABLE_NAME = '" . $table . "'";
343		}
344
345		/**
346		* {@inheritDoc}
347		*/
348	View Code Duplication	public function getListTableForeignKeysSQL($table, $database = null)
		0 ignored issues – show Duplication introduced 2017-07-31 14:44 UTC by Report Bug Copy Issue Report Show Similar Issues like this This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
349		{
350		if ($database) {
351		$database = "'" . $database . "'";
352		} else {
353		$database = 'DATABASE()';
354		}
355
356		return "SELECT CONSTRAINT_NAME, CONSTRAINT_COLUMNS, REFERENCED_TABLE_NAME, REFERENCED_TABLE_COLUMNS, UPDATE_RULE, DELETE_RULE" .
357		" FROM DATA_DICTIONARY.FOREIGN_KEYS" .
358		" WHERE CONSTRAINT_SCHEMA=" . $database . " AND CONSTRAINT_TABLE='" . $table . "'";
359		}
360
361		/**
362		* {@inheritDoc}
363		*/
364	View Code Duplication	public function getListTableIndexesSQL($table, $database = null)
		0 ignored issues – show Duplication introduced 2017-07-31 14:44 UTC by Report Bug Copy Issue Report Show Similar Issues like this This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
365		{
366		if ($database) {
367		$database = "'" . $database . "'";
368		} else {
369		$database = 'DATABASE()';
370		}
371
372		return "SELECT INDEX_NAME AS 'key_name', COLUMN_NAME AS 'column_name', IS_USED_IN_PRIMARY AS 'primary', IS_UNIQUE=0 AS 'non_unique'" .
373		" FROM DATA_DICTIONARY.INDEX_PARTS" .
374		" WHERE TABLE_SCHEMA=" . $database . " AND TABLE_NAME='" . $table . "'";
375		}
376
377		/**
378		* {@inheritDoc}
379		*/
380		public function prefersIdentityColumns()
381		{
382		return true;
383		}
384
385		/**
386		* {@inheritDoc}
387		*/
388		public function supportsIdentityColumns()
389		{
390		return true;
391		}
392
393		/**
394		* {@inheritDoc}
395		*/
396		public function supportsInlineColumnComments()
397		{
398		return true;
399		}
400
401		/**
402		* {@inheritDoc}
403		*/
404		public function supportsViews()
405		{
406		return false;
407		}
408
409		/**
410		* {@inheritdoc}
411		*/
412		public function supportsColumnCollation()
413		{
414		return true;
415		}
416
417		/**
418		* {@inheritDoc}
419		*/
420	View Code Duplication	public function getDropIndexSQL($index, $table=null)
		0 ignored issues – show Duplication introduced 2017-07-31 14:44 UTC by Report Bug Copy Issue Report Show Similar Issues like this This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
421		{
422		if ($index instanceof Index) {
423		$indexName = $index->getQuotedName($this);
424		} elseif (is_string($index)) {
425		$indexName = $index;
426		} else {
427		throw new \InvalidArgumentException('DrizzlePlatform::getDropIndexSQL() expects $index parameter to be string or \Doctrine\DBAL\Schema\Index.');
428		}
429
430		if ($table instanceof Table) {
431		$table = $table->getQuotedName($this);
432		} elseif (!is_string($table)) {
433		throw new \InvalidArgumentException('DrizzlePlatform::getDropIndexSQL() expects $table parameter to be string or \Doctrine\DBAL\Schema\Table.');
434		}
435
436		if ($index instanceof Index && $index->isPrimary()) {
437		// drizzle primary keys are always named "PRIMARY",
438		// so we cannot use them in statements because of them being keyword.
439		return $this->getDropPrimaryKeySQL($table);
440		}
441
442		return 'DROP INDEX ' . $indexName . ' ON ' . $table;
443		}
444
445		/**
446		* {@inheritDoc}
447		*/
448		protected function getDropPrimaryKeySQL($table)
449		{
450		return 'ALTER TABLE ' . $table . ' DROP PRIMARY KEY';
451		}
452
453		/**
454		* {@inheritDoc}
455		*/
456	View Code Duplication	public function getDateTimeTypeDeclarationSQL(array $fieldDeclaration)
		0 ignored issues – show Duplication introduced 2017-07-31 14:44 UTC by Report Bug Copy Issue Report Show Similar Issues like this This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
457		{
458		if (isset($fieldDeclaration['version']) && $fieldDeclaration['version'] == true) {
459		return 'TIMESTAMP';
460		}
461
462		return 'DATETIME';
463		}
464
465		/**
466		* {@inheritDoc}
467		*/
468		public function getTimeTypeDeclarationSQL(array $fieldDeclaration)
469		{
470		return 'TIME';
471		}
472
473		/**
474		* {@inheritDoc}
475		*/
476		public function getDateTypeDeclarationSQL(array $fieldDeclaration)
477		{
478		return 'DATE';
479		}
480
481		/**
482		* {@inheritDoc}
483		*/
484		public function getAlterTableSQL(TableDiff $diff)
485		{
486		$columnSql = [];
487		$queryParts = [];
488
489		if ($diff->newName !== false) {
490		$queryParts[] = 'RENAME TO ' . $diff->getNewName()->getQuotedName($this);
491		}
492
493	View Code Duplication	foreach ($diff->addedColumns as $column) {
494		if ($this->onSchemaAlterTableAddColumn($column, $diff, $columnSql)) {
495		continue;
496		}
497
498		$columnArray = $column->toArray();
499		$columnArray['comment'] = $this->getColumnComment($column);
500		$queryParts[] = 'ADD ' . $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnArray);
501		}
502
503	View Code Duplication	foreach ($diff->removedColumns as $column) {
504		if ($this->onSchemaAlterTableRemoveColumn($column, $diff, $columnSql)) {
505		continue;
506		}
507
508		$queryParts[] = 'DROP ' . $column->getQuotedName($this);
509		}
510
511	View Code Duplication	foreach ($diff->changedColumns as $columnDiff) {
512		if ($this->onSchemaAlterTableChangeColumn($columnDiff, $diff, $columnSql)) {
513		continue;
514		}
515
516		/* @var $columnDiff \Doctrine\DBAL\Schema\ColumnDiff */
517		$column = $columnDiff->column;
518		$columnArray = $column->toArray();
519
520		// Do not generate column alteration clause if type is binary and only fixed property has changed.
521		// Drizzle only supports binary type columns with variable length.
522		// Avoids unnecessary table alteration statements.
523		if ($columnArray['type'] instanceof BinaryType &&
524		$columnDiff->hasChanged('fixed') &&
525		count($columnDiff->changedProperties) === 1
526		) {
527		continue;
528		}
529
530		$columnArray['comment'] = $this->getColumnComment($column);
531		$queryParts[] = 'CHANGE ' . ($columnDiff->getOldColumnName()->getQuotedName($this)) . ' '
532		. $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnArray);
533		}
534
535	View Code Duplication	foreach ($diff->renamedColumns as $oldColumnName => $column) {
536		if ($this->onSchemaAlterTableRenameColumn($oldColumnName, $column, $diff, $columnSql)) {
537		continue;
538		}
539
540		$oldColumnName = new Identifier($oldColumnName);
541
542		$columnArray = $column->toArray();
543		$columnArray['comment'] = $this->getColumnComment($column);
544		$queryParts[] = 'CHANGE ' . $oldColumnName->getQuotedName($this) . ' '
545		. $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnArray);
546		}
547
548		$sql = [];
549		$tableSql = [];
550
551	View Code Duplication	if ( ! $this->onSchemaAlterTable($diff, $tableSql)) {
552		if (count($queryParts) > 0) {
553		$sql[] = 'ALTER TABLE ' . $diff->getName($this)->getQuotedName($this) . ' ' . implode(", ", $queryParts);
554		}
555		$sql = array_merge(
556		$this->getPreAlterTableIndexForeignKeySQL($diff),
557		$sql,
558		$this->getPostAlterTableIndexForeignKeySQL($diff)
559		);
560		}
561
562		return array_merge($sql, $tableSql, $columnSql);
563		}
564
565		/**
566		* {@inheritDoc}
567		*/
568	View Code Duplication	public function getDropTemporaryTableSQL($table)
		0 ignored issues – show Duplication introduced 2017-07-31 14:44 UTC by Report Bug Copy Issue Report Show Similar Issues like this This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
569		{
570		if ($table instanceof Table) {
571		$table = $table->getQuotedName($this);
572		} elseif (!is_string($table)) {
573		throw new \InvalidArgumentException('getDropTableSQL() expects $table parameter to be string or \Doctrine\DBAL\Schema\Table.');
574		}
575
576		return 'DROP TEMPORARY TABLE ' . $table;
577		}
578
579		/**
580		* {@inheritDoc}
581		*/
582	View Code Duplication	public function convertBooleans($item)
		0 ignored issues – show Duplication introduced 2017-07-31 14:44 UTC by Report Bug Copy Issue Report Show Similar Issues like this This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
583		{
584		if (is_array($item)) {
585		foreach ($item as $key => $value) {
586		if (is_bool($value) \|\| is_numeric($item)) {
587		$item[$key] = ($value) ? 'true' : 'false';
588		}
589		}
590		} elseif (is_bool($item) \|\| is_numeric($item)) {
591		$item = ($item) ? 'true' : 'false';
592		}
593
594		return $item;
595		}
596
597		/**
598		* {@inheritDoc}
599		*/
600	View Code Duplication	public function getLocateExpression($str, $substr, $startPos = false)
		0 ignored issues – show Duplication introduced 2017-07-31 14:44 UTC by Report Bug Copy Issue Report Show Similar Issues like this This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
601		{
602		if ($startPos == false) {
603		return 'LOCATE(' . $substr . ', ' . $str . ')';
604		}
605
606		return 'LOCATE(' . $substr . ', ' . $str . ', '.$startPos.')';
607		}
608
609		/**
610		* {@inheritDoc}
611		*/
612		public function getGuidExpression()
613		{
614		return 'UUID()';
615		}
616
617		/**
618		* {@inheritDoc}
619		*/
620		public function getRegexpExpression()
621		{
622		return 'RLIKE';
623		}
624		}
625

doctrine / dbal

Push — master ( c7757e...39cb21 )

lib/Doctrine/DBAL/Platforms/DrizzlePlatform.php (8 issues)

Labels

Severity

Introduced By

Duplication Side-by-Side

Filter issues like