feat: separate virtual view and table

Author: masterbater

src/Schema/Builder.php

@@ -143,7 +143,7 @@ public function dropAllTables()
         }
     }
 
-    /** @param string|null $schema Database name */
+    /** @param  string|null $schema Database name */
     public function getTables($schema = null)
     {
         $db = $this->connection->getDatabase($schema);
@@ -161,12 +161,8 @@ public function getTables($schema = null)
             $isView = ($collectionInfo['type'] ?? '') === 'view';
             $stats = null;
 
-            if (! $isView) {
-                // Only run aggregation if it's a normal collection
-                $stats = $db->selectCollection($collectionName)->aggregate([
-                    ['$collStats' => ['storageStats' => ['scale' => 1]]],
-                    ['$project' => ['storageStats.totalSize' => 1]],
-                ])->toArray();
+            if ($isView) {
+                continue;
             }
 
             $collections[] = [
@@ -176,7 +172,45 @@ public function getTables($schema = null)
                 'size' => $stats[0]?->storageStats?->totalSize ?? null,
                 'comment' => null,
                 'collation' => null,
-                'engine' => $isView ? 'view' : 'collection',
+                'engine' => null,
+            ];
+        }
+
+        usort($collections, fn ($a, $b) => $a['name'] <=> $b['name']);
+
+        return $collections;
+    }
+
+    /** @param  string|null $schema Database name */
+    public function getViews($schema = null)
+    {
+        $db = $this->connection->getDatabase($schema);
+        $collections = [];
+
+        foreach ($db->listCollections() as $collectionInfo) {
+            $collectionName = $collectionInfo->getName();
+
+            // Skip system collections
+            if (str_starts_with($collectionName, 'system.')) {
+                continue;
+            }
+
+            // Skip views it doesnt suport aggregate
+            $isView = ($collectionInfo['type'] ?? '') === 'view';
+            $stats = null;
+
+            if (! $isView) {
+                continue;
+            }
+
+            $collections[] = [
+                'name' => $collectionName,
+                'schema' => $db->getDatabaseName(),
+                'schema_qualified_name' => $db->getDatabaseName() . '.' . $collectionName,
+                'size' => null,
+                'comment' => null,
+                'collation' => null,
+                'engine' => null,
             ];
         }
 

tests/SchemaTest.php

@@ -431,6 +431,44 @@ public function testGetTables()
             $this->fail('Collection "newcollection" not found');
         }
     }
+    public function testGetViews()
+    {
+        DB::connection('mongodb')->table('newcollection')->insert(['test' => 'value']);
+        DB::connection('mongodb')->table('newcollection_two')->insert(['test' => 'value']);
+        $dbName = DB::connection('mongodb')->getDatabaseName();
+
+      
+        DB::connection('mongodb')->getDatabase()->command([
+            'create' => 'test_view',
+            'viewOn' => 'newcollection',
+            'pipeline' => [],
+        ]);
+
+        $tables = Schema::getViews();
+        
+        $this->assertIsArray($tables);
+        $this->assertGreaterThanOrEqual(1, count($tables));
+        $found = false;
+        foreach ($tables as $table) {
+            $this->assertArrayHasKey('name', $table);
+            $this->assertArrayHasKey('size', $table);
+            $this->assertArrayHasKey('schema', $table);
+            $this->assertArrayHasKey('schema_qualified_name', $table);
+
+            if ($table['name'] === 'test_view') {
+                $this->assertEquals($dbName, $table['schema']);
+                $this->assertEquals($dbName . '.test_view', $table['schema_qualified_name']);
+                $found = true;
+            }
+
+            // Ensure system collections are excluded
+            $this->assertFalse(str_starts_with($table['name'], 'system.'));
+        }
+
+        if (! $found) {
+            $this->fail('Collection "test_view" not found');
+        }
+    }
 
     public function testGetTableListing()
     {