grocy/services/DatabaseMigrationService.php

<?php

namespace Grocy\Services;

class DatabaseMigrationService extends BaseService
{
	public function MigrateDatabase()
	{
	    $this->getDatabaseService()->ExecuteDbStatement("CREATE TABLE IF NOT EXISTS migrations (migration INTEGER NOT NULL PRIMARY KEY UNIQUE, execution_time_timestamp DATETIME DEFAULT (datetime('now', 'localtime')))");

        $migrationFiles = array();
		foreach (new \FilesystemIterator(__DIR__ . '/../migrations') as $file)
		{
            $migrationFiles[$file->getBasename()] = $file;
		}
		ksort($migrationFiles);
		foreach($migrationFiles as $migrationKey => $migrationFile)
		{
			if($migrationFile->getExtension() === 'php')
            {
                $migrationNumber = ltrim($migrationFile->getBasename('.php'), '0');
                $this->ExecutePhpMigrationWhenNeeded($migrationNumber, $migrationFile->getPathname());
            }
			else if($migrationFile->getExtension() === 'sql')
            {
                $migrationNumber = ltrim($migrationFile->getBasename('.sql'), '0');
                $this->ExecuteSqlMigrationWhenNeeded($migrationNumber, file_get_contents($migrationFile->getPathname()));
            }

        }
	}

	private function ExecuteSqlMigrationWhenNeeded(int $migrationId, string $sql)
	{
		$rowCount = $this->getDatabaseService()->ExecuteDbQuery('SELECT COUNT(*) FROM migrations WHERE migration = ' . $migrationId)->fetchColumn();
		if (intval($rowCount) === 0)
		{
			$this->getDatabaseService()->ExecuteDbStatement($sql);
			$this->getDatabaseService()->ExecuteDbStatement('INSERT INTO migrations (migration) VALUES (' . $migrationId . ')');
		}
	}

	private function ExecutePhpMigrationWhenNeeded(int $migrationId, string $phpFile)
	{
		$rowCount = $this->getDatabaseService()->ExecuteDbQuery('SELECT COUNT(*) FROM migrations WHERE migration = ' . $migrationId)->fetchColumn();
		if (intval($rowCount) === 0)
		{
			include $phpFile;
			$this->getDatabaseService()->ExecuteDbStatement('INSERT INTO migrations (migration) VALUES (' . $migrationId . ')');
		}
	}
}