App]

kernel/console/controllers/MigrationController.php

@@ -0,0 +1,95 @@
+<?php
+
+
+namespace kernel\console\controllers;
+
+
+use Illuminate\Filesystem\Filesystem;
+use kernel\App;
+use kernel\console\CgMigrationCreator;
+use kernel\console\ConsoleController;
+use Illuminate\Database\Migrations\DatabaseMigrationRepository;
+use Illuminate\Database\Migrations\MigrationCreator;
+use Illuminate\Database\Migrations\Migrator;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Database\Schema\Builder;
+
+
+class MigrationController extends ConsoleController
+{
+    //create migrations table
+    public function actionCreateMigrationTable(): void
+    {
+        try {
+            App::$db->schema->create('migration', function (Blueprint $table) {
+                $table->bigIncrements('id');
+                $table->string('migration', 255);
+                $table->integer('batch');
+            });
+            $this->out->r("Success", 'green');
+        }
+        catch (\Exception $e){
+            $this->out->r($e->getMessage(), 'red');
+        }
+    }
+
+    // create migrations
+    public function actionCreate(): void
+    {
+        try {
+            if (!isset($this->argv['name'])) {
+                throw new \Exception('Missing migration "--name" specified');
+            }
+            $m = new CgMigrationCreator(new Filesystem(), CgMigrationCreator::getCustomStubPath());
+
+            $path = $this->argv['path'] ?? 'migrations';
+
+            $res = $m->create(
+                $this->argv['name'],
+                ROOT_DIR . '/' . $path,
+                $this->argv['table'] ?? null,
+                !isset($this->argv['update'])
+            );
+            $this->out->r(basename($res) . " created", 'green');
+        } catch (\Exception $e) {
+            $this->out->r('Message: ' .$e->getMessage(), 'red');
+        }
+    }
+
+    //execute migrations
+    public function actionRun(): void
+    {
+        try {
+            $dmr = new DatabaseMigrationRepository(App::$db->capsule->getDatabaseManager(), 'migration');
+
+            $m = new Migrator($dmr, App::$db->capsule->getDatabaseManager(), new Filesystem());
+            //$migrationPaths = array_merge(App::$migrationsPaths, [ROOT_DIR . '/migrations']);
+            $migrationPaths = [ROOT_DIR . '/migrations'];
+            $res = $m->run($migrationPaths);
+            foreach ($res as $re){
+                $this->out->r(basename($re), 'green');
+            }
+        }
+        catch (\Exception $e){
+            $this->out->r('Message: ' .$e->getMessage(), 'red');
+        }
+    }
+
+    public function actionRollback(): void
+    {
+        try {
+            $dmr = new DatabaseMigrationRepository(App::$db->capsule->getDatabaseManager(), 'migration');
+
+            $m = new Migrator($dmr, App::$db->capsule->getDatabaseManager(), new Filesystem());
+            //$migrationPaths = array_merge(App::$migrationsPaths, [WORKSPACE_DIR . '/console/migrations']);
+            $migrationPaths = [ROOT_DIR . '/console/migrations'];
+            $res = $m->rollback($migrationPaths);
+            foreach ($res as $re){
+                $this->out->r(basename($re), 'green');
+            }
+        }
+        catch (\Exception $e){
+            $this->out->r('Message: ' .$e->getMessage(), 'red');
+        }
+    }
+}