SQLServerPlatform.php 52.5 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 InvalidArgumentException;
14 15 16 17 18 19
use function array_merge;
use function array_unique;
use function array_values;
use function count;
use function crc32;
use function dechex;
20
use function explode;
21
use function func_get_args;
22
use function implode;
23 24 25 26 27
use function is_array;
use function is_bool;
use function is_numeric;
use function is_string;
use function preg_match;
28
use function sprintf;
29 30 31 32
use function str_replace;
use function stripos;
use function stristr;
use function strlen;
33
use function strpos;
34 35 36
use function strtoupper;
use function substr;
use function substr_count;
37 38

/**
39 40
 * The SQLServerPlatform provides the behavior, features and SQL dialect of the
 * Microsoft SQL Server database platform.
41 42
 *
 * @deprecated Use SQL Server 2012 or newer
43
 */
44
class SQLServerPlatform extends AbstractPlatform
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 74
    /**
     * {@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);
    }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

228 229 230 231 232 233 234 235 236 237 238 239 240 241
        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
        );
242
    }
243 244

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

252 253 254 255 256
        $tableComment = $options['comment'] ?? null;
        if ($tableComment !== null) {
            $commentsSql[] = $this->getCommentOnTableSQL($tableName, $tableComment);
        }

257
        // @todo does other code breaks because of this?
258
        // force primary keys to be not null
259 260 261 262
        foreach ($columns as &$column) {
            if (isset($column['primary']) && $column['primary']) {
                $column['notnull'] = true;
            }
263

264
            // Build default constraints SQL statements.
265
            if (isset($column['default'])) {
266 267 268
                $defaultConstraintsSql[] = 'ALTER TABLE ' . $tableName .
                    ' ADD' . $this->getDefaultConstraintDeclarationSQL($tableName, $column);
            }
269

270 271
            if (empty($column['comment']) && ! is_numeric($column['comment'])) {
                continue;
272
            }
273 274

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

277
        $columnListSql = $this->getColumnDeclarationListSQL($columns);
278

279
        if (isset($options['uniqueConstraints']) && ! empty($options['uniqueConstraints'])) {
280 281 282 283
            foreach ($options['uniqueConstraints'] as $name => $definition) {
                $columnListSql .= ', ' . $this->getUniqueConstraintDeclarationSQL($name, $definition);
            }
        }
284

285
        if (isset($options['primary']) && ! empty($options['primary'])) {
286 287 288 289
            $flags = '';
            if (isset($options['primary_index']) && $options['primary_index']->hasFlag('nonclustered')) {
                $flags = ' NONCLUSTERED';
            }
Grégoire Paris's avatar
Grégoire Paris committed
290

291
            $columnListSql .= ', PRIMARY KEY' . $flags . ' (' . implode(', ', array_unique(array_values($options['primary']))) . ')';
292 293 294 295 296
        }

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

        $check = $this->getCheckDeclarationSQL($columns);
297
        if (! empty($check)) {
298 299
            $query .= ', ' . $check;
        }
Grégoire Paris's avatar
Grégoire Paris committed
300

301 302
        $query .= ')';

303
        $sql = [$query];
304

305
        if (isset($options['indexes']) && ! empty($options['indexes'])) {
306
            foreach ($options['indexes'] as $index) {
307 308 309 310 311
                $sql[] = $this->getCreateIndexSQL($index, $tableName);
            }
        }

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

317
        return array_merge($sql, $commentsSql, $defaultConstraintsSql);
318
    }
319

320
    /**
321
     * {@inheritDoc}
322 323 324
     */
    public function getCreatePrimaryKeySQL(Index $index, $table)
    {
Sergei Morozov's avatar
Sergei Morozov committed
325 326 327 328 329 330 331 332
        if ($table instanceof Table) {
            $identifier = $table->getQuotedName($this);
        } else {
            $identifier = $table;
        }

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

333
        if ($index->hasFlag('nonclustered')) {
Sergei Morozov's avatar
Sergei Morozov committed
334
            $sql .= ' NONCLUSTERED';
335
        }
336

Sergei Morozov's avatar
Sergei Morozov committed
337
        return $sql . ' (' . $this->getIndexFieldDeclarationListSQL($index) . ')';
338 339
    }

340 341 342 343 344 345 346 347 348 349 350
    /**
     * 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
351 352 353
     * @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.
354 355 356 357 358
     *
     * @return string
     */
    protected function getCreateColumnCommentSQL($tableName, $columnName, $comment)
    {
359 360 361 362 363 364 365 366 367
        if (strpos($tableName, '.') !== false) {
            [$schemaSQL, $tableSQL] = explode('.', $tableName);
            $schemaSQL              = $this->quoteStringLiteral($schemaSQL);
            $tableSQL               = $this->quoteStringLiteral($tableSQL);
        } else {
            $schemaSQL = "'dbo'";
            $tableSQL  = $this->quoteStringLiteral($tableName);
        }

368 369 370 371
        return $this->getAddExtendedPropertySQL(
            'MS_Description',
            $comment,
            'SCHEMA',
372
            $schemaSQL,
373
            'TABLE',
374
            $tableSQL,
375 376 377 378 379
            'COLUMN',
            $columnName
        );
    }

380 381 382
    /**
     * Returns the SQL snippet for declaring a default constraint.
     *
383 384
     * @param string  $table  Name of the table to return the default constraint declaration for.
     * @param mixed[] $column Column definition.
385 386 387
     *
     * @return string
     *
388
     * @throws InvalidArgumentException
389 390 391
     */
    public function getDefaultConstraintDeclarationSQL($table, array $column)
    {
392 393
        if (! isset($column['default'])) {
            throw new InvalidArgumentException("Incomplete column definition. 'default' required.");
394 395
        }

396 397
        $columnName = new Identifier($column['name']);

398
        return ' CONSTRAINT ' .
399 400
            $this->generateDefaultConstraintName($table, $column['name']) .
            $this->getDefaultValueDeclarationSQL($column) .
401
            ' FOR ' . $columnName->getQuotedName($this);
402 403
    }

404
    /**
405
     * {@inheritDoc}
406
     */
407
    public function getUniqueConstraintDeclarationSQL($name, Index $index)
408 409
    {
        $constraint = parent::getUniqueConstraintDeclarationSQL($name, $index);
410 411 412 413 414 415 416

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

        return $constraint;
    }

    /**
417
     * {@inheritDoc}
418 419 420 421 422
     */
    public function getCreateIndexSQL(Index $index, $table)
    {
        $constraint = parent::getCreateIndexSQL($index, $table);

423
        if ($index->isUnique() && ! $index->isPrimary()) {
424 425 426 427 428 429
            $constraint = $this->_appendUniqueConstraintDefinition($constraint, $index);
        }

        return $constraint;
    }

430
    /**
431
     * {@inheritDoc}
432 433 434 435 436 437 438 439 440 441
     */
    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
442
        } elseif ($index->hasFlag('nonclustered')) {
443 444 445 446 447 448
            $type .= 'NONCLUSTERED ';
        }

        return $type;
    }

449
    /**
450
     * Extend unique key constraint with required filters
451
     *
452
     * @param string $sql
453
     *
454 455 456 457
     * @return string
     */
    private function _appendUniqueConstraintDefinition($sql, Index $index)
    {
458
        $fields = [];
459

460
        foreach ($index->getQuotedColumns($this) as $field) {
461
            $fields[] = $field . ' IS NOT NULL';
462
        }
463 464 465

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

467
    /**
468
     * {@inheritDoc}
469
     */
470
    public function getAlterTableSQL(TableDiff $diff)
471
    {
472 473 474 475
        $queryParts  = [];
        $sql         = [];
        $columnSql   = [];
        $commentsSql = [];
476

477
        foreach ($diff->addedColumns as $column) {
478 479
            if ($this->onSchemaAlterTableAddColumn($column, $diff, $columnSql)) {
                continue;
480 481
            }

482
            $columnDef    = $column->toArray();
483 484
            $queryParts[] = 'ADD ' . $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnDef);

485
            if (isset($columnDef['default'])) {
486
                $queryParts[] = $this->getAlterTableAddDefaultConstraintClause($diff->name, $column);
487
            }
488 489 490

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

491 492
            if (empty($comment) && ! is_numeric($comment)) {
                continue;
493
            }
494 495 496 497 498 499

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

502
        foreach ($diff->removedColumns as $column) {
503 504
            if ($this->onSchemaAlterTableRemoveColumn($column, $diff, $columnSql)) {
                continue;
505 506
            }

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

510
        foreach ($diff->changedColumns as $columnDiff) {
511 512
            if ($this->onSchemaAlterTableChangeColumn($columnDiff, $diff, $columnSql)) {
                continue;
513 514
            }

515 516
            $column     = $columnDiff->column;
            $comment    = $this->getColumnComment($column);
517
            $hasComment = ! empty($comment) || is_numeric($comment);
518 519 520

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

523
                if ($hasFromComment && $hasComment && $fromComment !== $comment) {
524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544
                    $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;
            }

545
            $requireDropDefaultConstraint = $this->alterColumnRequiresDropDefaultConstraint($columnDiff);
546

547 548 549 550 551
            if ($requireDropDefaultConstraint) {
                $queryParts[] = $this->getAlterTableDropDefaultConstraintClause(
                    $diff->name,
                    $columnDiff->oldColumnName
                );
552 553
            }

554 555
            $columnDef = $column->toArray();

556
            $queryParts[] = 'ALTER COLUMN ' .
557 558
                    $this->getColumnDeclarationSQL($column->getQuotedName($this), $columnDef);

559 560
            if (! isset($columnDef['default']) || (! $requireDropDefaultConstraint && ! $columnDiff->hasChanged('default'))) {
                continue;
561
            }
562 563

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

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

571 572
            $oldColumnName = new Identifier($oldColumnName);

573
            $sql[] = "sp_RENAME '" .
574
                $diff->getName($this)->getQuotedName($this) . '.' . $oldColumnName->getQuotedName($this) .
575
                "', '" . $column->getQuotedName($this) . "', 'COLUMN'";
576

577
            // Recreate default constraint with new column name if necessary (for future reference).
578 579
            if ($column->getDefault() === null) {
                continue;
580
            }
581 582 583 584 585 586

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

589
        $tableSql = [];
590 591

        if ($this->onSchemaAlterTable($diff, $tableSql)) {
592
            return array_merge($tableSql, $columnSql);
593
        }
594

595
        foreach ($queryParts as $query) {
596
            $sql[] = 'ALTER TABLE ' . $diff->getName($this)->getQuotedName($this) . ' ' . $query;
597
        }
598

599
        $sql = array_merge($sql, $commentsSql);
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
600

Sergei Morozov's avatar
Sergei Morozov committed
601 602 603 604
        $newName = $diff->getNewName();

        if ($newName !== false) {
            $sql[] = "sp_RENAME '" . $diff->getName($this)->getQuotedName($this) . "', '" . $newName->getName() . "'";
605 606 607 608 609 610 611 612 613 614 615 616

            /**
             * 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
617
                "'" . $this->generateIdentifierName($newName->getName()) . "') + ''', ''OBJECT'';' " .
618 619
                'FROM sys.default_constraints dc ' .
                'JOIN sys.tables tbl ON dc.parent_object_id = tbl.object_id ' .
Sergei Morozov's avatar
Sergei Morozov committed
620
                "WHERE tbl.name = '" . $newName->getName() . "';" .
621
                'EXEC sp_executesql @sql';
622 623
        }

624 625 626 627 628 629
        $sql = array_merge(
            $this->getPreAlterTableIndexForeignKeySQL($diff),
            $sql,
            $this->getPostAlterTableIndexForeignKeySQL($diff)
        );

630
        return array_merge($sql, $tableSql, $columnSql);
631
    }
632

633 634 635
    /**
     * Returns the SQL clause for adding a default constraint in an ALTER TABLE statement.
     *
636 637
     * @param string $tableName The name of the table to generate the clause for.
     * @param Column $column    The column to generate the clause for.
638 639 640 641 642
     *
     * @return string
     */
    private function getAlterTableAddDefaultConstraintClause($tableName, Column $column)
    {
643
        $columnDef         = $column->toArray();
644 645 646 647 648 649 650 651
        $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.
     *
652 653
     * @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.
654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669
     *
     * @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.
     *
670
     * @param ColumnDiff $columnDiff The column diff to evaluate.
671
     *
672
     * @return bool True if the column alteration requires dropping its default constraint first, false otherwise.
673 674 675 676 677
     */
    private function alterColumnRequiresDropDefaultConstraint(ColumnDiff $columnDiff)
    {
        // We can only decide whether to drop an existing default constraint
        // if we know the original default value.
678
        if (! $columnDiff->fromColumn instanceof Column) {
679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695
            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
696
        return $columnDiff->hasChanged('type') || $columnDiff->hasChanged('fixed');
697 698
    }

699 700 701 702 703 704 705 706 707 708 709
    /**
     * 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
710 711 712
     * @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.
713 714 715 716 717
     *
     * @return string
     */
    protected function getAlterColumnCommentSQL($tableName, $columnName, $comment)
    {
718 719 720 721 722 723 724 725 726
        if (strpos($tableName, '.') !== false) {
            [$schemaSQL, $tableSQL] = explode('.', $tableName);
            $schemaSQL              = $this->quoteStringLiteral($schemaSQL);
            $tableSQL               = $this->quoteStringLiteral($tableSQL);
        } else {
            $schemaSQL = "'dbo'";
            $tableSQL  = $this->quoteStringLiteral($tableName);
        }

727 728 729 730
        return $this->getUpdateExtendedPropertySQL(
            'MS_Description',
            $comment,
            'SCHEMA',
731
            $schemaSQL,
732
            'TABLE',
733
            $tableSQL,
734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756
            '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)
    {
757 758 759 760 761 762 763 764 765
        if (strpos($tableName, '.') !== false) {
            [$schemaSQL, $tableSQL] = explode('.', $tableName);
            $schemaSQL              = $this->quoteStringLiteral($schemaSQL);
            $tableSQL               = $this->quoteStringLiteral($tableSQL);
        } else {
            $schemaSQL = "'dbo'";
            $tableSQL  = $this->quoteStringLiteral($tableName);
        }

766 767 768
        return $this->getDropExtendedPropertySQL(
            'MS_Description',
            'SCHEMA',
769
            $schemaSQL,
770
            'TABLE',
771
            $tableSQL,
772 773 774 775 776
            'COLUMN',
            $columnName
        );
    }

777 778 779 780 781
    /**
     * {@inheritdoc}
     */
    protected function getRenameIndexSQL($oldIndexName, Index $index, $tableName)
    {
782 783 784 785 786 787
        return [sprintf(
            "EXEC sp_RENAME N'%s.%s', N'%s', N'INDEX'",
            $tableName,
            $oldIndexName,
            $index->getQuotedName($this)
        ),
788
        ];
789 790
    }

791 792 793
    /**
     * Returns the SQL statement for adding an extended property to a database object.
     *
794 795
     * @link http://msdn.microsoft.com/en-us/library/ms180047%28v=sql.90%29.aspx
     *
796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816
     * @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
    ) {
817
        return 'EXEC sp_addextendedproperty ' .
Sergei Morozov's avatar
Sergei Morozov committed
818 819 820 821
            '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;
822 823 824 825 826
    }

    /**
     * Returns the SQL statement for dropping an extended property from a database object.
     *
827 828
     * @link http://technet.microsoft.com/en-gb/library/ms178595%28v=sql.90%29.aspx
     *
829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847
     * @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
    ) {
848 849
        return 'EXEC sp_dropextendedproperty ' .
            'N' . $this->quoteStringLiteral($name) . ', ' .
Sergei Morozov's avatar
Sergei Morozov committed
850 851 852
            'N' . $this->quoteStringLiteral((string) $level0Type) . ', ' . $level0Name . ', ' .
            'N' . $this->quoteStringLiteral((string) $level1Type) . ', ' . $level1Name . ', ' .
            'N' . $this->quoteStringLiteral((string) $level2Type) . ', ' . $level2Name;
853 854 855 856 857
    }

    /**
     * Returns the SQL statement for updating an extended property of a database object.
     *
858 859
     * @link http://msdn.microsoft.com/en-us/library/ms186885%28v=sql.90%29.aspx
     *
860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880
     * @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
    ) {
881
        return 'EXEC sp_updateextendedproperty ' .
Sergei Morozov's avatar
Sergei Morozov committed
882 883 884 885
            '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;
886 887
    }

888
    /**
889
     * {@inheritDoc}
890
     */
891
    public function getEmptyIdentityInsertSQL($quotedTableName, $quotedIdentifierColumnName)
892
    {
893
        return 'INSERT INTO ' . $quotedTableName . ' DEFAULT VALUES';
894 895
    }

896
    /**
897
     * {@inheritDoc}
898
     */
899
    public function getListTablesSQL()
900
    {
901
        // "sysdiagrams" table must be ignored as it's internal SQL Server table for Database Diagrams
902 903
        // 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";
904 905 906
    }

    /**
907
     * {@inheritDoc}
908
     */
909
    public function getListTableColumnsSQL($table, $database = null)
910
    {
911 912 913 914 915 916 917 918
        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,
919 920
                          col.collation_name AS collation,
                          CAST(prop.value AS NVARCHAR(MAX)) AS comment -- CAST avoids driver error for sql_variant type
921 922 923 924 925
                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
926 927
                JOIN      sys.schemas AS scm
                ON        obj.schema_id = scm.schema_id
928 929 930
                LEFT JOIN sys.default_constraints def
                ON        col.default_object_id = def.object_id
                AND       col.object_id = def.parent_object_id
931 932 933 934
                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'
935
                WHERE     obj.type = 'U'
936
                AND       " . $this->getTableWhereClause($table, 'scm.name', 'obj.name');
937 938 939
    }

    /**
940 941 942 943
     * @param string      $table
     * @param string|null $database
     *
     * @return string
944 945 946
     */
    public function getListTableForeignKeysSQL($table, $database = null)
    {
947
        return 'SELECT f.name AS ForeignKey,
948 949 950 951 952 953 954 955 956 957 958 959
                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
960
                WHERE ' .
961
                $this->getTableWhereClause($table, 'SCHEMA_NAME (f.schema_id)', 'OBJECT_NAME (f.parent_object_id)');
962 963 964
    }

    /**
965
     * {@inheritDoc}
966
     */
967
    public function getListTableIndexesSQL($table, $currentDatabase = null)
968
    {
969 970
        return "SELECT idx.name AS key_name,
                       col.name AS column_name,
Steve Müller's avatar
Steve Müller committed
971 972
                       ~idx.is_unique AS non_unique,
                       idx.is_primary_key AS [primary],
973 974 975 976 977 978
                       CASE idx.type
                           WHEN '1' THEN 'clustered'
                           WHEN '2' THEN 'nonclustered'
                           ELSE NULL
                       END AS flags
                FROM sys.tables AS tbl
979
                JOIN sys.schemas AS scm ON tbl.schema_id = scm.schema_id
980 981 982
                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
983 984
                WHERE " . $this->getTableWhereClause($table, 'scm.name', 'tbl.name') . '
                ORDER BY idx.index_id ASC, idxcol.key_ordinal ASC';
985
    }
986 987

    /**
988
     * {@inheritDoc}
989
     */
990
    public function getCreateViewSQL($name, $sql)
991 992 993
    {
        return 'CREATE VIEW ' . $name . ' AS ' . $sql;
    }
994 995

    /**
996
     * {@inheritDoc}
997
     */
998
    public function getListViewsSQL($database)
999 1000 1001 1002
    {
        return "SELECT name FROM sysobjects WHERE type = 'V' ORDER BY name";
    }

1003 1004 1005 1006
    /**
     * Returns the where clause to filter schema and table name in a query.
     *
     * @param string $table        The full qualified name of the table.
1007 1008
     * @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.
1009 1010 1011 1012 1013
     *
     * @return string
     */
    private function getTableWhereClause($table, $schemaColumn, $tableColumn)
    {
1014 1015 1016 1017
        if (strpos($table, '.') !== false) {
            [$schema, $table] = explode('.', $table);
            $schema           = $this->quoteStringLiteral($schema);
            $table            = $this->quoteStringLiteral($table);
1018
        } else {
1019 1020
            $schema = 'SCHEMA_NAME()';
            $table  = $this->quoteStringLiteral($table);
1021 1022
        }

1023
        return sprintf('(%s = %s AND %s = %s)', $tableColumn, $table, $schemaColumn, $schema);
1024 1025
    }

1026
    /**
1027
     * {@inheritDoc}
1028 1029 1030
     */
    public function getDropViewSQL($name)
    {
1031
        return 'DROP VIEW ' . $name;
1032
    }
1033 1034

    /**
1035
     * {@inheritDoc}
1036 1037
     *
     * @deprecated Use application-generated UUIDs instead
1038 1039 1040
     */
    public function getGuidExpression()
    {
1041
        return 'NEWID()';
1042
    }
1043 1044

    /**
1045
     * {@inheritDoc}
1046
     */
1047
    public function getLocateExpression($str, $substr, $startPos = false)
1048
    {
1049
        if ($startPos === false) {
1050 1051
            return 'CHARINDEX(' . $substr . ', ' . $str . ')';
        }
1052 1053

        return 'CHARINDEX(' . $substr . ', ' . $str . ', ' . $startPos . ')';
1054
    }
1055

1056
    /**
1057
     * {@inheritDoc}
1058
     */
1059
    public function getModExpression($expression1, $expression2)
1060
    {
1061
        return $expression1 . ' % ' . $expression2;
1062
    }
1063

1064
    /**
1065
     * {@inheritDoc}
1066
     */
1067
    public function getTrimExpression($str, $pos = TrimMode::UNSPECIFIED, $char = false)
1068
    {
1069
        if (! $char) {
1070
            switch ($pos) {
1071
                case TrimMode::LEADING:
1072 1073 1074
                    $trimFn = 'LTRIM';
                    break;

1075
                case TrimMode::TRAILING:
1076 1077 1078 1079 1080
                    $trimFn = 'RTRIM';
                    break;

                default:
                    return 'LTRIM(RTRIM(' . $str . '))';
1081 1082 1083 1084
            }

            return $trimFn . '(' . $str . ')';
        }
1085 1086 1087 1088 1089 1090 1091 1092 1093 1094

        /** 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;
         */
1095
        $pattern = "'%[^' + " . $char . " + ']%'";
1096

1097
        if ($pos === TrimMode::LEADING) {
1098 1099 1100
            return 'stuff(' . $str . ', 1, patindex(' . $pattern . ', ' . $str . ') - 1, null)';
        }

1101
        if ($pos === TrimMode::TRAILING) {
1102 1103 1104 1105
            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))';
1106
    }
1107

1108
    /**
1109
     * {@inheritDoc}
1110 1111
     */
    public function getConcatExpression()
1112
    {
1113
        $args = func_get_args();
1114

1115
        return '(' . implode(' + ', $args) . ')';
1116
    }
1117

Benjamin Morel's avatar
Benjamin Morel committed
1118 1119 1120
    /**
     * {@inheritDoc}
     */
1121
    public function getListDatabasesSQL()
1122
    {
1123
        return 'SELECT * FROM sys.databases';
1124
    }
1125

1126 1127 1128 1129 1130
    /**
     * {@inheritDoc}
     */
    public function getListNamespacesSQL()
    {
1131
        return "SELECT name FROM sys.schemas WHERE name NOT IN('guest', 'INFORMATION_SCHEMA', 'sys')";
1132 1133
    }

1134
    /**
1135
     * {@inheritDoc}
1136
     */
1137
    public function getSubstringExpression($value, $from, $length = null)
1138
    {
1139
        if ($length !== null) {
1140
            return 'SUBSTRING(' . $value . ', ' . $from . ', ' . $length . ')';
1141
        }
1142

1143
        return 'SUBSTRING(' . $value . ', ' . $from . ', LEN(' . $value . ') - ' . $from . ' + 1)';
1144
    }
1145

1146
    /**
1147
     * {@inheritDoc}
1148
     */
1149
    public function getLengthExpression($column)
1150
    {
1151
        return 'LEN(' . $column . ')';
1152 1153
    }

1154
    /**
1155
     * {@inheritDoc}
1156
     */
1157
    public function getSetTransactionIsolationSQL($level)
romanb's avatar
romanb committed
1158
    {
1159
        return 'SET TRANSACTION ISOLATION LEVEL ' . $this->_getTransactionIsolationLevelSQL($level);
romanb's avatar
romanb committed
1160
    }
1161

1162
    /**
1163
     * {@inheritDoc}
1164
     */
1165
    public function getIntegerTypeDeclarationSQL(array $field)
1166
    {
1167
        return 'INT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
1168 1169
    }

1170
    /**
1171
     * {@inheritDoc}
1172
     */
1173
    public function getBigIntTypeDeclarationSQL(array $field)
1174
    {
1175
        return 'BIGINT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
1176 1177
    }

1178
    /**
1179
     * {@inheritDoc}
1180
     */
1181
    public function getSmallIntTypeDeclarationSQL(array $field)
1182
    {
1183
        return 'SMALLINT' . $this->_getCommonIntegerTypeDeclarationSQL($field);
1184 1185
    }

1186
    /**
1187
     * {@inheritDoc}
1188
     */
1189
    public function getGuidTypeDeclarationSQL(array $field)
1190 1191 1192 1193
    {
        return 'UNIQUEIDENTIFIER';
    }

1194 1195 1196
    /**
     * {@inheritDoc}
     */
1197
    protected function getVarcharTypeDeclarationSQLSnippet($length, $fixed)
1198
    {
1199
        return $fixed ? ($length ? 'NCHAR(' . $length . ')' : 'CHAR(255)') : ($length ? 'NVARCHAR(' . $length . ')' : 'NVARCHAR(255)');
1200
    }
1201

Steve Müller's avatar
Steve Müller committed
1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217
    /**
     * {@inheritdoc}
     */
    protected function getBinaryTypeDeclarationSQLSnippet($length, $fixed)
    {
        return $fixed ? 'BINARY(' . ($length ?: 255) . ')' : 'VARBINARY(' . ($length ?: 255) . ')';
    }

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

1218 1219 1220
    /**
     * {@inheritDoc}
     */
1221
    public function getClobTypeDeclarationSQL(array $field)
1222
    {
1223
        return 'VARCHAR(MAX)';
1224
    }
1225

1226
    /**
1227
     * {@inheritDoc}
1228
     */
1229
    protected function _getCommonIntegerTypeDeclarationSQL(array $columnDef)
1230
    {
1231
        return ! empty($columnDef['autoincrement']) ? ' IDENTITY' : '';
1232
    }
1233

1234
    /**
1235
     * {@inheritDoc}
1236
     */
1237
    public function getDateTimeTypeDeclarationSQL(array $fieldDeclaration)
1238
    {
1239
        return 'DATETIME';
1240 1241
    }

1242
    /**
1243
     * {@inheritDoc}
1244
     */
1245
    public function getDateTypeDeclarationSQL(array $fieldDeclaration)
1246
    {
1247
        return 'DATETIME';
1248
    }
1249 1250

    /**
1251
     * {@inheritDoc}
1252
     */
1253
    public function getTimeTypeDeclarationSQL(array $fieldDeclaration)
1254
    {
1255
        return 'DATETIME';
1256
    }
1257

1258
    /**
1259
     * {@inheritDoc}
1260
     */
1261
    public function getBooleanTypeDeclarationSQL(array $field)
1262 1263 1264 1265
    {
        return 'BIT';
    }

1266
    /**
1267
     * {@inheritDoc}
1268
     */
1269
    protected function doModifyLimitQuery($query, $limit, $offset = null)
1270
    {
1271 1272 1273 1274
        $where = [];

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

1277 1278 1279 1280 1281 1282 1283 1284 1285 1286
        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;
        }
1287

1288
        // We'll find a SELECT or SELECT distinct and prepend TOP n to it
1289 1290 1291
        // 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.
1292
        if (! preg_match('/^(\s*SELECT\s+(?:DISTINCT\s+)?)(.*)$/is', $query, $matches)) {
Sergei Morozov's avatar
Sergei Morozov committed
1293 1294 1295 1296
            return $query;
        }

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

1298
        if (stristr($query, 'ORDER BY')) {
1299
            // Inner order by is not valid in SQL Server for our purposes
1300
            // unless it's in a TOP N subquery.
1301
            $query = $this->scrubInnerOrderBy($query);
Fabio B. Silva's avatar
Fabio B. Silva committed
1302 1303
        }

1304 1305
        // Build a new limited query around the original, using a CTE
        return sprintf(
1306 1307 1308 1309
            'WITH dctrn_cte AS (%s) '
            . 'SELECT * FROM ('
            . 'SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte'
            . ') AS doctrine_tbl '
1310
            . 'WHERE %s ORDER BY doctrine_rownum ASC',
1311
            $query,
1312
            implode(' AND ', $where)
1313 1314
        );
    }
1315

1316 1317
    /**
     * Remove ORDER BY clauses in subqueries - they're not supported by SQL Server.
1318
     * Caveat: will leave ORDER BY in TOP N subqueries.
1319
     *
1320
     * @param string $query
1321
     *
1322 1323
     * @return string
     */
Bill Schaller's avatar
Bill Schaller committed
1324 1325
    private function scrubInnerOrderBy($query)
    {
1326
        $count  = substr_count(strtoupper($query), 'ORDER BY');
1327
        $offset = 0;
Bill Schaller's avatar
Bill Schaller committed
1328

1329
        while ($count-- > 0) {
1330
            $orderByPos = stripos($query, ' ORDER BY', $offset);
1331 1332 1333 1334
            if ($orderByPos === false) {
                break;
            }

1335 1336
            $qLen            = strlen($query);
            $parenCount      = 0;
1337
            $currentPosition = $orderByPos;
1338

1339
            while ($parenCount >= 0 && $currentPosition < $qLen) {
1340
                if ($query[$currentPosition] === '(') {
1341
                    $parenCount++;
1342
                } elseif ($query[$currentPosition] === ')') {
1343
                    $parenCount--;
Fabio B. Silva's avatar
Fabio B. Silva committed
1344
                }
1345

1346 1347
                $currentPosition++;
            }
1348 1349 1350 1351 1352 1353 1354 1355

            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;
            }

1356 1357
            if ($currentPosition >= $qLen - 1) {
                continue;
Fabio B. Silva's avatar
Fabio B. Silva committed
1358
            }
1359 1360 1361

            $query  = substr($query, 0, $orderByPos) . substr($query, $currentPosition - 1);
            $offset = $orderByPos;
1362
        }
1363

1364
        return $query;
1365
    }
1366

1367 1368 1369
    /**
     * Check an ORDER BY clause to see if it is in a TOP N query or subquery.
     *
1370 1371
     * @param string $query           The query
     * @param int    $currentPosition Start position of ORDER BY clause
1372
     *
1373 1374 1375 1376 1377 1378
     * @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 = '';
1379
        $parenCount     = 0;
1380

Bill Schaller's avatar
Bill Schaller committed
1381
        // If $parenCount goes negative, we've exited the subquery we're examining.
1382 1383
        // If $currentPosition goes negative, we've reached the beginning of the query.
        while ($parenCount >= 0 && $currentPosition >= 0) {
1384
            if ($query[$currentPosition] === '(') {
1385
                $parenCount--;
Bill Schaller's avatar
Bill Schaller committed
1386
            } elseif ($query[$currentPosition] === ')') {
1387 1388
                $parenCount++;
            }
1389 1390

            // Only yank query text on the same nesting level as the ORDER BY clause.
1391
            $subQueryBuffer = ($parenCount === 0 ? $query[$currentPosition] : ' ') . $subQueryBuffer;
1392 1393 1394 1395

            $currentPosition--;
        }

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

1399
    /**
1400
     * {@inheritDoc}
1401 1402 1403 1404 1405 1406
     */
    public function supportsLimitOffset()
    {
        return false;
    }

1407
    /**
1408
     * {@inheritDoc}
1409
     */
1410
    public function convertBooleans($item)
1411
    {
1412 1413
        if (is_array($item)) {
            foreach ($item as $key => $value) {
1414
                if (! is_bool($value) && ! is_numeric($value)) {
1415
                    continue;
1416
                }
1417 1418

                $item[$key] = $value ? 1 : 0;
1419
            }
Steve Müller's avatar
Steve Müller committed
1420
        } elseif (is_bool($item) || is_numeric($item)) {
1421
            $item = $item ? 1 : 0;
1422
        }
1423

1424
        return $item;
1425
    }
1426 1427

    /**
1428
     * {@inheritDoc}
1429
     */
1430
    public function getCreateTemporaryTableSnippetSQL()
1431
    {
1432
        return 'CREATE TABLE';
1433
    }
1434

1435
    /**
1436
     * {@inheritDoc}
1437 1438 1439 1440 1441 1442
     */
    public function getTemporaryTableName($tableName)
    {
        return '#' . $tableName;
    }

1443
    /**
1444
     * {@inheritDoc}
1445 1446 1447
     */
    public function getDateTimeFormatString()
    {
1448 1449
        return 'Y-m-d H:i:s.000';
    }
1450

1451
    /**
1452
     * {@inheritDoc}
1453
     */
1454 1455 1456 1457 1458 1459
    public function getDateFormatString()
    {
        return 'Y-m-d H:i:s.000';
    }

    /**
1460
     * {@inheritDoc}
1461
     */
1462 1463 1464
    public function getTimeFormatString()
    {
        return 'Y-m-d H:i:s.000';
1465
    }
1466

1467
    /**
1468
     * {@inheritDoc}
1469 1470 1471 1472 1473
     */
    public function getDateTimeTzFormatString()
    {
        return $this->getDateTimeFormatString();
    }
1474

1475
    /**
1476
     * {@inheritDoc}
1477
     */
1478
    public function getName()
1479
    {
1480
        return 'mssql';
1481
    }
1482

Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1483
    /**
1484
     * {@inheritDoc}
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1485
     */
1486 1487
    protected function initializeDoctrineTypeMappings()
    {
1488
        $this->doctrineTypeMapping = [
1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509
            '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
1510 1511
            'binary' => 'binary',
            'varbinary' => 'binary',
1512
            'image' => 'blob',
1513
            'uniqueidentifier' => 'guid',
1514
        ];
1515
    }
1516 1517

    /**
1518
     * {@inheritDoc}
1519 1520 1521 1522 1523 1524 1525
     */
    public function createSavePoint($savepoint)
    {
        return 'SAVE TRANSACTION ' . $savepoint;
    }

    /**
1526
     * {@inheritDoc}
1527 1528 1529 1530 1531 1532 1533
     */
    public function releaseSavePoint($savepoint)
    {
        return '';
    }

    /**
1534
     * {@inheritDoc}
1535 1536 1537 1538
     */
    public function rollbackSavePoint($savepoint)
    {
        return 'ROLLBACK TRANSACTION ' . $savepoint;
1539
    }
1540

1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553
    /**
     * {@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);
    }

1554
    /**
1555
     * {@inheritDoc}
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1556
     */
1557
    public function appendLockHint($fromClause, $lockMode)
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1558
    {
1559
        switch (true) {
1560
            case $lockMode === LockMode::NONE:
1561
                return $fromClause . ' WITH (NOLOCK)';
1562

1563
            case $lockMode === LockMode::PESSIMISTIC_READ:
1564
                return $fromClause . ' WITH (HOLDLOCK, ROWLOCK)';
1565

1566
            case $lockMode === LockMode::PESSIMISTIC_WRITE:
1567
                return $fromClause . ' WITH (UPDLOCK, ROWLOCK)';
1568

Steve Müller's avatar
Steve Müller committed
1569
            default:
1570
                return $fromClause;
Steve Müller's avatar
Steve Müller committed
1571
        }
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1572 1573 1574
    }

    /**
1575
     * {@inheritDoc}
Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
1576 1577 1578 1579 1580
     */
    public function getForUpdateSQL()
    {
        return ' ';
    }
1581

1582 1583 1584
    /**
     * {@inheritDoc}
     */
1585 1586
    protected function getReservedKeywordsClass()
    {
1587
        return Keywords\SQLServerKeywords::class;
1588
    }
1589 1590

    /**
1591
     * {@inheritDoc}
1592
     */
1593
    public function quoteSingleIdentifier($str)
1594
    {
1595
        return '[' . str_replace(']', '][', $str) . ']';
1596
    }
1597

1598 1599 1600
    /**
     * {@inheritDoc}
     */
1601 1602
    public function getTruncateTableSQL($tableName, $cascade = false)
    {
1603 1604 1605
        $tableIdentifier = new Identifier($tableName);

        return 'TRUNCATE TABLE ' . $tableIdentifier->getQuotedName($this);
1606
    }
1607 1608

    /**
1609
     * {@inheritDoc}
1610 1611 1612 1613 1614
     */
    public function getBlobTypeDeclarationSQL(array $field)
    {
        return 'VARBINARY(MAX)';
    }
1615

1616 1617 1618 1619 1620 1621 1622 1623 1624 1625
    /**
     * {@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 {
1626
            $collation = isset($field['collation']) && $field['collation'] ?
1627
                ' ' . $this->getColumnCollationDeclarationSQL($field['collation']) : '';
1628

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

1631
            $unique = isset($field['unique']) && $field['unique'] ?
1632 1633
                ' ' . $this->getUniqueFieldDeclarationSQL() : '';

1634
            $check = isset($field['check']) && $field['check'] ?
1635 1636
                ' ' . $field['check'] : '';

1637
            $typeDecl  = $field['type']->getSQLDeclaration($field, $this);
1638
            $columnDef = $typeDecl . $collation . $notnull . $unique . $check;
1639 1640 1641 1642
        }

        return $name . ' ' . $columnDef;
    }
1643 1644 1645 1646 1647 1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665

    /**
     * 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)
    {
1666 1667 1668 1669
        // Always generate name for unquoted identifiers to ensure consistency.
        $identifier = new Identifier($identifier);

        return strtoupper(dechex(crc32($identifier->getName())));
1670
    }
1671 1672 1673 1674 1675

    protected function getCommentOnTableSQL(string $tableName, ?string $comment) : string
    {
        return sprintf(
            <<<'SQL'
Sergei Morozov's avatar
Sergei Morozov committed
1676 1677
EXEC sys.sp_addextendedproperty @name=N'MS_Description',
  @value=N%s, @level0type=N'SCHEMA', @level0name=N'dbo',
1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695 1696 1697 1698 1699 1700 1701
  @level1type=N'TABLE', @level1name=N%s
SQL
            ,
            $this->quoteStringLiteral((string) $comment),
            $this->quoteStringLiteral($tableName)
        );
    }

    public function getListTableMetadataSQL(string $table) : string
    {
        return sprintf(
            <<<'SQL'
SELECT
  p.value AS [table_comment]
FROM
  sys.tables AS tbl
  INNER JOIN sys.extended_properties AS p ON p.major_id=tbl.object_id AND p.minor_id=0 AND p.class=1
WHERE
  (tbl.name=N%s and SCHEMA_NAME(tbl.schema_id)=N'dbo' and p.name=N'MS_Description')
SQL
            ,
            $this->quoteStringLiteral($table)
        );
    }
1702
}