fetch($params)) { self::set_properties($this, $data); } else { self::set_properties($this, $this->optional_fields);//apply defaults for optional fields self::set_properties($this, $params); } } else { self::set_properties($this, $params); } } else { self::set_properties($this, $this->optional_fields);//apply defaults for optional fields } } /** * Makes sure all the optional fields are loaded. * If id present (==instance exists in db) fetches data from db. * Defaults are used for new instances. */ public function load_optional_fields() { global $DB; foreach ($this->optional_fields as $field=>$default) { if (property_exists($this, $field)) { continue; } if (empty($this->id)) { $this->$field = $default; } else { $this->$field = $DB->get_field($this->table, $field, array('id', $this->id)); } } } /** * Finds and returns a data_object instance based on params. * @static abstract * * @param array $params associative arrays varname=>value * @return object data_object instance or false if none found. */ public static function fetch($params) { throw new coding_exception('fetch() method needs to be overridden in each subclass of data_object'); } /** * Finds and returns all data_object instances based on params. * * @param array $params associative arrays varname=>value * @return array array of data_object instances or false if none found. */ public static function fetch_all($params) { throw new coding_exception('fetch_all() method needs to be overridden in each subclass of data_object'); } /** * Factory method - uses the parameters to retrieve matching instance from the DB. * @static final protected * @return mixed object instance or false if not found */ protected static function fetch_helper($table, $classname, $params) { if ($instances = self::fetch_all_helper($table, $classname, $params)) { if (count($instances) > 1) { // we should not tolerate any errors here - problems might appear later print_error('morethanonerecordinfetch','debug'); } return reset($instances); } else { return false; } } /** * Factory method - uses the parameters to retrieve all matching instances from the DB. * @static final protected * @return mixed array of object instances or false if not found */ public static function fetch_all_helper($table, $classname, $params) { $instance = new $classname(); $classvars = (array)$instance; $params = (array)$params; $wheresql = array(); foreach ($params as $var=>$value) { if (!in_array($var, $instance->required_fields) and !array_key_exists($var, $instance->optional_fields)) { continue; } if (is_null($value)) { $wheresql[] = " $var IS NULL "; } else { $wheresql[] = " $var = ? "; $params[] = $value; } } if (empty($wheresql)) { $wheresql = ''; } else { $wheresql = implode("AND", $wheresql); } global $DB; if ($datas = $DB->get_records_select($table, $wheresql, $params)) { $result = array(); foreach($datas as $data) { $instance = new $classname(); self::set_properties($instance, $data); $result[$instance->id] = $instance; } return $result; } else { return false; } } /** * Updates this object in the Database, based on its object variables. ID must be set. * @return boolean success */ public function update() { global $DB; if (empty($this->id)) { debugging('Can not update data object, no id!'); return false; } $data = $this->get_record_data(); $DB->update_record($this->table, $data); $this->notify_changed(false); return true; } /** * Deletes this object from the database. * @return boolean success */ public function delete() { global $DB; if (empty($this->id)) { debugging('Can not delete data object, no id!'); return false; } $data = $this->get_record_data(); if ($DB->delete_records($this->table, array('id'=>$this->id))) { $this->notify_changed(true); return true; } else { return false; } } /** * Returns object with fields and values that are defined in database */ public function get_record_data() { $data = new stdClass(); foreach ($this as $var=>$value) { if (in_array($var, $this->required_fields) or array_key_exists($var, $this->optional_fields)) { if (is_object($value) or is_array($value)) { debugging("Incorrect property '$var' found when inserting data object"); } else { $data->$var = $value; } } } return $data; } /** * Records this object in the Database, sets its id to the returned value, and returns that value. * If successful this function also fetches the new object data from database and stores it * in object properties. * @return int PK ID if successful, false otherwise */ public function insert() { global $DB; if (!empty($this->id)) { debugging("Data object already exists!"); return false; } $data = $this->get_record_data(); $this->id = $DB->insert_record($this->table, $data); // set all object properties from real db data $this->update_from_db(); $this->notify_changed(false); return $this->id; } /** * Using this object's id field, fetches the matching record in the DB, and looks at * each variable in turn. If the DB has different data, the db's data is used to update * the object. This is different from the update() function, which acts on the DB record * based on the object. */ public function update_from_db() { if (empty($this->id)) { debugging("The object could not be used in its state to retrieve a matching record from the DB, because its id field is not set."); return false; } global $DB; if (!$params = $DB->get_record($this->table, array('id' => $this->id))) { debugging("Object with this id:{$this->id} does not exist in table:{$this->table}, can not update from db!"); return false; } self::set_properties($this, $params); return true; } /** * Given an associated array or object, cycles through each key/variable * and assigns the value to the corresponding variable in this object. * @static final */ public static function set_properties(&$instance, $params) { $params = (array) $params; foreach ($params as $var => $value) { if (in_array($var, $instance->required_fields) or array_key_exists($var, $instance->optional_fields)) { $instance->$var = $value; } } } /** * Called immediately after the object data has been inserted, updated, or * deleted in the database. Default does nothing, can be overridden to * hook in special behaviour. * * @param bool $deleted */ function notify_changed($deleted) { } }