Umbrellio\RollbackMissingMigrations\Helpers\DbHelper

Complexity

Total Complexity

6

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	updateBatch()	0	6	1
A	restoreBatchNumbers()	0	7	1
A	__construct()	0	3	1
A	backupBatchNumbers()	0	5	1
A	checkIfRollbackIsSuccessful()	0	8	2

<?php

declare(strict_types=1);

namespace Umbrellio\RollbackMissingMigrations\Helpers;

use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\DB;
use Umbrellio\RollbackMissingMigrations\Exceptions\RollbackMissingMigrationException;

class DbHelper
{
    private $migrationTable;

    public function __construct()
    {
        $this->migrationTable = Config::get('database.migrations');
    }

    public function backupBatchNumbers(array $migrationsNames): Collection
    {
        return DB::table($this->migrationTable)
            ->whereIn('migration', $migrationsNames)
            ->get();
    }

    public function updateBatch(array $migrationsNames, int $batchNumber)
    {
        DB::table($this->migrationTable)
            ->whereIn('migration', $migrationsNames)
            ->update([
                'batch' => $batchNumber,
            ]);
    }

    public function restoreBatchNumbers(Collection $backupData)
    {
        $backupData->each(function ($migrationData) {
            DB::table($this->migrationTable)
                ->where('migration', $migrationData->migration)
                ->update([
                    'batch' => $migrationData->batch,
                ]);
        });
    }

    public function checkIfRollbackIsSuccessful($migrationsForRollback): void
    {
        $migrations = DB::table($this->migrationTable)
            ->whereIn('migration', $migrationsForRollback)
            ->pluck('migration');

        if ($migrations->isNotEmpty()) {
            throw new RollbackMissingMigrationException($migrations);
        }
    }
}