Compatible with firebird3.0

composer.json

@@ -1,12 +1,12 @@
 {
-    "name": "marquine/php-etl",
+    "name": "claonilton/php-etl",
     "description": "Extract, Transform and Load data using PHP.",
     "keywords": ["etl", "extract", "transform", "load", "extraction", "transformation", "seed", "data", "laravel"],
     "license": "MIT",
     "authors": [
         {
-            "name": "Leonardo Marquine",
-            "email": "leonardomarquine@gmail.com"
+            "name": "Claonilton Jr",
+            "email": "claonilton@vscorp.com.br"
         }
     ],
     "require": {

src/Database/ConnectionFactory.php

@@ -38,6 +38,8 @@ protected function getConnector($driver)
                 return new Connectors\PostgresConnector;
             case 'sqlsrv':
                 return new Connectors\SqlServerConnector;
+            case 'firebird':
+                return new Connectors\FirebirdConnector;
         }
 
         throw new InvalidArgumentException("Unsupported driver: $driver");

src/Database/Connectors/FirebirdConnector.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace Marquine\Etl\Database\Connectors;
+
+class FirebirdConnector extends Connector
+{
+    /**
+    * Connect to a database.
+    *
+    * @param  array  $config
+    * @return \PDO
+    */
+    public function connect($config)
+    {
+        $dsn = $this->getDsn($config);
+
+        $connection = $this->createConnection($dsn, $config);
+
+
+        return $connection;
+
+
+    }
+
+       /**
+     * Get the DSN string.
+     *
+     * @param  array  $config
+     * @return string
+     */
+    public function getDsn($config)
+    {
+        extract($config, EXTR_SKIP);
+
+        $dsn = [];
+
+        if (isset($host) && ! isset($unix_socket)) {
+            $dsn['host'] = $host;
+        }
+
+        if (isset($port) && ! isset($unix_socket)) {
+            $dsn['port'] = $port;
+        }
+        if (isset($charset) && ! isset($unix_socket)) {
+            $dsn['charset'] = $charset;
+        }
+        if (isset($port) && isset($database) && isset($host) && ! isset($unix_socket)) {
+            $dsn['dbname'] = "$host/$port:$database";
+        }
+
+        return urldecode('firebird:' . http_build_query($dsn, '', ';'));
+
+
+    }
+}

src/Transformers/Base64Decode.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace Marquine\Etl\Transformers;
+
+use Marquine\Etl\Row;
+
+class Base64Decode extends Transformer
+{
+    /**
+     * Transformer columns.
+     *
+     * @var array
+     */
+    protected $columns = [];
+
+    /**
+     * Properties that can be set via the options method.
+     *
+     * @var array
+     */
+    protected $availableOptions = [
+        'columns',
+    ];
+
+    /**
+     * Transform the given row.
+     *
+     * @param  \Marquine\Etl\Row  $row
+     * @return void
+     */
+    public function transform(Row $row)
+    {
+        $row->transform($this->columns, function ($column) {
+            return base64_decode($column);
+        });
+    }
+}
+

src/Transformers/Base64Encode.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace Marquine\Etl\Transformers;
+
+use Marquine\Etl\Row;
+
+class Base64Encode extends Transformer
+{
+    /**
+     * Transformer columns.
+     *
+     * @var array
+     */
+    protected $columns = [];
+
+    /**
+     * Properties that can be set via the options method.
+     *
+     * @var array
+     */
+    protected $availableOptions = [
+        'columns',
+    ];
+
+    /**
+     * Transform the given row.
+     *
+     * @param  \Marquine\Etl\Row  $row
+     * @return void
+     */
+    public function transform(Row $row)
+    {
+        $row->transform($this->columns, function ($column) {
+            return base64_encode($column);
+	});
+	return($row);
+
+    }
+}
+

src/bindings.php

@@ -28,6 +28,8 @@
 $container->bind('replace_transformer', Marquine\Etl\Transformers\Replace::class);
 $container->bind('trim_transformer', Marquine\Etl\Transformers\Trim::class);
 $container->bind('unique_rows_transformer', Marquine\Etl\Transformers\UniqueRows::class);
+$container->bind('base64_encode_transformer', Marquine\Etl\Transformers\Base64Encode::class);
+$container->bind('base64_decode_transformer', Marquine\Etl\Transformers\Base64Decode::class);
 
 // Loaders
 $container->bind('insert_loader', Marquine\Etl\Loaders\Insert::class);