diff --git a/Tests/Functional/Domain/Repository/Fixtures/Product/PersistedTea.csv b/Tests/Functional/Domain/Repository/Fixtures/Product/PersistedTea.csv
new file mode 100644
index 0000000..6384ffe
--- /dev/null
+++ b/Tests/Functional/Domain/Repository/Fixtures/Product/PersistedTea.csv
@@ -0,0 +1,3 @@
+"tx_tea_domain_model_product_tea"
+,"uid","title"
+,1,"Godesberger Burgtee"
diff --git a/Tests/Functional/Domain/Repository/Product/TeaRepositoryTest.php b/Tests/Functional/Domain/Repository/Product/TeaRepositoryTest.php
index 1fe5ee9..176539e 100644
--- a/Tests/Functional/Domain/Repository/Product/TeaRepositoryTest.php
+++ b/Tests/Functional/Domain/Repository/Product/TeaRepositoryTest.php
@@ -119,16 +119,7 @@ final class TeaRepositoryTest extends FunctionalTestCase
         $this->subject->add($model);
         $this->persistenceManager->persistAll();
 
-        $connection = $this->getConnectionPool()->getConnectionForTable('tx_tea_domain_model_product_tea');
-        $databaseRow = $connection
-            ->executeQuery(
-                'SELECT * FROM tx_tea_domain_model_product_tea WHERE uid = :uid',
-                ['uid' => $model->getUid()]
-            )
-            ->fetchAssociative();
-
-        self::assertIsArray($databaseRow);
-        self::assertSame($title, $databaseRow['title']);
+        $this->assertCSVDataSet(__DIR__ . '/../Fixtures/Product/PersistedTea.csv');
     }
 
     /**