. */ namespace Doctrine\ORM\Export; use Doctrine\ORM\EntityManager; /** * The ClassExporter can generate database schemas/structures from ClassMetadata * class descriptors. * * @package Doctrine * @subpackage Export * @author Konsta Vesterinen * @author Lukas Smith (PEAR MDB2 library) * @author Roman Borschel * @license http://www.opensource.org/licenses/lgpl-license.php LGPL * @link www.doctrine-project.org * @since 2.0 * @version $Revision: 4805 $ */ class ClassExporter { /** The SchemaManager */ private $_sm; /** The EntityManager */ private $_em; /** The DatabasePlatform */ private $_platform; /** * Initializes a new ClassExporter instance that uses the connection of the * provided EntityManager. * * @param Doctrine\ORM\EntityManager $em */ public function __construct(EntityManager $em) { $this->_em = $em; $this->_sm = $em->getConnection()->getSchemaManager(); $this->_platform = $em->getConnection()->getDatabasePlatform(); } /** * Exports entity classes to a database, according to the specified mappings. * * @param array $classes */ public function exportClasses(array $classes) { $foreignKeyConstraints = array(); // First we create the tables foreach ($classes as $class) { $columns = array(); $options = array(); foreach ($class->getFieldMappings() as $fieldName => $mapping) { $column = array(); $column['name'] = $mapping['columnName']; $column['type'] = $mapping['type']; $column['length'] = $mapping['length']; $column['notnull'] = ! $mapping['nullable']; if ($class->isIdentifier($fieldName)) { $column['primary'] = true; if ($class->isIdGeneratorIdentity()) { $column['autoincrement'] = true; } } $columns[$mapping['columnName']] = $column; } foreach ($class->getAssociationMappings() as $mapping) { $foreignClass = $this->_em->getClassMetadata($mapping->getTargetEntityName()); if ($mapping->isOneToOne() && $mapping->isOwningSide()) { $constraint = array(); $constraint['tableName'] = $class->getTableName(); $constraint['foreignTable'] = $foreignClass->getTableName(); $constraint['local'] = array(); $constraint['foreign'] = array(); foreach ($mapping->getJoinColumns() as $joinColumn) { $column = array(); $column['name'] = $joinColumn['name']; $column['type'] = $foreignClass->getTypeOfColumn($joinColumn['referencedColumnName']); $columns[$joinColumn['name']] = $column; $constraint['local'][] = $joinColumn['name']; $constraint['foreign'][] = $joinColumn['referencedColumnName']; } $foreignKeyConstraints[] = $constraint; } else if ($mapping->isOneToMany() && $mapping->isOwningSide()) { //... create join table, one-many through join table supported later throw new DoctrineException("Not yet implemented."); } else if ($mapping->isManyToMany() && $mapping->isOwningSide()) { //... create join table $joinTableColumns = array(); $joinTable = $mapping->getJoinTable(); $constraint1 = array(); $constraint1['tableName'] = $joinTable['name']; $constraint1['foreignTable'] = $class->getTableName(); $constraint1['local'] = array(); $constraint1['foreign'] = array(); foreach ($joinTable['joinColumns'] as $joinColumn) { $column = array(); $column['primary'] = true; $column['name'] = $joinColumn['name']; $column['type'] = $class->getTypeOfColumn($joinColumn['referencedColumnName']); $joinTableColumns[$joinColumn['name']] = $column; $constraint1['local'][] = $joinColumn['name']; $constraint1['foreign'][] = $joinColumn['referencedColumnName']; } $foreignKeyConstraints[] = $constraint1; $constraint2 = array(); $constraint2['tableName'] = $joinTable['name']; $constraint2['foreignTable'] = $foreignClass->getTableName(); $constraint2['local'] = array(); $constraint2['foreign'] = array(); foreach ($joinTable['inverseJoinColumns'] as $inverseJoinColumn) { $column = array(); $column['primary'] = true; $column['name'] = $inverseJoinColumn['name']; $column['type'] = $this->_em->getClassMetadata($mapping->getTargetEntityName()) ->getTypeOfColumn($inverseJoinColumn['referencedColumnName']); $joinTableColumns[$inverseJoinColumn['name']] = $column; $constraint2['local'][] = $inverseJoinColumn['name']; $constraint2['foreign'][] = $inverseJoinColumn['referencedColumnName']; } $foreignKeyConstraints[] = $constraint2; $this->_sm->createTable($joinTable['name'], $joinTableColumns, array()); } } $this->_sm->createTable($class->getTableName(), $columns, $options); } // Now create the foreign key constraints if ($this->_platform->supportsForeignKeyConstraints()) { foreach ($foreignKeyConstraints as $fkConstraint) { $this->_sm->createForeignKey($fkConstraint['tableName'], $fkConstraint); } } } }