SQLServerPlatform.php 52.2 KB
Newer Older
1 2
<?php

3
namespace Doctrine\DBAL\Platforms;
4

5
use Doctrine\DBAL\LockMode;
6
use Doctrine\DBAL\Schema\Column;
7
use Doctrine\DBAL\Schema\ColumnDiff;
8
use Doctrine\DBAL\Schema\ForeignKeyConstraint;
9
use Doctrine\DBAL\Schema\Identifier;
10 11
use Doctrine\DBAL\Schema\Index;
use Doctrine\DBAL\Schema\Table;
12
use Doctrine\DBAL\Schema\TableDiff;
13
use Doctrine\DBAL\Types;
14
use InvalidArgumentException;
15 16 17 18 19 20
use function array_merge;
use function array_unique;
use function array_values;
use function count;
use function crc32;
use function dechex;
21
use function explode;
22
use function func_get_args;
23
use function implode;
24 25 26 27 28
use function is_array;
use function is_bool;
use function is_numeric;
use function is_string;
use function preg_match;
29
use function sprintf;
30 31 32 33
use function str_replace;
use function stripos;
use function stristr;
use function strlen;
34
use function strpos;
35 36 37
use function strtoupper;
use function substr;
use function substr_count;
38 39

/**
40 41
 * The SQLServerPlatform provides the behavior, features and SQL dialect of the
 * Microsoft SQL Server database platform.
42
 */
43
class SQLServerPlatform extends AbstractPlatform
44
{
45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73
    /**
     * {@inheritdoc}
     */
    public function getCurrentDateSQL()
    {
        return $this->getConvertExpression('date', 'GETDATE()');
    }

    /**
     * {@inheritdoc}
     */
    public function getCurrentTimeSQL()
    {
        return $this->getConvertExpression('time', 'GETDATE()');
    }

    /**
     * Returns an expression that converts an expression of one data type to another.
     *
     * @param string $dataType   The target native data type. Alias data types cannot be used.
     * @param string $expression The SQL expression to convert.
     *
     * @return string
     */
    private function getConvertExpression($dataType, $expression)
    {
        return sprintf('CONVERT(%s, %s)', $dataType, $expression);
    }

74
    /**
75
     * {@inheritdoc}
76
     */
77
    protected function getDateArithmeticIntervalExpression($date, $operator, $interval, $unit)
78
    {
79
        $factorClause = '';
80

81
        if ($operator === '-') {
82 83
            $factorClause = '-1 * ';
        }
84

85
        return 'DATEADD(' . $unit . ', ' . $factorClause . $interval . ', ' . $date . ')';
86
    }
87

88 89 90
    /**
     * {@inheritDoc}
     */
91
    public function getDateDiffExpression($date1, $date2)
92
    {
93
        return 'DATEDIFF(day, ' . $date2 . ',' . $date1 . ')';
94
    }
95

96
    /**
97 98
     * {@inheritDoc}
     *
99 100
     * Microsoft SQL Server prefers "autoincrement" identity columns
     * since sequences can only be emulated with a table.
101
     */
102
    public function prefersIdentityColumns()
103
    {
104 105
        return true;
    }
106

107
    /**
108
     * {@inheritDoc}
109
     *
110
     * Microsoft SQL Server supports this through AUTO_INCREMENT columns.
111 112 113 114 115 116 117
     */
    public function supportsIdentityColumns()
    {
        return true;
    }

    /**
118
     * {@inheritDoc}
119
     */
120
    public function supportsReleaseSavepoints()
121 122 123
    {
        return false;
    }
124

125 126 127 128 129 130 131 132
    /**
     * {@inheritdoc}
     */
    public function supportsSchemas()
    {
        return true;
    }

133 134 135 136 137 138 139 140
    /**
     * {@inheritdoc}
     */
    public function getDefaultSchemaName()
    {
        return 'dbo';
    }

141 142 143 144 145 146 147 148
    /**
     * {@inheritDoc}
     */
    public function supportsColumnCollation()
    {
        return true;
    }

149 150 151 152 153 154 155 156
    /**
     * {@inheritDoc}
     */
    public function hasNativeGuidType()
    {
        return true;
    }

157
    /**
158
     * {@inheritDoc}
159 160 161 162 163
     */
    public function getCreateDatabaseSQL($name)
    {
        return 'CREATE DATABASE ' . $name;
    }
164

165
    /**
166
     * {@inheritDoc}
167 168 169
     */
    public function getDropDatabaseSQL($name)
    {
170 171 172 173
        return 'DROP DATABASE ' . $name;
    }

    /**
174
     * {@inheritDoc}
175
     */
176
    public function supportsCreateDropDatabase()
177
    {
178
        return true;
179 180
    }

181 182 183 184 185 186 187 188
    /**
     * {@inheritDoc}
     */
    public function getCreateSchemaSQL($schemaName)
    {
        return 'CREATE SCHEMA ' . $schemaName;
    }

189
    /**
190
     * {@inheritDoc}
191 192 193
     */
    public function getDropForeignKeySQL($foreignKey, $table)
    {
194 195
        if (! $foreignKey instanceof ForeignKeyConstraint) {
            $foreignKey = new Identifier($foreignKey);
196 197
        }

198 199
        if (! $table instanceof Table) {
            $table = new Identifier($table);
200 201
        }

202
        $foreignKey = $foreignKey->getQuotedName($this);
203
        $table      = $table->getQuotedName($this);
204

205
        return 'ALTER TABLE ' . $table . ' DROP CONSTRAINT ' . $foreignKey;
206
    }
207 208

    /**
209
     * {@inheritDoc}
210
     */
211
    public function getDropIndexSQL($index, $table = null)
212
    {
213
        if ($index instanceof Index) {
214
            $index = $index->getQuotedName($this);
215 216
        } elseif (! is_string($index)) {
            throw new InvalidArgumentException('AbstractPlatform::getDropIndexSQL() expects $index parameter to be string or \Doctrine\DBAL\Schema\Index.');
217 218
        }

219
        if (! isset($table)) {
220
            return 'DROP INDEX ' . $index;
221
        }
222

223 224
        if ($table instanceof Table) {
            $table = $table->getQuotedName($this);
225
        }
226

227 228 229 230 231 232 233 234 235 236 237 238 239 240
        return sprintf(
            <<<SQL
IF EXISTS (SELECT * FROM sysobjects WHERE name = '%s')
    ALTER TABLE %s DROP CONSTRAINT %s
ELSE
    DROP INDEX %s ON %s
SQL
            ,
            $index,
            $table,
            $index,
            $index,
            $table
        );
241
    }
242 243

    /**
244
     * {@inheritDoc}
245
     */
246
    protected function _getCreateTableSQL($tableName, array $columns, array $options = [])
247
    {
248 249
        $defaultConstraintsSql = [];
        $commentsSql           = [];
250

251
        // @todo does other code breaks because of this?
252
        // force primary keys to be not null
253 254 255 256
        foreach ($columns as &$column) {
            if (isset($column['primary']) && $column['primary']) {
                $column['notnull'] = true;
            }
257

258
            // Build default constraints SQL statements.
259
            if (isset($column['default'])) {
260 261 262
                $defaultConstraintsSql[] = 'ALTER TABLE ' . $tableName .
                    ' ADD' . $this->getDefaultConstraintDeclarationSQL($tableName, $column);
            }
263

264 265
            if (empty($column['comment']) && ! is_numeric($column['comment'])) {
                continue;
266
            }
267 268

            $commentsSql[] = $this->getCreateColumnCommentSQL($tableName, $column['name'], $column['comment']);
269 270
        }

271
        $columnListSql = $this->getColumnDeclarationListSQL($columns);
272

273
        if (isset($options['uniqueConstraints']) && ! empty($options['uniqueConstraints'])) {
274 275 276 277
            foreach ($options['uniqueConstraints'] as $name => $definition) {
                $columnListSql .= ', ' . $this->getUniqueConstraintDeclarationSQL($name, $definition);
            }
        }
278

279
        if (isset($options['primary']) && ! empty($options['primary'])) {
280 281 282 283 284
            $flags = '';
            if (isset($options['primary_index']) && $options['primary_index']->hasFlag('nonclustered')) {
                $flags = ' NONCLUSTERED';
            }
            $columnListSql .= ', PRIMARY KEY' . $flags . ' (' . implode(', ', array_unique(array_values($options['primary']))) . ')';
285 286 287 288 289
        }

        $query = 'CREATE TABLE ' . $tableName . ' (' . $columnListSql;

        $check = $this->getCheckDeclarationSQL($columns);
290
        if (! empty($check)) {
291 292 293 294
            $query .= ', ' . $check;
        }
        $query .= ')';

295
        $sql = [$query];
296

297
        if (isset($options['indexes']) && ! empty($options['indexes'])) {
298
            foreach ($options['indexes'] as $index) {
299 300 301 302 303
                $sql[] = $this->getCreateIndexSQL($index, $tableName);
            }
        }

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

309
        return array_merge($sql, $commentsSql, $defaultConstraintsSql);
310
    }
311

312
    /**
313
     * {@inheritDoc}
314 315 316
     */
    public function getCreatePrimaryKeySQL(Index $index, $table)
    {
Sergei Morozov's avatar
Sergei Morozov committed
317 318 319 320 321 322 323 324
        if ($table instanceof Table) {
            $identifier = $table->getQuotedName($this);
        } else {
            $identifier = $table;
        }

        $sql = 'ALTER TABLE ' . $identifier . ' ADD PRIMARY KEY';

325
        if ($index->hasFlag('nonclustered')) {
Sergei Morozov's avatar
Sergei Morozov committed
326
            $sql .= ' NONCLUSTERED';
327
        }
328

Sergei Morozov's avatar
Sergei Morozov committed
329
        return $sql . ' (' . $this->getIndexFieldDeclarationListSQL($index) . ')';
330 331
    }

332 333 334 335 336 337 338 339 340 341 342
    /**
     * Returns the SQL statement for creating a column comment.
     *
     * SQL Server does not support native column comments,
     * therefore the extended properties functionality is used
     * as a workaround to store them.
     * The property name used to store column comments is "MS_Description"
     * which provides compatibility with SQL Server Management Studio,
     * as column comments are stored in the same property there when
     * specifying a column's "Description" attribute.
     *
Sergei Morozov's avatar
Sergei Morozov committed
343 344 345
     * @param string      $tableName  The quoted table name to which the column belongs.
     * @param string      $columnName The quoted column name to create the comment for.
     * @param string|null $comment    The column's comment.
346 347 348 349 350
     *
     * @return string
     */
    protected function getCreateColumnCommentSQL($tableName, $columnName, $comment)
    {
351 352 353 354 355 356 357 358 359
        if (strpos($tableName, '.') !== false) {
            [$schemaSQL, $tableSQL] = explode('.', $tableName);
            $schemaSQL              = $this->quoteStringLiteral($schemaSQL);
            $tableSQL               = $this->quoteStringLiteral($tableSQL);
        } else {
            $schemaSQL = "'dbo'";
            $tableSQL  = $this->quoteStringLiteral($tableName);
        }

360 361 362 363
        return $this->getAddExtendedPropertySQL(
            'MS_Description',
            $comment,
            'SCHEMA',
364
            $schemaSQL,
365
            'TABLE',
366
            $tableSQL,
367 368 369 370 371
            'COLUMN',
            $columnName
        );
    }

372 373 374
    /**
     * Returns the SQL snippet for declaring a default constraint.
     *
375 376
     * @param string  $table  Name of the table to return the default constraint declaration for.
     * @param mixed[] $column Column definition.
377 378 379
     *
     * @return string
     *
380
     * @throws InvalidArgumentException
381 382 383
     */
    public function getDefaultConstraintDeclarationSQL($table, array $column)
    {
384 385
        if (! isset($column['default'])) {
            throw new InvalidArgumentException("Incomplete column definition. 'default' required.");
386 387
        }

388 389
        $columnName = new Identifier($column['name']);

390
        return ' CONSTRAINT ' .
391 392
            $this->generateDefaultConstraintName($table, $column['name']) .
            $this->getDefaultValueDeclarationSQL($column) .
393
            ' FOR ' . $columnName->getQuotedName($this);
394 395
    }

396
    /**
397
     * {@inheritDoc}
398
     */
399
    public function getUniqueConstraintDeclarationSQL($name, Index $index)
400 401
    {
        $constraint = parent::getUniqueConstraintDeclarationSQL($name, $index);
402 403 404 405 406 407 408

        $constraint = $this->_appendUniqueConstraintDefinition($constraint, $index);

        return $constraint;
    }

    /**
409
     * {@inheritDoc}
410 411 412 413 414
     */
    public function getCreateIndexSQL(Index $index, $table)
    {
        $constraint = parent::getCreateIndexSQL($index, $table);

415
        if ($index->isUnique() && ! $index->isPrimary()) {
416 417 418 419 420 421
            $constraint = $this->_appendUniqueConstraintDefinition($constraint, $index);
        }

        return $constraint;
    }

422
    /**
423
     * {@inheritDoc}
424 425 426 427 428 429 430 431 432 433
     */
    protected function getCreateIndexSQLFlags(Index $index)
    {
        $type = '';
        if ($index->isUnique()) {
            $type .= 'UNIQUE ';
        }

        if ($index->hasFlag('clustered')) {
            $type .= 'CLUSTERED ';
Steve Müller's avatar
Steve Müller committed
434
        } elseif ($index->hasFlag('nonclustered')) {
435 436 437 438 439 440
            $type .= 'NONCLUSTERED ';
        }

        return $type;
    }

441
    /**
442
     * Extend unique key constraint with required filters
443
     *
444
     * @param string $sql
445
     *
446 447 448 449
     * @return string
     */
    private function _appendUniqueConstraintDefinition($sql, Index $index)
    {
450
        $fields = [];
451

452
        foreach ($index->getQuotedColumns($this) as $field) {
453
            $fields[] = $field . ' IS NOT NULL';
454
        }
455 456 457

        return $sql . ' WHERE ' . implode(' AND ', $fields);
    }
458

459
    /**
460
     * {@inheritDoc}
461
     */
462
    public function getAlterTableSQL(TableDiff $diff)
463
    {
464 465 466 467
        $queryParts  = [];
        $sql         = [];
        $columnSql   = [];
        $commentsSql = [];
468

469
        foreach ($diff->addedColumns as $column) {
470 471
            if ($this->onSchemaAlterTableAddColumn($column, $diff, $columnSql)) {
                continue;
472 473
            }

474
            $columnDef    = $column->toArray();
475 476
            $queryParts[] = 'ADD ' . $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnDef);

477
            if (isset($columnDef['default'])) {
478
                $queryParts[] = $this->getAlterTableAddDefaultConstraintClause($diff->name, $column);
479
            }
480 481 482

            $comment = $this->getColumnComment($column);

483 484
            if (empty($comment) && ! is_numeric($comment)) {
                continue;
485
            }
486 487 488 489 490 491

            $commentsSql[] = $this->getCreateColumnCommentSQL(
                $diff->name,
                $column->getQuotedName($this),
                $comment
            );
492 493
        }

494
        foreach ($diff->removedColumns as $column) {
495 496
            if ($this->onSchemaAlterTableRemoveColumn($column, $diff, $columnSql)) {
                continue;
497 498
            }

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

502
        foreach ($diff->changedColumns as $columnDiff) {
503 504
            if ($this->onSchemaAlterTableChangeColumn($columnDiff, $diff, $columnSql)) {
                continue;
505 506
            }

507 508
            $column     = $columnDiff->column;
            $comment    = $this->getColumnComment($column);
509
            $hasComment = ! empty($comment) || is_numeric($comment);
510 511 512

            if ($columnDiff->fromColumn instanceof Column) {
                $fromComment    = $this->getColumnComment($columnDiff->fromColumn);
513
                $hasFromComment = ! empty($fromComment) || is_numeric($fromComment);
514

515
                if ($hasFromComment && $hasComment && $fromComment !== $comment) {
516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536
                    $commentsSql[] = $this->getAlterColumnCommentSQL(
                        $diff->name,
                        $column->getQuotedName($this),
                        $comment
                    );
                } elseif ($hasFromComment && ! $hasComment) {
                    $commentsSql[] = $this->getDropColumnCommentSQL($diff->name, $column->getQuotedName($this));
                } elseif ($hasComment) {
                    $commentsSql[] = $this->getCreateColumnCommentSQL(
                        $diff->name,
                        $column->getQuotedName($this),
                        $comment
                    );
                }
            }

            // Do not add query part if only comment has changed.
            if ($columnDiff->hasChanged('comment') && count($columnDiff->changedProperties) === 1) {
                continue;
            }

537
            $requireDropDefaultConstraint = $this->alterColumnRequiresDropDefaultConstraint($columnDiff);
538

539 540 541 542 543
            if ($requireDropDefaultConstraint) {
                $queryParts[] = $this->getAlterTableDropDefaultConstraintClause(
                    $diff->name,
                    $columnDiff->oldColumnName
                );
544 545
            }

546 547
            $columnDef = $column->toArray();

548
            $queryParts[] = 'ALTER COLUMN ' .
549 550
                    $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnDef);

551 552
            if (! isset($columnDef['default']) || (! $requireDropDefaultConstraint && ! $columnDiff->hasChanged('default'))) {
                continue;
553
            }
554 555

            $queryParts[] = $this->getAlterTableAddDefaultConstraintClause($diff->name, $column);
556 557
        }

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

563 564
            $oldColumnName = new Identifier($oldColumnName);

565
            $sql[] = "sp_RENAME '" .
566
                $diff->getName($this)->getQuotedName($this) . '.' . $oldColumnName->getQuotedName($this) .
567
                "', '" . $column->getQuotedName($this) . "', 'COLUMN'";
568

569
            // Recreate default constraint with new column name if necessary (for future reference).
570 571
            if ($column->getDefault() === null) {
                continue;
572
            }
573 574 575 576 577 578

            $queryParts[] = $this->getAlterTableDropDefaultConstraintClause(
                $diff->name,
                $oldColumnName->getQuotedName($this)
            );
            $queryParts[] = $this->getAlterTableAddDefaultConstraintClause($diff->name, $column);
579
        }
580

581
        $tableSql = [];
582 583

        if ($this->onSchemaAlterTable($diff, $tableSql)) {
584
            return array_merge($tableSql, $columnSql);
585
        }
586

587
        foreach ($queryParts as $query) {
588
            $sql[] = 'ALTER TABLE ' . $diff->getName($this)->getQuotedName($this) . ' ' . $query;
589
        }
590

591
        $sql = array_merge($sql, $commentsSql);
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
592

Sergei Morozov's avatar
Sergei Morozov committed
593 594 595 596
        $newName = $diff->getNewName();

        if ($newName !== false) {
            $sql[] = "sp_RENAME '" . $diff->getName($this)->getQuotedName($this) . "', '" . $newName->getName() . "'";
597 598 599 600 601 602 603 604 605 606 607 608

            /**
             * Rename table's default constraints names
             * to match the new table name.
             * This is necessary to ensure that the default
             * constraints can be referenced in future table
             * alterations as the table name is encoded in
             * default constraints' names.
             */
            $sql[] = "DECLARE @sql NVARCHAR(MAX) = N''; " .
                "SELECT @sql += N'EXEC sp_rename N''' + dc.name + ''', N''' " .
                "+ REPLACE(dc.name, '" . $this->generateIdentifierName($diff->name) . "', " .
Sergei Morozov's avatar
Sergei Morozov committed
609
                "'" . $this->generateIdentifierName($newName->getName()) . "') + ''', ''OBJECT'';' " .
610 611
                'FROM sys.default_constraints dc ' .
                'JOIN sys.tables tbl ON dc.parent_object_id = tbl.object_id ' .
Sergei Morozov's avatar
Sergei Morozov committed
612
                "WHERE tbl.name = '" . $newName->getName() . "';" .
613
                'EXEC sp_executesql @sql';
614 615
        }

616 617 618 619 620 621
        $sql = array_merge(
            $this->getPreAlterTableIndexForeignKeySQL($diff),
            $sql,
            $this->getPostAlterTableIndexForeignKeySQL($diff)
        );

622
        return array_merge($sql, $tableSql, $columnSql);
623
    }
624

625 626 627
    /**
     * Returns the SQL clause for adding a default constraint in an ALTER TABLE statement.
     *
628 629
     * @param string $tableName The name of the table to generate the clause for.
     * @param Column $column    The column to generate the clause for.
630 631 632 633 634
     *
     * @return string
     */
    private function getAlterTableAddDefaultConstraintClause($tableName, Column $column)
    {
635
        $columnDef         = $column->toArray();
636 637 638 639 640 641 642 643
        $columnDef['name'] = $column->getQuotedName($this);

        return 'ADD' . $this->getDefaultConstraintDeclarationSQL($tableName, $columnDef);
    }

    /**
     * Returns the SQL clause for dropping an existing default constraint in an ALTER TABLE statement.
     *
644 645
     * @param string $tableName  The name of the table to generate the clause for.
     * @param string $columnName The name of the column to generate the clause for.
646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661
     *
     * @return string
     */
    private function getAlterTableDropDefaultConstraintClause($tableName, $columnName)
    {
        return 'DROP CONSTRAINT ' . $this->generateDefaultConstraintName($tableName, $columnName);
    }

    /**
     * Checks whether a column alteration requires dropping its default constraint first.
     *
     * Different to other database vendors SQL Server implements column default values
     * as constraints and therefore changes in a column's default value as well as changes
     * in a column's type require dropping the default constraint first before being to
     * alter the particular column to the new definition.
     *
662
     * @param ColumnDiff $columnDiff The column diff to evaluate.
663
     *
664
     * @return bool True if the column alteration requires dropping its default constraint first, false otherwise.
665 666 667 668 669
     */
    private function alterColumnRequiresDropDefaultConstraint(ColumnDiff $columnDiff)
    {
        // We can only decide whether to drop an existing default constraint
        // if we know the original default value.
670
        if (! $columnDiff->fromColumn instanceof Column) {
671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687
            return false;
        }

        // We only need to drop an existing default constraint if we know the
        // column was defined with a default value before.
        if ($columnDiff->fromColumn->getDefault() === null) {
            return false;
        }

        // We need to drop an existing default constraint if the column was
        // defined with a default value before and it has changed.
        if ($columnDiff->hasChanged('default')) {
            return true;
        }

        // We need to drop an existing default constraint if the column was
        // defined with a default value before and the native column type has changed.
Gabriel Caruso's avatar
Gabriel Caruso committed
688
        return $columnDiff->hasChanged('type') || $columnDiff->hasChanged('fixed');
689 690
    }

691 692 693 694 695 696 697 698 699 700 701
    /**
     * Returns the SQL statement for altering a column comment.
     *
     * SQL Server does not support native column comments,
     * therefore the extended properties functionality is used
     * as a workaround to store them.
     * The property name used to store column comments is "MS_Description"
     * which provides compatibility with SQL Server Management Studio,
     * as column comments are stored in the same property there when
     * specifying a column's "Description" attribute.
     *
Sergei Morozov's avatar
Sergei Morozov committed
702 703 704
     * @param string      $tableName  The quoted table name to which the column belongs.
     * @param string      $columnName The quoted column name to alter the comment for.
     * @param string|null $comment    The column's comment.
705 706 707 708 709
     *
     * @return string
     */
    protected function getAlterColumnCommentSQL($tableName, $columnName, $comment)
    {
710 711 712 713 714 715 716 717 718
        if (strpos($tableName, '.') !== false) {
            [$schemaSQL, $tableSQL] = explode('.', $tableName);
            $schemaSQL              = $this->quoteStringLiteral($schemaSQL);
            $tableSQL               = $this->quoteStringLiteral($tableSQL);
        } else {
            $schemaSQL = "'dbo'";
            $tableSQL  = $this->quoteStringLiteral($tableName);
        }

719 720 721 722
        return $this->getUpdateExtendedPropertySQL(
            'MS_Description',
            $comment,
            'SCHEMA',
723
            $schemaSQL,
724
            'TABLE',
725
            $tableSQL,
726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748
            'COLUMN',
            $columnName
        );
    }

    /**
     * Returns the SQL statement for dropping a column comment.
     *
     * SQL Server does not support native column comments,
     * therefore the extended properties functionality is used
     * as a workaround to store them.
     * The property name used to store column comments is "MS_Description"
     * which provides compatibility with SQL Server Management Studio,
     * as column comments are stored in the same property there when
     * specifying a column's "Description" attribute.
     *
     * @param string $tableName  The quoted table name to which the column belongs.
     * @param string $columnName The quoted column name to drop the comment for.
     *
     * @return string
     */
    protected function getDropColumnCommentSQL($tableName, $columnName)
    {
749 750 751 752 753 754 755 756 757
        if (strpos($tableName, '.') !== false) {
            [$schemaSQL, $tableSQL] = explode('.', $tableName);
            $schemaSQL              = $this->quoteStringLiteral($schemaSQL);
            $tableSQL               = $this->quoteStringLiteral($tableSQL);
        } else {
            $schemaSQL = "'dbo'";
            $tableSQL  = $this->quoteStringLiteral($tableName);
        }

758 759 760
        return $this->getDropExtendedPropertySQL(
            'MS_Description',
            'SCHEMA',
761
            $schemaSQL,
762
            'TABLE',
763
            $tableSQL,
764 765 766 767 768
            'COLUMN',
            $columnName
        );
    }

769 770 771 772 773
    /**
     * {@inheritdoc}
     */
    protected function getRenameIndexSQL($oldIndexName, Index $index, $tableName)
    {
774 775 776 777 778 779
        return [sprintf(
            "EXEC sp_RENAME N'%s.%s', N'%s', N'INDEX'",
            $tableName,
            $oldIndexName,
            $index->getQuotedName($this)
        ),
780
        ];
781 782
    }

783 784 785
    /**
     * Returns the SQL statement for adding an extended property to a database object.
     *
786 787
     * @link http://msdn.microsoft.com/en-us/library/ms180047%28v=sql.90%29.aspx
     *
788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808
     * @param string      $name       The name of the property to add.
     * @param string|null $value      The value of the property to add.
     * @param string|null $level0Type The type of the object at level 0 the property belongs to.
     * @param string|null $level0Name The name of the object at level 0 the property belongs to.
     * @param string|null $level1Type The type of the object at level 1 the property belongs to.
     * @param string|null $level1Name The name of the object at level 1 the property belongs to.
     * @param string|null $level2Type The type of the object at level 2 the property belongs to.
     * @param string|null $level2Name The name of the object at level 2 the property belongs to.
     *
     * @return string
     */
    public function getAddExtendedPropertySQL(
        $name,
        $value = null,
        $level0Type = null,
        $level0Name = null,
        $level1Type = null,
        $level1Name = null,
        $level2Type = null,
        $level2Name = null
    ) {
809
        return 'EXEC sp_addextendedproperty ' .
Sergei Morozov's avatar
Sergei Morozov committed
810 811 812 813
            'N' . $this->quoteStringLiteral($name) . ', N' . $this->quoteStringLiteral((string) $value) . ', ' .
            'N' . $this->quoteStringLiteral((string) $level0Type) . ', ' . $level0Name . ', ' .
            'N' . $this->quoteStringLiteral((string) $level1Type) . ', ' . $level1Name . ', ' .
            'N' . $this->quoteStringLiteral((string) $level2Type) . ', ' . $level2Name;
814 815 816 817 818
    }

    /**
     * Returns the SQL statement for dropping an extended property from a database object.
     *
819 820
     * @link http://technet.microsoft.com/en-gb/library/ms178595%28v=sql.90%29.aspx
     *
821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839
     * @param string      $name       The name of the property to drop.
     * @param string|null $level0Type The type of the object at level 0 the property belongs to.
     * @param string|null $level0Name The name of the object at level 0 the property belongs to.
     * @param string|null $level1Type The type of the object at level 1 the property belongs to.
     * @param string|null $level1Name The name of the object at level 1 the property belongs to.
     * @param string|null $level2Type The type of the object at level 2 the property belongs to.
     * @param string|null $level2Name The name of the object at level 2 the property belongs to.
     *
     * @return string
     */
    public function getDropExtendedPropertySQL(
        $name,
        $level0Type = null,
        $level0Name = null,
        $level1Type = null,
        $level1Name = null,
        $level2Type = null,
        $level2Name = null
    ) {
840 841
        return 'EXEC sp_dropextendedproperty ' .
            'N' . $this->quoteStringLiteral($name) . ', ' .
Sergei Morozov's avatar
Sergei Morozov committed
842 843 844
            'N' . $this->quoteStringLiteral((string) $level0Type) . ', ' . $level0Name . ', ' .
            'N' . $this->quoteStringLiteral((string) $level1Type) . ', ' . $level1Name . ', ' .
            'N' . $this->quoteStringLiteral((string) $level2Type) . ', ' . $level2Name;
845 846 847 848 849
    }

    /**
     * Returns the SQL statement for updating an extended property of a database object.
     *
850 851
     * @link http://msdn.microsoft.com/en-us/library/ms186885%28v=sql.90%29.aspx
     *
852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872
     * @param string      $name       The name of the property to update.
     * @param string|null $value      The value of the property to update.
     * @param string|null $level0Type The type of the object at level 0 the property belongs to.
     * @param string|null $level0Name The name of the object at level 0 the property belongs to.
     * @param string|null $level1Type The type of the object at level 1 the property belongs to.
     * @param string|null $level1Name The name of the object at level 1 the property belongs to.
     * @param string|null $level2Type The type of the object at level 2 the property belongs to.
     * @param string|null $level2Name The name of the object at level 2 the property belongs to.
     *
     * @return string
     */
    public function getUpdateExtendedPropertySQL(
        $name,
        $value = null,
        $level0Type = null,
        $level0Name = null,
        $level1Type = null,
        $level1Name = null,
        $level2Type = null,
        $level2Name = null
    ) {
873
        return 'EXEC sp_updateextendedproperty ' .
Sergei Morozov's avatar
Sergei Morozov committed
874 875 876 877
            'N' . $this->quoteStringLiteral($name) . ', N' . $this->quoteStringLiteral((string) $value) . ', ' .
            'N' . $this->quoteStringLiteral((string) $level0Type) . ', ' . $level0Name . ', ' .
            'N' . $this->quoteStringLiteral((string) $level1Type) . ', ' . $level1Name . ', ' .
            'N' . $this->quoteStringLiteral((string) $level2Type) . ', ' . $level2Name;
878 879
    }

880
    /**
881
     * {@inheritDoc}
882
     */
883
    public function getEmptyIdentityInsertSQL($quotedTableName, $quotedIdentifierColumnName)
884
    {
885
        return 'INSERT INTO ' . $quotedTableName . ' DEFAULT VALUES';
886 887
    }

888
    /**
889
     * {@inheritDoc}
890
     */
891
    public function getListTablesSQL()
892
    {
893
        // "sysdiagrams" table must be ignored as it's internal SQL Server table for Database Diagrams
894 895
        // Category 2 must be ignored as it is "MS SQL Server 'pseudo-system' object[s]" for replication
        return "SELECT name FROM sysobjects WHERE type = 'U' AND name != 'sysdiagrams' AND category != 2 ORDER BY name";
896 897 898
    }

    /**
899
     * {@inheritDoc}
900
     */
901
    public function getListTableColumnsSQL($table, $database = null)
902
    {
903 904 905 906 907 908 909 910
        return "SELECT    col.name,
                          type.name AS type,
                          col.max_length AS length,
                          ~col.is_nullable AS notnull,
                          def.definition AS [default],
                          col.scale,
                          col.precision,
                          col.is_identity AS autoincrement,
911 912
                          col.collation_name AS collation,
                          CAST(prop.value AS NVARCHAR(MAX)) AS comment -- CAST avoids driver error for sql_variant type
913 914 915 916 917
                FROM      sys.columns AS col
                JOIN      sys.types AS type
                ON        col.user_type_id = type.user_type_id
                JOIN      sys.objects AS obj
                ON        col.object_id = obj.object_id
918 919
                JOIN      sys.schemas AS scm
                ON        obj.schema_id = scm.schema_id
920 921 922
                LEFT JOIN sys.default_constraints def
                ON        col.default_object_id = def.object_id
                AND       col.object_id = def.parent_object_id
923 924 925 926
                LEFT JOIN sys.extended_properties AS prop
                ON        obj.object_id = prop.major_id
                AND       col.column_id = prop.minor_id
                AND       prop.name = 'MS_Description'
927
                WHERE     obj.type = 'U'
928
                AND       " . $this->getTableWhereClause($table, 'scm.name', 'obj.name');
929 930 931
    }

    /**
932
     * {@inheritDoc}
933 934 935
     */
    public function getListTableForeignKeysSQL($table, $database = null)
    {
936
        return 'SELECT f.name AS ForeignKey,
937 938 939 940 941 942 943 944 945 946 947 948
                SCHEMA_NAME (f.SCHEMA_ID) AS SchemaName,
                OBJECT_NAME (f.parent_object_id) AS TableName,
                COL_NAME (fc.parent_object_id,fc.parent_column_id) AS ColumnName,
                SCHEMA_NAME (o.SCHEMA_ID) ReferenceSchemaName,
                OBJECT_NAME (f.referenced_object_id) AS ReferenceTableName,
                COL_NAME(fc.referenced_object_id,fc.referenced_column_id) AS ReferenceColumnName,
                f.delete_referential_action_desc,
                f.update_referential_action_desc
                FROM sys.foreign_keys AS f
                INNER JOIN sys.foreign_key_columns AS fc
                INNER JOIN sys.objects AS o ON o.OBJECT_ID = fc.referenced_object_id
                ON f.OBJECT_ID = fc.constraint_object_id
949
                WHERE ' .
950
                $this->getTableWhereClause($table, 'SCHEMA_NAME (f.schema_id)', 'OBJECT_NAME (f.parent_object_id)');
951 952 953
    }

    /**
954
     * {@inheritDoc}
955
     */
956
    public function getListTableIndexesSQL($table, $currentDatabase = null)
957
    {
958 959
        return "SELECT idx.name AS key_name,
                       col.name AS column_name,
Steve Müller's avatar
Steve Müller committed
960 961
                       ~idx.is_unique AS non_unique,
                       idx.is_primary_key AS [primary],
962 963 964 965 966 967
                       CASE idx.type
                           WHEN '1' THEN 'clustered'
                           WHEN '2' THEN 'nonclustered'
                           ELSE NULL
                       END AS flags
                FROM sys.tables AS tbl
968
                JOIN sys.schemas AS scm ON tbl.schema_id = scm.schema_id
969 970 971
                JOIN sys.indexes AS idx ON tbl.object_id = idx.object_id
                JOIN sys.index_columns AS idxcol ON idx.object_id = idxcol.object_id AND idx.index_id = idxcol.index_id
                JOIN sys.columns AS col ON idxcol.object_id = col.object_id AND idxcol.column_id = col.column_id
972 973
                WHERE " . $this->getTableWhereClause($table, 'scm.name', 'tbl.name') . '
                ORDER BY idx.index_id ASC, idxcol.key_ordinal ASC';
974
    }
975 976

    /**
977
     * {@inheritDoc}
978
     */
979
    public function getCreateViewSQL($name, $sql)
980 981 982
    {
        return 'CREATE VIEW ' . $name . ' AS ' . $sql;
    }
983 984

    /**
985
     * {@inheritDoc}
986
     */
987
    public function getListViewsSQL($database)
988 989 990 991
    {
        return "SELECT name FROM sysobjects WHERE type = 'V' ORDER BY name";
    }

992 993 994 995
    /**
     * Returns the where clause to filter schema and table name in a query.
     *
     * @param string $table        The full qualified name of the table.
996 997
     * @param string $schemaColumn The name of the column to compare the schema to in the where clause.
     * @param string $tableColumn  The name of the column to compare the table to in the where clause.
998 999 1000 1001 1002
     *
     * @return string
     */
    private function getTableWhereClause($table, $schemaColumn, $tableColumn)
    {
1003 1004 1005 1006
        if (strpos($table, '.') !== false) {
            [$schema, $table] = explode('.', $table);
            $schema           = $this->quoteStringLiteral($schema);
            $table            = $this->quoteStringLiteral($table);
1007
        } else {
1008 1009
            $schema = 'SCHEMA_NAME()';
            $table  = $this->quoteStringLiteral($table);
1010 1011
        }

1012
        return sprintf('(%s = %s AND %s = %s)', $tableColumn, $table, $schemaColumn, $schema);
1013 1014
    }

1015
    /**
1016
     * {@inheritDoc}
1017 1018 1019
     */
    public function getDropViewSQL($name)
    {
1020
        return 'DROP VIEW ' . $name;
1021
    }
1022 1023

    /**
1024
     * {@inheritDoc}
1025 1026
     *
     * @deprecated Use application-generated UUIDs instead
1027 1028 1029
     */
    public function getGuidExpression()
    {
1030
        return 'NEWID()';
1031
    }
1032 1033

    /**
1034
     * {@inheritDoc}
1035
     */
1036
    public function getLocateExpression($str, $substr, $startPos = false)
1037
    {
1038
        if ($startPos === false) {
1039 1040
            return 'CHARINDEX(' . $substr . ', ' . $str . ')';
        }
1041 1042

        return 'CHARINDEX(' . $substr . ', ' . $str . ', ' . $startPos . ')';
1043
    }
1044

1045
    /**
1046
     * {@inheritDoc}
1047
     */
1048
    public function getModExpression($expression1, $expression2)
1049
    {
1050
        return $expression1 . ' % ' . $expression2;
1051
    }
1052

1053
    /**
1054
     * {@inheritDoc}
1055
     */
1056
    public function getTrimExpression($str, $pos = TrimMode::UNSPECIFIED, $char = false)
1057
    {
1058
        if (! $char) {
1059
            switch ($pos) {
1060
                case TrimMode::LEADING:
1061 1062 1063
                    $trimFn = 'LTRIM';
                    break;

1064
                case TrimMode::TRAILING:
1065 1066 1067 1068 1069
                    $trimFn = 'RTRIM';
                    break;

                default:
                    return 'LTRIM(RTRIM(' . $str . '))';
1070 1071 1072 1073
            }

            return $trimFn . '(' . $str . ')';
        }
1074 1075 1076 1077 1078 1079 1080 1081 1082 1083

        /** Original query used to get those expressions
          declare @c varchar(100) = 'xxxBarxxx', @trim_char char(1) = 'x';
          declare @pat varchar(10) = '%[^' + @trim_char + ']%';
          select @c as string
          , @trim_char as trim_char
          , stuff(@c, 1, patindex(@pat, @c) - 1, null) as trim_leading
          , reverse(stuff(reverse(@c), 1, patindex(@pat, reverse(@c)) - 1, null)) as trim_trailing
          , reverse(stuff(reverse(stuff(@c, 1, patindex(@pat, @c) - 1, null)), 1, patindex(@pat, reverse(stuff(@c, 1, patindex(@pat, @c) - 1, null))) - 1, null)) as trim_both;
         */
1084
        $pattern = "'%[^' + " . $char . " + ']%'";
1085

1086
        if ($pos === TrimMode::LEADING) {
1087 1088 1089
            return 'stuff(' . $str . ', 1, patindex(' . $pattern . ', ' . $str . ') - 1, null)';
        }

1090
        if ($pos === TrimMode::TRAILING) {
1091 1092 1093 1094
            return 'reverse(stuff(reverse(' . $str . '), 1, patindex(' . $pattern . ', reverse(' . $str . ')) - 1, null))';
        }

        return 'reverse(stuff(reverse(stuff(' . $str . ', 1, patindex(' . $pattern . ', ' . $str . ') - 1, null)), 1, patindex(' . $pattern . ', reverse(stuff(' . $str . ', 1, patindex(' . $pattern . ', ' . $str . ') - 1, null))) - 1, null))';
1095
    }
1096

1097
    /**
1098
     * {@inheritDoc}
1099 1100
     */
    public function getConcatExpression()
1101
    {
1102
        $args = func_get_args();
1103

1104
        return '(' . implode(' + ', $args) . ')';
1105
    }
1106

Benjamin Morel's avatar
Benjamin Morel committed
1107 1108 1109
    /**
     * {@inheritDoc}
     */
1110
    public function getListDatabasesSQL()
1111
    {
1112
        return 'SELECT * FROM sys.databases';
1113
    }
1114

1115 1116 1117 1118 1119
    /**
     * {@inheritDoc}
     */
    public function getListNamespacesSQL()
    {
1120
        return "SELECT name FROM sys.schemas WHERE name NOT IN('guest', 'INFORMATION_SCHEMA', 'sys')";
1121 1122
    }

1123
    /**
1124
     * {@inheritDoc}
1125
     */
1126
    public function getSubstringExpression($value, $from, $length = null)
1127
    {
1128
        if ($length !== null) {
1129
            return 'SUBSTRING(' . $value . ', ' . $from . ', ' . $length . ')';
1130
        }
1131

1132
        return 'SUBSTRING(' . $value . ', ' . $from . ', LEN(' . $value . ') - ' . $from . ' + 1)';
1133
    }
1134

1135
    /**
1136
     * {@inheritDoc}
1137
     */
1138
    public function getLengthExpression($column)
1139
    {
1140
        return 'LEN(' . $column . ')';
1141 1142
    }

1143
    /**
1144
     * {@inheritDoc}
1145
     */
1146
    public function getSetTransactionIsolationSQL($level)
romanb's avatar
romanb committed
1147
    {
1148
        return 'SET TRANSACTION ISOLATION LEVEL ' . $this->_getTransactionIsolationLevelSQL($level);
romanb's avatar
romanb committed
1149
    }
1150

1151
    /**
1152
     * {@inheritDoc}
1153
     */
1154
    public function getIntegerTypeDeclarationSQL(array $field)
1155
    {
1156
        return 'INT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
1157 1158
    }

1159
    /**
1160
     * {@inheritDoc}
1161
     */
1162
    public function getBigIntTypeDeclarationSQL(array $field)
1163
    {
1164
        return 'BIGINT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
1165 1166
    }

1167
    /**
1168
     * {@inheritDoc}
1169
     */
1170
    public function getSmallIntTypeDeclarationSQL(array $field)
1171
    {
1172
        return 'SMALLINT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
1173 1174
    }

1175
    /**
1176
     * {@inheritDoc}
1177
     */
1178
    public function getGuidTypeDeclarationSQL(array $field)
1179 1180 1181 1182
    {
        return 'UNIQUEIDENTIFIER';
    }

1183 1184 1185
    /**
     * {@inheritDoc}
     */
1186
    protected function getVarcharTypeDeclarationSQLSnippet($length, $fixed)
1187
    {
1188
        return $fixed ? ($length ? 'NCHAR(' . $length . ')' : 'CHAR(255)') : ($length ? 'NVARCHAR(' . $length . ')' : 'NVARCHAR(255)');
1189
    }
1190

Steve Müller's avatar
Steve Müller committed
1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206
    /**
     * {@inheritdoc}
     */
    protected function getBinaryTypeDeclarationSQLSnippet($length, $fixed)
    {
        return $fixed ? 'BINARY(' . ($length ?: 255) . ')' : 'VARBINARY(' . ($length ?: 255) . ')';
    }

    /**
     * {@inheritdoc}
     */
    public function getBinaryMaxLength()
    {
        return 8000;
    }

1207 1208 1209
    /**
     * {@inheritDoc}
     */
1210
    public function getClobTypeDeclarationSQL(array $field)
1211
    {
1212
        return 'VARCHAR(MAX)';
1213
    }
1214

1215
    /**
1216
     * {@inheritDoc}
1217
     */
1218
    protected function _getCommonIntegerTypeDeclarationSQL(array $columnDef)
1219
    {
1220
        return ! empty($columnDef['autoincrement']) ? ' IDENTITY' : '';
1221
    }
1222

1223
    /**
1224
     * {@inheritDoc}
1225
     */
1226
    public function getDateTimeTypeDeclarationSQL(array $fieldDeclaration)
1227
    {
1228
        return 'DATETIME';
1229 1230
    }

1231
    /**
1232
     * {@inheritDoc}
1233
     */
1234
    public function getDateTypeDeclarationSQL(array $fieldDeclaration)
1235
    {
1236
        return 'DATETIME';
1237
    }
1238 1239

    /**
1240
     * {@inheritDoc}
1241
     */
1242
    public function getTimeTypeDeclarationSQL(array $fieldDeclaration)
1243
    {
1244
        return 'DATETIME';
1245
    }
1246

1247
    /**
1248
     * {@inheritDoc}
1249
     */
1250
    public function getBooleanTypeDeclarationSQL(array $field)
1251 1252 1253 1254
    {
        return 'BIT';
    }

1255
    /**
1256
     * {@inheritDoc}
1257
     */
1258
    protected function doModifyLimitQuery($query, $limit, $offset = null)
1259
    {
1260 1261 1262 1263
        $where = [];

        if ($offset > 0) {
            $where[] = sprintf('doctrine_rownum >= %d', $offset + 1);
Fabio B. Silva's avatar
Fabio B. Silva committed
1264
        }
1265

1266 1267 1268 1269 1270 1271 1272 1273 1274 1275
        if ($limit !== null) {
            $where[] = sprintf('doctrine_rownum <= %d', $offset + $limit);
            $top     = sprintf('TOP %d', $offset + $limit);
        } else {
            $top = 'TOP 9223372036854775807';
        }

        if (empty($where)) {
            return $query;
        }
1276

1277
        // We'll find a SELECT or SELECT distinct and prepend TOP n to it
1278 1279 1280
        // Even if the TOP n is very large, the use of a CTE will
        // allow the SQL Server query planner to optimize it so it doesn't
        // actually scan the entire range covered by the TOP clause.
1281
        if (! preg_match('/^(\s*SELECT\s+(?:DISTINCT\s+)?)(.*)$/is', $query, $matches)) {
Sergei Morozov's avatar
Sergei Morozov committed
1282 1283 1284 1285
            return $query;
        }

        $query = $matches[1] . $top . ' ' . $matches[2];
1286

1287
        if (stristr($query, 'ORDER BY')) {
1288
            // Inner order by is not valid in SQL Server for our purposes
1289
            // unless it's in a TOP N subquery.
1290
            $query = $this->scrubInnerOrderBy($query);
Fabio B. Silva's avatar
Fabio B. Silva committed
1291 1292
        }

1293 1294
        // Build a new limited query around the original, using a CTE
        return sprintf(
1295 1296 1297 1298
            'WITH dctrn_cte AS (%s) '
            . 'SELECT * FROM ('
            . 'SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte'
            . ') AS doctrine_tbl '
1299
            . 'WHERE %s ORDER BY doctrine_rownum ASC',
1300
            $query,
1301
            implode(' AND ', $where)
1302 1303
        );
    }
1304

1305 1306
    /**
     * Remove ORDER BY clauses in subqueries - they're not supported by SQL Server.
1307
     * Caveat: will leave ORDER BY in TOP N subqueries.
1308
     *
1309
     * @param string $query
1310
     *
1311 1312
     * @return string
     */
Bill Schaller's avatar
Bill Schaller committed
1313 1314
    private function scrubInnerOrderBy($query)
    {
1315
        $count  = substr_count(strtoupper($query), 'ORDER BY');
1316
        $offset = 0;
Bill Schaller's avatar
Bill Schaller committed
1317

1318
        while ($count-- > 0) {
1319
            $orderByPos = stripos($query, ' ORDER BY', $offset);
1320 1321 1322 1323
            if ($orderByPos === false) {
                break;
            }

1324 1325
            $qLen            = strlen($query);
            $parenCount      = 0;
1326
            $currentPosition = $orderByPos;
1327

1328
            while ($parenCount >= 0 && $currentPosition < $qLen) {
1329
                if ($query[$currentPosition] === '(') {
1330
                    $parenCount++;
1331
                } elseif ($query[$currentPosition] === ')') {
1332
                    $parenCount--;
Fabio B. Silva's avatar
Fabio B. Silva committed
1333
                }
1334

1335 1336
                $currentPosition++;
            }
1337 1338 1339 1340 1341 1342 1343 1344

            if ($this->isOrderByInTopNSubquery($query, $orderByPos)) {
                // If the order by clause is in a TOP N subquery, do not remove
                // it and continue iteration from the current position.
                $offset = $currentPosition;
                continue;
            }

1345 1346
            if ($currentPosition >= $qLen - 1) {
                continue;
Fabio B. Silva's avatar
Fabio B. Silva committed
1347
            }
1348 1349 1350

            $query  = substr($query, 0, $orderByPos) . substr($query, $currentPosition - 1);
            $offset = $orderByPos;
1351
        }
1352
        return $query;
1353
    }
1354

1355 1356 1357
    /**
     * Check an ORDER BY clause to see if it is in a TOP N query or subquery.
     *
1358 1359
     * @param string $query           The query
     * @param int    $currentPosition Start position of ORDER BY clause
1360
     *
1361 1362 1363 1364 1365 1366
     * @return bool true if ORDER BY is in a TOP N query, false otherwise
     */
    private function isOrderByInTopNSubquery($query, $currentPosition)
    {
        // Grab query text on the same nesting level as the ORDER BY clause we're examining.
        $subQueryBuffer = '';
1367
        $parenCount     = 0;
1368

Bill Schaller's avatar
Bill Schaller committed
1369
        // If $parenCount goes negative, we've exited the subquery we're examining.
1370 1371
        // If $currentPosition goes negative, we've reached the beginning of the query.
        while ($parenCount >= 0 && $currentPosition >= 0) {
1372
            if ($query[$currentPosition] === '(') {
1373
                $parenCount--;
Bill Schaller's avatar
Bill Schaller committed
1374
            } elseif ($query[$currentPosition] === ')') {
1375 1376
                $parenCount++;
            }
1377 1378

            // Only yank query text on the same nesting level as the ORDER BY clause.
1379
            $subQueryBuffer = ($parenCount === 0 ? $query[$currentPosition] : ' ') . $subQueryBuffer;
1380 1381 1382 1383

            $currentPosition--;
        }

Gabriel Caruso's avatar
Gabriel Caruso committed
1384
        return (bool) preg_match('/SELECT\s+(DISTINCT\s+)?TOP\s/i', $subQueryBuffer);
1385 1386
    }

1387
    /**
1388
     * {@inheritDoc}
1389 1390 1391 1392 1393 1394
     */
    public function supportsLimitOffset()
    {
        return false;
    }

1395
    /**
1396
     * {@inheritDoc}
1397
     */
1398
    public function convertBooleans($item)
1399
    {
1400 1401
        if (is_array($item)) {
            foreach ($item as $key => $value) {
1402
                if (! is_bool($value) && ! is_numeric($value)) {
1403
                    continue;
1404
                }
1405 1406

                $item[$key] = $value ? 1 : 0;
1407
            }
Steve Müller's avatar
Steve Müller committed
1408
        } elseif (is_bool($item) || is_numeric($item)) {
1409
            $item = $item ? 1 : 0;
1410
        }
1411

1412
        return $item;
1413
    }
1414 1415

    /**
1416
     * {@inheritDoc}
1417
     */
1418
    public function getCreateTemporaryTableSnippetSQL()
1419
    {
1420
        return 'CREATE TABLE';
1421
    }
1422

1423
    /**
1424
     * {@inheritDoc}
1425 1426 1427 1428 1429 1430
     */
    public function getTemporaryTableName($tableName)
    {
        return '#' . $tableName;
    }

1431
    /**
1432
     * {@inheritDoc}
1433 1434 1435
     */
    public function getDateTimeFormatString()
    {
1436 1437
        return 'Y-m-d H:i:s.000';
    }
1438

1439
    /**
1440
     * {@inheritDoc}
1441
     */
1442 1443 1444 1445 1446 1447
    public function getDateFormatString()
    {
        return 'Y-m-d H:i:s.000';
    }

    /**
1448
     * {@inheritDoc}
1449
     */
1450 1451 1452
    public function getTimeFormatString()
    {
        return 'Y-m-d H:i:s.000';
1453
    }
1454

1455
    /**
1456
     * {@inheritDoc}
1457 1458 1459 1460 1461
     */
    public function getDateTimeTzFormatString()
    {
        return $this->getDateTimeFormatString();
    }
1462

1463
    /**
1464
     * {@inheritDoc}
1465
     */
1466
    public function getName()
1467
    {
1468
        return 'mssql';
1469
    }
1470

Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1471
    /**
1472
     * {@inheritDoc}
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1473
     */
1474 1475
    protected function initializeDoctrineTypeMappings()
    {
1476
        $this->doctrineTypeMapping = [
1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497
            'bigint' => 'bigint',
            'numeric' => 'decimal',
            'bit' => 'boolean',
            'smallint' => 'smallint',
            'decimal' => 'decimal',
            'smallmoney' => 'integer',
            'int' => 'integer',
            'tinyint' => 'smallint',
            'money' => 'integer',
            'float' => 'float',
            'real' => 'float',
            'double' => 'float',
            'double precision' => 'float',
            'smalldatetime' => 'datetime',
            'datetime' => 'datetime',
            'char' => 'string',
            'varchar' => 'string',
            'text' => 'text',
            'nchar' => 'string',
            'nvarchar' => 'string',
            'ntext' => 'text',
Steve Müller's avatar
Steve Müller committed
1498 1499
            'binary' => 'binary',
            'varbinary' => 'binary',
1500
            'image' => 'blob',
1501
            'uniqueidentifier' => 'guid',
1502
        ];
1503
    }
1504 1505

    /**
1506
     * {@inheritDoc}
1507 1508 1509 1510 1511 1512 1513
     */
    public function createSavePoint($savepoint)
    {
        return 'SAVE TRANSACTION ' . $savepoint;
    }

    /**
1514
     * {@inheritDoc}
1515 1516 1517 1518 1519 1520 1521
     */
    public function releaseSavePoint($savepoint)
    {
        return '';
    }

    /**
1522
     * {@inheritDoc}
1523 1524 1525 1526
     */
    public function rollbackSavePoint($savepoint)
    {
        return 'ROLLBACK TRANSACTION ' . $savepoint;
1527
    }
1528

1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541
    /**
     * {@inheritdoc}
     */
    public function getForeignKeyReferentialActionSQL($action)
    {
        // RESTRICT is not supported, therefore falling back to NO ACTION.
        if (strtoupper($action) === 'RESTRICT') {
            return 'NO ACTION';
        }

        return parent::getForeignKeyReferentialActionSQL($action);
    }

1542
    /**
1543
     * {@inheritDoc}
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1544
     */
1545
    public function appendLockHint($fromClause, $lockMode)
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1546
    {
1547
        switch (true) {
1548
            case $lockMode === LockMode::NONE:
1549 1550
                return $fromClause . ' WITH (NOLOCK)';

1551
            case $lockMode === LockMode::PESSIMISTIC_READ:
1552 1553
                return $fromClause . ' WITH (HOLDLOCK, ROWLOCK)';

1554
            case $lockMode === LockMode::PESSIMISTIC_WRITE:
1555 1556
                return $fromClause . ' WITH (UPDLOCK, ROWLOCK)';

Steve Müller's avatar
Steve Müller committed
1557
            default:
1558
                return $fromClause;
Steve Müller's avatar
Steve Müller committed
1559
        }
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1560 1561 1562
    }

    /**
1563
     * {@inheritDoc}
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1564 1565 1566 1567 1568
     */
    public function getForUpdateSQL()
    {
        return ' ';
    }
1569

1570 1571 1572
    /**
     * {@inheritDoc}
     */
1573 1574
    protected function getReservedKeywordsClass()
    {
1575
        return Keywords\SQLServerKeywords::class;
1576
    }
1577 1578

    /**
1579
     * {@inheritDoc}
1580
     */
1581
    public function quoteSingleIdentifier($str)
1582
    {
1583
        return '[' . str_replace(']', '][', $str) . ']';
1584
    }
1585

1586 1587 1588
    /**
     * {@inheritDoc}
     */
1589 1590
    public function getTruncateTableSQL($tableName, $cascade = false)
    {
1591 1592 1593
        $tableIdentifier = new Identifier($tableName);

        return 'TRUNCATE TABLE ' . $tableIdentifier->getQuotedName($this);
1594
    }
1595 1596

    /**
1597
     * {@inheritDoc}
1598 1599 1600 1601 1602
     */
    public function getBlobTypeDeclarationSQL(array $field)
    {
        return 'VARBINARY(MAX)';
    }
1603 1604 1605 1606

    /**
     * {@inheritDoc}
     */
1607 1608
    public function getDefaultValueDeclarationSQL($field)
    {
1609
        if (! isset($field['default'])) {
1610 1611 1612
            return empty($field['notnull']) ? ' NULL' : '';
        }

1613
        if (! isset($field['type'])) {
1614
            return " DEFAULT '" . $field['default'] . "'";
1615
        }
1616

1617 1618 1619
        $type = $field['type'];

        if ($type instanceof Types\PhpIntegerMappingType) {
1620
            return ' DEFAULT ' . $field['default'];
1621 1622
        }

1623
        if ($type instanceof Types\PhpDateTimeMappingType && $field['default'] === $this->getCurrentTimestampSQL()) {
1624
            return ' DEFAULT ' . $this->getCurrentTimestampSQL();
1625 1626
        }

1627
        if ($type instanceof Types\BooleanType) {
1628 1629 1630 1631
            return " DEFAULT '" . $this->convertBooleans($field['default']) . "'";
        }

        return " DEFAULT '" . $field['default'] . "'";
1632
    }
1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643

    /**
     * {@inheritdoc}
     *
     * Modifies column declaration order as it differs in Microsoft SQL Server.
     */
    public function getColumnDeclarationSQL($name, array $field)
    {
        if (isset($field['columnDefinition'])) {
            $columnDef = $this->getCustomTypeDeclarationSQL($field);
        } else {
1644
            $collation = isset($field['collation']) && $field['collation'] ?
1645
                ' ' . $this->getColumnCollationDeclarationSQL($field['collation']) : '';
1646

1647
            $notnull = isset($field['notnull']) && $field['notnull'] ? ' NOT NULL' : '';
1648

1649
            $unique = isset($field['unique']) && $field['unique'] ?
1650 1651
                ' ' . $this->getUniqueFieldDeclarationSQL() : '';

1652
            $check = isset($field['check']) && $field['check'] ?
1653 1654
                ' ' . $field['check'] : '';

1655
            $typeDecl  = $field['type']->getSQLDeclaration($field, $this);
1656
            $columnDef = $typeDecl . $collation . $notnull . $unique . $check;
1657 1658 1659 1660
        }

        return $name . ' ' . $columnDef;
    }
1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683

    /**
     * Returns a unique default constraint name for a table and column.
     *
     * @param string $table  Name of the table to generate the unique default constraint name for.
     * @param string $column Name of the column in the table to generate the unique default constraint name for.
     *
     * @return string
     */
    private function generateDefaultConstraintName($table, $column)
    {
        return 'DF_' . $this->generateIdentifierName($table) . '_' . $this->generateIdentifierName($column);
    }

    /**
     * Returns a hash value for a given identifier.
     *
     * @param string $identifier Identifier to generate a hash value for.
     *
     * @return string
     */
    private function generateIdentifierName($identifier)
    {
1684 1685 1686 1687
        // Always generate name for unquoted identifiers to ensure consistency.
        $identifier = new Identifier($identifier);

        return strtoupper(dechex(crc32($identifier->getName())));
1688
    }
1689
}