Fisharebest\Webtrees\Http\Middleware\UpdateDatabaseSchema

Complexity

Total Complexity

14

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Importance

Changes

0

<?php

/**
 * Middleware to update the database automatically, after an upgrade.
 */
class UpdateDatabaseSchema implements MiddlewareInterface
{
    private MigrationService $migration_service;

    /**
     * @param MigrationService $migration_service
     */
    public function __construct(MigrationService $migration_service)
    {
        $this->migration_service = $migration_service;
    }

    /**
     * Update the database schema, if necessary.
     *
     * @param ServerRequestInterface  $request
     * @param RequestHandlerInterface $handler
     *
     * @return ResponseInterface
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $this->migration_service
            ->updateSchema('\Fisharebest\Webtrees\Schema', 'WT_SCHEMA_VERSION', Webtrees::SCHEMA_VERSION);

        $platform = DB::getDBALConnection()->getDatabasePlatform();
        $platform->registerDoctrineTypeMapping(dbType: 'enum', doctrineType: 'string');

        $schema_manager = DB::getDBALConnection()->createSchemaManager();
        $comparator     = $schema_manager->createComparator();
        $source         = $schema_manager->introspectSchema();
        $target         = WebtreesSchema::schema();

        // doctrine/dbal 4.0 does not have the concept of "saveSQL"
        foreach ($source->getTables() as $table) {
            if (!$target->hasTable($table->getName())) {
                $source->dropTable($table->getName());
            }
        }

<<<<<<< HEAD
        $schema_diff    = $comparator->compareSchemas(oldSchema: $source, newSchema: $target);
        $queries        = $platform->getAlterSchemaSQL($schema_diff);

        foreach ($target->getTables() as $table) {
            foreach ($table->getForeignKeys() as $foreign_key) {
                // Cannot do this with self-referencing tables
                if ($table->getName() !== $foreign_key->getForeignTableName()) {
                    $queries[] =
                        'DELETE FROM ' . $table->getName() .
                        ' WHERE (' . implode(', ', $foreign_key->getLocalColumns()) . ')' .
                        ' NOT IN (' .
                        '  SELECT ' . implode(', ', $foreign_key->getForeignColumns()) . ' FROM ' . $foreign_key->getForeignTableName() .
                        '  WHERE ' . implode(' AND ', array_map(static fn (string $col): string => $col . ' IS NOT NULL ', $foreign_key->getLocalColumns())) .
                        ' )';
                }
            }
        }

        // SQLite, PostgreSQL and SQL-Server all support DDL in transactions
        if (DB::getDBALConnection()->getDriver() instanceof AbstractMySQLDriver) {
            $phase = fn (string $query): int => str_contains($query, 'DROP FOREIGN KEY') ? 1 : (str_contains($query, 'FOREIGN KEY') ? 3 : 2);
            usort($queries, fn (string $x, string $y): int => $phase($x) <=> $phase($y));
=======
        $schema_diff = $comparator->compareSchemas(oldSchema: $source, newSchema: $target);
        $queries     = $platform->getAlterSchemaSQL(diff: $schema_diff);

        // SQLite, PostgreSQL and SQL-Server all support DDL in transactions
        if (DB::getDBALConnection()->getDriver() instanceof AbstractMySQLDriver) {
            $queries = [
                'SET FOREIGN_KEY_CHECKS := 0',
                ...$queries,
                'SET FOREIGN_KEY_CHECKS := 1',
            ];
>>>>>>> cbed0ac0da (Create a new database abstraction layer)
        } else {
            $queries = [
                'START TRANSACTION',
                ...$queries,
                'COMMIT',
            ];
        }


        foreach ($queries as $query) {
<<<<<<< HEAD
            if (str_contains($query, 'RENAME INDEX')) {
                echo '<p><i>', $query, ';</i></p>';