Add hasColumn/hasColumns method

CHANGELOG.md

@@ -4,7 +4,7 @@ All notable changes to this project will be documented in this file.
 ## [4.5.0] - upcoming
 
 * Add GridFS integration for Laravel File Storage by @GromNaN in [#2984](https://github.com/mongodb/laravel-mongodb/pull/2985)
-
+* Add `hasColumn` and `hasColumns` method by @Alex-Belyi in [#3002](https://github.com/mongodb/laravel-mongodb/pull/3001)
 ## [4.4.0] - 2024-05-31
 
 * Support collection name prefix by @GromNaN in [#2930](https://github.com/mongodb/laravel-mongodb/pull/2930)

src/Schema/Builder.php

@@ -13,16 +13,37 @@
 
 class Builder extends \Illuminate\Database\Schema\Builder
 {
-    /** @inheritdoc */
-    public function hasColumn($table, $column)
+    /**
+     * Check if column exists in the collection schema.
+     *
+     * @param $table
+     * @param $column
+     * @return bool
+     */
+    public function hasColumn($table, $column): bool
     {
-        return true;
+        $collection = $this->connection->table($table);
+
+        return $collection->where($column, 'exists', true)
+            ->project(['_id' => 1])
+            ->exists();
     }
 
-    /** @inheritdoc */
-    public function hasColumns($table, array $columns)
+    /**
+     * Check if columns exists in the collection schema.
+     *
+     * @param       $table
+     * @param array $columns
+     *
+     * @return bool
+     */
+    public function hasColumns($table, array $columns): bool
     {
-        return true;
+        $collection = $this->connection->table($table);
+
+        return $collection->whereAll($columns, 'exists', true)
+            ->project(['_id' => 1])
+            ->exists();
     }
 
     /**

tests/SchemaTest.php

@@ -377,6 +377,25 @@ public function testRenameColumn(): void
         $this->assertSame($check[2]['column'], $check2[2]['column']);
     }
 
+    public function testHasColumn(): void
+    {
+        DB::connection()->collection('newcollection')->insert(['column1' => 'value']);
+
+        $this->assertTrue(Schema::hasColumn('newcollection', 'column1'));
+        $this->assertFalse(Schema::hasColumn('newcollection', 'column2'));
+    }
+
+    public function testHasColumns(): void
+    {
+        // Insert documents with both column1 and column2
+        DB::connection()->collection('newcollection')->insert([
+            ['column1' => 'value1', 'column2' => 'value2']
+        ]);
+
+        $this->assertTrue(Schema::hasColumns('newcollection', ['column1', 'column2']));
+        $this->assertFalse(Schema::hasColumns('newcollection', ['column1', 'column3']));
+    }
+
     protected function getIndex(string $collection, string $name)
     {
         $collection = DB::getCollection($collection);