Record.php

Go to the documentation of this file.

<?php

namespace Rsi\Fred\Def;

class Record extends \Rsi\Thing{

  protected $_def = null;
  protected $_table = null;

  protected $_columns = null;
  protected $_key = null;
  protected $_record = [];

  public function __construct($def,$table){
    $this->_def = $def;
    $this->_table = $table;
  }
  /**
   * Load the record.
   * @param mixed $key  Unique identifier for this record, based on the primary key (array when multiple columns).
   * @return bool  True when found.
   */
  public function load($key){
    $this->_key = [];
    if(!is_array($id = $key)) switch(count($key = $this->_def->key($this->_table))){
      case 0: throw new \Exception('No primary key and no column specified');
      case 1: $this->_key[array_pop($key)] = $id; break;
      default: throw new \Exception('Multi column primary key and only one value given');
    }
    else{
      foreach($this->columns as $name => $column) if(array_key_exists($name,$key)) $this->_key[$column['column']] = $key[$name];
      if(!$this->_key) throw new \Exception('Empty key');
    }
    switch(count($records = $this->db->_select($this->_table,'*',$this->_key,null,2) ?: [])){
      case 0: return $this->_key = false;
      case 1: $this->_record = array_pop($records); break;
      default: throw new \Exception('Key not unique');
    }
    return true;
  }
  /**
   * Save the record.
   * @return mixed  Key on success (auto insert ID when applicable; array when multiple columns; false when no primary key).
   */
  public function save(){
    if(!$this->_key){
      $this->db->_insert($this->_table,$this->_record);
      if(!($key = $this->_def->key($this->_table))) return false;
      $this->_key = ($id = $this->db->lastInsertId()) ? [array_shift($key) => $id] : \Rsi\Record::select($this->_record,$key);
    }
    elseif(!$this->db->_update($this->_table,$this->_record,$this->_key)) throw new \Exception('Record disappeared');
    $key = [];
    foreach($this->columns as $name => $def) if(array_key_exists($def['column'],$this->_key)) $key[$name] = $this->_key[$def['column']];
    return $key;
  }

  protected function _get($key){
    return $this->_record[$this->columns[$key]['column']] ?? $this->columns[$key]['defaultValue'] ?? false;
  }

  protected function _set($key,$value){
    $this->_record[$this->columns[$key]['column']] = $value;
  }

  protected function getColumns(){
    if($this->_columns === null){
      $this->_columns = [];
      foreach($this->_def->table($this->_table) as $column => $def){
        $def = $this->_def->column($this->_table,$column);
        $this->_columns[$def['alias'] ?? $column] = $def + ['column' => $column];
      }
    }
    return $this->_columns;
  }

  protected function getDb(){
    return $this->_def->component('db');
  }

}