class.ActiveRecord.php

Go to the documentation of this file.

<?php
require_once('class.ActiveRecordList.php');
require_once('Connector/class.arConnector.php');
require_once('Connector/class.arConnectorDB.php');
require_once('Cache/class.arObjectCache.php');
require_once('Fields/class.arFieldList.php');
require_once('Cache/class.arFieldCache.php');
require_once('Storage/int.arStorageInterface.php');
require_once('Factory/class.arFactory.php');
require_once('Cache/class.arCalledClassCache.php');
require_once('Connector/class.arConnectorMap.php');
 
abstract class ActiveRecord implements arStorageInterface {
 
        const ACTIVE_RECORD_VERSION = '2.0.7';
        protected $ar_safe_read = true;
        protected $connector_container_name = '';
 
 
        public function getArConnector() {
                return arConnectorMap::get($this);
        }
 
 
        public function getArFieldList() {
                return arFieldCache::get($this);
        }
 
 
        public static function returnDbTableName() {
                throw new arException(arException::UNKNONWN_EXCEPTION, 'Implement getConnectorContainerName in your child-class');
        }
 
 
        public function getConnectorContainerName() {
                // WILL BE ABSTRACT TO REPLACE returnDbTableName() IN NEXT VERSION
                if ($this->connector_container_name) {
                        return $this->connector_container_name;
                } else {
                        $ar = self::getCalledClass();
 
                        return $ar::returnDbTableName();
                }
        }
 
 
        public function setConnectorContainerName($connector_container_name) {
                $this->connector_container_name = $connector_container_name;
        }
 
 
        public function getPrimaryFieldValue() {
                $primary_fieldname = arFieldCache::getPrimaryFieldName($this);
 
                return $this->{$primary_fieldname};
        }
 
 
        public function setPrimaryFieldValue($value) {
                $primary_fieldname = arFieldCache::getPrimaryFieldName($this);
 
                $this->{$primary_fieldname} = $value;
        }
 
 
        public function __construct($primary_key = 0, arConnector $connector = null) {
                if ($connector == null) {
                        $connector = new arConnectorDB();
                }
                arConnectorMap::register($this, $connector);
 
                $arFieldList = arFieldCache::get($this);
 
                $key = $arFieldList->getPrimaryFieldName();
                $this->{$key} = $primary_key;
                if ($primary_key !== 0 AND $primary_key !== null AND $primary_key !== false) {
                        $this->read();
                }
        }
 
 
        public function storeObjectToCache() {
                arObjectCache::store($this);
        }
 
 
        public function __getConvertedDateFieldsAsArray($format = null) {
                $converted_dates = array();
                foreach ($this->getArFieldList()->getFields() as $field) {
                        if ($field->isDateField()) {
                                $name = $field->getName();
                                $value = $this->{$name};
                                $converted_dates[$name] = array(
                                        'unformatted' => $value,
                                        'unix'        => strtotime($value),
                                );
                                if ($format) {
                                        $converted_dates[$name]['formatted'] = date($format, strtotime($value));
                                }
                        }
                }
 
                return $converted_dates;
        }
 
 
        public function __asCsv($separator = ';', $header = false) {
                $line = '';
                if ($header) {
                        $line .= implode($separator, array_keys($this->getArFieldList()->getRawFields()));
                        $line .= "\n";
                }
                $array = array();
                foreach ($this->__asArray() as $field_name => $value) {
                        $serialized = $this->serializeToCSV($field_name);
                        if ($serialized === null) {
                                $array[$field_name] = $this->{$field_name};
                        } else {
                                $array[$field_name] = $serialized;
                        }
                }
                $line .= implode($separator, array_values($array));
 
                return $line;
        }
 
 
        protected function serializeToCSV($field) {
                return null;
        }
 
 
        public function __asArray() {
                $return = array();
                foreach ($this->getArFieldList()->getFields() as $field) {
                        $fieldname = $field->getName();
                        $return[$fieldname] = $this->{$fieldname};
                }
 
                return $return;
        }
 
 
        public function __asStdClass() {
                $return = new stdClass();
                foreach ($this->getArFieldList()->getFields() as $field) {
                        $fieldname = $field->getName();
                        $return->{$fieldname} = $this->{$fieldname};
                }
 
                return $return;
        }
 
 
        public function __asSerializedObject() {
                return serialize($this);
        }
 
 
        public function buildFromArray(array $array) {
                $class = get_class($this);
                $primary = $this->getArFieldList()->getPrimaryFieldName();
                $primary_value = $array[$primary];
                if ($primary_value AND arObjectCache::isCached($class, $primary_value)) {
                        return arObjectCache::get($class, $primary_value);
                }
                foreach ($array as $field_name => $value) {
                        if ($this->wakeUp($field_name, $value) === null) {
                                $this->{$field_name} = $value;
                        } else {
                                $this->{$field_name} = $this->wakeUp($field_name, $value);
                        }
                }
                arObjectCache::store($this);
                $this->afterObjectLoad();
 
                return $this;
        }
 
 
        public function fixDateField($field_name, $value) {
                if ($this->getArFieldList()->getFieldByName($field_name)->isDateField()) {
                        return $this->getArConnector()->fixDate($value);
                }
 
                return $value;
        }
 
 
        public function sleep($field_name) {
                return null;
        }
 
 
        public function wakeUp($field_name, $field_value) {
                return null;
        }
 
 
        final public function getArrayForDb() {
                return $this->getArrayForConnector();
        }
 
 
        final public function getArrayForConnector() {
                $data = array();
                foreach ($this->getArFieldList()->getFields() as $field) {
                        $field_name = $field->getName();
                        $sleeped = $this->sleep($field_name);
                        $var = ($sleeped === null) ? ($this->{$field_name}) : $sleeped;
                        $data[$field_name] = array( $field->getFieldType(), $var );
                }
 
                return $data;
        }
 
 
 
 
        //
        // Collector Modifications
        //
 
        static protected function getCalledClass() {
                $class = get_called_class();
 
                return arCalledClassCache::get($class);
        }
 
 
        final public static function installDB() {
                return self::getCalledClass()->installDatabase();
        }
 
 
        public function installConnector() {
                return $this->installDatabase();
        }
 
 
        final public static function renameDBField($old_name, $new_name) {
                return self::getCalledClass()->getArConnector()->renameField(self::getCalledClass(), $old_name, $new_name);
        }
 
 
        final public static function tableExists() {
                return self::getCalledClass()->getArConnector()->checkTableExists(self::getCalledClass());
        }
 
 
        final public static function fieldExists($field_name) {
                return self::getCalledClass()->getArConnector()->checkFieldExists(self::getCalledClass(), $field_name);
        }
 
 
        final public static function removeDBField($field_name) {
                return self::getCalledClass()->getArConnector()->removeField(self::getCalledClass(), $field_name);
        }
 
 
        final protected function installDatabase() {
                if (!$this->tableExists()) {
                        $fields = array();
                        foreach ($this->getArFieldList()->getFields() as $field) {
                                $fields[$field->getName()] = $field->getAttributesForConnector();
                        }
 
                        return $this->getArConnector()->installDatabase($this, $fields);
                } else {
                        return $this->getArConnector()->updateDatabase($this);
                }
        }
 
 
        final public static function updateDB() {
                if (!self::tableExists()) {
                        self::getCalledClass()->installDatabase();
 
                        return true;
                }
 
                return self::getCalledClass()->getArConnector()->updateDatabase(self::getCalledClass());
        }
 
 
        final public static function resetDB() {
                return self::getCalledClass()->getArConnector()->resetDatabase(self::getCalledClass());
        }
 
 
        final public static function truncateDB() {
                return self::getCalledClass()->getArConnector()->truncateDatabase(self::getCalledClass());
        }
 
 
        final public static function flushDB() {
                return self::truncateDB();
        }
 
        //
        // CRUD
        //
        public function store() {
                $primary_fieldname = arFieldCache::getPrimaryFieldName($this);
                $primary_value = $this->getPrimaryFieldValue();
 
                if (!self::where(array( $primary_fieldname => $primary_value ))->hasSets()) {
                        $this->create();
                } else {
                        $this->update();
                }
        }
 
 
        public function save() {
                $this->store();
        }
 
 
        public function create() {
                if ($this->getArFieldList()->getPrimaryField()->getSequence()) {
                        $primary_fieldname = arFieldCache::getPrimaryFieldName($this);
                        $this->{$primary_fieldname} = $this->getArConnector()->nextID($this);
                }
 
                $this->getArConnector()->create($this, $this->getArrayForConnector());
                arObjectCache::store($this);
        }
 
 
        public function copy($new_id = 0) {
                if (self::where(array( $this->getArFieldList()->getPrimaryFieldName() => $new_id ))->hasSets()) {
                        throw new arException(arException::COPY_DESTINATION_ID_EXISTS);
                }
                $new_obj = clone($this);
                $new_obj->setPrimaryFieldValue($new_id);
 
                return $new_obj;
        }
 
 
        public function afterObjectLoad() {
        }
 
 
        public function read() {
                $records = $this->getArConnector()->read($this);
                if (count($records) == 0 AND $this->ar_safe_read == true) {
                        throw new arException(arException::RECORD_NOT_FOUND, $this->getPrimaryFieldValue());
                } elseif (count($records) == 0 AND $this->ar_safe_read == false) {
                        $this->is_new = true;
                }
                foreach ($records as $rec) {
                        foreach ($this->getArrayForConnector() as $k => $v) {
                                if ($this->wakeUp($k, $rec->{$k}) === null) {
                                        $this->{$k} = $rec->{$k};
                                } else {
                                        $this->{$k} = $this->wakeUp($k, $rec->{$k});
                                }
                        }
                        arObjectCache::store($this);
                        $this->afterObjectLoad();
                }
        }
 
 
        public function update() {
                $this->getArConnector()->update($this);
                arObjectCache::store($this);
        }
 
 
        public function delete() {
                $this->getArConnector()->delete($this);
                arObjectCache::purge($this);
        }
 
 
 
        //
        // Collection
        //
        public static function preloadObjects() {
                return self::get();
        }
 
 
        public static function additionalParams(array $additional_params) {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
                $srModelObjectList->additionalParams($additional_params);
 
                return $srModelObjectList;
        }
 
 
        public static function find($primary_key, array $add_constructor_args = array()) {
                try {
                        $class_name = get_called_class();
                        if (!arObjectCache::isCached($class_name, $primary_key)) {
                                $obj = arFactory::getInstance($class_name, $primary_key, $add_constructor_args);
                                $obj->storeObjectToCache();
 
                                return $obj;
                        }
                } catch (arException $e) {
                        return null;
                }
 
                try {
                        $obj = arObjectCache::get($class_name, $primary_key);
                } catch (arException $e) {
                        return null;
                }
 
                return $obj;
        }
 
 
        public static function findOrFail($primary_key, array $add_constructor_args = array()) {
                $obj = self::find($primary_key, $add_constructor_args);
                if (is_null($obj)) {
                        throw new arException(arException::RECORD_NOT_FOUND);
                }
 
                return $obj;
        }
 
 
        public static function findOrGetInstance($primary_key, array $add_constructor_args = array()) {
                $obj = self::find($primary_key, $add_constructor_args);
                if ($obj !== null) {
                        return $obj;
                } else {
                        $class_name = get_called_class();
                        $obj = arFactory::getInstance($class_name, 0, $add_constructor_args);
                        $obj->setPrimaryFieldValue($primary_key);
                        $obj->is_new = true;
                        $obj->storeObjectToCache();
 
                        return $obj;
                }
        }
 
 
        public static function where($where, $operator = null) {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
                $srModelObjectList->where($where, $operator);
 
                return $srModelObjectList;
        }
 
 
        public static function innerjoinAR(ActiveRecord $ar, $on_this, $on_external, $fields = array( '*' ), $operator = '=', $both_external = false) {
                return self::innerjoin($ar->getConnectorContainerName(), $on_this, $on_external, $fields, $operator, $both_external);
        }
 
 
        public static function innerjoin($tablename, $on_this, $on_external, $fields = array( '*' ), $operator = '=', $both_external = false) {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->innerjoin($tablename, $on_this, $on_external, $fields, $operator, $both_external);
        }
 
 
        public static function leftjoin($tablename, $on_this, $on_external, $fields = array( '*' ), $operator = '=', $both_external = false) {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->leftjoin($tablename, $on_this, $on_external, $fields, $operator, $both_external);
        }
 
 
        public static function orderBy($orderBy, $orderDirection = 'ASC') {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
                $srModelObjectList->orderBy($orderBy, $orderDirection);
 
                return $srModelObjectList;
        }
 
 
        public static function dateFormat($date_format = 'd.m.Y - H:i:s') {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
                $srModelObjectList->dateFormat($date_format);
 
                return $srModelObjectList;
        }
 
 
        public static function limit($start, $end) {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
                $srModelObjectList->limit($start, $end);
 
                return $srModelObjectList;
        }
 
 
        public static function affectedRows() {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->affectedRows();
        }
 
 
        public static function count() {
                return self::affectedRows();
        }
 
 
        public static function get() {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->get();
        }
 
 
        public static function debug() {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->debug();
        }
 
 
        public static function first() {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->first();
        }
 
 
        public static function getCollection() {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList;
        }
 
 
        public static function last() {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->last();
        }
 
 
        public static function getFirstFromLastQuery() {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->getFirstFromLastQuery();
        }
 
 
        public static function connector(arConnector $connector) {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->connector($connector);
        }
 
 
        public static function raw($set_raw = true) {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->raw($set_raw);
        }
 
 
        public static function getArray($key = null, $values = null) {
                $srModelObjectList = new ActiveRecordList(self::getCalledClass());
 
                return $srModelObjectList->getArray($key, $values);
        }
 
        //
        // Magic Methods & Helpers
        //
        public function __call($name, $arguments) {
                // Getter
                if (preg_match("/get([a-zA-Z]*)/u", $name, $matches) AND count($arguments) == 0) {
                        return $this->{self::fromCamelCase($matches[1])};
                }
                // Setter
                if (preg_match("/set([a-zA-Z]*)/u", $name, $matches) AND count($arguments) == 1) {
                        $this->{self::fromCamelCase($matches[1])} = $arguments[0];
                }
                if (preg_match("/findBy([a-zA-Z]*)/u", $name, $matches) AND count($arguments) == 1) {
                        return self::where(array( self::fromCamelCase($matches[1]) => $arguments[0] ))->getFirst();
                }
        }
 
 
        public static function _toCamelCase($str, $capitalise_first_char = false) {
                if ($capitalise_first_char) {
                        $str[0] = strtoupper($str[0]);
                }
                $func = create_function('$c', 'return strtoupper($c[1]);');
 
                return preg_replace_callback('/_([a-z])/', $func, $str);
        }
 
 
        protected static function fromCamelCase($str) {
                $str[0] = strtolower($str[0]);
                $func = create_function('$c', 'return "_" . strtolower($c[1]);');
 
                return preg_replace_callback('/([A-Z])/', $func, $str);
        }
}
 
?>