Merge pull request #2 from jcarouth/fix-postgres-import

Fix broken Postgres support

Author: ralphschindler

README.md

@@ -4,6 +4,48 @@ Define ETL pipelines to extract, transform, and load data from one source to ano
 
 # Installation
 
-    composer require ralphschindler/php-etl-pipeliner
+    composer require ralphschindler/etl-pipeliner
 
-#
+# Usage
+
+To build an ETL pipeline you need the ETL, an Extractor, a Loader and an Executor.
+
+## ETL object
+
+Implement a class extending `\EtlPipeliner\AbstractEtl`. This package ships with an extractor and a loader for use within Laravel application. 
+
+```php
+class MyEtlObject extends \EtlPipeline\AbstractEtl
+{
+    public function extractor(): \EtlPipeliner\AbstractExtractor
+    {
+        return new \EtlPipeliner\Laravel\DbExtractor(app('db')->connection());
+    }
+
+    public function transform(array $data)
+    {
+        return $data;
+    }
+
+    public function loader(): \EtlPipeliner\AbstractLoader
+    {
+            return new \EtlPipeliner\Laravel\DbLoader(app('db')->connection());
+    }
+}
+```
+
+## Execute the ETL
+
+```php
+$executor = new \EtlPipeliner\EtlExecutor();
+
+$executor->execute(new MyEtlObject());
+```
+
+# Database support
+
+The Laravel extractor and loader currently support:
+
+- [x] Mysql
+- [x] SQL Server
+- [x] Postgres

src/Laravel/DbExtractor.php

@@ -5,6 +5,7 @@
 use EtlPipeliner\AbstractExtractor;
 use Illuminate\Database\Connection;
 use Illuminate\Database\MySqlConnection;
+use Illuminate\Database\PostgresConnection;
 use Illuminate\Database\SqlServerConnection;
 
 class DbExtractor extends AbstractExtractor
@@ -106,7 +107,7 @@ protected function createHashedQuery()
                 )
             );
         } else {
-            throw new \RuntimeException('Currently only MySQL and SqlServer are supported inside the ' . __CLASS__);
+            throw new \RuntimeException('Currently only MySQL, Postgres, and SqlServer are supported inside the ' . __CLASS__);
         }
 
         $hashedQuery = $this->connection->query();