platform: added getPrimarySequenceName() method (bc break!)

src/Platforms/CachedPlatform.php

@@ -54,6 +54,14 @@ public function getForeignKeys($table)
 	}
 
 
+	public function getPrimarySequenceName($table)
+	{
+		return $this->cache->load('seq.' . md5($table), function () use ($table) {
+			return $this->platform->getPrimarySequenceName($table);
+		});
+	}
+
+
 	public function clearCache()
 	{
 		$this->cache->clean();

src/Platforms/IPlatform.php

@@ -30,4 +30,13 @@ public function getColumns($table);
 	 * @return array
 	 */
 	public function getForeignKeys($table);
+
+
+	/**
+	 * Returns primary sequence name for the table.
+	 * If not supported nor present, returns a null.
+	 * @param  string $table
+	 * @return string|null
+	 */
+	public function getPrimarySequenceName($table);
 }

src/Platforms/MySqlPlatform.php

@@ -81,4 +81,10 @@ public function getForeignKeys($table)
 		}
 		return $keys;
 	}
+
+
+	public function getPrimarySequenceName($table)
+	{
+		return null;
+	}
 }

src/Platforms/PostgreSqlPlatform.php

@@ -112,4 +112,15 @@ public function getForeignKeys($table)
 		}
 		return $keys;
 	}
+
+
+	public function getPrimarySequenceName($table)
+	{
+		foreach ($this->getColumns($table) as $column) {
+			if ($column['is_primary']) {
+				return $column['sequence'];
+			}
+		}
+		return null;
+	}
 }

tests/cases/integration/platform.mysql.phpt

@@ -132,6 +132,11 @@ class PlatformMysqlTest extends IntegrationTestCase
 		], $keys);
 	}
 
+
+	public function testPrimarySequence()
+	{
+		Assert::null($this->connection->getPlatform()->getPrimarySequenceName('books'));
+	}
 }
 
 

tests/cases/integration/platform.pgsql.phpt

@@ -140,6 +140,11 @@ class PlatformPostgreTest extends IntegrationTestCase
 		], $keys);
 	}
 
+
+	public function testPrimarySequence()
+	{
+		Assert::same('books_id_seq', $this->connection->getPlatform()->getPrimarySequenceName('books'));
+	}
 }
 
 

tests/cases/unit/CachedPlatformTest.phpt

@@ -137,6 +137,33 @@ class CachedPlatformTest extends TestCase
 		$cols = $this->platform->getForeignKeys('foo');
 		Assert::same($expectedFk, $cols);
 	}
+
+
+	public function testQueryPS()
+	{
+		$expectedPs = 'ps_name';
+		$this->storageMock
+			->shouldReceive('read')
+			->with("nextras.dbal.platform.b5ad707c2b9f71ed843ba3004e50b37d\x00bd00c4ff6d83b5c76532c1ed83cb7855")
+			->once()
+			->andReturnNull();
+		$this->storageMock
+			->shouldReceive('lock')
+			->with("nextras.dbal.platform.b5ad707c2b9f71ed843ba3004e50b37d\x00bd00c4ff6d83b5c76532c1ed83cb7855")
+			->once();
+		$this->storageMock
+			->shouldReceive('write')
+			->with(
+				"nextras.dbal.platform.b5ad707c2b9f71ed843ba3004e50b37d\x00bd00c4ff6d83b5c76532c1ed83cb7855",
+				$expectedPs,
+				[]
+			)
+			->once();
+		$this->platformMock->shouldReceive('getPrimarySequenceName')->with('foo')->once()->andReturn($expectedPs);
+
+		$cols = $this->platform->getPrimarySequenceName('foo');
+		Assert::same($expectedPs, $cols);
+	}
 }