git.m6w6.name Git - m6w6/pq-gateway/blob - lib/pq/Gateway/Row.php

   1 <?php
   2
   3 namespace pq\Gateway;
   4
   5 class Row implements \JsonSerializable
   6 {
   7         /**
   8          * @var \pq\Gateway\Table
   9          */
  10         protected $table;
  11
  12         /**
  13          * @var array
  14          */
  15         protected $data;
  16
  17         /**
  18          * @var array
  19          */
  20         protected $mods = array();
  21
  22         /**
  23          * @param \pq\Gateway\Table $table
  24          * @param array $data
  25          * @param bool $prime whether to mark all columns as modified
  26          */
  27         function __construct(Table $table, array $data = null, $prime = false) {
  28                 $this->table = $table;
  29                 $this->data = $data;
  30
  31                 if ($prime) {
  32                         $this->prime();
  33                 }
  34         }
  35
  36         /**
  37          * Copy constructor
  38          * @param array $data
  39          * @return \pq\Gateway\Row
  40          */
  41         function __invoke(array $data) {
  42                 $that = clone $this;
  43                 $that->data = $data;
  44                 return $that->prime();
  45         }
  46
  47         /**
  48          * @implements JsonSerializable
  49          * @return array
  50          */
  51         function jsonSerialize() {
  52                 return $this->data;
  53         }
  54
  55         /**
  56          * @return \pq\Gateway\Table
  57          */
  58         function getTable() {
  59                 return $this->table;
  60         }
  61
  62         /**
  63          * @return array
  64          */
  65         function getData() {
  66                 return $this->data;
  67         }
  68
  69         /**
  70          * Fill modified cells
  71          * @return \pq\Gateway\Row
  72          */
  73         protected function prime() {
  74                 $this->mods = array();
  75                 foreach ($this->data as $key => $val) {
  76                         $this->mods[$key] = new Cell($this, $key, $val);
  77                 }
  78                 return $this;
  79         }
  80
  81         /**
  82          * Transform data array to where criteria
  83          * @param array $data
  84          * @return array
  85          */
  86         protected function criteria() {
  87                 $where = array();
  88                 array_walk($this->data, function($v, $k) use (&$where) {
  89                         $where["$k="] = $v;
  90                 });
  91                 return $where;
  92         }
  93
  94         protected function changes() {
  95                 $changes = array();
  96                 foreach ($this->mods as $name => $cell) {
  97                         $changes[$name] = $cell->get();
  98                 }
  99                 return $changes;
 100         }
 101
 102         /**
 103          * Get a cell
 104          * @param string $p
 105          * @return \pq\Gateway\Cell
 106          */
 107         function __get($p) {
 108                 if (!isset($this->mods[$p])) {
 109                         $this->mods[$p] = new Cell($this, $p, $this->data[$p]);
 110                 }
 111                 return $this->mods[$p];
 112         }
 113
 114         /**
 115          * Set a cell value
 116          * @param string $p
 117          * @param mixed $v
 118          */
 119         function __set($p, $v) {
 120                 $this->__get($p)->set(($v instanceof Cell) ? $v->get() : $v);
 121         }
 122
 123         /**
 124          * Create this row in the database
 125          * @return \pq\Gateway\Row
 126          */
 127         function create() {
 128                 $this->data = $this->table->create($this->changes())->current()->data;
 129                 $this->mods = array();
 130                 return $this;
 131         }
 132
 133         /**
 134          * Update this row in the database
 135          * @return \pq\Gateway\Row
 136          */
 137         function update() {
 138                 $this->data = $this->table->update($this->criteria(), $this->changes())->current()->data;
 139                 $this->mods = array();
 140                 return $this;
 141         }
 142
 143         /**
 144          * Delete this row in the database
 145          * @return \pq\Gateway\Row
 146          */
 147         function delete() {
 148                 $this->data = $this->table->delete($this->criteria(), "*")->current()->data;
 149                 return $this->prime();
 150         }
 151 }