123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238 |
- <?php
- namespace Doctrine\DBAL\Schema;
- use Doctrine\DBAL\Platforms\SQLAnywherePlatform;
- use Doctrine\DBAL\Types\Type;
- use function assert;
- use function is_string;
- use function preg_replace;
- /**
- * SAP Sybase SQL Anywhere schema manager.
- */
- class SQLAnywhereSchemaManager extends AbstractSchemaManager
- {
- /**
- * {@inheritdoc}
- *
- * Starts a database after creation
- * as SQL Anywhere needs a database to be started
- * before it can be used.
- *
- * @see startDatabase
- */
- public function createDatabase($database)
- {
- parent::createDatabase($database);
- $this->startDatabase($database);
- }
- /**
- * {@inheritdoc}
- *
- * Tries stopping a database before dropping
- * as SQL Anywhere needs a database to be stopped
- * before it can be dropped.
- *
- * @see stopDatabase
- */
- public function dropDatabase($database)
- {
- $this->tryMethod('stopDatabase', $database);
- parent::dropDatabase($database);
- }
- /**
- * Starts a database.
- *
- * @param string $database The name of the database to start.
- *
- * @return void
- */
- public function startDatabase($database)
- {
- assert($this->_platform instanceof SQLAnywherePlatform);
- $this->_execSql($this->_platform->getStartDatabaseSQL($database));
- }
- /**
- * Stops a database.
- *
- * @param string $database The name of the database to stop.
- *
- * @return void
- */
- public function stopDatabase($database)
- {
- assert($this->_platform instanceof SQLAnywherePlatform);
- $this->_execSql($this->_platform->getStopDatabaseSQL($database));
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableDatabaseDefinition($database)
- {
- return $database['name'];
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableSequenceDefinition($sequence)
- {
- return new Sequence($sequence['sequence_name'], $sequence['increment_by'], $sequence['start_with']);
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableColumnDefinition($tableColumn)
- {
- $type = $this->_platform->getDoctrineTypeMapping($tableColumn['type']);
- $type = $this->extractDoctrineTypeFromComment($tableColumn['comment'], $type);
- $tableColumn['comment'] = $this->removeDoctrineTypeFromComment($tableColumn['comment'], $type);
- $precision = null;
- $scale = null;
- $fixed = false;
- $default = null;
- if ($tableColumn['default'] !== null) {
- // Strip quotes from default value.
- $default = preg_replace(["/^'(.*)'$/", "/''/"], ['$1', "'"], $tableColumn['default']);
- if ($default === 'autoincrement') {
- $default = null;
- }
- }
- switch ($tableColumn['type']) {
- case 'binary':
- case 'char':
- case 'nchar':
- $fixed = true;
- break;
- }
- switch ($type) {
- case 'decimal':
- case 'float':
- $precision = $tableColumn['length'];
- $scale = $tableColumn['scale'];
- break;
- }
- return new Column(
- $tableColumn['column_name'],
- Type::getType($type),
- [
- 'length' => $type === 'string' ? $tableColumn['length'] : null,
- 'precision' => $precision,
- 'scale' => $scale,
- 'unsigned' => (bool) $tableColumn['unsigned'],
- 'fixed' => $fixed,
- 'notnull' => (bool) $tableColumn['notnull'],
- 'default' => $default,
- 'autoincrement' => (bool) $tableColumn['autoincrement'],
- 'comment' => isset($tableColumn['comment']) && $tableColumn['comment'] !== ''
- ? $tableColumn['comment']
- : null,
- ]
- );
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableDefinition($table)
- {
- return $table['table_name'];
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableForeignKeyDefinition($tableForeignKey)
- {
- return new ForeignKeyConstraint(
- $tableForeignKey['local_columns'],
- $tableForeignKey['foreign_table'],
- $tableForeignKey['foreign_columns'],
- $tableForeignKey['name'],
- $tableForeignKey['options']
- );
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableForeignKeysList($tableForeignKeys)
- {
- $foreignKeys = [];
- foreach ($tableForeignKeys as $tableForeignKey) {
- if (! isset($foreignKeys[$tableForeignKey['index_name']])) {
- $foreignKeys[$tableForeignKey['index_name']] = [
- 'local_columns' => [$tableForeignKey['local_column']],
- 'foreign_table' => $tableForeignKey['foreign_table'],
- 'foreign_columns' => [$tableForeignKey['foreign_column']],
- 'name' => $tableForeignKey['index_name'],
- 'options' => [
- 'notnull' => $tableForeignKey['notnull'],
- 'match' => $tableForeignKey['match'],
- 'onUpdate' => $tableForeignKey['on_update'],
- 'onDelete' => $tableForeignKey['on_delete'],
- 'check_on_commit' => $tableForeignKey['check_on_commit'],
- 'clustered' => $tableForeignKey['clustered'],
- 'for_olap_workload' => $tableForeignKey['for_olap_workload'],
- ],
- ];
- } else {
- $foreignKeys[$tableForeignKey['index_name']]['local_columns'][] = $tableForeignKey['local_column'];
- $foreignKeys[$tableForeignKey['index_name']]['foreign_columns'][] = $tableForeignKey['foreign_column'];
- }
- }
- return parent::_getPortableTableForeignKeysList($foreignKeys);
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableTableIndexesList($tableIndexes, $tableName = null)
- {
- foreach ($tableIndexes as &$tableIndex) {
- $tableIndex['primary'] = (bool) $tableIndex['primary'];
- $tableIndex['flags'] = [];
- if ($tableIndex['clustered']) {
- $tableIndex['flags'][] = 'clustered';
- }
- if ($tableIndex['with_nulls_not_distinct']) {
- $tableIndex['flags'][] = 'with_nulls_not_distinct';
- }
- if (! $tableIndex['for_olap_workload']) {
- continue;
- }
- $tableIndex['flags'][] = 'for_olap_workload';
- }
- return parent::_getPortableTableIndexesList($tableIndexes, $tableName);
- }
- /**
- * {@inheritdoc}
- */
- protected function _getPortableViewDefinition($view)
- {
- $definition = preg_replace('/^.*\s+as\s+SELECT(.*)/i', 'SELECT$1', $view['view_def']);
- assert(is_string($definition));
- return new View($view['table_name'], $definition);
- }
- }
|