. */ /** * Doctrine_Relation_Parser * * @author Konsta Vesterinen * @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 */ protected $_relations = array(); /** * @var array $_pending relations waiting for parsing */ protected $_pending = array(); /** * 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() { 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]; } public function hasRelation($name) { if ( ! isset($this->_pending[$name]) && ! isset($this->_relations[$name])) { return false; } return true; } /** * binds a relation * * @param string $name * @param string $field * @return void */ public function bind($name, $options = array()) { if (isset($this->relations[$name])) { unset($this->relations[$name]); } $lower = strtolower($name); if ($this->_table->hasColumn($lower)) { throw new Doctrine_Relation_Exception("Couldn't bind relation. Column with name " . $lower . ' already exists!'); } $e = explode(' as ', $name); $name = $e[0]; $alias = isset($e[1]) ? $e[1] : $name; if ( ! isset($options['type'])) { throw new Doctrine_Relation_Exception('Relation type not set.'); } if (strpos($name, '[Component]') !== false) { $name = str_replace('[Component]', $this->_table->getComponentName(), $name); $templateName = substr($name, strlen($this->_table->getComponentName())); if (substr($name, -8) === 'Template') { $name = substr($name, 0, -8); } $parent = new ReflectionClass($this->_table->getComponentName()); $fileName = dirname($parent->getFileName()) . DIRECTORY_SEPARATOR . $name . '.php'; if (file_exists($fileName)) { require_once($fileName); } if ( ! class_exists($name)) { $template = new $templateName(); $conn = $this->_table->getConnection(); $refl = new ReflectionClass($templateName); $file = file($refl->getFileName()); $lines[] = 'class ' . $name . ' extends Doctrine_Record' . "\n"; $lines[] = '{'. "\n"; // read all template method definitions foreach ($refl->getMethods() as $method) { if ($method->getDeclaringClass()->getName() === $refl->getName()) { $start = $method->getStartLine() - 1; $end = $method->getEndLine() - 1; // append method definitions $lines = array_merge($lines, array_slice($file, $start, ($end - $start) + 1)); } } $lines[] = '}' . "\n"; if (file_exists($fileName)) { throw new Doctrine_Template_Exception("Couldn't generate class for template."); } $code = str_replace('[Component]', $this->_table->getComponentName(), implode("", $lines)); // create the actual class file $fp = fopen($fileName, 'w+'); fwrite($fp, "_pending[$alias] = array_merge($options, array('class' => $name, 'alias' => $alias)); $m = Doctrine_Manager::getInstance(); if (isset($options['onDelete'])) { $m->addDeleteAction($name, $this->_table->getComponentName(), $options['onDelete']); } if (isset($options['onUpdate'])) { $m->addUpdateAction($name, $this->_table->getComponentName(), $options['onUpdate']); } return $this->_pending[$alias]; } /** * getRelation * * @param string $alias relation alias */ public function getRelation($alias, $recursive = true) { if (isset($this->_relations[$alias])) { return $this->_relations[$alias]; } if (isset($this->_pending[$alias])) { $def = $this->_pending[$alias]; // check if reference class name exists // if it does we are dealing with association relation if (isset($def['refClass'])) { $def = $this->completeAssocDefinition($def); $localClasses = array_merge($this->_table->getOption('parents'), array($this->_table->getComponentName())); if ( ! isset($this->_pending[$def['refClass']]) && ! isset($this->_relations[$def['refClass']])) { $parser = $def['refTable']->getRelationParser(); if ( ! $parser->hasRelation($this->_table->getComponentName())) { $parser->bind($this->_table->getComponentName(), array('type' => Doctrine_Relation::ONE, 'local' => $def['local'], 'foreign' => $this->_table->getIdentifier(), 'localKey' => true, )); } if ( ! $this->hasRelation($def['refClass'])) { $this->bind($def['refClass'], array('type' => Doctrine_Relation::MANY, 'foreign' => $def['local'], 'local' => $this->_table->getIdentifier())); } } if (in_array($def['class'], $localClasses)) { $rel = new Doctrine_Relation_Nest($def); } else { $rel = new Doctrine_Relation_Association($def); } } else { // simple foreign key relation $def = $this->completeDefinition($def); if (isset($def['localKey'])) { $rel = new Doctrine_Relation_LocalKey($def); } else { $rel = new Doctrine_Relation_ForeignKey($def); } } if (isset($rel)) { // unset pending relation unset($this->_pending[$alias]); $this->_relations[$alias] = $rel; return $rel; } } if ($recursive) { $this->getRelations(); return $this->getRelation($alias, false); } else { throw new Doctrine_Table_Exception('Unknown relation alias ' . $alias); } } /** * getRelations * returns an array containing all relation objects * * @return array an array of Doctrine_Relation objects */ public function getRelations() { foreach ($this->_pending as $k => $v) { $this->getRelation($k); } return $this->_relations; } /** * Completes the given association definition * * @param array $def definition array to be completed * @return array completed definition array */ public function completeAssocDefinition($def) { $conn = $this->_table->getConnection(); $def['table'] = $conn->getTable($def['class']); $def['refTable'] = $conn->getTable($def['refClass']); $id = $def['refTable']->getIdentifier(); if (count($id) > 1) { if ( ! isset($def['foreign'])) { // foreign key not set // try to guess the foreign key $def['foreign'] = ($def['local'] === $id[0]) ? $id[1] : $id[0]; } if ( ! isset($def['local'])) { // foreign key not set // try to guess the foreign key $def['local'] = ($def['foreign'] === $id[0]) ? $id[1] : $id[0]; } } else { if ( ! isset($def['foreign'])) { // foreign key not set // try to guess the foreign key $columns = $this->getIdentifiers($def['table']); $def['foreign'] = $columns; } if ( ! isset($def['local'])) { // local key not set // try to guess the local key $columns = $this->getIdentifiers($this->_table); $def['local'] = $columns; } } return $def; } /** * 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 */ 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; } /** * guessColumns * * @param array $classes an array of class names * @param Doctrine_Table $foreignTable foreign table object * @return array an array of column names */ public function guessColumns(array $classes, Doctrine_Table $foreignTable) { $conn = $this->_table->getConnection(); foreach ($classes as $class) { try { $table = $conn->getTable($class); } catch (Doctrine_Table_Exception $e) { continue; } $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; } /** * Completes the given definition * * @param array $def definition array to be completed * @return array completed definition array */ public function completeDefinition($def) { $conn = $this->_table->getConnection(); $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())); if (isset($def['local'])) { if ( ! isset($def['foreign'])) { // local key is set, but foreign key is not // try to guess the foreign key if ($def['local'] === $this->_table->getIdentifier()) { $def['foreign'] = $this->guessColumns($localClasses, $def['table']); } else { // the foreign field is likely to be the // identifier of the foreign class $def['foreign'] = $def['table']->getIdentifier(); $def['localKey'] = true; } } else { if ($def['local'] !== $this->_table->getIdentifier() && $def['type'] == Doctrine_Relation::ONE) { $def['localKey'] = true; } } } else { if (isset($def['foreign'])) { // local key not set, but foreign key is set // try to guess the local key if ($def['foreign'] === $def['table']->getIdentifier()) { $def['localKey'] = true; try { $def['local'] = $this->guessColumns($foreignClasses, $this->_table); } catch (Doctrine_Relation_Exception $e) { $def['local'] = $this->_table->getIdentifier(); } } else { $def['local'] = $this->_table->getIdentifier(); } } else { // neither local or foreign key is being set // try to guess both keys $conn = $this->_table->getConnection(); // the following loops are needed for covering inheritance foreach ($localClasses as $class) { $table = $conn->getTable($class); $column = strtolower($table->getComponentName()) . '_' . $table->getIdentifier(); foreach ($foreignClasses as $class2) { $table2 = $conn->getTable($class2); if ($table2->hasColumn($column)) { $def['foreign'] = $column; $def['local'] = $table->getIdentifier(); return $def; } } } foreach ($foreignClasses as $class) { $table = $conn->getTable($class); $column = strtolower($table->getComponentName()) . '_' . $table->getIdentifier(); foreach ($localClasses as $class2) { $table2 = $conn->getTable($class2); if ($table2->hasColumn($column)) { $def['foreign'] = $table->getIdentifier(); $def['local'] = $column; $def['localKey'] = true; return $def; } } } // auto-add columns and auto-build relation $columns = array(); foreach ((array) $this->_table->getIdentifier() as $id) { $column = strtolower($table->getComponentName()) . '_' . $id; $col = $this->_table->getDefinitionOf($id); $type = $col['type']; $length = $col['length']; unset($col['type']); unset($col['length']); unset($col['autoincrement']); unset($col['sequence']); unset($col['primary']); $def['table']->setColumn($column, $type, $length, $col); $columns[] = $column; } if (count($columns) > 1) { $def['foreign'] = $columns; } else { $def['foreign'] = $columns[0]; } $def['local'] = $this->_table->getIdentifier(); } } return $def; } }