return false;
}
+ function refresh() {
+ $this->data = $this->table->find($this->criteria(), null, 1, 0)->current()->data;
+ $this->cell = array();
+ return $this;
+ }
+
/**
* Fill modified cells
* @return \pq\Gateway\Row
return $this->table;
}
- function create() {
- array_map(function ($row) {
- $row->create();
- }, $this->rows);
+ /**
+ * Create all rows of this rowset
+ * @param bool $txn
+ * @return \pq\Gateway\Rowset
+ * @throws Exception
+ */
+ function create($txn = true) {
+ $txn = $txn ? $this->table->getConnection()->startTransaction() : false;
+ try {
+ foreach ($this->rows as $row) {
+ $row->create();
+ }
+ } catch (\Exception $e) {
+ if ($txn) {
+ $txn->rollback();
+ }
+ throw $e;
+ }
+ if ($txn) {
+ $txn->commit();
+ }
return $this;
}
- function update() {
- array_map(function ($row) {
- $row->update();
- }, $this->rows);
+ /**
+ * Update all rows of this rowset
+ * @param bool $txn
+ * @return \pq\Gateway\Rowset
+ * @throws \Exception
+ */
+ function update($txn = true) {
+ $txn = $txn ? $this->table->getConnection()->startTransaction() : false;
+ try {
+ foreach ($this->rows as $row) {
+ $row->update();
+ }
+ } catch (\Exception $e) {
+ if ($txn) {
+ $txn->rollback();
+ }
+ throw $e;
+ }
+ if ($txn) {
+ $txn->commit();
+ }
return $this;
}
- function delete() {
- array_map(function ($row) {
- $row->delete();
- }, $this->rows);
+ /**
+ * Delete all rows of this rowset
+ * @param type $txn
+ * @return \pq\Gateway\Rowset
+ * @throws \Exception
+ */
+ function delete($txn = true) {
+ $txn = $txn ? $this->table->getConnection()->startTransaction() : false;
+ try {
+ foreach ($this->rows as $row) {
+ $row->delete();
+ }
+ } catch (\Exception $e) {
+ if ($txn) {
+ $txn->rollback();
+ }
+ throw $e;
+ }
+ if ($txn) {
+ $txn->commit();
+ }
return $this;
}
if (!$this->valid()) {
throw new \OutOfBoundsException("Invalid seek position ($pos)");
}
+
+ return $this;
}
/**
return $this->rows;
}
+ /**
+ * Apply a callback on each row of this rowset
+ * @param callable $cb
+ * @return \pq\Gateway\Rowset
+ */
+ function apply(callable $cb) {
+ array_walk($this->rows, $cb, $this);
+ return $this;
+ }
+
/**
* Filter by callback
* @param callable $cb
$rowset->rows = array_filter($this->rows, $cb);
return $rowset;
}
+
+ /**
+ * Append a row to the rowset
+ * @param \pq\Gateway\Row $row
+ */
+ function append(Row $row) {
+ $this->rows[] = $row;
+ return $this;
+ }
}
--- /dev/null
+<?php
+
+namespace pq\Gateway;
+
+include_once __DIR__."/../../../setup.inc";
+
+class RowTest extends \PHPUnit_Framework_TestCase {
+
+ /**
+ * @var \pq\Connection
+ */
+ protected $conn;
+
+ /**
+ * @var \pq\Gateway\Table
+ */
+ protected $table;
+
+ protected function setUp() {
+ $this->conn = new \pq\Connection(PQ_DSN);
+ $this->conn->exec(PQ_TEST_DROP_TABLE);
+ $this->conn->exec(PQ_TEST_CREATE_TABLE);
+ $this->conn->exec(PQ_TEST_CREATE_DATA);
+
+ $this->table = new Table(PQ_TEST_TABLE_NAME, $this->conn);
+ }
+
+ protected function tearDown() {
+ $this->conn->exec(PQ_TEST_DROP_TABLE);
+ }
+
+ function testBasic() {
+ $row = new Row($this->table, array("id" => 3), true);
+ $this->assertTrue($row->isDirty());
+ $row->refresh();
+ $this->assertSame(
+ array(
+ "id" => "3",
+ "created" => date("Y-m-d H:i:s", strtotime("tomorrow")),
+ "counter" => "1",
+ "number" => "1.1",
+ "data" => "tomorrow"
+ ),
+ $row->getData()
+ );
+ $this->assertFalse($row->isDirty());
+ }
+
+ function testGetTable() {
+ $row = new Row($this->table);
+ $this->assertSame($this->table, $row->getTable());
+ }
+}
--- /dev/null
+<?php
+
+namespace pq\Gateway;
+
+include_once __DIR__."/../../../setup.inc";
+
+class RowsetTest extends \PHPUnit_Framework_TestCase {
+
+ /**
+ * @var \pq\Connection
+ */
+ protected $conn;
+
+ /**
+ * @var \pq\Gateway\Table
+ */
+ protected $table;
+
+ protected function setUp() {
+ $this->conn = new \pq\Connection(PQ_DSN);
+ $this->conn->exec(PQ_TEST_DROP_TABLE);
+ $this->conn->exec(PQ_TEST_CREATE_TABLE);
+ $this->conn->exec(PQ_TEST_CREATE_DATA);
+
+ $this->table = new Table(PQ_TEST_TABLE_NAME, $this->conn);
+ }
+
+ protected function tearDown() {
+ $this->conn->exec(PQ_TEST_DROP_TABLE);
+ }
+
+ public function test__invoke() {
+ $rowset = $this->table->find();
+ $this->table->setRowsetPrototype(null);
+ $result = $this->table->find();
+ $rowset2 = $rowset($result);
+ $this->assertEquals($rowset, $rowset2);
+ }
+
+ public function testSetRowPrototype() {
+ $prop = new \ReflectionProperty("\\pq\\Gateway\\Rowset", "row");
+ $prop->setAccessible(true);
+ $prototype = new Rowset($this->table);
+ $this->assertEquals("\\pq\\Gateway\\Row", $prop->getValue($prototype));
+ $prototype->setRowPrototype(null);
+ $this->assertNull($prop->getValue($prototype));
+ $this->table->setRowsetPrototype($prototype);
+ $rowset = $this->table->find();
+ foreach ($rowset as $row) {
+ $this->assertInstanceOf("stdClass", $row);
+ $this->assertObjectHasAttribute("id", $row);
+ }
+ $prototype->setRowPrototype(new Row($this->table));
+ $rowset = $this->table->find();
+ foreach ($rowset as $index => $row) {
+ $this->assertInstanceOf("\\pq\\Gateway\\Row", $row);
+ $this->assertEquals($index+1, $row->id->get());
+ }
+ }
+
+ public function testGetTable() {
+ $rowset = new Rowset($this->table);
+ $this->assertSame($this->table, $rowset->getTable());
+ }
+
+ public function testCreate() {
+ $rowset = new Rowset($this->table);
+ $rowset->append(new Row($this->table));
+ $rowset->create();
+ $this->assertCount(1, $rowset);
+ $this->assertCount(4, $this->table->find());
+ }
+
+ public function testUpdate() {
+ $rowset = $this->table->find();
+ $rowset->apply(function($row) {
+ $row->data = "updated";
+ });
+ $rowset->update();
+ $rowset = $this->table->find();
+ $rowset->apply(function($row) {
+ $this->assertSame("updated", $row->data->get());
+ });
+ }
+
+ public function testDelete() {
+ $this->table->find()->delete();
+ $this->assertCount(0, $this->table->find());
+ }
+
+ public function testJsonSerialize() {
+ $json = sprintf('[{"id":"1","created":"%s","counter":"-1","number":"-1.1","data":"yesterday"}'
+ .',{"id":"2","created":"%s","counter":"0","number":"0","data":"today"}'
+ .',{"id":"3","created":"%s","counter":"1","number":"1.1","data":"tomorrow"}]',
+ date("Y-m-d H:i:s", strtotime("yesterday")),
+ date("Y-m-d H:i:s", strtotime("today")),
+ date("Y-m-d H:i:s", strtotime("tomorrow"))
+ );
+ $this->assertJsonStringEqualsJsonString($json, json_encode($this->table->find()));
+ }
+
+ public function testIterator() {
+ $counter = 0;
+ foreach ($this->table->find() as $index => $row) {
+ $this->assertSame($counter++, $index);
+ $this->assertInstanceOf("\\pq\\Gateway\\Row", $row);
+ }
+ }
+
+ public function testSeekEx() {
+ $this->setExpectedException("\\OutOfBoundsException", "Invalid seek position (3)");
+ $this->table->find()->seek(3);
+ }
+
+ public function testSeek() {
+ $rowset = $this->table->find();
+ for ($i = count($rowset); $i > 0; --$i) {
+ $this->assertEquals($i, $rowset->seek($i-1)->current()->id->get());
+ }
+ }
+
+ public function testCount() {
+ $this->assertCount(3, $this->table->find());
+ }
+
+ public function testGetRows() {
+ $rowset = $this->table->find();
+ $rows = $rowset->getRows();
+ $rowset2 = $rowset->filter(function($row) { return true; });
+ $this->assertEquals($rows, $rowset2->getRows());
+ $rowset3 = $rowset->filter(function($row) { return false; });
+ $this->assertCount(0, $rowset3);
+ $this->assertSame(array(), $rowset3->getRows());
+ $this->assertCount(1, $rowset->filter(function($row) { return $row->id->get() == 1; }));
+ }
+}
namespace pq\Gateway;
-include __DIR__."/../../../setup.inc";
+include_once __DIR__."/../../../setup.inc";
-/**
- * Generated by PHPUnit_SkeletonGenerator 1.2.0 on 2013-03-05 at 16:08:03.
- */
class TableTest extends \PHPUnit_Framework_TestCase {
/**
/**
* @var Table
*/
- protected $object;
+ protected $table;
- /**
- * Sets up the fixture, for example, opens a network connection.
- * This method is called before a test is executed.
- */
protected function setUp() {
$this->conn = new \pq\Connection(PQ_DSN);
$this->conn->exec(PQ_TEST_DROP_TABLE);
$this->conn->exec(PQ_TEST_CREATE_TABLE);
Table::$defaultConnection = $this->conn;
- $this->object = new Table(PQ_TEST_TABLE_NAME);
+ $this->table = new Table(PQ_TEST_TABLE_NAME);
}
- /**
- * Tears down the fixture, for example, closes a network connection.
- * This method is called after a test is executed.
- */
protected function tearDown() {
$this->conn->exec(PQ_TEST_DROP_TABLE);
}
- /**
- * Creates test data in the test table
- */
protected function createTestData() {
$this->conn->exec(PQ_TEST_CREATE_DATA);
}
- /**
- * @covers pq\Gateway\Table::setRowsetPrototype
- */
public function testSetRowsetPrototype() {
$prop = new \ReflectionProperty("\\pq\\Gateway\\Table", "rowset");
$prop->setAccessible(true);
- $this->assertEquals("\\pq\\Gateway\\Rowset", $prop->getValue($this->object));
- $this->object->setRowsetPrototype(null);
- $this->assertNull($prop->getValue($this->object));
- $rowset = new \pq\Gateway\Rowset($this->object);
- $this->object->setRowsetPrototype($rowset);
- $this->assertSame($rowset, $prop->getValue($this->object));
+ $this->assertEquals("\\pq\\Gateway\\Rowset", $prop->getValue($this->table));
+ $this->table->setRowsetPrototype(null);
+ $this->assertNull($prop->getValue($this->table));
+ $rowset = new \pq\Gateway\Rowset($this->table);
+ $this->table->setRowsetPrototype($rowset);
+ $this->assertSame($rowset, $prop->getValue($this->table));
}
- /**
- * @covers pq\Gateway\Table::getConnection
- */
public function testGetConnection() {
- $this->assertSame($this->conn, $this->object->getConnection());
+ $this->assertSame($this->conn, $this->table->getConnection());
}
- /**
- * @covers pq\Gateway\Table::getName
- */
public function testGetName() {
- $this->assertSame(PQ_TEST_TABLE_NAME, $this->object->getName());
+ $this->assertSame(PQ_TEST_TABLE_NAME, $this->table->getName());
}
- /**
- * @covers pq\Gateway\Table::find
- */
public function testFind() {
- $rowset = $this->object->find();
+ $rowset = $this->table->find();
$this->assertInstanceOf("\\pq\\Gateway\\Rowset", $rowset);
- $rowset = $this->object->find(array("id = " => 1));
+ $rowset = $this->table->find(array("id = " => 1));
$this->assertInstanceOf("\\pq\\Gateway\\Rowset", $rowset);
- $rowset = $this->object->find(array("id = " => 0));
+ $rowset = $this->table->find(array("id = " => 0));
$this->assertInstanceOf("\\pq\\Gateway\\Rowset", $rowset);
- $rowset = $this->object->find(array(array("id<" => 2), array("id>" => 2)));
+ $rowset = $this->table->find(array(array("id<" => 2), array("id>" => 2)));
$this->assertInstanceOf("\\pq\\Gateway\\Rowset", $rowset);
}
- /**
- * @covers pq\Gateway\Table::create
- */
public function testCreate() {
- $rowset = $this->object->create(array("id" => new \pq\Query\Expr("DEFAULT")));
+ $rowset = $this->table->create(array("id" => new \pq\Query\Expr("DEFAULT")));
$this->assertInstanceOf("\\pq\\Gateway\\Rowset", $rowset);
$this->assertCount(1, $rowset);
}
- /**
- * @covers pq\Gateway\Table::update
- */
public function testUpdate() {
- $row = $this->object->create(array())->current();
+ $row = $this->table->create(array())->current();
$data = array(
"created" => "2013-03-03 03:03:03",
"counter" => 2,
"number" => 2.2,
"data" => "this is a test",
);
- $row = $this->object->update(array("id = " => $row->id), $data)->current();
+ $row = $this->table->update(array("id = " => $row->id), $data)->current();
$data = array("id" => $row->id->get()) + $data;
$this->assertSame(array_map(function($v){return strval($v);}, $data), $row->getData());
}
- /**
- * @covers pq\Gateway\Table::delete
- */
public function testDelete() {
- $this->object->delete(array("id!=" => 0));
- $this->assertCount(0, $this->object->find());
+ $this->table->delete(array("id!=" => 0));
+ $this->assertCount(0, $this->table->find());
}
-
}
projects / m6w6 / pq-gateway / commitdiff
