Add MySQL connection

src/Database/Connectors/ConnectionFactory.php

@@ -36,6 +36,8 @@ public static function selectConnector($driver)
         switch ($driver) {
             case 'sqlite':
                 return new SqliteConnector;
+            case 'mysql':
+                return new MySqlConnector;
         }
 
         throw new InvalidArgumentException('The specified driver is not valid.');

src/Database/Connectors/Connector.php

@@ -28,5 +28,23 @@ abstract class Connector
    */
    abstract public function connect($config);
 
+   /**
+     * Create a new PDO connection.
+     *
+     * @param string $dsn
+     * @param array $config
+     * @param array $options
+     * @return \PDO
+     */
+    public function createConnection($dsn, array $config)
+    {
+        $username = isset($config['username']) ? $config['username'] : null;
+
+        $password = isset($config['password']) ? $config['password'] : null;
+
+        return new PDO($dsn, $username, $password, $this->options);
+    }
+
+
    // TODO: method to merge custom options
 }

src/Database/Connectors/MySqlConnector.php

@@ -0,0 +1,87 @@
+<?php
+
+namespace Marquine\Etl\Database\Connectors;
+
+use PDO;
+
+class MySqlConnector extends Connector
+{
+    /**
+    * Connect to a database.
+    *
+    * @param array $config
+    * @return \PDO
+    */
+    public function connect($config)
+    {
+        $dsn = $this->getDsn($config);
+
+        $connection = $this->createConnection($dsn, $config);
+
+        $this->postConnection($connection, $config);
+
+        return $connection;
+    }
+
+    /**
+     * Get the DSN string.
+     *
+     * @param array $config
+     * @return string
+     */
+    public function getDsn($config)
+    {
+        extract($config, EXTR_SKIP);
+
+        $dsn = [];
+
+        if (isset($unix_socket)) {
+            $dsn['unix_socket'] = $unix_socket;
+        }
+
+        if (isset($host) && ! isset($unix_socket)) {
+            $dsn['host'] = $host;
+        }
+
+        if (isset($port) && ! isset($unix_socket)) {
+            $dsn['port'] = $port;
+        }
+
+        if (isset($database) && ! isset($unix_socket)) {
+            $dsn['dbname'] = $database;
+        }
+
+        return 'mysql:' . http_build_query($dsn, '', ';');
+    }
+
+    /**
+     * Handle post connection setup.
+     *
+     * @param \PDO $connection
+     * @param array $config
+     * @return void
+     */
+    public function postConnection($connection, $config)
+    {
+        extract($config, EXTR_SKIP);
+
+        if (isset($database)) {
+            $connection->exec("use `$database`");
+        }
+
+        if (isset($charset)) {
+            $statement = "set names '$charset'";
+
+            if (isset($collation)) {
+                $statement .= " collate '$collation'";
+            }
+
+            $connection->prepare($statement)->execute();
+        }
+
+        if (isset($timezone)) {
+            $connection->prepare("set time_zone = '$timezone'")->execute();
+        }
+
+    }
+}

src/Loaders/Table.php

@@ -158,7 +158,7 @@ protected function insert($items)
                     $item['updated_at'] = $this->time;
                 }
 
-                $statement->execute(array_values($item));
+                $statement->execute($item);
             }
         };
 

src/Providers/Laravel/EtlServiceProvider.php

@@ -19,7 +19,7 @@ public function boot()
         ]);
 
         foreach (config('database.connections') as $name => $connection) {
-            if ($connection['driver'] == 'sqlite') {
+            if (in_array($connection['driver'], ['sqlite', 'mysql'])) {
                 if ($name == config('database.default')) {
                     Etl::addConnection($connection, 'default');
                 }