Merge pull request #12 from sekoyadigital/feature/prefix

Support prefixes

Author: kitar

README.md

@@ -88,6 +88,7 @@ Add dynamodb configs to config/database.php:
         'token' => env('AWS_SESSION_TOKEN'),
         'region' => env('AWS_DEFAULT_REGION', 'us-east-1'),
         'endpoint' => env('DYNAMODB_ENDPOINT'),
+        'prefix' => 'table_prefix_',
     ],
 
     ...

src/Kitar/Dynamodb/Connection.php

@@ -19,6 +19,8 @@ public function __construct($config)
     {
         $this->client = $this->createClient($config);
 
+        $this->tablePrefix = $config['prefix'] ?? '';
+
         $this->useDefaultPostProcessor();
 
         $this->useDefaultQueryGrammar();
@@ -119,7 +121,7 @@ protected function getDefaultPostProcessor()
      */
     protected function getDefaultQueryGrammar()
     {
-        return new Query\Grammar();
+        return $this->withTablePrefix(new Query\Grammar());
     }
 
     /**

src/Kitar/Dynamodb/Query/Grammar.php

@@ -55,7 +55,7 @@ public function __construct()
     public function compileTableName($table_name)
     {
         return [
-            'TableName' => $table_name
+            'TableName' => $this->tablePrefix . $table_name
         ];
     }
 

tests/Query/BuilderTest.php

@@ -974,4 +974,20 @@ public function it_can_forward_call_to_unknown_method()
 
         $query->filterNotIn(['foo', 'bar']);
     }
+
+    /** @test */
+    public function it_returns_prefixed_builder()
+    {
+        $connection = new Connection(['prefix' => 'my_table_prefix_']);
+
+        $result = $connection
+            ->table('some_table')
+            ->dryRun()
+            ->getItem(['id' => 'hello']);
+
+        $this->assertEquals(
+            'my_table_prefix_some_table',
+            $result['params']['TableName']
+        );
+    }
 }