123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139 |
- <?php
- declare(strict_types=1);
- namespace OC\DB;
- use Doctrine\DBAL\Exception;
- use Doctrine\DBAL\Schema\Schema;
- class OracleMigrator extends Migrator {
-
- protected function getDiff(Schema $targetSchema, \Doctrine\DBAL\Connection $connection): \Doctrine\DBAL\Schema\SchemaDiff {
-
- $quotedSchema = new Schema();
- foreach ($targetSchema->getTables() as $table) {
- $quotedTable = $quotedSchema->createTable(
- $this->connection->quoteIdentifier($table->getName()),
- );
- foreach ($table->getColumns() as $column) {
- $newColumn = $quotedTable->addColumn(
- $this->connection->quoteIdentifier($column->getName()),
- $column->getType()->getTypeRegistry()->lookupName($column->getType()),
- );
- $newColumn->setAutoincrement($column->getAutoincrement());
- $newColumn->setColumnDefinition($column->getColumnDefinition());
- $newColumn->setComment($column->getComment());
- $newColumn->setDefault($column->getDefault());
- $newColumn->setFixed($column->getFixed());
- $newColumn->setLength($column->getLength());
- $newColumn->setNotnull($column->getNotnull());
- $newColumn->setPrecision($column->getPrecision());
- $newColumn->setScale($column->getScale());
- $newColumn->setUnsigned($column->getUnsigned());
- $newColumn->setPlatformOptions($column->getPlatformOptions());
- }
- foreach ($table->getIndexes() as $index) {
- if ($index->isPrimary()) {
- $quotedTable->setPrimaryKey(
- array_map(function ($columnName) {
- return $this->connection->quoteIdentifier($columnName);
- }, $index->getColumns()),
-
- $index->getName(),
- );
- } elseif ($index->isUnique()) {
- $quotedTable->addUniqueIndex(
- array_map(function ($columnName) {
- return $this->connection->quoteIdentifier($columnName);
- }, $index->getColumns()),
-
- $index->getName(),
- $index->getOptions(),
- );
- } else {
- $quotedTable->addIndex(
- array_map(function ($columnName) {
- return $this->connection->quoteIdentifier($columnName);
- }, $index->getColumns()),
-
- $index->getName(),
- $index->getFlags(),
- $index->getOptions(),
- );
- }
- }
- foreach ($table->getUniqueConstraints() as $constraint) {
- $quotedTable->addUniqueConstraint(
- array_map(function ($columnName) {
- return $this->connection->quoteIdentifier($columnName);
- }, $constraint->getColumns()),
- $this->connection->quoteIdentifier($constraint->getName()),
- $constraint->getFlags(),
- $constraint->getOptions(),
- );
- }
- foreach ($table->getForeignKeys() as $foreignKey) {
- $quotedTable->addForeignKeyConstraint(
- $this->connection->quoteIdentifier($foreignKey->getForeignTableName()),
- array_map(function ($columnName) {
- return $this->connection->quoteIdentifier($columnName);
- }, $foreignKey->getLocalColumns()),
- array_map(function ($columnName) {
- return $this->connection->quoteIdentifier($columnName);
- }, $foreignKey->getForeignColumns()),
- $foreignKey->getOptions(),
- $this->connection->quoteIdentifier($foreignKey->getName()),
- );
- }
- foreach ($table->getOptions() as $option => $value) {
- $quotedTable->addOption(
- $option,
- $value,
- );
- }
- }
- foreach ($targetSchema->getSequences() as $sequence) {
- $quotedSchema->createSequence(
- $sequence->getName(),
- $sequence->getAllocationSize(),
- $sequence->getInitialValue(),
- );
- }
- return parent::getDiff($quotedSchema, $connection);
- }
-
- protected function convertStatementToScript($statement) {
- if (str_ends_with($statement, ';')) {
- return $statement . PHP_EOL . '/' . PHP_EOL;
- }
- $script = $statement . ';';
- $script .= PHP_EOL;
- $script .= PHP_EOL;
- return $script;
- }
- protected function getFilterExpression() {
- return '/^"' . preg_quote($this->config->getSystemValueString('dbtableprefix', 'oc_')) . '/';
- }
- }
|