Implements: Serializable
Menu Model Class
Class declared in MODPATH/gleez/classes/model/menu.php on line 10.
integer 5
string $left_columnleft column name
string $level_columnlevel column name
$parent_columnstring $right_columnright column name
$scope_columnarray $_belongs_to"Belongs to" relationships
bool $_cachearray $_cast_dataData to be loaded into the model from a database call cast
array $_changedarray $_column_cacheStores column information for ORM models
array(0) string $_created_columnAuto-update columns for creation
object $_datatablesDataTables
Database $_dbDatabase Object
array $_db_appliedDatabase methods applied
Database_Query_Builder_Where $_db_builderDatabase query builder
String $_db_groupDatabase config group
array $_db_pendingDatabase methods pending
bool $_db_resetReset builder
string $_errors_filenameThe message filename used for validation errors. Defaults to ORM::$_object_name
string $_foreign_key_suffixForeign key suffix
array $_has_many"Has many" relationships
array $_has_many_keys"Many to many" relationships
array $_has_one"Has one" relationships
array $_ignored_columnsIgnored columns
array $_init_cacheInitialization storage for ORM models
array(0) array $_load_withRelationships that should always be joined
bool $_loadedarray $_objectCurrent object
string $_object_nameModel name
string $_object_pluralPlural model name
array $_original_valuesstring $_primary_keyTable primary key
mixed $_primary_key_valuePrimary key value
array $_relatedbool $_reload_on_wakeupModel configuration, reload on wakeup?
bool $_savedarray $_serialize_columnsAuto-serialize and unserialize columns on get/set
array $_sorting $_table_columnsstring $_table_nameTable name
bool $_table_names_pluralModel configuration, table names plural?
bool $_updatedstring $_updated_columnAuto-update columns for updates
bool $_validValidation $_validationValidation object created before saving/updating
array $_with_appliedWith calls already applied
Create a new term in the tree as a child of $parent
$location is "first" or "last" the term will be the first or last child$location is an int, the term will be the next sibling of term with id $locationORM_MPTT|integer
$parent
required - The parentstring|integer
$location
= string(4) "last" - The location [Optional]Model_Menupublic function create_at($parent, $location = 'last')
{
// Create the term as first child, last child, or as next sibling based on location
if ($location == 'first')
{
$this->insert_as_first_child($parent);
}
else if ($location == 'last')
{
$this->insert_as_last_child($parent);
}
else
{
$target = ORM::factory('menu',(int) $location);
if ( ! $target->loaded())
{
throw new Gleez_Exception("Could not create menu, could not find target for
insert_as_next_sibling id: " . (int) $location);
}
$this->insert_as_last_child($target);
}
return $this;
}
Labels for fields in this model
array - Array of labelspublic function labels()
{
return array(
'title' => __('Title'),
'name' => __('Slug'),
'url' => __('Link'),
);
}
Move the item to $target based on action
$target
$target
required - Integer The target term id$action
$action
= string(5) "after" - String The action to perform (before/after/first/last) afterpublic function move_to($target, $action = 'after')
{
// Find the target
$target = ORM::factory('menu',(int) $target);
// Make sure it exists
if ( ! $target->loaded())
{
throw new Gleez_Exception("Could not move item, target item did not exist." . (int) $target->id);
}
if ($action == 'before')
$this->move_to_prev_sibling($target);
elseif ($action == 'after')
$this->move_to_next_sibling($target);
elseif ($action == 'first')
$this->move_to_first_child($target);
elseif ($action == 'last')
$this->move_to_last_child($target);
else
throw new Gleez_Exception("Could not move item, action should be 'before', 'after', 'first' or 'last'.");
}
Rule definitions for validation
array - Array of rulespublic function rules()
{
return array(
'name' => array(
array('not_empty'),
),
);
}
Updates or Creates the record depending on loaded()
Validation
$validation
= NULL - Validation objectORMpublic function save(Validation $validation = NULL)
{
$this->name = $this->_unique_slug(URL::title(empty($this->name) ? $this->title : $this->name));
$this->params = empty($this->params) ? NULL : serialize($this->params);
return parent::save( $validation );
}
Load the default column names.
mixed
$id
= NULL - Parameter for find or object to loadvoidpublic function __construct($id = NULL)
{
if (empty($this->_sorting))
{
$this->_sorting = array($this->scope_column => 'ASC', $this->left_column => 'ASC');
}
else
{
$this->_sorting = Arr::unshift($this->_sorting, $this->left_column, 'ASC');
$this->_sorting = Arr::unshift($this->_sorting, $this->scope_column, 'ASC');
}
parent::__construct($id);
}
Magic get function, maps field names to class functions.
string
$column
required - Name of the field to getmixedpublic function __get($column)
{
switch ($column)
{
case 'parent':
return $this->parent();
case 'parents':
return $this->parents();
case 'children':
return $this->children();
case 'first_child':
return $this->children(FALSE, 'ASC', 1);
case 'last_child':
return $this->children(FALSE, 'DESC', 1);
case 'siblings':
return $this->siblings();
case 'root':
return $this->root();
case 'roots':
return $this->roots();
case 'leaves':
return $this->leaves();
case 'descendants':
return $this->descendants();
case 'fulltree':
return $this->fulltree();
default:
return parent::__get($column);
}
}
Returns direct children of the current node.
bool
$self
= bool FALSE - Include the current nodestring
$direction
= string(3) "ASC" - Direction to order the left column byint
$limit
= bool FALSE - Number of children to getORM_MPTTpublic function children($self = FALSE, $direction = 'ASC', $limit = FALSE)
{
return $this->descendants($self, $direction, TRUE, FALSE, $limit);
}
Returns the number of descendants the current node has.
intpublic function count()
{
return ($this->size() - 2) / 2;
}
Deletes the current node and all descendants.
voidpublic function delete($query = NULL)
{
if ($query !== NULL)
{
throw new Kohana_Exception('ORM_MPTT does not support passing a query object to delete()');
}
//$this->lock();
// Start the transaction
$this->_db->begin();
try
{
DB::delete($this->_table_name)
->where($this->left_column,' >=',$this->left())
->where($this->right_column,' <= ',$this->right())
->where($this->scope_column,' = ',$this->scope())
->execute($this->_db);
$this->delete_space($this->left(), $this->size());
}
catch (Kohana_Exception $e)
{
//$this->unlock();
$this->_db->rollback();
throw $e;
}
//$this->unlock();
// Commit the transaction
$this->_db->commit();
}
Returns the descendants of the current node.
bool
$self
= bool FALSE - Include the current nodestring
$direction
= string(3) "ASC" - Direction to order the left column by.bool
$direct_children_only
= bool FALSE - Include direct children onlybool
$leaves_only
= bool FALSE - Include leaves onlyint
$limit
= bool FALSE - Number of results to getORM_MPTTpublic function descendants($self = FALSE, $direction = 'ASC', $direct_children_only = FALSE, $leaves_only = FALSE, $limit = FALSE)
{
$left_operator = $self ? '>=' : '>';
$right_operator = $self ? '<=' : '<';
$query = self::factory($this->object_name())
->where($this->left_column, $left_operator, $this->left())
->where($this->right_column, $right_operator, $this->right())
->where($this->scope_column, '=', $this->scope())
->order_by($this->left_column, $direction);
if ($direct_children_only)
{
if ($self)
{
$query
->and_where_open()
->where($this->level_column, '=', $this->level())
->or_where($this->level_column, '=', $this->level() + 1)
->and_where_close();
}
else
{
$query->where($this->level_column, '=', $this->level() + 1);
}
}
if ($leaves_only)
{
$query->where($this->right_column, '=', DB::expr($this->left_column.' + 1'));
}
if ($limit !== FALSE)
{
$query->limit($limit);
}
return $query->find_all();
}
Returns a full hierarchical tree, with or without scope checking.
bool
$scope
= NULL - Only retrieve nodes with specified scopeobjectpublic function fulltree($scope = NULL)
{
$result = self::factory($this->object_name());
if ( ! is_null($scope))
{
$result->where($this->scope_column, '=', $scope);
}
else
{
$result->order_by($this->scope_column, 'ASC')
->order_by($this->left_column, 'ASC');
}
return $result->find_all();
}
Get all posible level values
int
$scope
= NULL - Restrict to the given scopeDatabase_Resultpublic function get_levels($scope = NULL)
{
$result = DB::select($this->level_column)
->distinct(TRUE)
->from($this->_table_name);
if ( ! empty($scope))
{
$result->where($this->scope_column, '=', (int) $scope);
}
return $result->execute($this->_db);
}
Checks if the current node has any children.
boolpublic function has_children()
{
return ($this->size() > 2);
}
Inserts a new node as the first child of the target node.
ORM_MPTT|int
$target
required - Primary key value or ORM_MPTT object of target nodeORM_MPTTpublic function insert_as_first_child($target)
{
$target = $this->parent_from($target);
return $this->insert($target, $this->left_column, 1, 1);
}
Inserts a new node as the last child of the target node.
ORM_MPTT|int
$target
required - Primary key value or ORM_MPTT object of target nodeORM_MPTTpublic function insert_as_last_child($target)
{
$target = $this->parent_from($target, $this->primary_key());
return $this->insert($target, $this->right_column, 0, 1);
}
Inserts a new node as the next sibling of the target node.
ORM_MPTT|int
$target
required - Primary key value or ORM_MPTT object of target nodeORM_MPTTpublic function insert_as_next_sibling($target)
{
$target = $this->parent_from($target, $this->parent_column);
return $this->insert($target, $this->right_column, 1, 0);
}
Inserts a new node as a previous sibling of the target node.
ORM_MPTT|int
$target
required - Primary key value or ORM_MPTT object of target nodeORM_MPTTpublic function insert_as_prev_sibling($target)
{
$target = $this->parent_from($target, $this->parent_column);
return $this->insert($target, $this->left_column, 0, 0);
}
Checks if the current node is a direct child of the supplied node.
ORM_MPTT|int
$target
required - ORM_MPTT object or primary key value of target nodeboolpublic function is_child($target)
{
if ( ! ($target instanceof $this))
{
$target = self::factory($this->object_name(), $target);
}
return ((int) $this->{$this->parent_column} === (int) $target->pk());
}
Is the current node a descendant of the supplied node.
ORM_MPTT|int
$target
required - ORM_MPTT object or primary key value of target nodeboolpublic function is_descendant($target)
{
if ( ! ($target instanceof $this))
{
$target = self::factory($this->object_name(), $target);
}
return (
$this->{$this->left_column} > $target->{$target->left_column}
AND $this->{$this->right_column} < $target->{$target->right_column}
AND $this->{$this->scope_column} = $target->{$target->scope_column}
);
}
Checks if the current node is one of the parents of a specific node.
int|object
$target
required - Id or object of parent nodeboolpublic function is_in_parents($target)
{
if ( ! ($target instanceof $this))
{
$target = self::factory($this->object_name(), $target);
}
return $target->is_descendant($this);
}
Is the current node a leaf node?
boolpublic function is_leaf()
{
return ( ! $this->has_children());
}
Checks if the current node is a direct parent of a specific node.
ORM_MPTT|int
$target
required - ORM_MPTT object or primary key value of child nodeboolpublic function is_parent($target)
{
if ( ! ($target instanceof $this))
{
$target = self::factory($this->object_name(), $target);
}
return ((int) $this->pk() === (int) $target->{$this->parent_column});
}
Checks if the current node is a root node.
boolpublic function is_root()
{
return ($this->left() === 1);
}
Checks if the current node is a sibling of a supplied node. (Both have the same direct parent)
ORM_MPTT|int
$target
required - ORM_MPTT object or primary key value of target nodeboolpublic function is_sibling($target)
{
if ( ! ($target instanceof $this))
{
$target = self::factory($this->object_name(), $target);
}
if ((int) $this->pk() === (int) $target->pk())
return FALSE;
return ((int) $this->{$this->parent_column} === (int) $target->{$target->parent_column});
}
Returns the leaves of the current node.
bool
$self
= bool FALSE - Include the current nodestring
$direction
= string(3) "ASC" - Direction to order the left column byORM_MPTTpublic function leaves($self = FALSE, $direction = 'ASC')
{
return $this->descendants($self, $direction, TRUE, TRUE);
}
Returns the value of the current nodes left column.
intpublic function left()
return (INT) $this->{$this->left_column};
Returns the value of the current nodes level column.
intpublic function level()
{
return (INT) $this->{$this->level_column};
}
Creates a new node as root, or moves a node to root
int
$validation
= NULL - The new scopeunknown
$scope
= NULLORM_MPTTpublic function make_root(Validation $validation = NULL, $scope = NULL)
{
// If node already exists, and already root, exit
if ($this->loaded() AND $this->is_root())
return $this;
// delete node space first
if ($this->loaded())
{
$this->delete_space($this->left(), $this->size());
}
if (is_null($scope))
{
// Increment next scope
$scope = self::get_next_scope();
}
elseif ( ! $this->scope_available($scope))
{
return FALSE;
}
$this->{$this->scope_column} = $scope;
$this->{$this->level_column} = 1;
$this->{$this->left_column} = 1;
$this->{$this->right_column} = 2;
$this->{$this->parent_column} = NULL;
try
{
parent::save($validation);
}
catch (ORM_Validation_Exception $e)
{
// Some fields didn't validate, throw an exception
throw $e;
}
return $this;
}
public function move_to_first_child($target)
{
$target = $this->parent_from($target, $this->primary_key());
return $this->move($target, TRUE, 1, 1, TRUE);
}
public function move_to_last_child($target)
{
$target = $this->parent_from($target, $this->primary_key());
return $this->move($target, FALSE, 0, 1, TRUE);
}
public function move_to_next_sibling($target)
{
$target = $this->parent_from($target, $this->parent_column);
return $this->move($target, FALSE, 1, 0, FALSE);
}
public function move_to_prev_sibling($target)
{
$target = $this->parent_from($target, $this->parent_column);
return $this->move($target, TRUE, 0, 0, FALSE);
}
Returns the parent node of the current node
ORM_MPTTpublic function parent()
{
if ($this->is_root())
return NULL;
return self::factory($this->object_name(), $this->{$this->parent_column});
}
Returns all of the current nodes parents.
bool
$root
= bool TRUE - Include root nodebool
$with_self
= bool FALSE - Include current nodestring
$direction
= string(3) "ASC" - Direction to order the left column bybool
$direct_parent_only
= bool FALSE - Retrieve the direct parent onlyORM_MPTTpublic function parents($root = TRUE, $with_self = FALSE, $direction = 'ASC', $direct_parent_only = FALSE)
{
$suffix = $with_self ? '=' : '';
$query = self::factory($this->object_name())
->where($this->left_column, '<'.$suffix, $this->left())
->where($this->right_column, '>'.$suffix, $this->right())
->where($this->scope_column, '=', $this->scope())
->order_by($this->left_column, $direction);
if ( ! $root)
{
$query->where($this->left_column, '!=', 1);
}
if ($direct_parent_only)
{
$query
->where($this->level_column, '=', $this->level() - 1)
->limit(1);
}
return $query->find_all();
}
Rebuilds the tree using the parent_column. Order of the tree is not guaranteed to be consistent with structure prior to reconstruction. This method will reduce the tree structure to eliminating any holes. If you have a child node that is outside of the left/right constraints it will not be moved under the root.
int
$left
= integer 1 - Left Starting value for left branchORM_MPTT
$target
= NULL - Target Target node to use as rootintpublic function rebuild_tree($left = 1, $target = NULL)
{
// check if using target or self as root and load if not loaded
if (is_null($target) AND ! $this->loaded())
{
return FALSE;
}
elseif (is_null($target))
{
$target = $this;
}
if ( ! $target->loaded())
{
$target->_load();
}
// Use the current node left value for entire tree
if (is_null($left))
{
$left = $target->{$target->left_column};
}
//$target->lock();
// Start the transaction
$this->_db->begin();
$right = $left + 1;
$children = $target->children();
foreach ($children as $child)
{
$right = $child->rebuild_tree($right);
}
$target->{$target->left_column} = $left;
$target->{$target->right_column} = $right;
$target->save();
//$target->unlock();
// Commit the transaction
$this->_db->commit();
return $right + 1;
}
Returns the value of the current nodes right column.
intpublic function right()
{
return (INT) $this->{$this->right_column};
}
Returns the root node of the current object instance.
int
$scope
= NULL - ScopeORM_MPTT|FALSEpublic function root($scope = NULL)
{
if (is_null($scope) AND $this->loaded())
{
$scope = $this->scope();
}
elseif (is_null($scope) AND ! $this->loaded())
{
throw new Kohana_Exception(':method must be called on an ORM_MPTT object instance.', array(':method' => 'root'));
}
return self::factory($this->object_name(), array($this->left_column => 1, $this->scope_column => $scope));
}
Returns all root node's
ORM_MPTTpublic function roots()
{
return self::factory($this->object_name())
->where($this->left_column, '=', 1)
->find_all();
}
Returns the value of the current nodes scope column.
intpublic function scope()
{
return (INT) $this->{$this->scope_column};
}
Overloads the select_list method to support indenting.
string
$key
= NULL - First table column.string
$value
= NULL - $val second table column.string
$indent
= NULL - Character used for indenting.arraypublic function select_list($key = NULL, $value = NULL, $indent = NULL)
{
if ($key === NULL)
{
// Use the default key
$key = $this->_primary_key;
}
if ($value === NULL)
{
// Use the default value
$value = $this->pk();
}
$result = DB::select($key, $value, $this->level_column)
->from($this->_table_name)
->where($this->scope_column, '=', $this->{$this->scope_column})
->where($this->_primary_key, '<>', $this->pk())
->where($this->level_column, '<>', 1)
->order_by($this->left_column, 'ASC')
->execute($this->_db);
if (is_string($indent))
{
$array = array('last' => '');
foreach ($result as $row)
{
//$array[$row->$key] = str_repeat($indent, ($row->{$this->_level_column} - 1)).$row->$value;
$array[$row[$key]] = str_repeat($indent, $row[$this->level_column] - 2).$row[$value];
}
return $array;
}
return $result->as_array($key, $value);
}
Returns the siblings of the current node
bool
$self
= bool FALSE - Include the current nodestring
$direction
= string(3) "ASC" - Direction to order the left column byORM_MPTTpublic function siblings($self = FALSE, $direction = 'ASC')
{
$query = self::factory($this->object_name())
->where($this->left_column, '>', $this->parent->left())
->where($this->right_column, '<', $this->parent->right())
->where($this->scope_column, '=', $this->scope())
->where($this->level_column, '=', $this->level())
->order_by($this->left_column, $direction);
if ( ! $self)
{
$query->where($this->primary_key(), '<>', $this->pk());
}
return $query->find_all();
}
Returns the size of the current node.
intpublic function size()
{
return $this->right() - $this->left() + 1;
}
Checks if object data is set.
string
$column
required - Column namebooleanpublic function __isset($column)
{
return (isset($this->_object[$column]) OR
isset($this->_related[$column]) OR
isset($this->_has_one[$column]) OR
isset($this->_belongs_to[$column]) OR
isset($this->_has_many[$column]));
}
Base set method - this should not be overridden.
string
$column
required - Column namemixed
$value
required - Column valuevoidpublic function __set($column, $value)
{
if ( ! isset($this->_object_name))
{
// Object not yet constructed, so we're loading data from a database call cast
$this->_cast_data[$column] = $value;
}
else
{
// Set the model's column to given value
$this->set($column, $value);
}
}
Displays the primary key of a model when it is converted to a string.
stringpublic function __toString()
{
return (string) $this->pk();
}
Unsets object data.
string
$column
required - Column namevoidpublic function __unset($column)
{
unset($this->_object[$column], $this->_changed[$column], $this->_related[$column]);
}
Adds a new relationship to between this model and another.
// Add the login role using a model instance
$model->add('roles', ORM::factory('role', array('name' => 'login')));
// Add the login role if you know the roles.id is 5
$model->add('roles', 5);
// Add multiple roles (for example, from checkboxes on a form)
$model->add('roles', array(1, 2, 3, 4));
string
$alias
required - Alias of the has_many "through" relationshipmixed
$far_keys
required - Related model, primary key, or an array of primary keysarray
$data
= NULL - Additional data to store in "through"/pivot tableORMpublic function add($alias, $far_keys, $data = NULL)
{
$far_keys = ($far_keys instanceof ORM) ? $far_keys->pk() : $far_keys;
$columns = array($this->_has_many[$alias]['foreign_key'], $this->_has_many[$alias]['far_key']);
$foreign_key = $this->pk();
if ($data !== NULL)
{
// Additional data stored in pivot table
$columns = array_merge($columns, array_keys($data));
}
$query = DB::insert($this->_has_many[$alias]['through'], $columns);
foreach ( (array) $far_keys as $key)
{
$values = array($foreign_key, $key);
if ($data !== NULL)
{
// Additional data stored in pivot table
$values = array_merge($values, array_values($data));
}
$query->values($values);
}
$query->execute($this->_db);
return $this;
}
Creates a new "AND HAVING" condition for the query.
mixed
$column
required - Column name or array($column, $alias) or objectstring
$op
required - Logic operatormixed
$value
= NULL - Column value$thispublic function and_having($column, $op, $value = NULL)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'and_having',
'args' => array($column, $op, $value),
);
return $this;
}
Closes an open "AND HAVING (...)" grouping.
$thispublic function and_having_close()
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'and_having_close',
'args' => array(),
);
return $this;
}
Opens a new "AND HAVING (...)" grouping.
$thispublic function and_having_open()
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'and_having_open',
'args' => array(),
);
return $this;
}
Creates a new "AND WHERE" condition for the query.
mixed
$column
required - Column name or array($column, $alias) or objectstring
$op
required - Logic operatormixed
$value
required - Column value$thispublic function and_where($column, $op, $value)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'and_where',
'args' => array($column, $op, $value),
);
return $this;
}
Closes an open "AND WHERE (...)" grouping.
$thispublic function and_where_close()
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'and_where_close',
'args' => array(),
);
return $this;
}
Opens a new "AND WHERE (...)" grouping.
$thispublic function and_where_open()
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'and_where_open',
'args' => array(),
);
return $this;
}
Returns the values of this object as an array, including any related one-one models that have already been loaded using with()
arraypublic function as_array()
{
$object = array();
$extra = array('url', 'edit_url', 'delete_url');
foreach ($this->_object as $column => $value)
{
// Call __get for any user processing
$object[$column] = $this->__get($column);
}
foreach ($this->_related as $column => $model)
{
// Include any related objects that are already loaded
$object[$column] = $model->as_array();
}
foreach ($extra as $column)
{
try
{
// Call __get for any user processing
$object[$column] = $this->__get($column);
}catch(Exception $e){}
}
return $object;
}
public function belongs_to()
{
return $this->_belongs_to;
}
Enables the query to be cached for a specified amount of time.
integer
$lifetime
= NULL - Number of seconds to cache$thispublic function cached($lifetime = NULL)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'cached',
'args' => array($lifetime),
);
return $this;
}
Check whether the model data has been modified. If $field is specified, checks whether that field was modified.
string
$field
= NULL - Field to check for changesbool - Whether or not the field has changedpublic function changed($field = NULL)
{
return ($field === NULL)
? $this->_changed
: Arr::get($this->_changed, $field);
}
Validates the current model's data
Validation
$extra_validation
= NULL - Validation objectORMpublic function check(Validation $extra_validation = NULL)
{
// Determine if any external validation failed
$extra_errors = ($extra_validation AND ! $extra_validation->check());
// Always build a new validation object
$this->_validation();
// add custom rules to $this->_validation();
Module::event($this->_object_name .'_validation', $this->_validation, $extra_errors);
$array = $this->_validation;
if (($this->_valid = $array->check()) === FALSE OR $extra_errors)
{
$exception = new ORM_Validation_Exception($this->errors_filename(), $array);
if ($extra_errors)
{
// Merge any possible errors from the external object
$exception->add_object('_external', $extra_validation);
}
$this->_validation = NULL; //Fixed memory leak @http://dev.kohanaframework.org/issues/4286
throw $exception;
}
$this->_validation = NULL; //Fixed memory leak @http://dev.kohanaframework.org/issues/4286
return $this;
}
Unloads the current object and clears the status.
ORMpublic function clear()
{
// Create an array with all the columns set to NULL
$values = array_combine(array_keys($this->_table_columns), array_fill(0, count($this->_table_columns), NULL));
// Replace the object and reset the object status
$this->_object = $this->_changed = $this->_related = $this->_original_values = array();
// Replace the current object with an empty one
$this->_load_values($values);
// Reset primary key
$this->_primary_key_value = NULL;
$this->reset();
return $this;
}
Count the number of records in the table.
integerpublic function count_all()
{
$selects = array();
foreach ($this->_db_pending as $key => $method)
{
if ($method['name'] == 'select')
{
// Ignore any selected columns for now
$selects[] = $method;
unset($this->_db_pending[$key]);
}
elseif ($method['name'] == 'order_by')
{
// Also, ignore order clause
$order_by[$key] = $method; // Fix of the fix here!
unset($this->_db_pending[$key]);
}
}
if ( ! empty($this->_load_with))
{
foreach ($this->_load_with as $alias)
{
// Bind relationship
$this->with($alias);
}
}
$this->_build(Database::SELECT);
$records = $this->_db_builder->from(array($this->_table_name, $this->_object_name))
->select(array('COUNT("*")', 'records_found'))
->execute($this->_db)
->get('records_found');
// Add back in selected columns
//$this->_db_pending += $selects;
$this->_db_pending = array_merge($this->_db_pending, $selects);
if( isset($order_by) )
{
// Add back in order_by clause
//$this->_db_pending += $order_by;
$this->_db_pending = array_merge($this->_db_pending, $order_by);
}
$this->reset();
// Return the total number of records in a table
return $records;
}
Insert a new object to the database added event support
Validation
$validation
= NULL - Validation objectORMpublic function create(Validation $validation = NULL)
{
if ($this->_loaded)
throw new Kohana_Exception('Cannot create :model model because it is already loaded.', array(':model' => $this->_object_name));
Module::event($this->_object_name .'_prevalid', $this, $validation);
// Require model validation before saving
if ( ! $this->_valid OR $validation)
{
$this->check($validation);
}
$this->before_save();
Module::event($this->_object_name .'_presave', $this, $validation);
$data = array();
foreach ($this->_changed as $column)
{
// Generate list of column => values
$data[$column] = $this->_object[$column];
}
if (is_array($this->_created_column))
{
// Fill the created column
$column = $this->_created_column['column'];
$format = $this->_created_column['format'];
$data[$column] = $this->_object[$column] = ($format === TRUE) ? time() : date($format);
}
$result = DB::insert($this->_table_name)
->columns(array_keys($data))
->values(array_values($data))
->execute($this->_db);
if ( ! array_key_exists($this->_primary_key, $data))
{
// Load the insert id as the primary key if it was left out
$this->_object[$this->_primary_key] = $this->_primary_key_value = $result[0];
}
// Object is now loaded and saved
$this->_loaded = $this->_saved = TRUE;
// All changes have been saved
$this->_changed = array();
$this->_original_values = $this->_object;
$this->after_save();
Module::event($this->_object_name .'_save', $this);
return $this;
}
public function created_column()
{
return $this->_created_column;
}
Setter/Getter for jquery DataTables support
object - DataTablespublic function dataTables(array $columns = NULL)
{
if ( ! empty($columns) )
{
$this->_datatables = DataTables::factory($this)->columns($columns)->execute();
}
return $this->_datatables;
}
Delete all objects in the associated table. This does NOT destroy relationships that have been created with other objects.
ORMpublic function delete_all()
{
if ( $this->_loaded)
throw new Kohana_Exception('Cannot delete all :model model because it is loaded.', array(':model' => $this->_object_name));
Module::event($this->_object_name .'_pre_delete_all', $this);
$this->_build(ORM::DELETE);
$this->_db_builder->execute($this->_db);
Module::event($this->_object_name .'_delete_all', $this);
return $this->clear();
}
Enables or disables selecting only unique columns using "SELECT DISTINCT"
boolean
$value
required - Enable or disable distinct columns$thispublic function distinct($value)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'distinct',
'args' => array($value),
);
return $this;
}
public function errors_filename()
{
return $this->_errors_filename;
}
Creates and returns a new model.
string
$model
required - Model namemixed
$id
= NULL - Parameter for find()ORMpublic static function factory($model, $id = NULL)
{
// Set class name
$model = 'Model_'.ucfirst($model);
return new $model($id);
}
Filter definitions for validation
arraypublic function filters()
{
return array();
}
Finds and loads a single database row into the object.
ORMpublic function find()
{
if ($this->_loaded)
throw new Kohana_Exception('Method find() cannot be called on loaded objects');
if ( ! empty($this->_load_with))
{
foreach ($this->_load_with as $alias)
{
// Bind auto relationships
$this->with($alias);
}
}
$this->_build(Database::SELECT);
return $this->_load_result(FALSE);
}
Finds multiple database rows and returns an iterator of the rows found.
Database_Resultpublic function find_all()
{
if ($this->_loaded)
throw new Kohana_Exception('Method find_all() cannot be called on loaded objects');
if ( ! empty($this->_load_with))
{
foreach ($this->_load_with as $alias)
{
// Bind auto relationships
$this->with($alias);
}
}
$this->_build(Database::SELECT);
return $this->_load_result(TRUE);
}
Finds or creates a model instance with the given values
array
$values
required - $values$thispublic function find_or_create($values)
{
// Unload any previously loaded objects
$this->clear();
// Attempt to find the object
foreach ($values as $key => $value)
{
$this->where($key, '=', $value);
}
$found = $this->find()->loaded();
if ($found)
{
return $this;
}
else
{
$this->values($values);
$s = $this->save();
return $s;
}
}
Choose the tables to select "FROM ..."
mixed
$tables
required - Table name or array($table, $alias) or object$thispublic function from($tables)
{
$tables = func_get_args();
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'from',
'args' => $tables,
);
return $this;
}
Creates a "GROUP BY ..." filter.
mixed
$columns
required - Column name or array($column, $alias) or object$thispublic function group_by($columns)
{
$columns = func_get_args();
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'group_by',
'args' => $columns,
);
return $this;
}
Tests if this object has a relationship to a different model, or an array of different models.
// Check if $model has the login role
$model->has('roles', ORM::factory('role', array('name' => 'login')));
// Check for the login role if you know the roles.id is 5
$model->has('roles', 5);
// Check for all of the following roles
$model->has('roles', array(1, 2, 3, 4));
// Check if $model has any roles
$model->has('roles')
string
$alias
required - Alias of the has_many "through" relationshipmixed
$far_keys
= NULL - Related model, primary key, or an array of primary keysDatabase_Resultpublic function has($alias, $far_keys = NULL)
{
if ($far_keys === NULL)
{
return (bool) DB::select(array('COUNT("*")', 'records_found'))
->from($this->_has_many[$alias]['through'])
->where($this->_has_many[$alias]['foreign_key'], '=', $this->pk())
->execute($this->_db)->get('records_found');
}
$far_keys = ($far_keys instanceof ORM) ? $far_keys->pk() : $far_keys;
// We need an array to simplify the logic
$far_keys = (array) $far_keys;
// Nothing to check if the model isn't loaded or we don't have any far_keys
if ( ! $far_keys OR ! $this->_loaded)
return FALSE;
$count = (int) DB::select(array('COUNT("*")', 'records_found'))
->from($this->_has_many[$alias]['through'])
->where($this->_has_many[$alias]['foreign_key'], '=', $this->pk())
->where($this->_has_many[$alias]['far_key'], 'IN', $far_keys)
->execute($this->_db)->get('records_found');
// Rows found need to match the rows searched
return $count === count($far_keys);
}
public function has_many()
{
return $this->_has_many;
}
public function has_many_keys()
{
return $this->_has_many_keys;
}
public function has_one()
{
return $this->_has_one;
}
Alias of and_having()
mixed
$column
required - Column name or array($column, $alias) or objectstring
$op
required - Logic operatormixed
$value
= NULL - Column value$thispublic function having($column, $op, $value = NULL)
{
return $this->and_having($column, $op, $value);
}
Closes an open "AND HAVING (...)" grouping.
$thispublic function having_close()
{
return $this->and_having_close();
}
Alias of and_having_open()
$thispublic function having_open()
{
return $this->and_having_open();
}
Adds addition tables to "JOIN ...".
mixed
$table
required - Column name or array($column, $alias) or objectstring
$type
= NULL - Join type (LEFT, RIGHT, INNER, etc)$thispublic function join($table, $type = NULL)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'join',
'args' => array($table, $type),
);
return $this;
}
Returns last executed query
stringpublic function last_query()
{
return $this->_db->last_query;
}
Return up to "LIMIT ..." results
integer
$number
required - Maximum results to return$thispublic function limit($number)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'limit',
'args' => array($number),
);
return $this;
}
Proxy method to Database list_columns.
arraypublic function list_columns()
{
// Proxy to database
return $this->_db->list_columns($this->_table_name);
}
public function load_with()
{
return $this->_load_with;
}
public function loaded()
{
return $this->_loaded;
}
Adds "ON ..." conditions for the last created JOIN statement.
mixed
$c1
required - Column name or array($column, $alias) or objectstring
$op
required - Logic operatormixed
$c2
required - Column name or array($column, $alias) or object$thispublic function my_on($c1, $op, $c2)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'join_and',
'args' => array($c1, $op, $c2),
);
return $this;
}
public function object()
{
return $this->_object;
}
public function object_name()
{
return $this->_object_name;
}
public function object_plural()
{
return $this->_object_plural;
}
Start returning results after "OFFSET ..."
integer
$number
required - Starting result number$thispublic function offset($number)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'offset',
'args' => array($number),
);
return $this;
}
Adds "ON ..." conditions for the last created JOIN statement.
mixed
$c1
required - Column name or array($column, $alias) or objectstring
$op
required - Logic operatormixed
$c2
required - Column name or array($column, $alias) or object$thispublic function on($c1, $op, $c2)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'on',
'args' => array($c1, $op, $c2),
);
return $this;
}
Creates a new "OR HAVING" condition for the query.
mixed
$column
required - Column name or array($column, $alias) or objectstring
$op
required - Logic operatormixed
$value
= NULL - Column value$thispublic function or_having($column, $op, $value = NULL)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'or_having',
'args' => array($column, $op, $value),
);
return $this;
}
Closes an open "OR HAVING (...)" grouping.
$thispublic function or_having_close()
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'or_having_close',
'args' => array(),
);
return $this;
}
Opens a new "OR HAVING (...)" grouping.
$thispublic function or_having_open()
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'or_having_open',
'args' => array(),
);
return $this;
}
Creates a new "OR WHERE" condition for the query.
mixed
$column
required - Column name or array($column, $alias) or objectstring
$op
required - Logic operatormixed
$value
required - Column value$thispublic function or_where($column, $op, $value)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'or_where',
'args' => array($column, $op, $value),
);
return $this;
}
Closes an open "OR WHERE (...)" grouping.
$thispublic function or_where_close()
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'or_where_close',
'args' => array(),
);
return $this;
}
Opens a new "OR WHERE (...)" grouping.
$thispublic function or_where_open()
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'or_where_open',
'args' => array(),
);
return $this;
}
Applies sorting with "ORDER BY ..."
mixed
$column
required - Column name or array($column, $alias) or objectstring
$direction
= NULL - Direction of sorting$thispublic function order_by($column, $direction = NULL)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'order_by',
'args' => array($column, $direction),
);
return $this;
}
public function original_values()
{
return $this->_original_values;
}
Set the value of a parameter in the query.
string
$param
required - Parameter key to replacemixed
$value
required - Value to use$thispublic function param($param, $value)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'param',
'args' => array($param, $value),
);
return $this;
}
Returns the value of the primary key
mixed - Primary keypublic function pk()
{
return $this->_primary_key_value;
}
public function primary_key()
{
return $this->_primary_key;
}
Reloads the current object from the database.
ORMpublic function reload()
{
$primary_key = $this->pk();
// Replace the object and reset the object status
$this->_object = $this->_changed = $this->_related = $this->_original_values = array();
// Only reload the object if we have one to reload
if ($this->_loaded)
return $this->clear()
->where($this->_object_name.'.'.$this->_primary_key, '=', $primary_key)
->find();
else
return $this->clear();
}
Reload column definitions.
boolean
$force
= bool FALSE - Force reloadingORMpublic function reload_columns($force = FALSE)
{
if ($force === TRUE OR empty($this->_table_columns))
{
if (isset(ORM::$_column_cache[$this->_object_name]))
{
// Use cached column information
$this->_table_columns = ORM::$_column_cache[$this->_object_name];
}
else
{
// Grab column information from database
$this->_table_columns = $this->list_columns(TRUE);
// Load column cache
ORM::$_column_cache[$this->_object_name] = $this->_table_columns;
}
}
return $this;
}
Removes a relationship between this model and another.
// Remove a role using a model instance
$model->remove('roles', ORM::factory('role', array('name' => 'login')));
// Remove the role knowing the primary key
$model->remove('roles', 5);
// Remove multiple roles (for example, from checkboxes on a form)
$model->remove('roles', array(1, 2, 3, 4));
// Remove all related roles
$model->remove('roles');
string
$alias
required - Alias of the has_many "through" relationshipmixed
$far_keys
= NULL - Related model, primary key, or an array of primary keysORMpublic function remove($alias, $far_keys = NULL)
{
$far_keys = ($far_keys instanceof ORM) ? $far_keys->pk() : $far_keys;
$query = DB::delete($this->_has_many[$alias]['through'])
->where($this->_has_many[$alias]['foreign_key'], '=', $this->pk());
if ($far_keys !== NULL)
{
// Remove all the relationships in the array
$query->where($this->_has_many[$alias]['far_key'], 'IN', (array) $far_keys);
}
$query->execute($this->_db);
return $this;
}
Clears query builder. Passing FALSE is useful to keep the existing query conditions for another query.
bool
$next
= bool TRUE - Pass FALSE to avoid resetting on the next callORMpublic function reset($next = TRUE)
{
if ($next AND $this->_db_reset)
{
$this->_db_pending = array();
$this->_db_applied = array();
$this->_db_builder = NULL;
$this->_with_applied = array();
}
// Reset on the next call?
$this->_db_reset = $next;
return $this;
}
public function saved()
{
return $this->_saved;
}
Choose the columns to select from.
mixed
$columns
= NULL - Column name or array($column, $alias) or object$thispublic function select($columns = NULL)
{
$columns = func_get_args();
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'select',
'args' => $columns,
);
return $this;
}
Allows serialization of only the object data and state, to prevent "stale" objects being unserialized, which also requires less memory.
arraypublic function serialize()
{
// Store only information about the object
foreach (array('_primary_key_value', '_object', '_changed', '_loaded', '_saved', '_sorting', '_original_values', '_ignored_columns') as $var)
{
$data[$var] = $this->{$var};
}
return serialize($data);
}
Handles setting of column
string
$column
required - Column namemixed
$value
required - Column valuevoidpublic function set($column, $value)
{
if ( ! isset($this->_object_name))
{
// Object not yet constructed, so we're loading data from a database call cast
$this->_cast_data[$column] = $value;
return $this;
}
if (in_array($column, $this->_serialize_columns))
{
$value = $this->_serialize_value($value);
}
if (array_key_exists($column, $this->_ignored_columns))
{
// No processing for ignored columns, just store it
$this->_object[$column] = $value;
}
elseif (array_key_exists($column, $this->_object))
{
// Filter the data
$value = $this->run_filter($column, $value);
// See if the data really changed
if ($value !== $this->_object[$column])
{
$this->_object[$column] = $value;
// Data has changed
$this->_changed[$column] = $column;
// Object is no longer saved or valid
$this->_saved = $this->_valid = FALSE;
}
}
elseif (isset($this->_belongs_to[$column]))
{
// Update related object itself
$this->_related[$column] = $value;
// Update the foreign key of this model
$this->_object[$this->_belongs_to[$column]['foreign_key']] = $value->pk();
$this->_changed[$column] = $this->_belongs_to[$column]['foreign_key'];
}
else
{
throw new Kohana_Exception('The :property: property does not exist in the :class: class',
array(':property:' => $column, ':class:' => get_class($this)));
}
return $this;
}
public function table_columns()
{
return $this->_table_columns;
}
public function table_name()
{
return $this->_table_name;
}
Checks whether a column value is unique. Excludes itself if loaded.
string
$field
required - The field to check for uniquenessmixed
$value
required - The value to check for uniquenessbool - Whteher the value is uniquepublic function unique($field, $value)
{
$model = ORM::factory($this->object_name())
->where($field, '=', $value)
->find();
if ($this->loaded())
{
return ( ! ($model->loaded() AND $model->pk() != $this->pk()));
}
return ( ! $model->loaded());
}
Prepares the database connection and reloads the object.
string
$data
required - String for unserializationvoidpublic function unserialize($data)
{
// Initialize model
$this->_initialize();
foreach (unserialize($data) as $name => $var)
{
$this->{$name} = $var;
}
if ($this->_reload_on_wakeup === TRUE)
{
// Reload the object
$this->reload();
}
}
Updates a single record or multiple records, added event support
Validation
$validation
= NULL - Validation objectORMpublic function update(Validation $validation = NULL)
{
if ( ! $this->_loaded)
throw new Kohana_Exception('Cannot update :model model because it is not loaded.', array(':model' => $this->_object_name));
Module::event($this->_object_name .'_prevalid', $this, $validation);
// Run validation if the model isn't valid or we have additional validation rules.
if ( ! $this->_valid OR $validation)
{
$this->check($validation);
}
if (empty($this->_changed))
{
return $this;
}
$this->before_save();
Module::event($this->_object_name .'_presave', $this, $validation);
$data = array();
foreach ($this->_changed as $column)
{
// Compile changed data
$data[$column] = $this->_object[$column];
}
if (is_array($this->_updated_column))
{
// Fill the updated column
$column = $this->_updated_column['column'];
$format = $this->_updated_column['format'];
$data[$column] = $this->_object[$column] = ($format === TRUE) ? time() : date($format);
}
// Use primary key value
$id = $this->pk();
// Update a single record
DB::update($this->_table_name)
->set($data)
->where($this->_primary_key, '=', $id)
->execute($this->_db);
if (isset($data[$this->_primary_key]))
{
// Primary key was changed, reflect it
$this->_primary_key_value = $data[$this->_primary_key];
}
// Object has been saved
$this->_saved = $this->_updated = TRUE;
// All changes have been saved
$this->_changed = array();
$this->_original_values = $this->_object;
$this->after_save();
Module::event($this->_object_name .'_save', $this);
return $this;
}
public function updated()
{
return $this->_updated;
}
public function updated_column()
{
return $this->_updated_column;
}
Adds "USING ..." conditions for the last created JOIN statement.
string
$columns
required - Column name$thispublic function using($columns)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'using',
'args' => array($columns),
);
return $this;
}
public function validation()
{
if ( ! isset($this->_validation))
{
// Initialize the validation object
$this->_validation();
}
return $this->_validation;
}
Set values from an array with support for one-one relationships. This method should be used for loading in post data, etc.
array
$values
required - Array of column => valarray
$expected
= NULL - Array of keys to take from $valuesORMpublic function values(array $values, array $expected = NULL)
{
// Default to expecting everything except the primary key
if ($expected === NULL)
{
$expected = array_keys($this->_table_columns);
// Don't set the primary key by default
unset($values[$this->_primary_key]);
}
if ( ! empty($this->_ignored_columns) )
{
// merge the columns needed to process
$expected = array_merge($expected, array_keys($this->_ignored_columns) );
}
foreach ($expected as $key => $column)
{
if (is_string($key))
{
// isset() fails when the value is NULL (we want it to pass)
if ( ! array_key_exists($key, $values))
continue;
// Try to set values to a related model
$this->{$key}->values($values[$key], $column);
}
else
{
// isset() fails when the value is NULL (we want it to pass)
if ( ! array_key_exists($column, $values))
continue;
// Update the column, respects __set()
$this->$column = $values[$column];
}
}
return $this;
}
Alias of and_where()
mixed
$column
required - Column name or array($column, $alias) or objectstring
$op
required - Logic operatormixed
$value
required - Column value$thispublic function where($column, $op, $value)
{
// Add pending database call which is executed after query type is determined
$this->_db_pending[] = array(
'name' => 'where',
'args' => array($column, $op, $value),
);
return $this;
}
Closes an open "AND WHERE (...)" grouping.
$thispublic function where_close()
{
return $this->and_where_close();
}
Alias of and_where_open()
$thispublic function where_open()
{
return $this->and_where_open();
}
Binds another one-to-one object to this model. One-to-one objects can be nested using 'object1:object2' syntax
string
$target_path
required - Target model to bind tovoidpublic function with($target_path)
{
if (isset($this->_with_applied[$target_path]))
{
// Don't join anything already joined
return $this;
}
// Split object parts
$aliases = explode(':', $target_path);
$target = $this;
foreach ($aliases as $alias)
{
// Go down the line of objects to find the given target
$parent = $target;
$target = $parent->_related($alias);
if ( ! $target)
{
// Can't find related object
return $this;
}
}
// Target alias is at the end
$target_alias = $alias;
// Pop-off top alias to get the parent path (user:photo:tag becomes user:photo - the parent table prefix)
array_pop($aliases);
$parent_path = implode(':', $aliases);
if (empty($parent_path))
{
// Use this table name itself for the parent path
$parent_path = $this->_object_name;
}
else
{
if ( ! isset($this->_with_applied[$parent_path]))
{
// If the parent path hasn't been joined yet, do it first (otherwise LEFT JOINs fail)
$this->with($parent_path);
}
}
// Add to with_applied to prevent duplicate joins
$this->_with_applied[$target_path] = TRUE;
// Use the keys of the empty object to determine the columns
foreach (array_keys($target->_object) as $column)
{
$name = $target_path.'.'.$column;
$alias = $target_path.':'.$column;
// Add the prefix so that load_result can determine the relationship
$this->select(array($name, $alias));
}
if (isset($parent->_belongs_to[$target_alias]))
{
// Parent belongs_to target, use target's primary key and parent's foreign key
$join_col1 = $target_path.'.'.$target->_primary_key;
$join_col2 = $parent_path.'.'.$parent->_belongs_to[$target_alias]['foreign_key'];
}
else
{
// Parent has_one target, use parent's primary key as target's foreign key
$join_col1 = $parent_path.'.'.$parent->_primary_key;
$join_col2 = $target_path.'.'.$parent->_has_one[$target_alias]['foreign_key'];
}
// Join the related object into the result
$this->join(array($target->_table_name, $target_path), 'LEFT')->on($join_col1, '=', $join_col2);
return $this;
}
Adds space to the tree for adding or inserting nodes.
int
$start
required - Start positionint
$size
= integer 2 - Size of the gap to add [optional]voidprotected function create_space($start, $size = 2)
{
DB::update($this->_table_name)
->set(array($this->left_column => DB::expr($this->left_column.' + '.$size)))
->where($this->left_column,'>=', $start)
->where($this->scope_column, '=', $this->scope())
->execute($this->_db);
DB::update($this->_table_name)
->set(array($this->right_column => DB::expr($this->right_column.' + '.$size)))
->where($this->right_column,'>=', $start)
->where($this->scope_column, '=', $this->scope())
->execute($this->_db);
}
Removes space from the tree after deleting or moving nodes.
int
$start
required - Start positionint
$size
= integer 2 - Size of the gap to remove [optional]voidprotected function delete_space($start, $size = 2)
{
DB::update($this->_table_name)
->set(array($this->left_column => DB::expr($this->left_column.' - '.$size)))
->where($this->left_column, '>=', $start)
->where($this->scope_column, '=', $this->scope())
->execute($this->_db);
DB::update($this->_table_name)
->set(array($this->right_column => DB::expr($this->right_column.' - '.$size)))
->where($this->right_column,'>=', $start)
->where($this->scope_column, '=', $this->scope())
->execute($this->_db);
}
Returns the next available value for scope.
intprotected function get_next_scope()
{
$scope = DB::select(DB::expr('IFNULL(MAX(`'.$this->scope_column.'`), 0) as scope'))
->from($this->_table_name)
->execute($this->_db)
->current();
if ($scope AND intval($scope['scope']) > 0)
return intval($scope['scope']) + 1;
return 1;
}
Insert the object
ORM_MPTT|int
$target
required - Primary key value or ORM_MPTT object of target node.string
$copy_left_from
required - Target object property to take new left value fromint
$left_offset
required - Offset for left valueint
$level_offset
required - Offset for level valueORM_MPTTprotected function insert($target, $copy_left_from, $left_offset, $level_offset)
{
// Insert should only work on new nodes.. if its already it the tree it needs to be moved!
if ($this->loaded())
return FALSE;
if ( ! $target instanceof $this)
{
$target = self::factory($this->object_name(), array($this->primary_key() => $target));
if ( ! $target->loaded())
{
return FALSE;
}
}
else
{
$target->reload();
}
//$this->lock();
// Start the transaction
$this->_db->begin();
$this->{$this->left_column} = $target->{$copy_left_from} + $left_offset;
$this->{$this->right_column} = $this->{$this->left_column} + 1;
$this->{$this->level_column} = $target->{$this->level_column} + $level_offset;
$this->{$this->scope_column} = $target->{$this->scope_column};
$this->create_space($this->{$this->left_column});
try
{
parent::save();
}
catch (ORM_Validation_Exception $e)
{
// We had a problem saving, make sure we clean up the tree
$this->delete_space($this->left());
//$this->unlock();
$this->_db->commit();
throw $e;
}
//$this->unlock();
// Commit the transaction
$this->_db->commit();
return $this;
}
Locks the current table.
voidprotected function lock()
{
$this->_db->query(NULL, 'LOCK TABLE '.$this->_db->quote_table($this->_table_name).' WRITE', TRUE);
}
protected function move($target, $left_column, $left_offset, $level_offset, $allow_root_target)
{
if ( ! $this->loaded())
return FALSE;
// store the changed parent id before reload
$parent_id = $this->{$this->parent_column};
// Make sure we have the most upto date version of this AFTER we lock
//$this->lock();
// Start the transaction
$this->_db->begin();
$this->reload();
// Catch any database or other excpetions and unlock
try
{
if ( ! $target instanceof $this)
{
$target = self::factory($this->object_name(), array($this->primary_key() => $target));
if ( ! $target->loaded())
{
//$this->unlock();
$this->_db->rollback();
return FALSE;
}
}
else
{
$target->reload();
}
// Stop $this being moved into a descendant or itself or disallow if target is root
if ($target->is_descendant($this)
OR $this->{$this->primary_key()} === $target->{$this->primary_key()}
OR ($allow_root_target === FALSE AND $target->is_root()))
{
//$this->unlock();
$this->_db->rollback();
return FALSE;
}
if ($level_offset > 0)
{
// We're moving to a child node so add 1 to left offset.
$left_offset = ($left_column === TRUE) ? ($target->left() + 1) : ($target->right() + $left_offset);
}
else
{
$left_offset = ($left_column === TRUE) ? $target->left() : ($target->right() + $left_offset);
}
$level_offset = $target->level() - $this->level() + $level_offset;
$size = $this->size();
$this->create_space($left_offset, $size);
$this->reload();
$offset = ($left_offset - $this->left());
$this->_db->query(Database::UPDATE, 'UPDATE '.$this->_db->quote_table($this->_table_name).' SET `'
. $this->left_column.'` = `'.$this->left_column.'` + '
. $offset.', `'.$this->right_column.'` = `'.$this->right_column.'` + '
. $offset.', `'.$this->level_column.'` = `'.$this->level_column.'` + '
. $level_offset.', `'.$this->scope_column.'` = '.$target->scope()
. ' WHERE `'.$this->left_column.'` >= '.$this->left().' AND `'
. $this->right_column.'` <= '.$this->right().' AND `'
. $this->scope_column.'` = '.$this->scope(), TRUE);
$this->delete_space($this->left(), $size);
}
catch (Kohana_Exception $e)
{
// Unlock table and re-throw exception
//$this->unlock();
$this->_db->rollback();
throw $e;
}
// all went well so save the parent_id if changed
if ($parent_id != $this->{$this->parent_column})
{
$this->{$this->parent_column} = $parent_id;
$this->save();
}
//$this->unlock();
// Commit the transaction
$this->_db->commit();
$this->reload();
return $this;
}
Sets the parent_column value to the given targets column value. Returns the target ORM_MPTT object.
ORM_MPTT|int
$target
required - Primary key value or ORM_MPTT object of target nodestring
$column
= NULL - Name of the targets nodes column to useORM_MPTTprotected function parent_from($target, $column = NULL)
{
if ( ! $target instanceof $this)
{
$target = self::factory($this->object_name(), array($this->primary_key() => $target));
}
if ($column === NULL)
{
$column = $target->primary_key();
}
if ($target->loaded())
{
$this->{$this->parent_column} = $target->{$column};
}
else
{
$this->{$this->parent_column} = NULL;
}
return $target;
}
Checks if the supplied scope is available.
int
$scope
required - Scope to check availability ofboolprotected function scope_available($scope)
{
return (bool) ! self::factory($this->_object_name)
->where($this->scope_column, '=', $scope)
->count_all();
}
Unlocks the current table.
voidprotected function unlock()
{
$this->_db->query(NULL, 'UNLOCK TABLES', TRUE);
}
Initializes the Database Builder to given query type
integer
$type
required - Type of Database queryORMprotected function _build($type)
{
// Construct new builder object based on query type
switch ($type)
{
case Database::SELECT:
$this->_db_builder = DB::select();
break;
case Database::UPDATE:
$this->_db_builder = DB::update(array($this->_table_name, $this->_object_name));
break;
case Database::DELETE:
$this->_db_builder = DB::delete(array($this->_table_name, $this->_object_name));
break;
case ORM::DELETE:
$this->_db_builder = DB::delete($this->_table_name);
}
// Process pending database method calls
foreach ($this->_db_pending as $method)
{
$name = $method['name'];
$args = $method['args'];
$this->_db_applied[$name] = $name;
call_user_func_array(array($this->_db_builder, $name), $args);
}
return $this;
}
Returns an array of columns to include in the select query. This method can be overridden to change the default select behavior.
array - Columns to selectprotected function _build_select()
{
$columns = array();
foreach ($this->_table_columns as $column => $_)
{
$columns[] = array($this->_object_name.'.'.$column, $column);
}
return $columns;
}
Prepares the model database connection, determines the table name, and loads column information.
voidprotected function _initialize()
{
// Set the object name and plural name
$this->_object_name = strtolower(substr(get_class($this), 6));
// Check if this model has already been initialized
if ( ! $init = Arr::get(ORM::$_init_cache, $this->_object_name, FALSE))
{
$init = array(
'_belongs_to' => array(),
'_has_one' => array(),
'_has_many' => array(),
'_has_many_keys' => array(),
);
// Set the object plural name if none predefined
if ( ! isset($this->_object_plural))
{
$init['_object_plural'] = Inflector::plural($this->_object_name);
}
if ( ! $this->_errors_filename)
{
$init['_errors_filename'] = $this->_object_name;
}
if ( ! is_object($this->_db))
{
// Get database instance
$init['_db'] = Database::instance($this->_db_group);
}
if (empty($this->_table_name))
{
// Table name is the same as the object name
$init['_table_name'] = $this->_object_name;
if ($this->_table_names_plural === TRUE)
{
// Make the table name plural
$init['_table_name'] = Arr::get($init, '_object_plural', $this->_object_plural);
}
}
if ( ! empty($this->_ignored_columns))
{
// Optimize for performance
$init['_ignored_columns']= array_combine($this->_ignored_columns, $this->_ignored_columns);
}
$defaults = array();
foreach ($this->_belongs_to as $alias => $details)
{
$defaults['model'] = $alias;
$defaults['foreign_key'] = $alias.$this->_foreign_key_suffix;
$init['_belongs_to'][$alias] = array_merge($defaults, $details);
}
foreach ($this->_has_one as $alias => $details)
{
$defaults['model'] = $alias;
$defaults['foreign_key'] = $this->_object_name.$this->_foreign_key_suffix;
$init['_has_one'][$alias] = array_merge($defaults, $details);
}
foreach ($this->_has_many as $alias => $details)
{
$defaults['model'] = Inflector::singular($alias);
$defaults['foreign_key'] = $this->_object_name.$this->_foreign_key_suffix;
$defaults['through'] = NULL;
$defaults['far_key'] = Inflector::singular($alias).$this->_foreign_key_suffix;
$init['_has_many'][$alias] = array_merge($defaults, $details);
}
foreach ($this->_has_many_keys as $alias => $details)
{
$defaults['model'] = Inflector::singular($alias);
$defaults['foreign_key'] = array($this->_object_name.$this->_foreign_key_suffix);
$defaults['far_key'] = array(Inflector::singular($alias).$this->_foreign_key_suffix);
$init['_has_many_keys'][$alias] = array_merge($defaults, $details);
}
ORM::$_init_cache[$this->_object_name] = $init;
}
// Assign initialized properties to the current object
foreach ($init as $property => $value)
{
$this->{$property} = $value;
}
// Load column information
$this->reload_columns();
// Clear initial model state
$this->clear();
}
Loads a database result, either as a new record for this model, or as an iterator for multiple rows.
bool
$multiple
= bool FALSE - Return an iterator or load a single rowORM|Database_Resultprotected function _load_result($multiple = FALSE)
{
$this->_db_builder->from(array($this->_table_name, $this->_object_name));
if ($multiple === FALSE)
{
// Only fetch 1 record
$this->_db_builder->limit(1);
}
// Select all columns by default
$this->_db_builder->select($this->_object_name.'.*');
if ( ! isset($this->_db_applied['order_by']) AND ! empty($this->_sorting))
{
foreach ($this->_sorting as $column => $direction)
{
if (strpos($column, '.') === FALSE)
{
// Sorting column for use in JOINs
$column = $this->_object_name.'.'.$column;
}
$this->_db_builder->order_by($column, $direction);
}
}
if ($multiple === TRUE)
{
// Return database iterator casting to this object type
$result = $this->_db_builder->as_object(get_class($this))->execute($this->_db);
$this->reset();
return $result;
}
else
{
// Load the result as an associative array
$result = $this->_db_builder->as_assoc()->execute($this->_db);
$this->reset();
if ($result->count() === 1)
{
// Load object values
$this->_load_values($result->current());
}
else
{
// Clear the object, nothing was found
$this->clear();
}
return $this;
}
}
Loads an array of values into into the current object.
array
$values
required - Values to loadORMprotected function _load_values(array $values)
{
if (array_key_exists($this->_primary_key, $values))
{
if ($values[$this->_primary_key] !== NULL)
{
// Flag as loaded and valid
$this->_loaded = $this->_valid = TRUE;
// Store primary key
$this->_primary_key_value = $values[$this->_primary_key];
}
else
{
// Not loaded or valid
$this->_loaded = $this->_valid = FALSE;
}
}
// Related objects
$related = array();
foreach ($values as $column => $value)
{
if (strpos($column, ':') === FALSE)
{
// Load the value to this model
$this->_object[$column] = $value;
}
else
{
// Column belongs to a related model
list ($prefix, $column) = explode(':', $column, 2);
$related[$prefix][$column] = $value;
}
}
if ( ! empty($related))
{
foreach ($related as $object => $values)
{
// Load the related objects with the values in the result
$this->_related($object)->_load_values($values);
}
}
if ($this->_loaded)
{
// Store the object in its original state
$this->_original_values = $this->_object;
}
return $this;
}
Returns an ORM model for the given one-one related alias
string
$alias
required - Alias nameORMprotected function _related($alias)
{
if (isset($this->_related[$alias]))
{
return $this->_related[$alias];
}
elseif (isset($this->_has_one[$alias]))
{
return $this->_related[$alias] = ORM::factory($this->_has_one[$alias]['model']);
}
elseif (isset($this->_belongs_to[$alias]))
{
return $this->_related[$alias] = ORM::factory($this->_belongs_to[$alias]['model']);
}
else
{
return FALSE;
}
}
protected function _serialize_value($value)
{
return json_encode($value);
}
protected function _unserialize_value($value)
{
return json_decode($value);
}
Initializes validation rules, and labels
voidprotected function _validation()
{
// Build the validation object with its rules
$this->_validation = Validation::factory($this->_object)
->bind(':model', $this)
->bind(':original_values', $this->_original_values)
->bind(':changed', $this->_changed);
foreach ($this->rules() as $field => $rules)
{
$this->_validation->rules($field, $rules);
}
// Use column names by default for labels
$columns = array_keys($this->_table_columns);
// Merge user-defined labels
$labels = array_merge(array_combine($columns, $columns), $this->labels());
foreach ($labels as $field => $label)
{
$this->_validation->label($field, $label);
}
}
Override this method to take actions after the document is deleted
protected function after_delete($id){}
Override this method to take actions after the values are loaded
protected function after_load(){}
Override this method to take actions after data is saved
protected function after_save(){}
Override this method to take actions before the document is deleted
protected function before_delete($id){}
Override this method to take actions before the values are loaded
protected function before_load(){}
Override this method to take certain actions before the data is saved
protected function before_save(){}
Filters a value for a specific column
string
$field
required - The column namestring
$value
required - The value to filterstringprotected function run_filter($field, $value)
{
$filters = $this->filters();
// Get the filters for this column
$wildcards = empty($filters[TRUE]) ? array() : $filters[TRUE];
// Merge in the wildcards
$filters = empty($filters[$field]) ? $wildcards : array_merge($wildcards, $filters[$field]);
// Bind the field name and model so they can be used in the filter method
$_bound = array
(
':field' => $field,
':model' => $this,
);
foreach ($filters as $array)
{
// Value needs to be bound inside the loop so we are always using the
// version that was modified by the filters that already ran
$_bound[':value'] = $value;
// Filters are defined as array($filter, $params)
$filter = $array[0];
$params = Arr::get($array, 1, array(':value'));
foreach ($params as $key => $param)
{
if (is_string($param) AND array_key_exists($param, $_bound))
{
// Replace with bound value
$params[$key] = $_bound[$param];
}
}
if (is_array($filter) OR ! is_string($filter))
{
// This is either a callback as an array or a lambda
$value = call_user_func_array($filter, $params);
}
elseif (strpos($filter, '::') === FALSE)
{
// Use a function call
$function = new ReflectionFunction($filter);
// Call $function($this[$field], $param, ...) with Reflection
$value = $function->invokeArgs($params);
}
else
{
// Split the class and method of the rule
list($class, $method) = explode('::', $filter, 2);
// Use a static method call
$method = new ReflectionMethod($class, $method);
// Call $Class::$method($this[$field], $param, ...) with Reflection
$value = $method->invokeArgs(NULL, $params);
}
}
return $value;
}
Creates unique slug for menu
string
$str
required - $strstringprivate function _unique_slug($str)
{
static $i;
$i = 1;
$original = $str;
while ($post = ORM::factory('menu', array('name' => $str)) AND $post->loaded() AND $post->id !== $this->id)
{
$str = $original . '-' . $i;
$i++;
}
return $str;
}