Merge pull request #2617 from photodude/patch-2

Testing of MSSQL on Windows with AppVeyor

.appveyor.yml

+build: false
+platform:
+  - x64
+#matrix:
+#  fast_finish: true # kills the build at the first failure
+clone_folder: C:\projects\dbal
+clone_depth: 1
+
+cache:
+  - C:\ProgramData\chocolatey\bin -> .appveyor.yml
+  - C:\ProgramData\chocolatey\lib -> .appveyor.yml
+  - c:\tools\php -> .appveyor.yml
+  - composer.phar
+  - '%LOCALAPPDATA%\Composer\files'
+  #- vendor
+
+## Build matrix for lowest and highest possible targets
+environment:
+  matrix:
+  - db: mssql
+    driver: sqlsrv
+    db_version: sql2008r2sp2
+    php: 7.1
+  - db: mssql
+    driver: sqlsrv
+    db_version: sql2012sp1
+    php: 7.1
+  - db: mssql
+    driver: sqlsrv
+    db_version: sql2017
+    php: 7.1
+  - db: mssql
+    driver: pdo_sqlsrv
+    db_version: sql2017
+    php: 7.1
+
+init:
+  - SET PATH=C:\Program Files\OpenSSL;c:\tools\php;%PATH%
+  - SET COMPOSER_NO_INTERACTION=1
+  - SET ANSICON=121x90 (121x90)
+
+## Install PHP and composer, and run the appropriate composer command
+install:
+    - ps: |
+        # Check if installation is cached
+        if (!(Test-Path c:\tools\php)) {
+          appveyor-retry cinst --params '""/InstallDir:C:\tools\php""' --ignore-checksums -y php --version ((choco search php --exact --all-versions -r | select-string -pattern $env:php | sort { [version]($_ -split '\|' | select -last 1) } -Descending | Select-Object -first 1) -replace '[php|]','')
+          # install sqlite
+          appveyor-retry cinst -y sqlite
+          Get-ChildItem -Path c:\tools\php
+          cd c:\tools\php
+
+          # Set PHP environment items that are always needed
+          copy php.ini-production php.ini
+          Add-Content php.ini "`n date.timezone=UTC"
+          Add-Content php.ini "`n extension_dir=ext"
+          Add-Content php.ini "`n extension=php_openssl.dll"
+          Add-Content php.ini "`n extension=php_mbstring.dll"
+          Add-Content php.ini "`n extension=php_fileinfo.dll"
+          Add-Content php.ini "`n extension=php_pdo_sqlite.dll"
+          Add-Content php.ini "`n extension=php_sqlite3.dll"
+
+          # If needed get the MSSQL DLL's
+          if ($env:db -eq "mssql") {
+            $DLLVersion = "5.2.0rc1"
+            cd c:\tools\php\ext
+            $source = "https://windows.php.net/downloads/pecl/releases/sqlsrv/$($DLLVersion)/php_sqlsrv-$($DLLVersion)-$($env:php)-nts-vc14-x64.zip"
+            $destination = "c:\tools\php\ext\php_sqlsrv-$($DLLVersion)-$($env:php)-nts-vc14-x64.zip"
+            Invoke-WebRequest $source -OutFile $destination
+            7z x -y php_sqlsrv-$($DLLVersion)-$($env:php)-nts-vc14-x64.zip > $null
+            $source = "https://windows.php.net/downloads/pecl/releases/pdo_sqlsrv/$($DLLVersion)/php_pdo_sqlsrv-$($DLLVersion)-$($env:php)-nts-vc14-x64.zip"
+            $destination = "c:\tools\php\ext\php_pdo_sqlsrv-$($DLLVersion)-$($env:php)-nts-vc14-x64.zip"
+            Invoke-WebRequest $source -OutFile $destination
+            7z x -y php_pdo_sqlsrv-$($DLLVersion)-$($env:php)-nts-vc14-x64.zip > $null
+            Remove-Item c:\tools\php\* -include .zip
+            cd c:\tools\php
+            Add-Content php.ini "`nextension=php_sqlsrv.dll"
+            Add-Content php.ini "`nextension=php_pdo_sqlsrv.dll"
+            Add-Content php.ini "`n"
+          }
+
+          cd c:\projects\dbal
+
+          if (!(Test-Path c:\projects\dbal\composer.phar)) {
+            appveyor-retry appveyor DownloadFile https://getcomposer.org/composer.phar
+          }
+        }
+    # install composer dependencies
+    - appveyor-retry php composer.phar self-update
+    - appveyor-retry php composer.phar install --no-progress --profile
+
+before_test:
+# Selectively start the services
+  - ps: >-
+      if ($env:db -eq "mssql") {
+        $instanceName = $env:db_version.ToUpper()
+        Start-Service "MSSQL`$$instanceName"
+      }
+
+test_script:
+  - cd C:\projects\dbal
+  - ps: >-
+      if ($env:db_version) {
+        vendor\bin\phpunit -c tests\appveyor\%db%.%db_version%.%driver%.appveyor.xml
+      }
+      else {
+        vendor\bin\phpunit -c tests\appveyor\%db%.%driver%.appveyor.xml
+      }

.gitattributes

@@ -3,6 +3,7 @@
 .gitattributes export-ignore
 .gitignore export-ignore
 .gitmodules export-ignore
+.appveyor.yml export-ignore
 .travis.yml export-ignore
 build.properties export-ignore
 build.xml export-ignore

composer.json

@@ -42,6 +42,6 @@
         }
     },
     "archive": {
-        "exclude": ["!vendor", "tests", "*phpunit.xml", ".travis.yml", "build.xml", "build.properties", "composer.phar"]
+        "exclude": ["!vendor", "tests", "*phpunit.xml", ".appveyor.yml", ".travis.yml", "build.xml", "build.properties", "composer.phar"]
     }
 }

lib/Doctrine/DBAL/Driver/SQLSrv/SQLSrvConnection.php

@@ -136,11 +136,11 @@ class SQLSrvConnection implements Connection, ServerInfoAwareConnection
         if ($name !== null) {
             $stmt = $this->prepare('SELECT CONVERT(VARCHAR(MAX), current_value) FROM sys.sequences WHERE name = ?');
             $stmt->execute([$name]);
-
-            return $stmt->fetchColumn();
+        } else {
+            $stmt = $this->query('SELECT @@IDENTITY');
         }
 
-        return $this->lastInsertId->getId();
+        return $stmt->fetchColumn();
     }
 
     /**

lib/Doctrine/DBAL/Driver/SQLSrv/SQLSrvStatement.php

@@ -24,6 +24,7 @@ use Doctrine\DBAL\FetchMode;
 use Doctrine\DBAL\ParameterType;
 use IteratorAggregate;
 use Doctrine\DBAL\Driver\Statement;
+use function func_get_args;
 
 /**
  * SQL Server Statement.
@@ -348,19 +349,19 @@ class SQLSrvStatement implements IteratorAggregate, Statement
 
         switch ($fetchMode) {
             case FetchMode::CUSTOM_OBJECT:
-                while ($row = call_user_func_array([$this, 'fetch'], func_get_args())) {
+                while (($row = $this->fetch(...func_get_args())) !== false) {
                     $rows[] = $row;
                 }
                 break;
 
             case FetchMode::COLUMN:
-                while ($row = $this->fetchColumn()) {
+                while (($row = $this->fetchColumn()) !== false) {
                     $rows[] = $row;
                 }
                 break;
 
             default:
-                while ($row = $this->fetch($fetchMode)) {
+                while (($row = $this->fetch($fetchMode)) !== false) {
                     $rows[] = $row;
                 }
         }

lib/Doctrine/DBAL/Platforms/SQLServerPlatform.php

@@ -28,6 +28,8 @@ use Doctrine\DBAL\Schema\Index;
 use Doctrine\DBAL\Schema\Table;
 use Doctrine\DBAL\Schema\TableDiff;
 use Doctrine\DBAL\Types;
+use function implode;
+use function sprintf;
 
 /**
  * The SQLServerPlatform provides the behavior, features and SQL dialect of the
@@ -1207,19 +1209,29 @@ class SQLServerPlatform extends AbstractPlatform
      */
     protected function doModifyLimitQuery($query, $limit, $offset = null)
     {
-        if ($limit === null) {
-            return $query;
+        $where = [];
+
+        if ($offset > 0) {
+            $where[] = sprintf('doctrine_rownum >= %d', $offset + 1);
         }
 
-        $start   = $offset + 1;
-        $end     = $offset + $limit;
+        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;
+        }
 
         // We'll find a SELECT or SELECT distinct and prepend TOP n to it
         // 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.
         $selectPattern = '/^(\s*SELECT\s+(?:DISTINCT\s+)?)(.*)$/im';
-        $replacePattern = sprintf('$1%s $2', "TOP $end");
+        $replacePattern = sprintf('$1%s $2', $top);
         $query = preg_replace($selectPattern, $replacePattern, $query);
 
         if (stristr($query, "ORDER BY")) {
@@ -1234,10 +1246,9 @@ class SQLServerPlatform extends AbstractPlatform
             . "SELECT * FROM ("
             . "SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte"
             . ") AS doctrine_tbl "
-            . "WHERE doctrine_rownum BETWEEN %d AND %d ORDER BY doctrine_rownum ASC",
+            . 'WHERE %s ORDER BY doctrine_rownum ASC',
             $query,
-            $start,
-            $end
+            implode(' AND ', $where)
         );
     }
 

tests/Doctrine/Tests/DBAL/Driver/Mysqli/MysqliConnectionTest.php

@@ -4,9 +4,10 @@ namespace Doctrine\Tests\DBAL\Driver\Mysqli;
 
 use Doctrine\DBAL\Driver\Mysqli\MysqliConnection;
 use Doctrine\DBAL\Driver\Mysqli\MysqliException;
-use Doctrine\Tests\DbalTestCase;
+use Doctrine\DBAL\Platforms\MySqlPlatform;
+use Doctrine\Tests\DbalFunctionalTestCase;
 
-class MysqliConnectionTest extends DbalTestCase
+class MysqliConnectionTest extends DbalFunctionalTestCase
 {
     /**
      * The mysqli driver connection mock under test.
@@ -23,6 +24,10 @@ class MysqliConnectionTest extends DbalTestCase
 
         parent::setUp();
 
+        if (! $this->_conn->getDatabasePlatform() instanceof MySqlPlatform) {
+            $this->markTestSkipped('MySQL only test.');
+        }
+
         $this->connectionMock = $this->getMockBuilder(MysqliConnection::class)
             ->disableOriginalConstructor()
             ->getMockForAbstractClass();
@@ -49,6 +54,4 @@ class MysqliConnectionTest extends DbalTestCase
         restore_error_handler();
         restore_error_handler();
     }
-
 }
-

tests/Doctrine/Tests/DBAL/Platforms/AbstractSQLServerPlatformTestCase.php

@@ -8,11 +8,10 @@ use Doctrine\DBAL\Schema\Table;
 use Doctrine\DBAL\Schema\TableDiff;
 use Doctrine\DBAL\TransactionIsolationLevel;
 use Doctrine\DBAL\Types\Type;
+use function sprintf;
 
 abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCase
 {
-    protected static $selectFromCtePattern = "WITH dctrn_cte AS (%s) SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte) AS doctrine_tbl WHERE doctrine_rownum BETWEEN %d AND %d ORDER BY doctrine_rownum ASC";
-
     public function getGenerateTableSql()
     {
         return 'CREATE TABLE test (id INT IDENTITY NOT NULL, test NVARCHAR(255), PRIMARY KEY (id))';
@@ -179,7 +178,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM user';
         $alteredSql = 'SELECT TOP 10 * FROM user';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10, 0);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     public function testModifyLimitQueryWithEmptyOffset()
@@ -187,7 +186,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM user';
         $alteredSql = 'SELECT TOP 10 * FROM user';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     public function testModifyLimitQueryWithOffset()
@@ -200,7 +199,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $alteredSql = 'SELECT TOP 15 * FROM user ORDER BY username DESC';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10, 5);
 
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 6, 15), $sql);
+        $this->expectCteWithMinAndMaxRowNums($alteredSql, 6, 15, $sql);
     }
 
     public function testModifyLimitQueryWithAscOrderBy()
@@ -209,7 +208,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $alteredSql = 'SELECT TOP 10 * FROM user ORDER BY username ASC';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
 
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     public function testModifyLimitQueryWithLowercaseOrderBy()
@@ -217,7 +216,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM user order by username';
         $alteredSql = 'SELECT TOP 10 * FROM user order by username';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     public function testModifyLimitQueryWithDescOrderBy()
@@ -225,7 +224,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM user ORDER BY username DESC';
         $alteredSql = 'SELECT TOP 10 * FROM user ORDER BY username DESC';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     public function testModifyLimitQueryWithMultipleOrderBy()
@@ -233,7 +232,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM user ORDER BY username DESC, usereamil ASC';
         $alteredSql = 'SELECT TOP 10 * FROM user ORDER BY username DESC, usereamil ASC';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     public function testModifyLimitQueryWithSubSelect()
@@ -241,7 +240,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM (SELECT u.id as uid, u.name as uname) dctrn_result';
         $alteredSql = 'SELECT TOP 10 * FROM (SELECT u.id as uid, u.name as uname) dctrn_result';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     public function testModifyLimitQueryWithSubSelectAndOrder()
@@ -249,12 +248,12 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM (SELECT u.id as uid, u.name as uname ORDER BY u.name DESC) dctrn_result';
         $alteredSql = 'SELECT TOP 10 * FROM (SELECT u.id as uid, u.name as uname) dctrn_result';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
 
         $querySql = 'SELECT * FROM (SELECT u.id, u.name ORDER BY u.name DESC) dctrn_result';
         $alteredSql = 'SELECT TOP 10 * FROM (SELECT u.id, u.name) dctrn_result';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     public function testModifyLimitQueryWithSubSelectAndMultipleOrder()
@@ -266,17 +265,17 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM (SELECT u.id as uid, u.name as uname ORDER BY u.name DESC, id ASC) dctrn_result';
         $alteredSql = 'SELECT TOP 15 * FROM (SELECT u.id as uid, u.name as uname) dctrn_result';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10, 5);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 6, 15), $sql);
+        $this->expectCteWithMinAndMaxRowNums($alteredSql, 6, 15, $sql);
 
         $querySql = 'SELECT * FROM (SELECT u.id uid, u.name uname ORDER BY u.name DESC, id ASC) dctrn_result';
         $alteredSql = 'SELECT TOP 15 * FROM (SELECT u.id uid, u.name uname) dctrn_result';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10, 5);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 6, 15), $sql);
+        $this->expectCteWithMinAndMaxRowNums($alteredSql, 6, 15, $sql);
 
         $querySql = 'SELECT * FROM (SELECT u.id, u.name ORDER BY u.name DESC, id ASC) dctrn_result';
         $alteredSql = 'SELECT TOP 15 * FROM (SELECT u.id, u.name) dctrn_result';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10, 5);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 6, 15), $sql);
+        $this->expectCteWithMinAndMaxRowNums($alteredSql, 6, 15, $sql);
     }
 
     public function testModifyLimitQueryWithFromColumnNames()
@@ -284,7 +283,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT a.fromFoo, fromBar FROM foo';
         $alteredSql = 'SELECT TOP 10 a.fromFoo, fromBar FROM foo';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     /**
@@ -303,7 +302,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $alteredSql.= 'AND (table5.column5 = table6.column6) AND (table5.column5 = table7.column7) AND (table5.column5 = table8.column8) AND (table6.column6 = table7.column7) AND (table6.column6 = table8.column8) AND (table7.column7 = table8.column8)';
 
         $sql = $this->_platform->modifyLimitQuery($query, 10);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     /**
@@ -319,7 +318,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $alteredSql = 'SELECT TOP 15 m0_.NOMBRE AS NOMBRE0, m0_.FECHAINICIO AS FECHAINICIO1, m0_.FECHAFIN AS FECHAFIN2 FROM MEDICION m0_ WITH (NOLOCK) INNER JOIN ESTUDIO e1_ ON m0_.ESTUDIO_ID = e1_.ID INNER JOIN CLIENTE c2_ ON e1_.CLIENTE_ID = c2_.ID INNER JOIN USUARIO u3_ ON c2_.ID = u3_.CLIENTE_ID WHERE u3_.ID = ? ORDER BY m0_.FECHAINICIO DESC';
         $actual     = $this->_platform->modifyLimitQuery($sql, 10, 5);
 
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 6, 15), $actual);
+        $this->expectCteWithMinAndMaxRowNums($alteredSql, 6, 15, $actual);
     }
 
     /**
@@ -343,7 +342,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
             "WHERE u.status = 'disabled'";
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
 
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     /**
@@ -372,7 +371,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
             "WHERE u.status = 'disabled' " .
             "ORDER BY u.username DESC";
         $sql = $this->_platform->modifyLimitQuery($querySql, 10, 5);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 6, 15), $sql);
+        $this->expectCteWithMinAndMaxRowNums($alteredSql, 6, 15, $sql);
     }
 
     /**
@@ -393,7 +392,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
             "GROUP BY code " .
             "ORDER BY MAX(heading_id) DESC";
         $sql = $this->_platform->modifyLimitQuery($querySql, 1, 0);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 1), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 1, $sql);
     }
 
     /**
@@ -417,10 +416,9 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
             . ") dctrn_result "
             . "ORDER BY id_0 ASC";
         $sql = $this->_platform->modifyLimitQuery($querySql, 5);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 5), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 5, $sql);
     }
 
-
     /**
      * @throws \Doctrine\DBAL\DBALException
      */
@@ -442,7 +440,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
             . ") dctrn_result "
             . "ORDER BY name_1 ASC";
         $sql = $this->_platform->modifyLimitQuery($querySql, 5);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 5), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 5, $sql);
     }
 
     /**
@@ -466,7 +464,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
             . ") dctrn_result "
             . "ORDER BY name_1 ASC, foo_2 DESC";
         $sql = $this->_platform->modifyLimitQuery($querySql, 5);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 5), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 5, $sql);
     }
 
     public function testModifyLimitSubquerySimple()
@@ -477,7 +475,7 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $alteredSql = "SELECT DISTINCT TOP 20 id_0 FROM (SELECT k0_.id AS id_0, k0_.field AS field_1 "
             . "FROM key_table k0_ WHERE (k0_.where_field IN (1))) dctrn_result";
         $sql = $this->_platform->modifyLimitQuery($querySql, 20);
-        self::assertEquals(sprintf(self::$selectFromCtePattern, $alteredSql, 1, 20), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 20, $sql);
     }
 
     /**
@@ -1353,12 +1351,12 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
         $querySql = 'SELECT * FROM test t WHERE t.id = (SELECT TOP 1 t2.id FROM test t2 ORDER BY t2.data DESC)';
         $alteredSql = 'SELECT TOP 10 * FROM test t WHERE t.id = (SELECT TOP 1 t2.id FROM test t2 ORDER BY t2.data DESC)';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(static::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
 
         $querySql = 'SELECT * FROM test t WHERE t.id = (SELECT TOP 1 t2.id FROM test t2 ORDER BY t2.data DESC) ORDER BY t.data2 DESC';
         $alteredSql = 'SELECT TOP 10 * FROM test t WHERE t.id = (SELECT TOP 1 t2.id FROM test t2 ORDER BY t2.data DESC) ORDER BY t.data2 DESC';
         $sql = $this->_platform->modifyLimitQuery($querySql, 10);
-        self::assertEquals(sprintf(static::$selectFromCtePattern, $alteredSql, 1, 10), $sql);
+        $this->expectCteWithMaxRowNum($alteredSql, 10, $sql);
     }
 
     /**
@@ -1442,4 +1440,16 @@ abstract class AbstractSQLServerPlatformTestCase extends AbstractPlatformTestCas
             );
         }
     }
+
+    private function expectCteWithMaxRowNum(string $expectedSql, int $expectedMax, string $sql) : void
+    {
+        $pattern = 'WITH dctrn_cte AS (%s) SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte) AS doctrine_tbl WHERE doctrine_rownum <= %d ORDER BY doctrine_rownum ASC';
+        self::assertEquals(sprintf($pattern, $expectedSql, $expectedMax), $sql);
+    }
+
+    private function expectCteWithMinAndMaxRowNums(string $expectedSql, int $expectedMin, int $expectedMax, string $sql) : void
+    {
+        $pattern = 'WITH dctrn_cte AS (%s) SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte) AS doctrine_tbl WHERE doctrine_rownum >= %d AND doctrine_rownum <= %d ORDER BY doctrine_rownum ASC';
+        self::assertEquals(sprintf($pattern, $expectedSql, $expectedMin, $expectedMax), $sql);
+    }
 }

tests/Doctrine/Tests/DBAL/Platforms/SQLServerPlatformTest.php

@@ -49,12 +49,22 @@ class SQLServerPlatformTest extends AbstractSQLServerPlatformTestCase
 
     public function getModifyLimitQueries()
     {
-        return array(
+        return [
             // Test re-ordered query with correctly-scrubbed ORDER BY clause
-            array('SELECT id_0, MIN(sclr_2) AS dctrn_minrownum FROM (SELECT c0_.id AS id_0, c0_.title AS title_1, ROW_NUMBER() OVER(ORDER BY c0_.title ASC) AS sclr_2 FROM TestTable c0_ ORDER BY c0_.title ASC) dctrn_result GROUP BY id_0 ORDER BY dctrn_minrownum ASC', 30, null, 'WITH dctrn_cte AS (SELECT TOP 30 id_0, MIN(sclr_2) AS dctrn_minrownum FROM (SELECT c0_.id AS id_0, c0_.title AS title_1, ROW_NUMBER() OVER(ORDER BY c0_.title ASC) AS sclr_2 FROM TestTable c0_) dctrn_result GROUP BY id_0 ORDER BY dctrn_minrownum ASC) SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte) AS doctrine_tbl WHERE doctrine_rownum BETWEEN 1 AND 30 ORDER BY doctrine_rownum ASC'),
+            [
+                'SELECT id_0, MIN(sclr_2) AS dctrn_minrownum FROM (SELECT c0_.id AS id_0, c0_.title AS title_1, ROW_NUMBER() OVER(ORDER BY c0_.title ASC) AS sclr_2 FROM TestTable c0_ ORDER BY c0_.title ASC) dctrn_result GROUP BY id_0 ORDER BY dctrn_minrownum ASC',
+                30,
+                null,
+                'WITH dctrn_cte AS (SELECT TOP 30 id_0, MIN(sclr_2) AS dctrn_minrownum FROM (SELECT c0_.id AS id_0, c0_.title AS title_1, ROW_NUMBER() OVER(ORDER BY c0_.title ASC) AS sclr_2 FROM TestTable c0_) dctrn_result GROUP BY id_0 ORDER BY dctrn_minrownum ASC) SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte) AS doctrine_tbl WHERE doctrine_rownum <= 30 ORDER BY doctrine_rownum ASC',
+            ],
 
             // Test re-ordered query with no scrubbed ORDER BY clause
-            array('SELECT id_0, MIN(sclr_2) AS dctrn_minrownum FROM (SELECT c0_.id AS id_0, c0_.title AS title_1, ROW_NUMBER() OVER(ORDER BY c0_.title ASC) AS sclr_2 FROM TestTable c0_) dctrn_result GROUP BY id_0 ORDER BY dctrn_minrownum ASC', 30, null, 'WITH dctrn_cte AS (SELECT TOP 30 id_0, MIN(sclr_2) AS dctrn_minrownum FROM (SELECT c0_.id AS id_0, c0_.title AS title_1, ROW_NUMBER() OVER(ORDER BY c0_.title ASC) AS sclr_2 FROM TestTable c0_) dctrn_result GROUP BY id_0 ORDER BY dctrn_minrownum ASC) SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte) AS doctrine_tbl WHERE doctrine_rownum BETWEEN 1 AND 30 ORDER BY doctrine_rownum ASC'),
-        );
+            [
+                'SELECT id_0, MIN(sclr_2) AS dctrn_minrownum FROM (SELECT c0_.id AS id_0, c0_.title AS title_1, ROW_NUMBER() OVER(ORDER BY c0_.title ASC) AS sclr_2 FROM TestTable c0_) dctrn_result GROUP BY id_0 ORDER BY dctrn_minrownum ASC',
+                30,
+                null,
+                'WITH dctrn_cte AS (SELECT TOP 30 id_0, MIN(sclr_2) AS dctrn_minrownum FROM (SELECT c0_.id AS id_0, c0_.title AS title_1, ROW_NUMBER() OVER(ORDER BY c0_.title ASC) AS sclr_2 FROM TestTable c0_) dctrn_result GROUP BY id_0 ORDER BY dctrn_minrownum ASC) SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY (SELECT 0)) AS doctrine_rownum FROM dctrn_cte) AS doctrine_tbl WHERE doctrine_rownum <= 30 ORDER BY doctrine_rownum ASC',
+            ],
+        ];
     }
 }

tests/appveyor/mssql.sql2008r2sp2.sqlsrv.appveyor.xml

+<?xml version="1.0" encoding="utf-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="http://schema.phpunit.de/4.8/phpunit.xsd"
+         backupGlobals="false"
+         colors="true"
+         bootstrap="../../vendor/autoload.php"
+>
+    <php>
+        <ini name="error_reporting" value="-1" />
+
+        <var name="db_type" value="sqlsrv"/>
+        <var name="db_host" value="(local)\SQL2008R2SP2" />
+        <var name="db_username" value="sa" />
+        <var name="db_password" value="Password12!" />
+        <var name="db_name" value="doctrine_tests" />
+        <var name="db_port" value="1433" />
+
+        <var name="tmpdb_type" value="sqlsrv"/>
+        <var name="tmpdb_host" value="(local)\SQL2008R2SP2" />
+        <var name="tmpdb_username" value="sa" />
+        <var name="tmpdb_password" value="Password12!" />
+        <var name="tmpdb_port" value="1433" />
+    </php>
+
+    <testsuites>
+        <testsuite name="Doctrine DBAL Test Suite">
+            <directory>../Doctrine/Tests/DBAL</directory>
+        </testsuite>
+    </testsuites>
+
+    <groups>
+        <exclude>
+            <group>performance</group>
+            <group>locking_functional</group>
+        </exclude>
+    </groups>
+</phpunit>

tests/appveyor/mssql.sql2012sp1.sqlsrv.appveyor.xml

+<?xml version="1.0" encoding="utf-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="http://schema.phpunit.de/4.8/phpunit.xsd"
+         backupGlobals="false"
+         colors="true"
+         bootstrap="../../vendor/autoload.php"
+>
+    <php>
+        <ini name="error_reporting" value="-1" />
+
+        <var name="db_type" value="sqlsrv"/>
+        <var name="db_host" value="(local)\SQL2012SP1" />
+        <var name="db_username" value="sa" />
+        <var name="db_password" value="Password12!" />
+        <var name="db_name" value="doctrine_tests" />
+        <var name="db_port" value="1433" />
+
+        <var name="tmpdb_type" value="sqlsrv"/>
+        <var name="tmpdb_host" value="(local)\SQL2012SP1" />
+        <var name="tmpdb_username" value="sa" />
+        <var name="tmpdb_password" value="Password12!" />
+        <var name="tmpdb_port" value="1433" />
+    </php>
+
+    <testsuites>
+        <testsuite name="Doctrine DBAL Test Suite">
+            <directory>../Doctrine/Tests/DBAL</directory>
+        </testsuite>
+    </testsuites>
+
+    <groups>
+        <exclude>
+            <group>performance</group>
+            <group>locking_functional</group>
+        </exclude>
+    </groups>
+</phpunit>

tests/appveyor/mssql.sql2017.pdo_sqlsrv.appveyor.xml

+<?xml version="1.0" encoding="utf-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="http://schema.phpunit.de/4.8/phpunit.xsd"
+         backupGlobals="false"
+         colors="true"
+         bootstrap="../../vendor/autoload.php"
+>
+    <php>
+        <ini name="error_reporting" value="-1" />
+
+        <var name="db_type" value="pdo_sqlsrv"/>
+        <var name="db_host" value="(local)\SQL2017" />
+        <var name="db_username" value="sa" />
+        <var name="db_password" value="Password12!" />
+        <var name="db_name" value="doctrine_tests" />
+        <var name="db_port" value="1433"/>
+
+        <var name="tmpdb_type" value="pdo_sqlsrv"/>
+        <var name="tmpdb_host" value="(local)\SQL2017" />
+        <var name="tmpdb_username" value="sa" />
+        <var name="tmpdb_password" value="Password12!" />
+        <var name="tmpdb_port" value="1433"/>
+    </php>
+
+    <testsuites>
+        <testsuite name="Doctrine DBAL Test Suite">
+            <directory>../Doctrine/Tests/DBAL</directory>
+        </testsuite>
+    </testsuites>
+
+    <groups>
+        <exclude>
+            <group>performance</group>
+            <group>locking_functional</group>
+        </exclude>
+    </groups>
+</phpunit>

tests/appveyor/mssql.sql2017.sqlsrv.appveyor.xml

+<?xml version="1.0" encoding="utf-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="http://schema.phpunit.de/4.8/phpunit.xsd"
+         backupGlobals="false"
+         colors="true"
+         bootstrap="../../vendor/autoload.php"
+>
+    <php>
+        <ini name="error_reporting" value="-1" />
+
+        <var name="db_type" value="sqlsrv"/>
+        <var name="db_host" value="(local)\SQL2017" />
+        <var name="db_username" value="sa" />
+        <var name="db_password" value="Password12!" />
+        <var name="db_name" value="doctrine_tests" />
+        <var name="db_port" value="1433" />
+
+        <var name="tmpdb_type" value="sqlsrv"/>
+        <var name="tmpdb_host" value="(local)\SQL2017" />
+        <var name="tmpdb_username" value="sa" />
+        <var name="tmpdb_password" value="Password12!" />
+        <var name="tmpdb_port" value="1433" />
+    </php>
+
+    <testsuites>
+        <testsuite name="Doctrine DBAL Test Suite">
+            <directory>../Doctrine/Tests/DBAL</directory>
+        </testsuite>
+    </testsuites>
+
+    <groups>
+        <exclude>
+            <group>performance</group>
+            <group>locking_functional</group>
+        </exclude>
+    </groups>
+</phpunit>