Adding flush for Doctrine

Author: phpfui

SOB/Doctrine/Tests.php

@@ -106,6 +106,11 @@ public function init(\SOB\Configuration $config) : static
 		return $this;
 		}
 
+	public function flush() : void
+		{
+		$this->entityManager->flush();
+		}
+
 	/**
 	 * class must insert one record with id=$id
 	 *

SOB/Test.php

@@ -14,6 +14,13 @@ final public function __construct()
 		{
 		}
 
+	/**
+	 * override to flush buffers between tests if needed
+	 */
+	public function flush() : void
+		{
+		}
+
 	/**
 	 * Close the database connection
 	 */

SOB/TestRunner.php

@@ -61,6 +61,7 @@ public function runTests() : bool
 			$this->test($tester, $config);
 			$this->addResults($this->currentResults);
 			$tester->closeConnection();
+			$tester = null;
 			}
 
 		return true;
@@ -98,10 +99,17 @@ private function test(\SOB\Test $tester, \SOB\Configuration $config) : bool
 
 		echo "Executing insert test\n";
 
+		$id = 0;
 		for ($i = 1; $i <= $iterations; ++$i)
 			{
-			$tester->insert($i);
+			$newId = $tester->insert($i);
+			if ($newId <= $id)
+				{
+				throw new \Exception('Failed to insert ' . $newId);
+				}
+			$id = $newId;
 			}
+		$tester->flush();
 		$this->setResult('Insert', $timer);
 
 		$timer = new \SOB\BaseLine();
@@ -112,6 +120,7 @@ private function test(\SOB\Test $tester, \SOB\Configuration $config) : bool
 			{
 			$tester->testUpdate($tester->read($i), "Last {$i}");
 			}
+		$tester->flush();
 		$this->setResult('Read', $timer);
 
 		$timer = new \SOB\BaseLine();
@@ -120,6 +129,7 @@ private function test(\SOB\Test $tester, \SOB\Configuration $config) : bool
 			{
 			$tester->update($i, $i + $this->updateOffset);
 			}
+		$tester->flush();
 		$this->setResult('Update', $timer);
 
 		$timer = new \SOB\BaseLine();
@@ -155,6 +165,7 @@ private function test(\SOB\Test $tester, \SOB\Configuration $config) : bool
 				throw new \Exception('Failed to delete ' . $i);
 				}
 			}
+		$tester->flush();
 		$this->setResult('Delete', $timer);
 
 		$this->setResult('Total Runtime', $runTime);