storage test

[m6w6/pq-gateway] / tests / lib / pq / Mapper / StorageTest.php

diff --git a/tests/lib/pq/Mapper/StorageTest.php b/tests/lib/pq/Mapper/StorageTest.php
index fc63f18325ae7f176c49b23dc4de1ab08f9b6811..c57716269528a0741a5c9593615ef0303f0f5191 100644 (file)
--- a/tests/lib/pq/Mapper/StorageTest.php
+++ b/tests/lib/pq/Mapper/StorageTest.php
@@ -68,4 +68,16 @@ class StorageTest extends PHPUnit_Framework_TestCase
                $this->mapper->mapOf(TestModel::class)->getObjects()->resetRow($obj);
                $this->assertCount(0, $this->storage->find(["id="=>$obj->id]));
        }
+
+       function testBuffer() {
+               $this->storage->buffer();
+               $this->assertEquals("yesterday", $this->storage->get(1)->data);
+               $this->mapper->mapOf(TestModel::class)->getObjects()->reset();
+               $exec = $this->mapper->mapOf(TestModel::class)->getGateway()->getQueryExecutor();
+               $xact = executeInConcurrentTransaction($exec, "UPDATE test SET data=\$2 WHERE id=\$1", [1, "the day before"]);
+               $this->assertEquals("yesterday", $this->storage->get(1)->data);
+               $xact->commit();
+               $this->storage->discard();
+               $this->assertEquals("the day before", $this->storage->get(1)->data);
+       }
 }