Handle new version dbal doctrine

Author: nasrulhazim

src/Data/Schema.php

@@ -20,27 +20,45 @@ public function getData()
 
         $this->collections = [];
         foreach ($tables as $table) {
-            $columns = $schema->listTableColumns($table);
-            $foreignKeys = collect($schema->listTableForeignKeys($table))->keyBy(function ($foreignColumn) {
-                return $foreignColumn->getLocalColumns()[0];
+            $columns = method_exists($schema, 'listTableColumns')
+                ? $schema->listTableColumns($table)
+                : $schema->getColumns($table);
+            $foreignKeys = collect(
+                method_exists($schema, 'listTableForeignKeys')
+                ? $schema->listTableForeignKeys($table)
+                : $schema->getForeignKeys($table)
+            )->keyBy(function ($foreignColumn) {
+                if (is_object($foreignColumn) && method_exists($foreignColumn, 'getLocalColumns')) {
+                    return $foreignColumn->getLocalColumns()[0];
+                }
+
+                return data_get($foreignColumn, 'columns.0');
             });
 
             foreach ($columns as $column) {
-                $columnName = $column->getName();
-                $columnType = $column->getType()->getName();
+                $columnName = is_object($column) && method_exists($column, 'getName') ? $column->getName() : data_get($column, 'name');
+                $columnType = is_object($column) && method_exists($column, 'getType') ? $column->getType()->getName() : data_get($column, 'type_name');
                 if (isset($foreignKeys[$columnName])) {
                     $foreignColumn = $foreignKeys[$columnName];
-                    $foreignTable = $foreignColumn->getForeignTableName();
+                    $foreignTable = is_object($foreignColumn) && method_exists($foreignColumn, 'getForeignTableName')
+                        ? $foreignColumn->getForeignTableName()
+                        : data_get($foreignColumn, 'foreign_table');
                     $columnType = 'FK -> '.$foreignTable;
                 }
-                $length = $column->getLength();
+                $length = is_object($column) && method_exists($column, 'getLength') ? $column->getLength() : count($columns);
 
                 $details['column'] = $columnName;
                 $details['type'] = $columnType.$this->determineUnsigned($column);
                 $details['length'] = $length != 0 ? $length : null;
                 $details['default'] = $this->getDefaultValue($column);
-                $details['nullable'] = $this->getExpression(! $column->getNotNull() === true);
-                $details['comment'] = $column->getComment();
+                $details['nullable'] = $this->getExpression(
+                    is_object($column) && method_exists($column, 'getNotNull')
+                    ? ! $column->getNotNull() === true
+                    : ! data_get($column, 'nullable')
+                );
+                $details['comment'] = is_object($column) && method_exists($column, 'getComment')
+                    ? $column->getComment()
+                    : data_get($column, 'comment');
 
                 $this->collections[$table][] = $details;
             }
@@ -51,16 +69,26 @@ public function getData()
 
     private function determineUnsigned($column)
     {
-        return ($column->getUnsigned() === true) ? '(unsigned)' : '';
+        if (is_object($column) && method_exists($column, 'getUnsigned')) {
+            return ($column->getUnsigned() === true) ? '(unsigned)' : '';
+        }
+
+        return str_contains(
+            data_get($column, 'type'), 'unsigned'
+        ) === true ? '(unsigned)' : '';
     }
 
     private function getDefaultValue($column)
     {
-        if ($column->getType()->getName() == 'boolean') {
+        if (is_object($column) && method_exists($column, 'getType') && $column->getType()->getName() == 'boolean') {
             return $column->getDefault() ? 'true' : 'false';
         }
 
-        return $column->getDefault();
+        if (is_object($column) && method_exists($column, 'getDefault')) {
+            return $column->getDefault();
+        }
+
+        return data_get($column, 'default') ? 'true' : 'false';
     }
 
     private function getExpression($status)

src/Processor.php

@@ -58,9 +58,21 @@ public function connect(string $database_connection, string $format): self
 
         throw_if(! class_exists($this->presenter), 'RuntimeException', "$this->presenter not exists.");
 
-        $this->connection = DB::connection($this->database_connection)->getDoctrineConnection();
-        $this->schema = $this->connection->createSchemaManager();
-        $this->tables = $this->schema->listTableNames();
+        $this->connection = DB::connection($this->database_connection);
+
+        if (method_exists($this->connection, 'getDoctrineConnection')) {
+            $this->connection = $this->connection->getDoctrineConnection();
+            $this->schema = $this->connection->createSchemaManager();
+            $this->tables = $this->schema->listTableNames();
+        } else {
+            $schemaBuilder = $this->connection->getSchemaBuilder();
+            $tables = method_exists($schemaBuilder, 'getTables')
+                ? $schemaBuilder->getTables()
+                : [];
+
+            $this->tables = array_column($tables, 'name');
+            $this->schema = $schemaBuilder;
+        }
 
         return $this;
     }