123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224 |
- <?php
- /*
- * 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 MIT license. For more information, see
- * <http://www.doctrine-project.org>.
- */
- namespace Doctrine\DBAL\Schema;
- /**
- * Schema manager for the MySql RDBMS.
- *
- * @author Konsta Vesterinen <kvesteri@cc.hut.fi>
- * @author Lukas Smith <smith@pooteeweet.org> (PEAR MDB2 library)
- * @author Roman Borschel <roman@code-factory.org>
- * @author Benjamin Eberlei <kontakt@beberlei.de>
- * @since 2.0
- */
- class MySqlSchemaManager extends AbstractSchemaManager
- {
- /**
- * {@inheritdoc}
- */
- protected function _getPortableViewDefinition($view)
- {
- return new View($view['TABLE_NAME'], $view['VIEW_DEFINITION']);
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableDefinition($table)
- {
- return array_shift($table);
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableUserDefinition($user)
- {
- return array(
- 'user' => $user['User'],
- 'password' => $user['Password'],
- );
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableIndexesList($tableIndexes, $tableName=null)
- {
- foreach($tableIndexes as $k => $v) {
- $v = array_change_key_case($v, CASE_LOWER);
- if($v['key_name'] == 'PRIMARY') {
- $v['primary'] = true;
- } else {
- $v['primary'] = false;
- }
- if (strpos($v['index_type'], 'FULLTEXT') !== false) {
- $v['flags'] = array('FULLTEXT');
- }
- $tableIndexes[$k] = $v;
- }
- return parent::_getPortableTableIndexesList($tableIndexes, $tableName);
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableSequenceDefinition($sequence)
- {
- return end($sequence);
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableDatabaseDefinition($database)
- {
- return $database['Database'];
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableColumnDefinition($tableColumn)
- {
- $tableColumn = array_change_key_case($tableColumn, CASE_LOWER);
- $dbType = strtolower($tableColumn['type']);
- $dbType = strtok($dbType, '(), ');
- if (isset($tableColumn['length'])) {
- $length = $tableColumn['length'];
- } else {
- $length = strtok('(), ');
- }
- $fixed = null;
- if ( ! isset($tableColumn['name'])) {
- $tableColumn['name'] = '';
- }
- $scale = null;
- $precision = null;
- $type = $this->_platform->getDoctrineTypeMapping($dbType);
- // In cases where not connected to a database DESCRIBE $table does not return 'Comment'
- if (isset($tableColumn['comment'])) {
- $type = $this->extractDoctrineTypeFromComment($tableColumn['comment'], $type);
- $tableColumn['comment'] = $this->removeDoctrineTypeFromComment($tableColumn['comment'], $type);
- }
- switch ($dbType) {
- case 'char':
- $fixed = true;
- break;
- case 'float':
- case 'double':
- case 'real':
- case 'numeric':
- case 'decimal':
- if(preg_match('([A-Za-z]+\(([0-9]+)\,([0-9]+)\))', $tableColumn['type'], $match)) {
- $precision = $match[1];
- $scale = $match[2];
- $length = null;
- }
- break;
- case 'tinyint':
- case 'smallint':
- case 'mediumint':
- case 'int':
- case 'integer':
- case 'bigint':
- case 'tinyblob':
- case 'mediumblob':
- case 'longblob':
- case 'blob':
- case 'year':
- $length = null;
- break;
- }
- $length = ((int) $length == 0) ? null : (int) $length;
- $options = array(
- 'length' => $length,
- 'unsigned' => (bool) (strpos($tableColumn['type'], 'unsigned') !== false),
- 'fixed' => (bool) $fixed,
- 'default' => isset($tableColumn['default']) ? $tableColumn['default'] : null,
- 'notnull' => (bool) ($tableColumn['null'] != 'YES'),
- 'scale' => null,
- 'precision' => null,
- 'autoincrement' => (bool) (strpos($tableColumn['extra'], 'auto_increment') !== false),
- 'comment' => (isset($tableColumn['comment'])) ? $tableColumn['comment'] : null
- );
- if ($scale !== null && $precision !== null) {
- $options['scale'] = $scale;
- $options['precision'] = $precision;
- }
- return new Column($tableColumn['field'], \Doctrine\DBAL\Types\Type::getType($type), $options);
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableForeignKeysList($tableForeignKeys)
- {
- $list = array();
- foreach ($tableForeignKeys as $value) {
- $value = array_change_key_case($value, CASE_LOWER);
- if (!isset($list[$value['constraint_name']])) {
- if (!isset($value['delete_rule']) || $value['delete_rule'] == "RESTRICT") {
- $value['delete_rule'] = null;
- }
- if (!isset($value['update_rule']) || $value['update_rule'] == "RESTRICT") {
- $value['update_rule'] = null;
- }
- $list[$value['constraint_name']] = array(
- 'name' => $value['constraint_name'],
- 'local' => array(),
- 'foreign' => array(),
- 'foreignTable' => $value['referenced_table_name'],
- 'onDelete' => $value['delete_rule'],
- 'onUpdate' => $value['update_rule'],
- );
- }
- $list[$value['constraint_name']]['local'][] = $value['column_name'];
- $list[$value['constraint_name']]['foreign'][] = $value['referenced_column_name'];
- }
- $result = array();
- foreach($list as $constraint) {
- $result[] = new ForeignKeyConstraint(
- array_values($constraint['local']), $constraint['foreignTable'],
- array_values($constraint['foreign']), $constraint['name'],
- array(
- 'onDelete' => $constraint['onDelete'],
- 'onUpdate' => $constraint['onUpdate'],
- )
- );
- }
- return $result;
- }
- }
|