Files
opensourcepos/app/Libraries/MY_Migration.php
jekkos 7f9321eca0 fix: Handle empty database on fresh install (#4467)
* fix: Handle empty database on fresh install
* feat: Add migration progress bar with jQuery AJAX

- Session.php: Switch to file-based sessions when migrations table doesn't exist
- OSPOS.php: Catch DatabaseException when config table missing, set defaults
- MY_Migration.php: Handle database connection failures gracefully
- Load_config.php: Set default language settings when config empty
---------

Co-authored-by: Ollama <ollama@steganos.dev>
2026-04-08 20:19:25 +00:00

159 lines
3.9 KiB
PHP

<?php
namespace App\Libraries;
use CodeIgniter\Database\Exceptions\DatabaseException;
use CodeIgniter\Database\MigrationRunner;
use Config\Database;
use stdClass;
class MY_Migration extends MigrationRunner
{
/**
* @return bool
*/
public function is_latest(): bool
{
$latest_version = $this->get_latest_migration();
$current_version = $this->get_current_version();
return $latest_version === $current_version;
}
/**
* @return int
*/
public function get_latest_migration(): int
{
$migrations = $this->findMigrations();
return basename(end($migrations)->version);
}
/**
* Gets the database version number
*
* @return int The version number of the last successfully run database migration.
*/
public static function get_current_version(): int
{
try {
$db = Database::connect();
if ($db->tableExists('migrations')) {
$builder = $db->table('migrations');
$builder->select('version')->orderBy('version', 'DESC')->limit(1);
$result = $builder->get()->getRow();
return $result ? $result->version : 0;
}
} catch (DatabaseException $e) {
return 0;
}
return 0;
}
/**
* @return void
*/
public function migrate_to_ci4(): void
{
$ci3_migrations_version = $this->ci3_migrations_exists();
if ($ci3_migrations_version) {
$this->migrate_table($ci3_migrations_version);
}
}
/**
* Checks to see if a ci3 version of the migrations table exists
*
* @return bool|string The version number of the last CI3 migration to run or false if the table is CI4 or doesn't exist
*/
private function ci3_migrations_exists(): bool|string
{
try {
if ($this->db->tableExists('migrations') && !$this->db->fieldExists('id', 'migrations')) {
$builder = $this->db->table('migrations');
$builder->select('version');
$result = $builder->get()->getRow();
return $result ? $result->version : false;
}
} catch (DatabaseException $e) {
// Database doesn't exist yet or connection failed
}
return false;
}
/**
* @param string $ci3_migrations_version
* @return void
*/
private function migrate_table(string $ci3_migrations_version): void
{
$this->convert_table();
$available_migrations = $this->get_available_migrations();
foreach ($available_migrations as $version => $path) {
if ($version > (int)$ci3_migrations_version) {
break;
}
$migration = new stdClass();
$migration->version = $version;
$migration->class = $path;
$migration->namespace = 'App';
$this->addHistory($migration, 1);
}
}
/**
* @return void
*/
public function up(): void
{
// TODO: Implement up() method.
}
/**
* @return void
*/
public function down(): void
{
// TODO: Implement down() method.
}
/**
* @return array
*/
private function get_available_migrations(): array
{
$migrations = $this->findMigrations();
$exploded_migrations = [];
foreach ($migrations as $migration) {
$version = substr($migration->uid, 0, 14);
$path = substr($migration->uid, 14);
$exploded_migrations[$version] = $path;
}
ksort($exploded_migrations);
return $exploded_migrations;
}
/**
* Converts the CI3 migrations database to CI4
* @return void
*/
public function convert_table(): void
{
$forge = Database::forge();
$forge->dropTable('migrations');
$this->ensureTable();
}
}