kumbia_active_record.php

Ir a la documentación de este archivo.

<?php
require CORE_PATH . 'libs/db/db.php';

class KumbiaActiveRecord
{
    //Soportados

    protected $db;
    protected $database;
    protected $schema;
    protected $source;
    protected $count;
    protected $fields = array();
    protected $primary_key = array();
    protected $non_primary = array();
    protected $not_null = array();
    protected $_with_default = array();
    protected $alias = array();
    protected $is_view = false;
    protected $debug = false;
    protected $logger = false;
    protected $persistent = false;
    protected $_validates = array('inclusion_in' => array(), 'exclusion_of' => array(), 'numericality_of' => array(),
        'format_of' => array(), 'date_in' => array(), 'email_in' => array(), 'uniqueness_of' => array());
    protected $_in = array();
    protected $_at = array();
    protected $_where_pk;
    protected $_dumped = false;
    protected $_dump_lock = false;
    protected $_data_type = array();
    protected $_has_one = array();
    protected $_has_many = array();
    protected $_belongs_to = array();
    protected $_has_and_belongs_to_many = array();
    protected $parent_of = array();
    protected static $_models = array();
    protected static $models = array();

    function __construct($data=null)
    {
        if (!$this->source) {
            $this->_model_name();
        }

        if (method_exists($this, 'initialize')) {
            $this->initialize();
        }

        $this->_connect();

        if ($data) {
            if (!is_array($data)) $data = Util::getParams(func_get_args());
            foreach($this->fields as $field) {
                if (isset($data[$field])) {
                    $this->$field = $data[$field];
                }
            }
        }
    }

    protected function _model_name()
    {
        if (!$this->source) {
            $this->source = Util::smallcase(get_class($this));
        }
    }

    public function set_source($source)
    {
        $this->source = $source;
    }

    public function get_source()
    {
        return $this->source;
    }

    public function set_database($database)
    {
        $this->database = $database;
    }

    public function get_database()
    {
        if ($this->database) {
            return $this->database;
        } else {
            $core = Config::read('config');
            return $core['application']['database'];
        }
    }

    public function is_dumped()
    {
        return $this->_dumped;
    }

    protected function _get_relation_data($mmodel)
    {
        if (array_key_exists($mmodel, $this->_belongs_to)) {
            $relation = $this->_belongs_to[$mmodel];
            return self::get($relation->model)->find_first($this->{$relation->fk});
        } elseif (array_key_exists($mmodel, $this->_has_one)) {
            $relation = $this->_has_one[$mmodel];
            if ($this->{$this->primary_key[0]}) {
                return self::get($relation->model)->find_first("{$relation->fk}={$this->db->add_quotes($this->{$this->primary_key[0]}) }");
            } else {
                return NULL;
            }
        } elseif (array_key_exists($mmodel, $this->_has_many)) {
            $relation = $this->_has_many[$mmodel];
            if ($this->{$this->primary_key[0]}) {
                return self::get($relation->model)->find("{$relation->fk}={$this->db->add_quotes($this->{$this->primary_key[0]}) }");
            } else {
                return array();
            }
        } elseif (array_key_exists($mmodel, $this->_has_and_belongs_to_many)) {
            $relation = $this->_has_and_belongs_to_many[$mmodel];
            $relation_model = self::get($relation->model);
            $source = ($this->schema ? "{$this->schema}." : NULL ) . $this->source;
            $relation_source = ($relation_model->schema ? "{$relation_model->schema}." : NULL ) . $relation_model->source;
            if (!isset($relation->through)) {
                if ($source > $relation_source) {
                    $relation->through = "{$this->source}_{$relation_source}";
                } else {
                    $relation->through = "{$relation_source}_{$this->source}";
                }
            }else{
                $through = explode('/', $relation->through);
                $relation->through = end($through);
            }
            if ($this->{$this->primary_key[0]}) {
                return $relation_model->find_all_by_sql("SELECT $relation_source.* FROM $relation_source, {$relation->through}, $source
                    WHERE {$relation->through}.{$relation->key} = {$this->db->add_quotes($this->{$this->primary_key[0]}) }
                    AND {$relation->through}.{$relation->fk} = $relation_source.{$relation_model->primary_key[0]}
                    AND {$relation->through}.{$relation->key} = $source.{$this->primary_key[0]}
                    ORDER BY $relation_source.{$relation_model->primary_key[0]}");
            } else {
                return array();
            }
        } else {
            return FALSE; //si no existe ninguna asociación devuelve false.
        }
    }

    function __get($property)
    {
        if (!$this->_dump_lock) {
            if (!isset($this->$property)) {
                return $this->_get_relation_data($property);
            }
        }
        return $this->$property;
    }

    function __set($property, $value)
    {
        if (!$this->_dump_lock) {
            if (is_object($value) && is_subclass_of($value, 'KumbiaActiveRecord')) {
                if (array_key_exists($property, $this->_belongs_to)) {
                    $relation = $this->_belongs_to[$property];
                    $value->dump_model();
                    $this->{$relation->fk} = $value->{$value->primary_key[0]};
                    return;
                } elseif (array_key_exists($property, $this->_has_one)) {
                    $relation = $this->_has_one[$property];
                    $value->{$relation->fk} = $this->{$this->primary_key[0]};
                    return;
                }
            } elseif ($property == "source") {
                $value = KumbiaActiveRecord::sql_item_sanitize($value);
            }
        }
        $this->$property = $value;
    }

    public function __call($method, $args = array())
    {
        if (substr($method, 0, 8) == "find_by_") {
            $field = substr($method, 8);
            KumbiaActiveRecord::sql_item_sanitize($field);
            if (isset($args[0])) {
                $arg = array("conditions: $field = {$this->db->add_quotes($args[0])}");
                unset($args[0]);
            } else {
                $arg = array();
            }
            return call_user_func_array(array($this, "find_first"), array_merge($arg, $args));
        }
        if (substr($method, 0, 9) == "count_by_") {
            $field = substr($method, 9);
            KumbiaActiveRecord::sql_item_sanitize($field);
            if (isset($args[0])) {
                $arg = array("conditions: $field = {$this->db->add_quotes($args[0])}");
                unset($args[0]);
            } else {
                $arg = array();
            }
            return call_user_func_array(array($this, "count"), array_merge($arg, $args));
        }
        if (substr($method, 0, 12) == "find_all_by_") {
            $field = substr($method, 12);
            KumbiaActiveRecord::sql_item_sanitize($field);
            if (isset($args[0])) {
                $arg = array("conditions: $field = {$this->db->add_quotes($args[0])}");
                unset($args[0]);
            } else {
                $arg = array();
            }
            return call_user_func_array(array($this, "find"), array_merge($arg, $args));
        }
        $model = preg_replace('/^get/', '', $method);
        $mmodel = Util::smallcase($model);
        if (($data = $this->_get_relation_data($mmodel)) !== FALSE) {
            return $data;
        }
        
        if (method_exists($this, $method)) {
            call_user_func_array(array($this, $method), $args);
        } else {
            throw new KumbiaException("No existe el método '$method' en ActiveRecord::" . get_class($this));
        }
        
        return $this->$method($args);
    }

    protected function _connect()
    {
        if (!is_object($this->db)) {
            $this->db = Db::factory($this->database);
        }
        $this->db->debug = $this->debug;
        $this->db->logger = $this->logger;
        $this->dump();
    }

    public function dump_model()
    {
        $this->_connect();
    }

    protected function dump()
    {
        if ($this->_dumped) {
            return false;
        }
        //$a = array();
        if ($this->source) {
            $this->source = str_replace(";", '', strtolower($this->source));
        } else {
            $this->_model_name();
            if (!$this->source) {
                return false;
            }
        }
        $table = $this->source;
        $schema = $this->schema;
        if (!count(self::get_meta_data($this->source))) {
            $this->_dumped = true;
            $this->_dump_info($table, $schema);
            if (!count($this->primary_key)) {
                if (!$this->is_view) {
                    throw new KumbiaException("No se ha definido una llave primaria para la tabla '$table' esto imposibilita crear el ActiveRecord para esta entidad");
                }
            }
        } else {
            if (!$this->is_dumped()) {
                $this->_dumped = true;
                $this->_dump_info($table, $schema);
            }
        }
        return true;
    }

    protected function _dump_info($table, $schema = '')
    {
        $this->_dump_lock = true;
        if (!count(self::get_meta_data($table))) {
            $meta_data = $this->db->describe_table($table, $schema);
            if ($meta_data) {
                self::set_meta_data($table, $meta_data);
            }
        }
        foreach (self::get_meta_data($table) as $field) {
            $this->fields[] = $field['Field'];
            $aliasAux = $field['Field'];
            if ($field['Key'] == 'PRI') {
                $this->primary_key[] = $field['Field'];
                $this->alias[$field['Field']] = 'Código';
            } else
                $this->non_primary[] = $field['Field'];
            if ($field['Null'] == 'NO' && !(isset($field['Default']) && $field['Default'])) {
                $this->not_null[] = $field['Field'];
            }
            if (isset($field['Default']) && $field['Default']) {
                $this->_with_default[] = $field['Field'];
            }
            if ($field['Type']) {
                $this->_data_type[$field['Field']] = strtolower($field['Type']);
            }
            if (substr($field['Field'], strlen($field['Field']) - 3, 3) == '_at') {
                $this->_at[] = $field['Field'];
                $aliasAux = substr($field['Field'], 0, -3);
            }
            if (substr($field['Field'], strlen($field['Field']) - 3, 3) == '_in') {
                $this->_in[] = $field['Field'];
                $aliasAux = substr($field['Field'], 0, -3);
            }
            if (substr($field['Field'], strlen($field['Field']) - 3, 3) == '_id') {
                $aliasAux = substr($field['Field'], 0, -3);
            }
            //humanizando el alias
            $this->alias[$field['Field']] = ucwords(strtr($aliasAux, '_-', '  '));
        }
        $this->_dump_lock = false;
        return true;
    }

    public function get_alias($key=null)
    {
        if ($key && array_key_exists($key, $this->alias)) {
            return $this->alias[$key];
        } else {
            throw new KumbiaException("No se pudo obtener el Alias, porque el key: \"$key\" no existe.");
        }
    }

    public function set_alias($key=null, $value=null)
    {
        if ($key && array_key_exists($key, $this->alias)) {
            $this->alias[$key] = $value;
        } else {
            throw new KumbiaException("No se pudo asignar el nuevo valor al Alias, porque el key: \"$key\" no existe.");
        }
    }

    public function commit()
    {
        return $this->db->commit();
    }

    public function rollback()
    {
        return $this->db->rollback();
    }

    public function begin()
    {
        $this->_connect();//(true);
        return $this->db->begin();
    }

    public function find_all_by_sql($sqlQuery)
    {
        $results = array();
        foreach ($this->db->fetch_all($sqlQuery) as $result) {
            $results[] = $this->dump_result($result);
        }
        return $results;
    }

    public function find_by_sql($sqlQuery)
    {
        $row = $this->db->fetch_one($sqlQuery);
        if ($row !== false) {
            $this->dump_result_self($row);
            return $this->dump_result($row);
        } else {
            return false;
        }
    }

    public function sql($sqlQuery)
    {
        return $this->db->query($sqlQuery);
    }

    public function find_first($what = '')
    {
        $what = Util::getParams(func_get_args());
        $select = "SELECT ";
        if (isset($what['columns'])) {
            $select.= KumbiaActiveRecord::sql_sanitize($what['columns']);
        } elseif (isset($what['distinct'])) {
            $select.= 'DISTINCT ';
            $select.= $what['distinct'] ? KumbiaActiveRecord::sql_sanitize($what['distinct']) : join(",", $this->fields);
        } else {
            $select.= join(",", $this->fields);
        }
        if ($this->schema) {
            $select.= " FROM {$this->schema}.{$this->source}";
        } else {
            $select.= " FROM {$this->source}";
        }
        $what['limit'] = 1;
        $select.= $this->convert_params_to_sql($what);
        $resp = false;
        
        $result = $this->db->fetch_one($select);
        if ($result) {
            $this->dump_result_self($result);
            $resp = $this->dump_result($result);
        }
        
        return $resp;
    }

    public function find($what = '')
    {
        $what = Util::getParams(func_get_args());
        $select = "SELECT ";
        if (isset($what['columns'])) {
            $select.= $what['columns'] ? KumbiaActiveRecord::sql_sanitize($what['columns']) : join(",", $this->fields);
        } elseif (isset($what['distinct'])) {
            $select.= 'DISTINCT ';
            $select.= $what['distinct'] ? KumbiaActiveRecord::sql_sanitize($what['distinct']) : join(",", $this->fields);
        } else {
            $select.= join(",", $this->fields);
        }
        if ($this->schema) {
            $select.= " FROM {$this->schema}.{$this->source}";
        } else {
            $select.= " FROM {$this->source}";
        }
        $select.= $this->convert_params_to_sql($what);
        $results = array();
        $all_results = $this->db->in_query($select);
        foreach ($all_results AS $result) {
            $results[] = $this->dump_result($result);
        }

        $this->count = count($results, COUNT_NORMAL);
        if (isset($what[0]) && is_numeric($what[0])) {
            if (!isset($results[0])) {
                $this->count = 0;
                return false;
            } else {
                $this->dump_result_self($all_results[0]);
                $this->count = 1;
                return $results[0];
            }
        } else {
            $this->count = count($results, COUNT_NORMAL);
            return $results;
        }
    }

    /*
     * Arma una consulta SQL con el parametro $what, así:
     *  $what = Util::getParams(func_get_args());
     *  $select = "SELECT * FROM Clientes";
     *  $select.= $this->convert_params_to_sql($what);
     *
     * @param string|array $what
     * @return string
     */

    public function convert_params_to_sql($what = '')
    {
        $select = '';
        if (is_array($what)) {
            if (!isset($what['conditions'])) {
                if (!isset($this->primary_key[0]) && (isset($this->id) || $this->is_view)) {
                    $this->primary_key[0] = "id";
                }
                KumbiaActiveRecord::sql_item_sanitize($this->primary_key[0]);
                if (isset($what[0])) {
                    if (is_numeric($what[0])) {
                        $what['conditions'] = "{$this->primary_key[0]} = ".(int)$what[0] ;
                    } else {
                        if ($what[0] == '') {
                            $what['conditions'] = "{$this->primary_key[0]} = ''";
                        } else {
                            $what['conditions'] = $what[0];
                        }
                    }
                }
            }
            if (isset($what['join'])) {
                $select.= " {$what['join']}";
            }
            if (isset($what['conditions'])) {
                $select.= " WHERE {$what['conditions']}";
            }
            if (isset($what['group'])) {
                $select.= " GROUP BY {$what['group']}";
            }
            if (isset($what['having'])) {
                $select.= " HAVING {$what['having']}";
            }
            if (isset($what['order'])) {
                KumbiaActiveRecord::sql_sanitize($what['order']);
                $select.= " ORDER BY {$what['order']}";
            }
            $limit_args = array($select);
            if (isset($what['limit'])) {
                array_push($limit_args, "limit: ".(int)$what['limit']);
            }
            if (isset($what['offset'])) {
                array_push($limit_args, "offset: ".(int)$what['offset']);
            }
            if (count($limit_args) > 1) {
                $select = call_user_func_array(array($this, 'limit'), $limit_args);
            }
        } else {
            if (strlen($what)) {
                if (is_numeric($what)) {
                    $select.= "WHERE {$this->primary_key[0]} = ".(int)$what[0] ;
                } else {
                    $select.= "WHERE $what";
                }
            }
        }
        return $select;
    }

    /*
     * Devuelve una clausula LIMIT adecuada al RDBMS empleado
     *
     * limit: maxima cantidad de elementos a mostrar
     * offset: desde que elemento se comienza a mostrar
     *
     * @param string $sql consulta select
     * @return String clausula LIMIT adecuada al RDBMS empleado
     */

    public function limit($sql)
    {
        $args = func_get_args();
        return call_user_func_array(array($this->db, 'limit'), $args);
    }

    public function distinct($what = '')
    {
        $what = Util::getParams(func_get_args());
        if ($this->schema) {
            $table = $this->schema . "." . $this->source;
        } else {
            $table = $this->source;
        }
        if (!isset($what['columns'])) {
            $what['columns'] = $what['0'];
        } else {
            if (!$what['columns']) {
                $what['columns'] = $what['0'];
            }
        }
        $what['columns'] = KumbiaActiveRecord::sql_sanitize($what['columns']);
        $select = "SELECT DISTINCT {$what['columns']} FROM $table ";
        unset($what[0]);
        $select.= $this->convert_params_to_sql($what);
        $results = array();
        foreach ($this->db->fetch_all($select) as $result) {
            $results[] = $result[0];
        }
        return $results;
    }

    static public function static_select_one($sql)
    {
        $db = Db::factory();
        if (substr(ltrim($sql), 0, 7) != "SELECT") {
            $sql = "SELECT " . $sql;
        }
        $num = $db->fetch_one($sql);
        return $num[0];
    }

    public function count($what = '')
    {
        $what = Util::getParams(func_get_args());
        if ($this->schema) {
            $table = "{$this->schema}.{$this->source}";
        } else {
            $table = $this->source;
        }
        unset($what['order']);
        if (isset($what['distinct']) && $what['distinct']) {
            if (isset($what['group'])) {
                $select = "SELECT COUNT(*) FROM (SELECT DISTINCT {$what['distinct']} FROM $table ";
                $select.= $this->convert_params_to_sql($what);
                $select.= ') AS t ';
            } else {
                $select = "SELECT COUNT(DISTINCT {$what['distinct']}) FROM $table ";
                $select.= $this->convert_params_to_sql($what);
            }
        } else {
            $select = "SELECT COUNT(*) FROM $table ";
            $select.= $this->convert_params_to_sql($what);
        }
        $num = $this->db->fetch_one($select);
        return $num[0];
    }

    public function average($what = '')
    {
        $what = Util::getParams(func_get_args());
        if (isset($what['column'])) {
            if (!$what['column']) {
                $what['column'] = $what[0];
            }
        } else {
            $what['column'] = $what[0];
        }
        unset($what[0]);
        KumbiaActiveRecord::sql_item_sanitize($what['column']);
        if ($this->schema) {
            $table = "{$this->schema}.{$this->source}";
        } else {
            $table = $this->source;
        }
        $select = "SELECT AVG({$what['column']}) FROM $table ";
        $select.= $this->convert_params_to_sql($what);
        $num = $this->db->fetch_one($select);
        return $num[0];
    }

    public function sum($what = '')
    {
        $what = Util::getParams(func_get_args());
        if (isset($what['column'])) {
            if (!$what['column']) {
                $what['column'] = $what[0];
            }
        } else {
            $what['column'] = $what[0];
        }
        unset($what[0]);
        KumbiaActiveRecord::sql_item_sanitize($what['column']);
        if ($this->schema) {
            $table = "{$this->schema}.{$this->source}";
        } else {
            $table = $this->source;
        }
        $select = "SELECT SUM({$what['column']}) FROM $table ";
        $select.= $this->convert_params_to_sql($what);
        $num = $this->db->fetch_one($select);
        return $num[0];
    }

    public function maximum($what = '')
    {
        $what = Util::getParams(func_get_args());
        if (isset($what['column'])) {
            if (!$what['column']) {
                $what['column'] = $what[0];
            }
        } else {
            $what['column'] = $what[0];
        }
        unset($what[0]);
        KumbiaActiveRecord::sql_item_sanitize($what['column']);
        if ($this->schema) {
            $table = "{$this->schema}.{$this->source}";
        } else {
            $table = $this->source;
        }
        $select = "SELECT MAX({$what['column']}) FROM $table ";
        $select.= $this->convert_params_to_sql($what);
        $num = $this->db->fetch_one($select);
        return $num[0];
    }

    public function minimum($what = '')
    {
        $what = Util::getParams(func_get_args());
        if (isset($what['column'])) {
            if (!$what['column']) {
                $what['column'] = $what[0];
            }
        } else {
            $what['column'] = $what[0];
        }
        unset($what[0]);
        KumbiaActiveRecord::sql_item_sanitize($what['column']);
        if ($this->schema) {
            $table = "{$this->schema}.{$this->source}";
        } else {
            $table = $this->source;
        }
        $select = "SELECT MIN({$what['column']}) FROM $table ";
        $select.= $this->convert_params_to_sql($what);
        $num = $this->db->fetch_one($select);
        return $num[0];
    }

    public function count_by_sql($sqlQuery)
    {
        $num = $this->db->fetch_one($sqlQuery);
        return $num[0];
    }

    public function dump_result($result)
    {
        $obj = clone $this;
        if (isset($result['type'])) {
            if (in_array($result['type'], $this->parent_of)) {
                if (class_exists($result['type'])) {
                    $obj = new $result['type'];
                    unset($result['type']);
                }
            }
        }
        $this->_dump_lock = true;
        if (is_array($result)) {
            foreach ($result as $k => $r) {
                if (!is_numeric($k)) {
                    $obj->$k = stripslashes($r);
                }
            }
        }
        $this->_dump_lock = false;
        return $obj;
    }

    public function dump_result_self($result)
    {
        $this->_dump_lock = true;
        if (is_array($result)) {
            foreach ($result as $k => $r) {
                if (!is_numeric($k)) {
                    $this->$k = stripslashes($r);
                }
            }
        }
        $this->_dump_lock = false;
    }

    public function create_from_request($form = null)
    {
        if (!$form) {
            $form = $this->source;
        }
        return $this->create($_REQUEST[$form]);
    }

    public function save_from_request($form = null)
    {
        if (!$form) {
            $form = $this->source;
        }
        return $this->save($_REQUEST[$form]);
    }

    public function update_from_request($form = null)
    {
        if (!$form) {
            $form = $this->source;
        }
        return $this->update($_REQUEST[$form]);
    }

    public function create()
    {
        if (func_num_args() > 0) {
            $params = Util::getParams(func_get_args());
            $values = (isset($params[0]) && is_array($params[0])) ? $params[0] : $params;
            foreach ($this->fields as $field) {
                if (isset($values[$field])) {
                    $this->$field = $values[$field];
                }
            }
        }
        if ($this->primary_key[0] == 'id') {
            $this->id = null;
        }
        return $this->save();
    }

    function exists($where_pk = '')
    {
        if ($this->schema) {
            $table = "{$this->schema}.{$this->source}";
        } else {
            $table = $this->source;
        }
        if (!$where_pk) {
            $where_pk = array();
            foreach ($this->primary_key as $key) {
                if ($this->$key) {
                    $where_pk[] = " $key = '{$this->$key}'";
                }
            }
            if (count($where_pk)) {
                $this->_where_pk = join(" AND ", $where_pk);
            } else {
                return 0;
            }
            $query = "SELECT COUNT(*) FROM $table WHERE {$this->_where_pk}";
        } else {
            if (is_numeric($where_pk)) {
                $query = "SELECT COUNT(*) FROM $table WHERE {$this->primary_key[0]} = '$where_pk'";
            } else {
                $query = "SELECT COUNT(*) FROM $table WHERE $where_pk";
            }
        }
        $num = $this->db->fetch_one($query);
        return $num[0];
    }

    public function save($values=null)
    {
        if ($values) {
            if (!is_array($values))
                $values = Util::getParams(func_get_args());
            foreach ($this->fields as $field) {
                if (isset($values[$field])) {
                    $this->$field = $values[$field];
                }
            }
        }
        $ex = $this->exists();
        if ($this->schema) {
            $table = $this->schema . "." . $this->source;
        } else {
            $table = $this->source;
        }
        #Run Validation Callbacks Before
        if (method_exists($this, 'before_validation')) {
            if ($this->before_validation() == 'cancel') {
                return false;
            }
        } else {
            if (isset($this->before_validation)) {
                $method = $this->before_validation;
                if ($this->$method() == 'cancel') {
                    return false;
                }
            }
        }
        if (!$ex) {
            if (method_exists($this, "before_validation_on_create")) {
                if ($this->before_validation_on_create() == 'cancel') {
                    return false;
                }
            } else {
                if (isset($this->before_validation_on_create)) {
                    $method = $this->before_validation_on_create;
                    if ($this->$method() == 'cancel') {
                        return false;
                    }
                }
            }
        }
        if ($ex) {
            if (method_exists($this, "before_validation_on_update")) {
                if ($this->before_validation_on_update() == 'cancel') {
                    return false;
                }
            } else {
                if (isset($this->before_validation_on_update)) {
                    $method = $this->before_validation_on_update;
                    if ($this->$method() == 'cancel') {
                        return false;
                    }
                }
            }
        }

        if (isset($this->_validates['presence_of'])) {
            foreach ($this->_validates['presence_of'] as $f => $opt) {
                if (isset($this->$f) && (is_null($this->$f) || $this->$f == '')) {
                    if (!$ex && $f == $this->primary_key[0])
                        continue;
                    if (isset($opt['message'])) {
                        Flash::error($opt['message']);
                        return false;
                    } else {
                        $field = isset($opt['field']) ? $opt['field'] : $f;
                        Flash::error("Error: El campo $field no puede ser nulo");
                        return false;
                    }
                }
            }
        }

        foreach ($this->not_null as $f) {
            if (in_array($f, $this->_with_default)) {
                continue;
            }

            if (!isset($this->$f) || is_null($this->$f) || $this->$f == '') {
                if (!$ex && $f == $this->primary_key[0]) {
                    continue;
                }
                if (!$ex && in_array($f, $this->_at)) {
                    continue;
                }
                if ($ex && in_array($f, $this->_in)) {
                    continue;
                }
                Flash::error("Error: El campo $f no puede ser nulo");
                return false;
            }
        }

        if (isset($this->_validates['length_of'])) {
            foreach ($this->_validates['length_of'] as $f => $opt) {
                if (isset($this->$f) && !is_null($this->$f) && $this->$f != '') {
                    $field = isset($opt['field']) ? $opt['field'] : $f;

                    if (strlen($this->$f) < $opt['min']) {
                        if (isset($opt['too_short']))
                            Flash::error($opt['too_short']);
                        else
                            Flash::error("Error: El campo $field debe tener como mínimo $opt[min] caracteres");
                        return false;
                    }

                    if (strlen($this->$f) > $opt['max']) {
                        if (isset($opt['too_long']))
                            Flash::error($opt['too_long']);
                        else
                            Flash::error("Error: El campo $field debe tener como máximo $opt[max] caracteres");
                        return false;
                    }
                }
            }
        }

        foreach ($this->_validates['inclusion_in'] as $f => $opt) {
            if (isset($this->$f) && !is_null($this->$f) && $this->$f != '') {
                if (!in_array($this->$f, $opt['list'])) {
                    if (isset($opt['message'])) {
                        Flash::error($opt['message']);
                    } else {
                        $field = isset($opt['field']) ? $opt['field'] : $f;
                        Flash::error("$field debe tener un valor entre (" . join(",", $opt['list']) . ")");
                    }
                    return false;
                }
            }
        }

        foreach ($this->_validates['exclusion_of'] as $f => $opt) {
            if (isset($this->$f) && !is_null($this->$f) && $this->$f != '') {
                if (in_array($this->$f, $opt['list'])) {
                    if (isset($opt['message'])) {
                        Flash::error($opt['message']);
                    } else {
                        $field = isset($opt['field']) ? $opt['field'] : $f;
                        Flash::error("$field no debe tener un valor entre (" . join(",", $opt['list']) . ")");
                    }
                    return false;
                }
            }
        }

        foreach ($this->_validates['numericality_of'] as $f => $opt) {
            if (isset($this->$f) && !is_null($this->$f) && $this->$f != '') {
                if (!is_numeric($this->$f)) {
                    if (isset($opt['message'])) {
                        Flash::error($opt['message']);
                    } else {
                        $field = isset($opt['field']) ? $opt['field'] : $f;
                        Flash::error("$field debe tener un valor numérico");
                    }
                    return false;
                }
            }
        }

        foreach ($this->_validates['format_of'] as $f => $opt) {
            if (isset($this->$f) && !is_null($this->$f) && $this->$f != '') {
                if (!filter_var($this->$f, FILTER_VALIDATE_REGEXP, array("options" => array("regexp" => $opt['pattern'])))) {
                    if (isset($opt['message'])) {
                        Flash::error($opt['message']);
                    } else {
                        $field = isset($opt['field']) ? $opt['field'] : $f;
                        Flash::error("Formato erroneo para $field");
                    }
                    return false;
                }
            }
        }

        foreach ($this->_validates['date_in'] as $f => $opt) {
            if (isset($this->$f) && !is_null($this->$f) && $this->$f != '') {
                if (!filter_var($this->$f, FILTER_VALIDATE_REGEXP, array("options" => array("regexp" => "/^\d{4}[-\/](0[1-9]|1[012])[-\/](0[1-9]|[12][0-9]|3[01])$/")))) {
                    if (isset($opt['message'])) {
                        Flash::error($opt['message']);
                    } else {
                        $field = isset($opt['field']) ? $opt['field'] : $f;
                        Flash::error("Formato de fecha erroneo para $field");
                    }
                    return false;
                }
            }
        }

        foreach ($this->_validates['email_in'] as $f => $opt) {
            if (isset($this->$f) && !is_null($this->$f) && $this->$f != '') {
                if (!filter_var($this->$f, FILTER_VALIDATE_EMAIL)) {
                    if (isset($opt['message'])) {
                        Flash::error($opt['message']);
                    } else {
                        $field = isset($opt['field']) ? $opt['field'] : $f;
                        Flash::error("Formato de e-mail erroneo en el campo $field");
                    }
                    return false;
                }
            }
        }

        // parche para que no tome encuenta el propio registro
        // al validar campos unicos, ya que si lo toma en cuenta
        // lanzará error de validacion porque ya existe un registro
        // con igual valor en el campo unico.
        $and_condition = $ex ? " AND {$this->primary_key[0]} != '{$this->{$this->primary_key[0]}}'" : '';
        foreach ($this->_validates['uniqueness_of'] as $f => $opt) {
            if (isset($this->$f) && !is_null($this->$f) && $this->$f != '') {
                $result = $this->db->fetch_one("SELECT COUNT(*) FROM $table WHERE $f = {$this->db->add_quotes($this->$f)} $and_condition");
                if ($result[0]) {
                    if (isset($opt['message'])) {
                        Flash::error($opt['message']);
                    } else {
                        $field = isset($opt['field']) ? $opt['field'] : $f;
                        Flash::error("El valor '{$this->$f}' ya existe para el campo $field");
                    }
                    return false;
                }
            }
        }

        #Run Validation Callbacks After
        if (!$ex) {
            if (method_exists($this, "after_validation_on_create")) {
                if ($this->after_validation_on_create() == 'cancel') {
                    return false;
                }
            } else {
                if (isset($this->after_validation_on_create)) {
                    $method = $this->after_validation_on_create;
                    if ($this->$method() == 'cancel') {
                        return false;
                    }
                }
            }
        }
        if ($ex) {
            if (method_exists($this, "after_validation_on_update")) {
                if ($this->after_validation_on_update() == 'cancel') {
                    return false;
                }
            } else {
                if (isset($this->after_validation_on_update)) {
                    $method = $this->after_validation_on_update;
                    if ($this->$method() == 'cancel')
                        return false;
                }
            }
        }

        if (method_exists($this, 'after_validation')) {
            if ($this->after_validation() == 'cancel') {
                return false;
            }
        } else {
            if (isset($this->after_validation)) {
                $method = $this->after_validation;
                if ($this->$method() == 'cancel') {
                    return false;
                }
            }
        }
        # Run Before Callbacks
        if (method_exists($this, "before_save")) {
            if ($this->before_save() == 'cancel') {
                return false;
            }
        } else {
            if (isset($this->before_save)) {
                $method = $this->before_save;
                if ($this->$method() == 'cancel') {
                    return false;
                }
            }
        }
        if ($ex) {
            if (method_exists($this, "before_update")) {
                if ($this->before_update() == 'cancel') {
                    return false;
                }
            } else {
                if (isset($this->before_update)) {
                    $method = $this->before_update;
                    if ($this->$method() == 'cancel') {
                        return false;
                    }
                }
            }
        }
        if (!$ex) {
            if (method_exists($this, "before_create")) {
                if ($this->before_create() == 'cancel') {
                    return false;
                }
            } else {
                if (isset($this->before_create)) {
                    $method = $this->before_create;
                    if ($this->$method() == 'cancel') {
                        return false;
                    }
                }
            }
        }
        $environment = Config::read('databases');
        $config = $environment[$this->get_database()];
        if ($ex) {
            $fields = array();
            $values = array();
            foreach ($this->non_primary as $np) {
                $np = KumbiaActiveRecord::sql_item_sanitize($np);
                if (in_array($np, $this->_in)) {
                    if ($config['type'] == 'oracle') {
                        $this->$np = date("Y-m-d");
                    } else {
                        $this->$np = date("Y-m-d G:i:s");
                    }
                }
                if (isset($this->$np)) {
                    $fields[] = $np;
                    if (is_null($this->$np) || $this->$np == '') {
                        $values[] = 'NULL';
                    } else {
                        if ($this->_data_type[$np] == 'date' && $config['type'] == 'oracle') {
                            $values[] = "TO_DATE(" . $this->db->add_quotes($this->$np) . ", 'YYYY-MM-DD')";
                        } else {
                            $values[] = $this->db->add_quotes($this->$np);
                        }
                    }
                }
            }
            $val = $this->db->update($table, $fields, $values, $this->_where_pk);
        } else {
            $fields = array();
            $values = array();
            foreach ($this->fields as $field) {
                if ($field != $this->primary_key[0] && !$this->id) {
                    if (in_array($field, $this->_at)) {
                        if ($config['type'] == 'oracle') {
                            $this->$field = date("Y-m-d");
                        } else {
                            $this->$field = date("Y-m-d G:i:s");
                        }
                    }
                    if (in_array($field, $this->_in)) {
                        unset($this->$field);
                    }

                    if (isset($this->$field) && $this->$field !== '' && $this->$field !== NULL) {
                        $fields[] = KumbiaActiveRecord::sql_sanitize($field);

                        if (($this->_data_type[$field] == 'datetime' OR $this->_data_type[$field] == 'date') && ($config['type'] == 'mysql' OR $config['type'] == 'mysqli')) {
                            $values[] = $this->db->add_quotes(date("Y-m-d G:i:s", strtotime($this->$field)));
                        } elseif ($this->_data_type[$field] == 'date' && $config['type'] == 'oracle') {
                            //Se debe especificar el formato de fecha en Oracle
                            $values[] = "TO_DATE(" . $this->db->add_quotes($this->$field) . ", 'YYYY-MM-DD')";
                        } else {
                            $values[] = $this->db->add_quotes($this->$field);
                        }
                    } elseif (in_array($field, $this->_with_default)) {
                        $fields[] = KumbiaActiveRecord::sql_sanitize($field);
                        $values[] = 'DEFAULT';
                    } else {
                        $fields[] = KumbiaActiveRecord::sql_sanitize($field);
                        $values[] = 'NULL';
                    }
                } else {
                    if ($config['type'] == 'oracle') {
                        if (!$this->id) {
                            $fields[] = "id";
                            $values[] = $this->source . "_id_seq.NEXTVAL";
                        }
                    }
                    if ($config['type'] == 'informix') {
                        if (!$this->id) {
                            $fields[] = "id";
                            $values[] = 0;
                        }
                    }
                }
            }

            $val = $this->db->insert($table, $values, $fields);
        }
        if (!isset($config['pdo']) && $config['type'] == 'oracle') {
            $this->commit();
        }
        if (!$ex) {
            //$this->db->logger = true;
            $m = $this->db->last_insert_id($table, $this->primary_key[0]);
            $this->find_first($m);
        }
        if ($val) {
            if ($ex) {
                if (method_exists($this, "after_update")) {
                    if ($this->after_update() == 'cancel') {
                        return false;
                    }
                } else {
                    if (isset($this->after_update)) {
                        $method = $this->after_update;
                        if ($this->$method() == 'cancel') {
                            return false;
                        }
                    }
                }
            }
            if (!$ex) {
                if (method_exists($this, "after_create")) {
                    if ($this->after_create() == 'cancel') {
                        return false;
                    }
                } else {
                    if (isset($this->after_create)) {
                        $method = $this->after_create;
                        if ($this->$method() == 'cancel') {
                            return false;
                        }
                    }
                }
            }
            if (method_exists($this, "after_save")) {
                if ($this->after_save() == 'cancel') {
                    return false;
                }
            } else {
                if (isset($this->after_save)) {
                    $method = $this->after_save;
                    if ($this->$method() == 'cancel') {
                        return false;
                    }
                }
            }
            return $val;
        } else {
            return false;
        }
    }

    function find_all_by($field, $value)
    {
        KumbiaActiveRecord::sql_item_sanitize($field);
        return $this->find("conditions: $field = {$this->db->add_quotes($value) }");
    }

    function update()
    {
        if (func_num_args() > 0) {
            $params = Util::getParams(func_get_args());
            $values = (isset($params[0]) && is_array($params[0])) ? $params[0] : $params;
            foreach ($this->fields as $field) {
                if (isset($values[$field])) {
                    $this->$field = $values[$field];
                }
            }
        }
        if ($this->exists()) {
            if (method_exists($this, 'before_change')) {
                $obj = clone $this;
                if ($this->before_change($obj->find($this->{$this->primary_key[0]})) == 'cancel') {
                    return false;
                }
                unset($obj);
            }
            if ($this->save()) {
                if (method_exists($this, 'after_change')) {
                    if ($this->after_change($this) == 'cancel') {
                        return false;
                    }
                }
                return true;
            }
        } else {
            Flash::error('No se puede actualizar porque el registro no existe');
            return false;
        }
    }

    public function delete($what = '')
    {
        if (func_num_args() > 1) {
            $what = Util::getParams(func_get_args());
        }
        if ($this->schema) {
            $table = $this->schema . "." . $this->source;
        } else {
            $table = $this->source;
        }
        $conditions = '';
        if (is_array($what)) {
            if ($what["conditions"]) {
                $conditions = $what["conditions"];
            }
        } else {
            if (is_numeric($what)) {
                KumbiaActiveRecord::sql_sanitize($this->primary_key[0]);
                $conditions = "{$this->primary_key[0]} = '$what'";
            } else {
                if ($what) {
                    $conditions = $what;
                } else {
                    KumbiaActiveRecord::sql_sanitize($this->primary_key[0]);
                    $conditions = "{$this->primary_key[0]} = '{$this->{$this->primary_key[0]}}'";
                }
            }
        }
        if (method_exists($this, "before_delete")) {
            if ($this->{$this->primary_key[0]}) {
                $this->find($this->{$this->primary_key[0]});
            }
            if ($this->before_delete() == 'cancel') {
                return false;
            }
        } else {
            if (isset($this->before_delete)) {
                if ($this->{$this->primary_key[0]}) {
                    $this->find($this->{$this->primary_key[0]});
                }
                $method = $this->before_delete;
                if ($this->$method() == 'cancel') {
                    return false;
                }
            }
        }
        $val = $this->db->delete($table, $conditions);
        if ($val) {
            if (method_exists($this, "after_delete")) {
                if ($this->after_delete() == 'cancel') {
                    return false;
                }
            } else {
                if (isset($this->after_delete)) {
                    $method = $this->after_delete;
                    if ($this->$method() == 'cancel') {
                        return false;
                    }
                }
            }
        }
        return $val;
    }

    public function update_all($values)
    {
        $params = array();
        if ($this->schema) {
            $table = $this->schema . "." . $this->source;
        } else {
            $table = $this->source;
        }
        if (func_num_args() > 1) {
            $params = Util::getParams(func_get_args());
        }
        if (!isset($params['conditions']) || !$params['conditions']) {
            if (isset($params[1])) {
                $params['conditions'] = $params[1];
            } else {
                $params['conditions'] = '';
            }
        }
        if ($params['conditions']) {
            $params['conditions'] = " WHERE " . $params['conditions'];
        }
        $sql = "UPDATE $table SET $values {$params['conditions']}";
        $limit_args = array($sql);
        if (isset($params['limit'])) {
            array_push($limit_args, "limit: $params[limit]");
        }
        if (isset($params['offset'])) {
            array_push($limit_args, "offset: $params[offset]");
        }
        if (count($limit_args) > 1) {
            $sql = call_user_func_array(array($this, 'limit'), $limit_args);
        }
        $environment = Config::read('databases');
        $config = $environment[$this->get_database()];
        if (!isset($config->pdo) || !$config->pdo) {
            if ($config['type'] == "informix") {
                $this->db->set_return_rows(false);
            }
        }
        return $this->db->query($sql);
    }

    public function delete_all($conditions = '')
    {
        //$limit = '';
        if ($this->schema) {
            $table = $this->schema . "." . $this->source;
        } else {
            $table = $this->source;
        }
        if (func_num_args() > 1) {
            $params = Util::getParams(func_get_args());
            $limit_args = array($select);
            if (isset($params['limit'])) {
                array_push($limit_args, "limit: $params[limit]");
            }
            if (isset($params['offset'])) {
                array_push($limit_args, "offset: $params[offset]");
            }
            if (count($limit_args) > 1) {
                $select = call_user_func_array(array($this, 'limit'), $limit_args);
            }
        }
        return $this->db->delete($table, $conditions);
    }

    public function inspect()
    {
        $inspect = array();
        foreach ($this->fields as $field) {
            if (!is_array($field)) {
                $inspect[] = "$field: {$this->$field}";
            }
        }
        return join(", ", $inspect);
    }

    protected function validates_presence_of($field, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['presence_of'][$field] = $params;
    }

    protected function validates_length_of($field, $max, $min=0, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['length_of'][$field] = $params;
        $this->_validates['length_of'][$field]['min'] = $min;
        $this->_validates['length_of'][$field]['max'] = $max;
    }

    protected function validates_inclusion_in($field, $list, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['inclusion_in'][$field] = $params;
        $this->_validates['inclusion_in'][$field]['list'] = $list;
    }

    protected function validates_exclusion_of($field, $list, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['exclusion_of'][$field] = $params;
        $this->_validates['exclusion_of'][$field]['list'] = $list;
    }

    protected function validates_format_of($field, $pattern, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['format_of'][$field] = $params;
        $this->_validates['format_of'][$field]['pattern'] = $pattern;
    }

    protected function validates_numericality_of($field, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['numericality_of'][$field] = $params;
    }

    protected function validates_email_in($field, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['email_in'][$field] = $params;
    }

    protected function validates_uniqueness_of($field, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['uniqueness_of'][$field] = $params;
    }

    protected function validates_date_in($field, $params=array())
    {
        if (is_string($params))
            $params = Util::getParams(func_get_args());

        $this->_validates['date_in'][$field] = $params;
    }

    public function is_a_numeric_type($field)
    {
        if (strpos(" " . $this->_data_type[$field], "int") || strpos(" " . $this->_data_type[$field], "decimal") || strpos(" " . $this->_data_type[$field], "number")) {
            return true;
        } else {
            return false;
        }
    }

    static function get_meta_data($table)
    {
        if (isset(self::$models[$table])) {
            return self::$models[$table];
        } elseif (PRODUCTION) {

            $metadata = Cache::driver()->get($table, 'kumbia.models');
            if ($metadata) {
                return self::$models[$table] = unserialize($metadata);
            }
        }
        return array();
    }

    static function set_meta_data($table, $meta_data)
    {
        if (PRODUCTION) {
            Cache::driver()->save(serialize($meta_data), Config::get('config.application.metadata_lifetime'), $table, 'kumbia.models');
        }
        self::$models[$table] = $meta_data;
        return true;
    }

    /*     * *****************************************************************************************
     * Metodos para generacion de relaciones
     * ***************************************************************************************** */

    protected function has_one($relation)
    {
        $params = Util::getParams(func_get_args());
        for ($i = 0; isset($params[$i]); $i++) {
            $relation = Util::smallcase($params[$i]);
            $index = explode('/', $relation); 
            $index = end($index);
            if (!array_key_exists($index, $this->_has_one)) {
                $this->_has_one[$index] = new stdClass();
                $this->_has_one[$index]->model = isset($params['model']) ? $params['model'] : $relation;
                $this->_has_one[$index]->fk = isset($params['fk']) ? $params['fk'] : Util::smallcase(get_class($this)) . '_id';
            }
        }
    }

    protected function belongs_to($relation)
    {
        $params = Util::getParams(func_get_args());
        for ($i = 0; isset($params[$i]); $i++) {
            $relation = Util::smallcase($params[$i]);
            $index = explode('/', $relation); 
            $index = end($index);
            if (!array_key_exists($index, $this->_belongs_to)) {
                $this->_belongs_to[$index] = new stdClass();
                $this->_belongs_to[$index]->model = isset($params['model']) ? $params['model'] : $relation;
                $this->_belongs_to[$index]->fk = isset($params['fk']) ? $params['fk'] : "{$relation}_id";
            }
        }
    }

    protected function has_many($relation)
    {
        $params = Util::getParams(func_get_args());
        for ($i = 0; isset($params[$i]); $i++) {
            $relation = Util::smallcase($params[$i]);
            $index = explode('/', $relation); 
            $index = end($index);
            if (!array_key_exists($index, $this->_has_many)) {
                $this->_has_many[$index] = new stdClass();
                $this->_has_many[$index]->model = isset($params['model']) ? $params['model'] : $relation;
                $this->_has_many[$index]->fk = isset($params['fk']) ? $params['fk'] : Util::smallcase(get_class($this)) . '_id';
            }
        }
    }

    protected function has_and_belongs_to_many($relation)
    {
        $params = Util::getParams(func_get_args());
        for ($i = 0; isset($params[$i]); $i++) {
            $relation = Util::smallcase($params[$i]);
            if (!array_key_exists($relation, $this->_has_and_belongs_to_many)) {
                $this->_has_and_belongs_to_many[$relation] = new stdClass();
                $this->_has_and_belongs_to_many[$relation]->model = isset($params['model']) ? $params['model'] : $relation;
                $this->_has_and_belongs_to_many[$relation]->fk = isset($params['fk']) ? $params['fk'] : "{$relation}_id";
                $this->_has_and_belongs_to_many[$relation]->key = isset($params['key']) ? $params['key'] : Util::smallcase(get_class($this)) . '_id';
                if (isset($params['through'])) {
                    $this->_has_and_belongs_to_many[$relation]->through = $params['through'];
                }
            }
        }
    }

    public function parent_of($parent)
    {
        $parents = func_get_args();
        foreach ($parents as $parent) {
            if (!in_array($parent, $this->parent_of)) {
                $this->parent_of[] = $parent;
            }
        }
    }

    public static function sql_item_sanitize($sql_item)
    {
        $sql_item = trim($sql_item);
        if ($sql_item !== '' && $sql_item !== null) {
            $sql_temp = preg_replace('/\s+/', '', $sql_item);
            if (!preg_match('/^[a-zA-Z0-9_\.]+$/', $sql_temp)) {
                throw new KumbiaException("Se esta tratando de ejecutar una operacion maliciosa!");
            }
        }
        return $sql_item;
    }

    public static function sql_sanitize($sql_item)
    {
        $sql_item = trim($sql_item);
        if ($sql_item !== '' && $sql_item !== null) {
            $sql_temp = preg_replace('/\s+/', '', $sql_item);
            if (!preg_match('/^[a-zA-Z_0-9\,\(\)\.\*]+$/', $sql_temp)) {
                throw new KumbiaException("Se esta tratando de ejecutar una operacion maliciosa!");
            }
        }
        return $sql_item;
    }

    protected function exceptions($e)
    {
        throw $e;
    }

    public function __toString()
    {
        return "<" . get_class() . " Object>";
    }

    public function paginate()
    {
        $args = func_get_args();
        array_unshift($args, $this);
        //if(!class_exists('Paginator')){
        require_once CORE_PATH . 'libs/kumbia_active_record/behaviors/paginate.php';
        //}
        return call_user_func_array(array('Paginator', 'paginate'), $args);
    }

    public function paginate_by_sql($sql)
    {
        $args = func_get_args();
        array_unshift($args, $this);
        //if(!class_exists('Paginator')){
        require_once CORE_PATH . 'libs/kumbia_active_record/behaviors/paginate.php';
        //}
        return call_user_func_array(array('Paginator', 'paginate_by_sql'), $args);
    }

    public function __sleep()
    {
        $this->db = null;

        return array_keys(get_object_vars($this));
    }

    public function __wakeup()
    {
        $this->_connect();
    }

    public static function get($model)
    {
        if (isset(self::$_models[$model])) {
            return self::$_models[$model];
        }

        $Model = Util::camelcase(basename($model));

        if (!class_exists($Model, false)) {
            $file = APP_PATH . "models/$model.php";
            if (is_file($file)) {
                include $file;
            } else {
                throw new KumbiaException(null, 'no_model');
            }
        }

        self::$_models[$model] = $obj = new $Model();
        return $obj;
    }

    public function to_json()
    {
        return json_encode($this);
    }

    public function to_array()
    {
        return ((array) $this);
    }

    public function serialize()
    {
        return serialize($this);
    }

}