issue-36: add primary key for migration_table

byjg · Mar 31, 2021 · 253cf9b · 253cf9b
1 parent a506e24
commit 253cf9b
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/src/Database/DblibDatabase.php b/src/Database/DblibDatabase.php
@@ -57,7 +57,7 @@ protected function createTableIfNotExists($database, $createTable)
     public function createVersion()
     {
         $database = preg_replace('~^/~', '', $this->getDbDriver()->getUri()->getPath());
-        $createTable = 'CREATE TABLE ' . $this->getMigrationTable() . ' (version int, status varchar(20))';
+        $createTable = 'CREATE TABLE ' . $this->getMigrationTable() . ' (version int, status varchar(20), PRIMARY KEY (version))';
         $this->createTableIfNotExists($database, $createTable);
         $this->checkExistsVersion();
     }

diff --git a/src/Database/MySqlDatabase.php b/src/Database/MySqlDatabase.php
@@ -40,7 +40,7 @@ public function dropDatabase()
      */
     public function createVersion()
     {
-        $this->getDbDriver()->execute('CREATE TABLE IF NOT EXISTS ' . $this->getMigrationTable() . ' (version int, status varchar(20))');
+        $this->getDbDriver()->execute('CREATE TABLE IF NOT EXISTS ' . $this->getMigrationTable() . ' (version int, status varchar(20), PRIMARY KEY (version))');
         $this->checkExistsVersion();
     }
 

diff --git a/src/Database/PgsqlDatabase.php b/src/Database/PgsqlDatabase.php
@@ -60,7 +60,7 @@ public function dropDatabase()
      */
     public function createVersion()
     {
-        $this->getDbDriver()->execute('CREATE TABLE IF NOT EXISTS ' . $this->getMigrationTable() . ' (version int, status varchar(20))');
+        $this->getDbDriver()->execute('CREATE TABLE IF NOT EXISTS ' . $this->getMigrationTable() . ' (version int, status varchar(20), PRIMARY KEY (version))');
         $this->checkExistsVersion();
     }
 

diff --git a/src/Database/SqliteDatabase.php b/src/Database/SqliteDatabase.php
@@ -36,7 +36,7 @@ public function dropDatabase()
      */
     public function createVersion()
     {
-        $this->getDbDriver()->execute('CREATE TABLE IF NOT EXISTS ' . $this->getMigrationTable() . ' (version int, status varchar(20))');
+        $this->getDbDriver()->execute('CREATE TABLE IF NOT EXISTS ' . $this->getMigrationTable() . ' (version int, status varchar(20), PRIMARY KEY (version))');
         $this->checkExistsVersion();
     }