H:/Workspace/php-axiom/www/php-axiom/libraries/axiom/axBaseModel.class.php

Go to the documentation of this file.

<?php
abstract class axBaseModel implements axModel {

    protected $_pdo;
    
    protected $_idKey = "id";

    protected $_data = array();

    protected $_statements = array();

    abstract protected function _init ($statement);

    public function __construct (PDO $pdo, $id = null) {
        if (!$pdo)
            throw new InvalidArgumentException('First parameters is expected to be a valid PDO instance');
        
        $this->_pdo = $pdo;
            
        if ($id !== null && $id !== false && !$this->retrieve($id))
            throw new RuntimeException("Cannot instanciate model");
    }

    public function __sleep () {
        return array('_idKey', '_data');
    }

    public function __get ($key) {
        return isset($this->_data[$key]) ? $this->_data[$key] : null;
    }

    public function __set ($key, $value) {
        $this->_data[$key] = $value;
    }

    public function __isset ($key) {
        return isset($this->_data[$key]);
    }

    public function getData () {
        return $this->_data;
    }

    public function create (array $data) {
        if (!$this->_init("create"))
            throw new RuntimeException("Cannot initialize " . __METHOD__, 2011);
         
        if ($this->_statements['create']->execute($data)) {
            $id = $this->_pdo->lastInsertId();
            return $this->retrieve($id);
        }
        return false;
    }
    
    public function retrieve ($id) {
        if (!$this->_init("retrieve"))
            throw new RuntimeException("Cannot initialize " . __METHOD__, 2010);
         
        if ($this->_statements['retrieve']->execute(array(":{$this->_idKey}" => $id))) {
            if ($this->_statements['retrieve']->rowCount()) {
                $this->_data = $this->_statements['retrieve']->fetch(PDO::FETCH_ASSOC);
                return $this;
            }
        }
        return false;
    }

    public function update (array $data = array()) {
        if (!$this->_init("update"))
            throw new RuntimeException("Cannot initialize " . __METHOD__, 2012);
         
        if (!empty($this->_data)) {
            $inputs = array_merge($this->_data, array_intersect_key($data, $this->_data));
            return $this->_statements['update']->execute($inputs) ? $this : false;
        }
        return false;
    }

    public function delete () {
        if (!$this->_init("delete"))
            throw new RuntimeException("Cannot initialize " . __METHOD__, 2013);
         
        if (!empty($this->_data))
            return $this->_statements['delete']->execute(array(":{$this->_idKey}" => $this->_data[$this->_idKey]));
        return false;
    }
}