PHPORM-82 Support prefix for collection names

Author: GromNaN

Diff for: src/Connection.php

@@ -66,6 +66,8 @@ public function __construct(array $config)
         // Select database
         $this->db = $this->connection->selectDatabase($this->getDefaultDatabaseName($dsn, $config));
 
+        $this->tablePrefix = $config['prefix'] ?? '';
+
         $this->useDefaultPostProcessor();
 
         $this->useDefaultSchemaGrammar();
@@ -109,7 +111,7 @@ public function table($table, $as = null)
      */
     public function getCollection($name)
     {
-        return new Collection($this, $this->db->selectCollection($name));
+        return new Collection($this, $this->db->selectCollection($this->tablePrefix . $name));
     }
 
     /** @inheritdoc */

Diff for: tests/ConnectionTest.php

@@ -178,6 +178,8 @@ public function testConnectionConfig(string $expectedUri, string $expectedDataba
 
         $this->assertSame($expectedUri, (string) $client);
         $this->assertSame($expectedDatabaseName, $connection->getMongoDB()->getDatabaseName());
+        $this->assertSame('foo', $connection->getCollection('foo')->getCollectionName());
+        $this->assertSame('foo', $connection->collection('foo')->raw()->getCollectionName());
     }
 
     public function testConnectionWithoutConfiguredDatabase(): void
@@ -200,6 +202,20 @@ public function testCollection()
         $this->assertInstanceOf(Builder::class, $collection);
     }
 
+    public function testPrefix()
+    {
+        $config = [
+            'dsn' => 'mongodb://127.0.0.1/',
+            'database' => 'tests',
+            'prefix' => 'prefix_',
+        ];
+
+        $connection = new Connection($config);
+
+        $this->assertSame('prefix_foo', $connection->getCollection('foo')->getCollectionName());
+        $this->assertSame('prefix_foo', $connection->collection('foo')->raw()->getCollectionName());
+    }
+
     public function testQueryLog()
     {
         DB::enableQueryLog();