2007-05-20 22:40:53 +04:00
|
|
|
<?php
|
|
|
|
/*
|
|
|
|
* $Id: Table.php 1397 2007-05-19 19:54:15Z zYne $
|
|
|
|
*
|
|
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
|
|
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
|
|
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
|
|
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
|
|
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
|
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
|
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
|
|
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
|
|
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
|
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
|
|
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
|
|
*
|
|
|
|
* This software consists of voluntary contributions made by many individuals
|
|
|
|
* and is licensed under the LGPL. For more information, see
|
|
|
|
* <http://www.phpdoctrine.com>.
|
|
|
|
*/
|
|
|
|
/**
|
|
|
|
* Doctrine_Relation_Parser
|
|
|
|
*
|
|
|
|
* @author Konsta Vesterinen <kvesteri@cc.hut.fi>
|
|
|
|
* @package Doctrine
|
|
|
|
* @license http://www.opensource.org/licenses/lgpl-license.php LGPL
|
|
|
|
* @version $Revision: 1397 $
|
|
|
|
* @category Object Relational Mapping
|
|
|
|
* @link www.phpdoctrine.com
|
|
|
|
* @since 1.0
|
|
|
|
*/
|
|
|
|
class Doctrine_Relation_Parser
|
|
|
|
{
|
|
|
|
/**
|
|
|
|
* @var Doctrine_Table $_table the table object this parser belongs to
|
|
|
|
*/
|
|
|
|
protected $_table;
|
|
|
|
/**
|
|
|
|
* @var array $_relations an array containing all the Doctrine_Relation objects for this table
|
|
|
|
*/
|
2007-05-20 23:28:21 +04:00
|
|
|
protected $_relations = array();
|
2007-05-20 22:40:53 +04:00
|
|
|
/**
|
2007-05-20 23:28:21 +04:00
|
|
|
* @var array $_pending relations waiting for parsing
|
2007-05-20 22:40:53 +04:00
|
|
|
*/
|
2007-05-20 23:28:21 +04:00
|
|
|
protected $_pending = array();
|
2007-05-20 22:40:53 +04:00
|
|
|
/**
|
2007-05-20 23:28:21 +04:00
|
|
|
* @var array $_relationAliases relation aliases
|
2007-05-20 22:40:53 +04:00
|
|
|
*/
|
2007-05-20 23:28:21 +04:00
|
|
|
protected $_aliases = array();
|
2007-05-20 22:40:53 +04:00
|
|
|
/**
|
|
|
|
* constructor
|
|
|
|
*
|
|
|
|
* @param Doctrine_Table $table the table object this parser belongs to
|
|
|
|
*/
|
|
|
|
public function __construct(Doctrine_Table $table)
|
|
|
|
{
|
|
|
|
$this->_table = $table;
|
|
|
|
}
|
|
|
|
/**
|
|
|
|
* getTable
|
|
|
|
*
|
|
|
|
* @return Doctrine_Table the table object this parser belongs to
|
|
|
|
*/
|
|
|
|
public function getTable()
|
|
|
|
{
|
2007-05-20 23:28:21 +04:00
|
|
|
return $this->_table;
|
|
|
|
}
|
|
|
|
/**
|
|
|
|
* getPendingRelation
|
|
|
|
*
|
|
|
|
* @return array an array defining a pending relation
|
|
|
|
*/
|
|
|
|
public function getPendingRelation($name)
|
|
|
|
{
|
|
|
|
if ( ! isset($this->_pending[$name])) {
|
|
|
|
throw new Doctrine_Relation_Exception('Unknown pending relation ' . $name);
|
|
|
|
}
|
|
|
|
|
|
|
|
return $this->_pending[$name];
|
2007-05-20 22:40:53 +04:00
|
|
|
}
|
|
|
|
/**
|
|
|
|
* binds a relation
|
|
|
|
*
|
|
|
|
* @param string $name
|
|
|
|
* @param string $field
|
|
|
|
* @return void
|
|
|
|
*/
|
2007-05-20 23:28:21 +04:00
|
|
|
public function bind($name, $options = array())
|
2007-05-20 22:40:53 +04:00
|
|
|
{
|
|
|
|
if (isset($this->relations[$name])) {
|
|
|
|
unset($this->relations[$name]);
|
|
|
|
}
|
|
|
|
|
|
|
|
$lower = strtolower($name);
|
|
|
|
|
2007-05-20 23:28:21 +04:00
|
|
|
if ($this->_table->hasColumn($lower)) {
|
|
|
|
throw new Doctrine_Relation_Exception("Couldn't bind relation. Column with name " . $lower . ' already exists!');
|
2007-05-20 22:40:53 +04:00
|
|
|
}
|
|
|
|
|
|
|
|
$e = explode(' as ', $name);
|
|
|
|
$name = $e[0];
|
|
|
|
|
|
|
|
if (isset($e[1])) {
|
|
|
|
$alias = $e[1];
|
2007-05-20 23:28:21 +04:00
|
|
|
$this->_aliases[$name] = $alias;
|
2007-05-20 22:40:53 +04:00
|
|
|
} else {
|
|
|
|
$alias = $name;
|
|
|
|
}
|
2007-05-21 00:49:42 +04:00
|
|
|
if ( ! isset($options['type'])) {
|
|
|
|
throw new Doctrine_Relation_Exception('Relation type not set.');
|
|
|
|
}
|
|
|
|
|
2007-05-20 23:28:21 +04:00
|
|
|
$this->_pending[$alias] = array_merge($options, array('class' => $name, 'alias' => $alias));
|
2007-05-20 22:40:53 +04:00
|
|
|
}
|
2007-05-21 00:35:21 +04:00
|
|
|
|
|
|
|
public function getRelation($name, $recursive = true)
|
|
|
|
{
|
|
|
|
if (isset($this->_relations[$name])) {
|
|
|
|
return $this->_relations[$name];
|
|
|
|
}
|
|
|
|
|
|
|
|
if (isset($this->_pending[$name])) {
|
|
|
|
$def = $this->_pending[$name];
|
2007-05-21 01:18:52 +04:00
|
|
|
|
|
|
|
if (isset($def['refClass'])) {
|
|
|
|
$def = $this->completeAssocDefinition($def);
|
|
|
|
} else {
|
|
|
|
$def = $this->completeDefinition($def);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2007-05-21 01:35:49 +04:00
|
|
|
/**
|
|
|
|
* Completes the given association definition
|
|
|
|
*
|
|
|
|
* @param array $def definition array to be completed
|
|
|
|
* @return array completed definition array
|
|
|
|
*/
|
2007-05-21 01:18:52 +04:00
|
|
|
public function completeAssocDefinition($def)
|
|
|
|
{
|
|
|
|
$conn = $this->_table->getConnection();
|
|
|
|
$def['table'] = $conn->getTable($def['class']);
|
|
|
|
$def['definer'] = $conn->getTable($def['definer']);
|
|
|
|
$def['refTable'] = $conn->getTable($def['refClass']);
|
2007-05-21 00:35:21 +04:00
|
|
|
|
2007-05-21 01:18:52 +04:00
|
|
|
if ( ! isset($def['foreign'])) {
|
|
|
|
// foreign key not set
|
|
|
|
// try to guess the foreign key
|
2007-05-21 00:35:21 +04:00
|
|
|
|
2007-05-21 01:18:52 +04:00
|
|
|
$columns = $this->getIdentifiers($def['table']);
|
|
|
|
|
|
|
|
$def['foreign'] = $columns;
|
2007-05-21 00:35:21 +04:00
|
|
|
}
|
2007-05-21 01:18:52 +04:00
|
|
|
if ( ! isset($def['local'])) {
|
|
|
|
// local key not set
|
|
|
|
// try to guess the local key
|
|
|
|
$columns = $this->getIdentifiers($this->_table);
|
|
|
|
|
|
|
|
$def['local'] = $columns;
|
|
|
|
}
|
|
|
|
|
|
|
|
return $def;
|
|
|
|
}
|
2007-05-21 01:35:49 +04:00
|
|
|
/**
|
|
|
|
* getIdentifiers
|
|
|
|
* gives a list of identifiers from given table
|
|
|
|
*
|
|
|
|
* the identifiers are in format:
|
|
|
|
* [componentName].[identifier]
|
|
|
|
*
|
|
|
|
* @param Doctrine_Table $table table object to retrieve identifiers from
|
|
|
|
*/
|
2007-05-21 01:18:52 +04:00
|
|
|
public function getIdentifiers(Doctrine_Table $table)
|
|
|
|
{
|
|
|
|
if (is_array($table->getIdentifier())) {
|
|
|
|
$columns = array();
|
|
|
|
foreach((array) $table->getIdentifier() as $identifier) {
|
|
|
|
$columns[] = strtolower($table->getComponentName())
|
|
|
|
. '_' . $table->getIdentifier();
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
$columns = strtolower($table->getComponentName())
|
|
|
|
. '_' . $table->getIdentifier();
|
|
|
|
}
|
|
|
|
|
|
|
|
return $columns;
|
2007-05-21 00:35:21 +04:00
|
|
|
}
|
2007-05-21 21:35:20 +04:00
|
|
|
public function guessColumns($classes, Doctrine_Table $foreignTable)
|
|
|
|
{
|
|
|
|
$conn = $this->_table->getConnection();
|
|
|
|
|
|
|
|
foreach ($classes as $class) {
|
|
|
|
$table = $conn->getTable($class);
|
|
|
|
$columns = $this->getIdentifiers($table);
|
|
|
|
$found = true;
|
|
|
|
|
|
|
|
foreach ((array) $columns as $column) {
|
|
|
|
if ( ! $foreignTable->hasColumn($column)) {
|
|
|
|
$found = false;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if ($found) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if ( ! $found) {
|
|
|
|
throw new Doctrine_Relation_Exception("Couldn't find columns.");
|
|
|
|
}
|
|
|
|
|
|
|
|
return $columns;
|
|
|
|
}
|
2007-05-21 01:35:49 +04:00
|
|
|
/**
|
|
|
|
* Completes the given definition
|
|
|
|
*
|
|
|
|
* @param array $def definition array to be completed
|
|
|
|
* @return array completed definition array
|
|
|
|
*/
|
2007-05-21 00:35:21 +04:00
|
|
|
public function completeDefinition($def)
|
|
|
|
{
|
2007-05-21 00:49:42 +04:00
|
|
|
$conn = $this->_table->getConnection();
|
2007-05-21 21:35:20 +04:00
|
|
|
$def['table'] = $conn->getTable($def['class']);
|
|
|
|
$foreignClasses = array_merge($def['table']->getOption('parents'), array($def['class']));
|
|
|
|
$localClasses = array_merge($this->_table->getOption('parents'), array($this->_table->getComponentName()));
|
2007-05-21 00:35:21 +04:00
|
|
|
|
|
|
|
if (isset($def['local'])) {
|
|
|
|
if ( ! isset($def['foreign'])) {
|
|
|
|
// local key is set, but foreign key is not
|
|
|
|
// try to guess the foreign key
|
|
|
|
|
2007-05-21 21:35:20 +04:00
|
|
|
if ($def['local'] === $this->_table->getIdentifier()) {
|
|
|
|
$def['foreign'] = $this->guessColumns($localClasses, $def['table']);
|
2007-05-21 00:35:21 +04:00
|
|
|
} else {
|
|
|
|
// the foreign field is likely to be the
|
|
|
|
// identifier of the foreign class
|
|
|
|
$def['foreign'] = $def['table']->getIdentifier();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
if (isset($def['foreign'])) {
|
|
|
|
// local key not set, but foreign key is set
|
|
|
|
// try to guess the local key
|
2007-05-21 21:35:20 +04:00
|
|
|
if ($def['foreign'] === $def['table']->getIdentifier()) {
|
|
|
|
$def['local'] = $this->guessColumns($foreignClasses, $this->_table);
|
2007-05-21 00:35:21 +04:00
|
|
|
} else {
|
2007-05-21 21:35:20 +04:00
|
|
|
$def['local'] = $this->_table->getIdentifier();
|
2007-05-21 00:35:21 +04:00
|
|
|
}
|
|
|
|
} else {
|
|
|
|
// neither local or foreign key is being set
|
|
|
|
// try to guess both keys
|
|
|
|
|
2007-05-21 21:35:20 +04:00
|
|
|
$column = strtolower($this->_table->getComponentName())
|
|
|
|
. '_' . $this->_table->getIdentifier();
|
2007-05-21 00:35:21 +04:00
|
|
|
|
|
|
|
if ($def['table']->hasColumn($column)) {
|
|
|
|
$def['foreign'] = $column;
|
2007-05-21 21:35:20 +04:00
|
|
|
$def['local'] = $this->_table->getIdentifier();
|
2007-05-21 00:35:21 +04:00
|
|
|
} else {
|
|
|
|
|
|
|
|
$column = strtolower($def['table']->getComponentName())
|
|
|
|
. '_' . $def['table']->getIdentifier();
|
|
|
|
|
2007-05-21 21:35:20 +04:00
|
|
|
if ($this->_table->hasColumn($column)) {
|
2007-05-21 00:35:21 +04:00
|
|
|
$def['foreign'] = $def['table']->getIdentifier();
|
|
|
|
$def['local'] = $column;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return $def;
|
|
|
|
}
|
2007-05-20 22:40:53 +04:00
|
|
|
/**
|
|
|
|
* getRelation
|
|
|
|
*
|
|
|
|
* @param string $name component name of which a foreign key object is bound
|
|
|
|
* @return Doctrine_Relation
|
|
|
|
*/
|
2007-05-21 00:35:21 +04:00
|
|
|
public function getRelation2($name, $recursive = true)
|
2007-05-20 22:40:53 +04:00
|
|
|
{
|
|
|
|
if (isset($this->relations[$name])) {
|
|
|
|
return $this->relations[$name];
|
|
|
|
}
|
|
|
|
|
|
|
|
if ( ! $this->conn->hasTable($this->options['name'])) {
|
|
|
|
$allowExport = true;
|
|
|
|
} else {
|
|
|
|
$allowExport = false;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (isset($this->bound[$name])) {
|
|
|
|
|
|
|
|
$definition = $this->bound[$name];
|
|
|
|
|
|
|
|
list($component, $tmp) = explode('.', $definition['field']);
|
|
|
|
|
|
|
|
if ( ! isset($definition['foreign'])) {
|
|
|
|
$definition['foreign'] = $tmp;
|
|
|
|
}
|
|
|
|
|
|
|
|
unset($definition['field']);
|
|
|
|
|
|
|
|
$definition['table'] = $this->conn->getTable($definition['class'], $allowExport);
|
|
|
|
|
|
|
|
$classes = array_merge($this->options['parents'], array($this->options['name']));
|
|
|
|
|
|
|
|
foreach (array_reverse($classes) as $class) {
|
|
|
|
try {
|
|
|
|
$bound = $definition['table']->getBoundForName($class, $component);
|
|
|
|
break;
|
|
|
|
} catch(Doctrine_Table_Exception $exc) { }
|
|
|
|
}
|
|
|
|
if ( ! isset($bound)) {
|
|
|
|
throw new Doctrine_Table_Exception("Couldn't map many-to-many relation for "
|
|
|
|
. $this->options['name'] . " and $name. Components use different join tables.");
|
|
|
|
}
|
2007-05-21 01:35:49 +04:00
|
|
|
|
2007-05-20 22:40:53 +04:00
|
|
|
$e2 = explode('.', $bound['field']);
|
|
|
|
$fields = explode('-', $e2[1]);
|
|
|
|
|
|
|
|
if ($e2[0] != $component) {
|
|
|
|
throw new Doctrine_Table_Exception($e2[0] . ' doesn\'t match ' . $component);
|
|
|
|
}
|
|
|
|
$associationTable = $this->conn->getTable($e2[0], $allowExport);
|
|
|
|
|
|
|
|
if (count($fields) > 1) {
|
|
|
|
// SELF-REFERENCING THROUGH JOIN TABLE
|
|
|
|
|
|
|
|
$def['table'] = $associationTable;
|
|
|
|
$def['local'] = $this->identifier;
|
|
|
|
$def['foreign'] = $fields[0];
|
|
|
|
$def['alias'] = $e2[0];
|
|
|
|
$def['class'] = $e2[0];
|
|
|
|
$def['type'] = Doctrine_Relation::MANY_COMPOSITE;
|
|
|
|
|
|
|
|
$this->relations[$e2[0]] = new Doctrine_Relation_ForeignKey($def);
|
|
|
|
|
|
|
|
$definition['assocTable'] = $associationTable;
|
|
|
|
$definition['local'] = $fields[0];
|
|
|
|
$definition['foreign'] = $fields[1];
|
|
|
|
$relation = new Doctrine_Relation_Association_Self($definition);
|
|
|
|
} else {
|
|
|
|
if($definition['table'] === $this) {
|
|
|
|
|
|
|
|
} else {
|
|
|
|
// auto initialize a new one-to-one relationships for association table
|
2007-05-21 01:18:52 +04:00
|
|
|
$associationTable->bind($this->getComponentName(),
|
2007-05-20 22:40:53 +04:00
|
|
|
$associationTable->getComponentName(). '.' . $e2[1],
|
|
|
|
Doctrine_Relation::ONE_AGGREGATE
|
|
|
|
);
|
|
|
|
|
|
|
|
$associationTable->bind($definition['table']->getComponentName(),
|
|
|
|
$associationTable->getComponentName(). '.' . $definition['foreign'],
|
|
|
|
Doctrine_Relation::ONE_AGGREGATE
|
|
|
|
);
|
|
|
|
|
|
|
|
// NORMAL MANY-TO-MANY RELATIONSHIP
|
|
|
|
|
|
|
|
$def['table'] = $associationTable;
|
|
|
|
$def['foreign'] = $e2[1];
|
|
|
|
$def['local'] = $definition['local'];
|
|
|
|
$def['alias'] = $e2[0];
|
|
|
|
$def['class'] = $e2[0];
|
|
|
|
$def['type'] = Doctrine_Relation::MANY_COMPOSITE;
|
|
|
|
$this->relations[$e2[0]] = new Doctrine_Relation_ForeignKey($def);
|
|
|
|
|
|
|
|
$definition['local'] = $e2[1];
|
|
|
|
$definition['assocTable'] = $associationTable;
|
|
|
|
$relation = new Doctrine_Relation_Association($definition);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
$this->relations[$name] = $relation;
|
|
|
|
|
|
|
|
return $this->relations[$name];
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// load all relations
|
|
|
|
$this->getRelations();
|
|
|
|
|
|
|
|
if ($recursive) {
|
|
|
|
return $this->getRelation($name, false);
|
|
|
|
} else {
|
|
|
|
throw new Doctrine_Table_Exception($this->options['name'] . " doesn't have a relation to " . $name);
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|