From 0111e4616e6c83e1b6941c82678031fb884be1cf Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tom=C3=A1=C5=A1=20Zat=C5=99ep=C3=A1lek?=
 <tzatrepalek@inwk.com>
Date: Mon, 21 Jan 2019 14:37:03 +0100
Subject: [PATCH 1/5] PSR-4 autoloading for exceptions

---
 composer.bridgeless.json   |  2 +-
 composer.json              |  2 +-
 src/Exception.php          | 14 +++++++++
 src/ExecutionException.php | 17 +++++++++++
 src/IOException.php        | 17 +++++++++++
 src/LockException.php      | 17 +++++++++++
 src/LogicException.php     | 17 +++++++++++
 src/RuntimeException.php   | 17 +++++++++++
 src/exceptions.php         | 58 --------------------------------------
 9 files changed, 101 insertions(+), 60 deletions(-)
 create mode 100644 src/Exception.php
 create mode 100644 src/ExecutionException.php
 create mode 100644 src/IOException.php
 create mode 100644 src/LockException.php
 create mode 100644 src/LogicException.php
 create mode 100644 src/RuntimeException.php
 delete mode 100644 src/exceptions.php

diff --git a/composer.bridgeless.json b/composer.bridgeless.json
index 74aa5598..5a7fb0b8 100644
--- a/composer.bridgeless.json
+++ b/composer.bridgeless.json
@@ -5,7 +5,7 @@
 	},
 	"autoload": {
 		"psr-4": { "Nextras\\Migrations\\": "src/" },
-		"classmap": ["src/exceptions.php", "src/deprecated"]
+		"classmap": ["src/deprecated"]
 	},
 	"autoload-dev": {
 		"classmap": ["tests/inc"]
diff --git a/composer.json b/composer.json
index 29c2e670..26d29b65 100644
--- a/composer.json
+++ b/composer.json
@@ -39,7 +39,7 @@
 	},
 	"autoload": {
 		"psr-4": { "Nextras\\Migrations\\": "src/" },
-		"classmap": ["src/exceptions.php", "src/deprecated"]
+		"classmap": ["src/deprecated"]
 	},
 	"autoload-dev": {
 		"classmap": ["tests/inc"]
diff --git a/src/Exception.php b/src/Exception.php
new file mode 100644
index 00000000..426ddba6
--- /dev/null
+++ b/src/Exception.php
@@ -0,0 +1,14 @@
+<?php
+
+/**
+ * This file is part of the Nextras community extensions of Nette Framework
+ *
+ * @license    New BSD License
+ * @link       https://github.com/nextras/migrations
+ */
+
+namespace Nextras\Migrations;
+
+interface Exception
+{
+}
diff --git a/src/ExecutionException.php b/src/ExecutionException.php
new file mode 100644
index 00000000..35b8b9be
--- /dev/null
+++ b/src/ExecutionException.php
@@ -0,0 +1,17 @@
+<?php
+
+/**
+ * This file is part of the Nextras community extensions of Nette Framework
+ *
+ * @license    New BSD License
+ * @link       https://github.com/nextras/migrations
+ */
+
+namespace Nextras\Migrations;
+
+/**
+ * Executing migration has failed.
+ */
+class ExecutionException extends RuntimeException
+{
+}
diff --git a/src/IOException.php b/src/IOException.php
new file mode 100644
index 00000000..ba6495ab
--- /dev/null
+++ b/src/IOException.php
@@ -0,0 +1,17 @@
+<?php
+
+/**
+ * This file is part of the Nextras community extensions of Nette Framework
+ *
+ * @license    New BSD License
+ * @link       https://github.com/nextras/migrations
+ */
+
+namespace Nextras\Migrations;
+
+/**
+ * Permission denied, file not found...
+ */
+class IOException extends RuntimeException
+{
+}
diff --git a/src/LockException.php b/src/LockException.php
new file mode 100644
index 00000000..90d71c8f
--- /dev/null
+++ b/src/LockException.php
@@ -0,0 +1,17 @@
+<?php
+
+/**
+ * This file is part of the Nextras community extensions of Nette Framework
+ *
+ * @license    New BSD License
+ * @link       https://github.com/nextras/migrations
+ */
+
+namespace Nextras\Migrations;
+
+/**
+ * Lock cannot be released or acquired.
+ */
+class LockException extends RuntimeException
+{
+}
diff --git a/src/LogicException.php b/src/LogicException.php
new file mode 100644
index 00000000..acdfaeba
--- /dev/null
+++ b/src/LogicException.php
@@ -0,0 +1,17 @@
+<?php
+
+/**
+ * This file is part of the Nextras community extensions of Nette Framework
+ *
+ * @license    New BSD License
+ * @link       https://github.com/nextras/migrations
+ */
+
+namespace Nextras\Migrations;
+
+/**
+ * Error in usage or implementation.
+ */
+class LogicException extends \LogicException implements Exception
+{
+}
diff --git a/src/RuntimeException.php b/src/RuntimeException.php
new file mode 100644
index 00000000..13317810
--- /dev/null
+++ b/src/RuntimeException.php
@@ -0,0 +1,17 @@
+<?php
+
+/**
+ * This file is part of the Nextras community extensions of Nette Framework
+ *
+ * @license    New BSD License
+ * @link       https://github.com/nextras/migrations
+ */
+
+namespace Nextras\Migrations;
+
+/**
+ * Error during runtime.
+ */
+abstract class RuntimeException extends \RuntimeException implements Exception
+{
+}
diff --git a/src/exceptions.php b/src/exceptions.php
deleted file mode 100644
index 051aacde..00000000
--- a/src/exceptions.php
+++ /dev/null
@@ -1,58 +0,0 @@
-<?php
-
-/**
- * This file is part of the Nextras community extensions of Nette Framework
- *
- * @license    New BSD License
- * @link       https://github.com/nextras/migrations
- */
-
-namespace Nextras\Migrations;
-
-
-/**
- * Marker interface.
- */
-interface Exception
-{
-}
-
-
-/**
- * Error in usage or implementation.
- */
-class LogicException extends \LogicException implements Exception
-{
-}
-
-
-/**
- * Error during runtime.
- */
-abstract class RuntimeException extends \RuntimeException implements Exception
-{
-}
-
-
-/**
- * Executing migration has failed.
- */
-class ExecutionException extends RuntimeException
-{
-}
-
-
-/**
- * Permission denied, file not found...
- */
-class IOException extends RuntimeException
-{
-}
-
-
-/**
- * Lock cannot be released or acquired.
- */
-class LockException extends RuntimeException
-{
-}

From 34cfdf2ce901671147dfd4ab683bb72dcd092699 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tom=C3=A1=C5=A1=20Zat=C5=99ep=C3=A1lek?=
 <tzatrepalek@inwk.com>
Date: Tue, 22 Jan 2019 16:25:42 +0100
Subject: [PATCH 2/5] Phalcon adapter and migration task

---
 composer.json                          |   1 +
 src/Bridges/Phalcon/MigrationsTask.php | 245 +++++++++++++++++++++++++
 src/Bridges/Phalcon/PhalconAdapter.php |  80 ++++++++
 3 files changed, 326 insertions(+)
 create mode 100644 src/Bridges/Phalcon/MigrationsTask.php
 create mode 100755 src/Bridges/Phalcon/PhalconAdapter.php

diff --git a/composer.json b/composer.json
index 26d29b65..8005053e 100644
--- a/composer.json
+++ b/composer.json
@@ -17,6 +17,7 @@
 		"nette/tester": "~1.7 | ~2.0",
 		"nette/utils": "~2.3",
 		"nextras/dbal": "~1.0 | ~2.0 | ~3.0",
+		"phalcon/ide-stubs": "~3.4",
 		"symfony/config": "~2.6 | ~3.0 | ~4.0",
 		"symfony/console": "~2.6 | ~3.0 | ~4.0",
 		"symfony/dependency-injection": "~2.6 | ~3.0 | ~4.0",
diff --git a/src/Bridges/Phalcon/MigrationsTask.php b/src/Bridges/Phalcon/MigrationsTask.php
new file mode 100644
index 00000000..a6a09fef
--- /dev/null
+++ b/src/Bridges/Phalcon/MigrationsTask.php
@@ -0,0 +1,245 @@
+<?php
+
+namespace Nextras\Migrations\Bridges\Phalcon;
+
+use Nextras\Migrations\Controllers\ConsoleController;
+use Nextras\Migrations\Extensions\SqlHandler;
+use Nextras\Migrations\IDriver;
+use Phalcon\Cli\Task;
+use Phalcon\Di\FactoryDefault\Cli;
+
+class MigrationsTask extends Task
+{
+    /** @var string|null */
+    private $migrationsDir;
+
+    /** @var IDriver|null */
+    private $driver;
+
+    /** @var Cli|null */
+    private $di;
+
+    const ACTION_CREATE = 'create';
+    const ACTION_CREATE_ABBR = 'cr';
+    const ACTION_RESET = 'reset';
+    const ACTION_RESET_ABBR = 're';
+    const ACTION_CONTINUE = 'continue';
+    const ACTION_CONTINUE_ABBR = 'co';
+
+    const GROUP_BASIC_DATA = 'basic-data';
+    const GROUP_BASIC_DATA_ABBR = 'b';
+    const GROUP_DUMMY_DATA = 'dummy-data';
+    const GROUP_DUMMY_DATA_ABBR = 'd';
+    const GROUP_STRUCTURES = 'structures';
+    const GROUP_STRUCTURES_ABBR = 's';
+
+    /** @var array */
+    private static $groups = [
+        self::GROUP_BASIC_DATA_ABBR => self::GROUP_BASIC_DATA,
+        self::GROUP_DUMMY_DATA_ABBR => self::GROUP_DUMMY_DATA,
+        self::GROUP_STRUCTURES_ABBR => self::GROUP_STRUCTURES,
+    ];
+
+    private function getContainer()
+    {
+        if ($this->di === null) {
+            $this->di = $this->getDI();
+        }
+
+        return $this->di;
+    }
+
+    /**
+     * @return string
+     */
+    private function getMigrationsDir()
+    {
+        if ($this->migrationsDir === null) {
+            $this->migrationsDir = $this->getContainer()->get('config')->migrationsDir;
+        }
+
+        return $this->migrationsDir;
+    }
+
+    /**
+     * @return IDriver
+     */
+    private function getDriver()
+    {
+        if ($this->driver === null) {
+            $this->driver = $this->getContainer()->get('driver');
+        }
+        return $this->driver;
+    }
+
+    /**
+     * @param array $params
+     */
+    public function mainAction($params)
+    {
+        error_reporting(E_ALL);
+        ini_set('display_errors', 1);
+
+        try {
+            $params = $this->handleParams($params);
+        } catch (\InvalidArgumentException $e) {
+            $this->error($e->getMessage());
+        }
+
+        $controller = new ConsoleController($this->getDriver());
+
+        $controller->addGroup('structures', $this->getMigrationsDir() . '/structures');
+        $controller->addGroup('basic-data', $this->getMigrationsDir() . '/basic-data', ['structures']);
+        $controller->addGroup('dummy-data', $this->getMigrationsDir() . '/dummy-data', ['basic-data']);
+        $controller->addExtension('sql', new SqlHandler($this->getDriver()));
+
+        // override parameters
+        $_SERVER['argv'] = array_merge([$_SERVER['argv'][0]], $params);
+
+        $controller->run();
+    }
+
+    /**
+     * @param array $params
+     * @return array
+     * @throws \InvalidArgumentException
+     */
+    private function handleParams($params)
+    {
+        if (count($params) !== 1) {
+            throw new \InvalidArgumentException('Invalid number of params.');
+        }
+
+        $param_parts = explode(':', $params[0]);
+        $count = count($param_parts);
+
+        // continue or reset
+        if ($count > 0 && $count < 3) {
+            $production = false;
+            if (isset($param_parts[1])) {
+                if ($param_parts[1] === 'production') {
+                    $production = true;
+                } else {
+                    throw new \InvalidArgumentException('Invalid params.');
+                }
+            }
+
+            return $this->runMigrations($param_parts[0], $production);
+        } elseif ($count === 3) {
+            // create
+            if (!in_array($param_parts[0], [self::ACTION_CREATE, self::ACTION_CREATE_ABBR], true)) {
+                throw new \InvalidArgumentException('Invalid params.'); // 3 arguments can have only create action
+            }
+
+            $this->createMigration($param_parts[1], $param_parts[2]);
+        }
+
+        throw new \InvalidArgumentException('Invalid params.');
+    }
+
+    /**
+     * @param string $message
+     */
+    private function error($message)
+    {
+        echo 'ERROR: ' . $message . PHP_EOL;
+        $this->printUsage();
+        exit(1);
+    }
+
+    /**
+     * @param string $action
+     * @param bool $production
+     * @return array
+     * @throws \InvalidArgumentException
+     */
+    private function runMigrations($action, $production)
+    {
+        if (!in_array($action, [self::ACTION_CONTINUE, self::ACTION_CONTINUE_ABBR, self::ACTION_RESET, self::ACTION_RESET_ABBR], true)) {
+            throw new \InvalidArgumentException('Invalid action.');
+        }
+
+        $return = [self::GROUP_STRUCTURES, self::GROUP_BASIC_DATA];
+
+        if ($production === false) {
+            $return[] = self::GROUP_DUMMY_DATA;
+        }
+
+        if (in_array($action, [self::ACTION_RESET, self::ACTION_RESET_ABBR], true)) {
+            $return[] = '--reset';
+        }
+
+        return $return;
+    }
+
+    /**
+     * @param string $group
+     * @param string $label
+     * @throws \InvalidArgumentException
+     */
+    private function createMigration($group, $label)
+    {
+        if (!in_array($group, array_merge(array_keys(self::$groups), array_values(self::$groups)), true)) {
+            throw new \InvalidArgumentException('Invalid group.');
+        }
+
+        // replace group abbreviation for group name
+        if (array_key_exists($group, self::$groups)) {
+            $group = self::$groups[$group];
+        }
+
+        $dir = $this->getMigrationsDir() . '/' . $group;
+        $name = date('Y-m-d-His-') . preg_replace('/[[:^print:]]/', '', $label) . '.sql';
+        @mkdir($dir, 0777, true);
+        touch("$dir/$name");
+
+        exit;
+    }
+
+    private function printUsage()
+    {
+        $scriptFile = isset($_SERVER['argv'][0]) ? $_SERVER['argv'][0] : 'app/cli.php';
+
+        echo '------------------------------' . PHP_EOL;
+        echo 'Usage:    php ' . $scriptFile . ' Nextras\\\\Migrations\\\\Bridges\\\\Phalcon\\\\Migrations main <action>[:<group>:<label>][:production]' . PHP_EOL;
+        echo PHP_EOL;
+        echo 'Example:  php ' . $scriptFile . ' Nextras\\\\Migrations\\\\Bridges\\\\Phalcon\\\\Migrations main create:dummy-data:users' . PHP_EOL;
+        echo 'Example:  php ' . $scriptFile . ' Nextras\\\\Migrations\\\\Bridges\\\\Phalcon\\\\Migrations main cr:d:users' . PHP_EOL;
+        echo 'Example:  php ' . $scriptFile . ' Nextras\\\\Migrations\\\\Bridges\\\\Phalcon\\\\Migrations main reset' . PHP_EOL;
+        echo 'Example:  php ' . $scriptFile . ' Nextras\\\\Migrations\\\\Bridges\\\\Phalcon\\\\Migrations main co:production' . PHP_EOL;
+        echo PHP_EOL;
+        echo 'Actions:' . PHP_EOL;
+        echo '    create' . PHP_EOL;
+        echo '        Can be aliased as "cr".' . PHP_EOL;
+        echo '        Creates empty sql file named YYYY-MM-DD-HHMMSS-label.sql.' . PHP_EOL;
+        echo '        E.g. 2015-03-16-170342-users.sql.' . PHP_EOL;
+        echo '        <label> is mandatory for "create" action.' . PHP_EOL;
+        echo '    continue' . PHP_EOL;
+        echo '        Can be aliased as "co".' . PHP_EOL;
+        echo '        Migrates not migrated sql files only.' . PHP_EOL;
+        echo '        Optional flag "production" (if present all dummy-data files are skipped).' . PHP_EOL;
+        echo '    reset' . PHP_EOL;
+        echo '        Can be aliased as "re".' . PHP_EOL;
+        echo '        Drop whole database and then migrates all sql files.' . PHP_EOL;
+        echo '        Optional flag "production" (if present all dummy-data files are skipped).' . PHP_EOL;
+        echo PHP_EOL;
+        echo 'Groups:' . PHP_EOL;
+        echo '    basic-data' . PHP_EOL;
+        echo '        Can be aliased as "b".' . PHP_EOL;
+        echo '        Data for both development and production.' . PHP_EOL;
+        echo '    dummy-data' . PHP_EOL;
+        echo '        Can be aliased as "d".' . PHP_EOL;
+        echo '        Data for development on localhost.' . PHP_EOL;
+        echo '    structures' . PHP_EOL;
+        echo '        Can be aliased as "s".' . PHP_EOL;
+        echo '        Creates, alter tables, etc.' . PHP_EOL;
+        echo PHP_EOL;
+        echo 'Label:' . PHP_EOL;
+        echo '    For "create" action only. Should be some brief name for sql file contents.' . PHP_EOL;
+        echo PHP_EOL;
+        echo 'Production:' . PHP_EOL;
+        echo '    For "continue" and "reset" actions only.' . PHP_EOL;
+        echo '    If present all dummy-data files are skipped.' . PHP_EOL;
+        echo '------------------------------' . PHP_EOL;
+    }
+}
diff --git a/src/Bridges/Phalcon/PhalconAdapter.php b/src/Bridges/Phalcon/PhalconAdapter.php
new file mode 100755
index 00000000..b473561d
--- /dev/null
+++ b/src/Bridges/Phalcon/PhalconAdapter.php
@@ -0,0 +1,80 @@
+<?php
+
+namespace Nextras\Migrations\Bridges\Phalcon;
+
+use DateTime;
+use Nextras\Migrations\ExecutionException;
+use Nextras\Migrations\IDbal;
+use Phalcon\Db\Adapter\Pdo;
+
+
+class PhalconAdapter implements IDbal
+{
+    /** @var string Value from \Phalcon\Db\Adapter\Pdo\Mysql::$_type */
+    const TYPE_MYSQL = 'mysql';
+
+    /** @var string Value from \Phalcon\Db\Adapter\Pdo\Postgresql::$_type */
+    const TYPE_PGSQL = 'pgsql';
+
+	/** @var Pdo */
+	private $conn;
+
+
+	public function __construct(Pdo $connection)
+	{
+		$this->conn = $connection;
+		$this->conn->connect();
+	}
+
+
+	public function query($sql)
+	{
+	    return $this->conn->fetchAll($sql);
+	}
+
+
+	public function exec($sql)
+	{
+	    $this->conn->execute($sql);
+	    $this->conn->affectedRows();
+	}
+
+
+	public function escapeString($value)
+	{
+	    return $this->conn->escapeString($value);
+	}
+
+
+	public function escapeInt($value)
+	{
+		return (string)(int)$value;
+	}
+
+
+	public function escapeBool($value)
+	{
+        return (string)(int)$value;
+	}
+
+
+	public function escapeDateTime(DateTime $value)
+	{
+        return $this->conn->escapeString($this->formatDateTime($value));
+	}
+
+
+	public function escapeIdentifier($value)
+	{
+	    return $this->conn->escapeIdentifier($value);
+	}
+
+    private function formatDateTime(DateTime $value)
+    {
+        if (in_array($this->conn->getType(), [self::TYPE_MYSQL, self::TYPE_PGSQL], true)) {
+            return $value->format('Y-m-d H:i:s');
+        } else {
+            throw new ExecutionException('Unsupported type of \Phalcon\Db\Adapter\Pdo driver.');
+        }
+	}
+}

From 4f69bbeecb936f52bc6fe4536d3ac38cc91bbec1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tom=C3=A1=C5=A1=20Zat=C5=99ep=C3=A1lek?=
 <tzatrepalek@inwk.com>
Date: Wed, 23 Jan 2019 13:11:31 +0100
Subject: [PATCH 3/5] Phalcon integration docs

---
 doc/default.texy | 175 +++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 175 insertions(+)

diff --git a/doc/default.texy b/doc/default.texy
index 16c863ff..e268f04f 100644
--- a/doc/default.texy
+++ b/doc/default.texy
@@ -148,3 +148,178 @@ $controller->addExtension('php', new Extensions\PhpHandler([
 	'dibi' => $conn,
 ]));
 \--
+
+
+Using as Phalcon Framework Task
+===============================
+
+Migrations come with predefined Phalcon CLI Task. Task uses these two services:
+
+* **config** (`\Phalcon\Config`) with key `migrationsDir`. See example config.php below.
+* **driver** (`\Nextras\Migrations\IDriver`). See example in cli.php below.
+
+Service `driver` needs `\Nextras\Migrations\Bridges\Phalcon\PhalconAdapter` as argument. Therefore you will probably need to declare other services (see cli.php) or create phalcon adapter inside **driver**'s lambda function.
+
+`config/config.php`
+/--code php
+<?php
+declare(strict_types=1);
+
+return [
+    'migrationsDir' => __DIR__ . '/../migrations',
+    'database' => [
+        'host' => getenv('DB_HOST'),
+        'username' => getenv('DB_NAME'),
+        'password' => getenv('DB_USER'),
+        'dbname' => getenv('DB_PASS'),
+    ],
+];
+\--
+
+`app/cli.php`
+/--code php
+<?php
+declare(strict_types=1);
+
+
+// Using the CLI factory default services container
+$di = new \Phalcon\Di\FactoryDefault\Cli();
+
+
+// Autoloader - register Nextras/Migrations
+$loader = new \Phalcon\Loader();
+$loader->registerNamespaces(
+    [
+        'Nextras\Migrations' => __DIR__ . '/../vendor/nextras/migrations/src',
+    ]
+);
+$loader->register();
+
+// DI services
+$di->set(
+    'config',
+    function () {
+        $configFile = __DIR__ . '/../config/config.php';
+        if (!is_readable($configFile)) {
+            die('Config file not readable.');
+        }
+        $config = include $configFile;
+        return new Phalcon\Config($config);
+    }
+);
+$di->set(
+    'migrationsDir',
+    function () {
+        /** @var \Phalcon\Config $config */
+        $config = $this->get('config');
+        return $config->migrationsDir;
+    }
+);
+$di->set(
+    'connection',
+    function () {
+        /** @var \Phalcon\Config $config */
+        $config = $this->get('config');
+        return new \Phalcon\Db\Adapter\Pdo\Mysql([
+            'host' => $config->database->host,
+            'username' => $config->database->username,
+            'password' => $config->database->password,
+            'dbname' => $config->database->dbname,
+            'dialectClass' => new \Phalcon\Db\Dialect\Mysql(),
+        ]);
+    }
+);
+$di->set(
+    'phalconAdapter',
+    function () {
+        /** @var \Phalcon\Db\Adapter\Pdo $connection */
+        $connection = $this->get('connection');
+        return new \Nextras\Migrations\Bridges\Phalcon\PhalconAdapter($connection);
+    }
+);
+$di->set(
+    'driver',
+    function () {
+        /** @var \Nextras\Migrations\Bridges\Phalcon\PhalconAdapter $phalconAdapter */
+        $phalconAdapter = $this->get('phalconAdapter');
+        return new \Nextras\Migrations\Drivers\MySqlDriver($phalconAdapter);
+    }
+);
+
+// Create a console application
+$console = new \Phalcon\Cli\Console();
+$console->setDI($di);
+
+// Process the console arguments
+$arguments = [];
+
+foreach ($argv as $k => $arg) {
+    if ($k === 1) {
+        $arguments['task'] = $arg;
+    } elseif ($k === 2) {
+        $arguments['action'] = $arg;
+    } elseif ($k >= 3) {
+        $arguments['params'][] = $arg;
+    }
+}
+
+try {
+    // Handle incoming arguments
+    $console->handle($arguments);
+} catch (\Phalcon\Exception $e) {
+    // Do Phalcon related stuff here
+    // ..
+    fwrite(STDERR, $e->getMessage() . PHP_EOL);
+    exit(1);
+} catch (\Throwable $throwable) {
+    fwrite(STDERR, $throwable->getMessage() . PHP_EOL);
+    exit(1);
+}
+
+\--
+
+Usage
+-----
+
+`php app/cli.php Nextras\\Migrations\\Bridges\\Phalcon\\Migrations main <action>[:<group>:<label>][:production]`
+
+Examples:
+* `php app/cli.php Nextras\\Migrations\\Bridges\\Phalcon\\Migrations main create:dummy-data:users`
+* `php app/cli.php Nextras\\Migrations\\Bridges\\Phalcon\\Migrations main cr:d:users`
+* `php app/cli.php Nextras\\Migrations\\Bridges\\Phalcon\\Migrations main reset`
+* `php app/cli.php Nextras\\Migrations\\Bridges\\Phalcon\\Migrations main co:production`
+
+**Actions:**
+* create
+  * Can be aliased as "cr".
+  * Creates empty sql file named YYYY-MM-DD-HHMMSS-label.sql.
+  * E.g. 2015-03-16-170342-users.sql.
+  * <label> is mandatory for "create" action.
+* continue
+  * Can be aliased as "co".
+  * Migrates not migrated sql files only.
+  * Optional flag "production" (if present all dummy-data files are skipped).
+* reset
+  * Can be aliased as "re".
+  * Drop whole database and then migrates all sql files.
+  * Optional flag "production" (if present all dummy-data files are skipped).
+
+**Groups:**
+* basic-data
+  * Can be aliased as "b".
+  * Data for both development and production.
+* dummy-data
+  * Can be aliased as "d".
+  * Data for development on localhost.
+* structures
+  * Can be aliased as "s".
+  * Creates, alter tables, etc.
+
+**Label:**
+* For "create" action only. Should be some brief name for sql file contents.
+
+**Production:**
+* For "continue" and "reset" actions only.
+* If present all dummy-data files are skipped.
+
+-------------------------

From 08ead017fd85a7946cd49d2a01307e45c5961b36 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tom=C3=A1=C5=A1=20Zat=C5=99ep=C3=A1lek?=
 <tzatrepalek@inwk.com>
Date: Thu, 24 Jan 2019 10:55:52 +0100
Subject: [PATCH 4/5] Test for Phalcon integration

---
 .travis.yml                                   |   5 +
 composer.json                                 |   1 +
 .../integration/phalcon/PhalconTest.phpt      | 150 ++++++++++++++++++
 tests/matrix/dbal/phalcon-3.4.sh              |   5 +
 .../matrix/phalcon/phalcon-php-5.5-to-7.2.sh  |   5 +
 tests/run-integration.sh                      |   9 +-
 6 files changed, 174 insertions(+), 1 deletion(-)
 create mode 100644 tests/cases/integration/phalcon/PhalconTest.phpt
 create mode 100644 tests/matrix/dbal/phalcon-3.4.sh
 create mode 100644 tests/matrix/phalcon/phalcon-php-5.5-to-7.2.sh

diff --git a/.travis.yml b/.travis.yml
index 90f471b6..7ad0c132 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -10,6 +10,10 @@ php:
     - 7.2
     - 7.3
 
+cache:
+    directories:
+        - ~/cphalcon
+
 matrix:
     fast_finish: true
 
@@ -23,6 +27,7 @@ before_script:
 
     - composer self-update
     - composer install --no-interaction --no-progress
+    - if [[ $TRAVIS_PHP_VERSION == "5.5" ]] || [[ $TRAVIS_PHP_VERSION == "5.6" ]] || [[ $TRAVIS_PHP_VERSION == "7.0" ]] || [[ $TRAVIS_PHP_VERSION == "7.1" ]] || [[ $TRAVIS_PHP_VERSION == "7.2" ]]; then vendor/bin/install-phalcon.sh 3.4.x; fi
 
 script:
     - ./tests/run-unit.sh
diff --git a/composer.json b/composer.json
index 8005053e..20954f41 100644
--- a/composer.json
+++ b/composer.json
@@ -22,6 +22,7 @@
 		"symfony/console": "~2.6 | ~3.0 | ~4.0",
 		"symfony/dependency-injection": "~2.6 | ~3.0 | ~4.0",
 		"symfony/http-kernel": "~2.6 | ~3.0 | ~4.0",
+		"techpivot/phalcon-ci-installer": "~1.0",
 		"tracy/tracy": "^2.2",
 		"ext-openssl": "*"
 	},
diff --git a/tests/cases/integration/phalcon/PhalconTest.phpt b/tests/cases/integration/phalcon/PhalconTest.phpt
new file mode 100644
index 00000000..54e23cc6
--- /dev/null
+++ b/tests/cases/integration/phalcon/PhalconTest.phpt
@@ -0,0 +1,150 @@
+<?php
+
+/**
+ * @testCase
+ * @dataProvider ../../../dbals.ini
+ */
+
+namespace NextrasTests\Migrations;
+
+use Phalcon\Cli\Dispatcher;
+use Tester\Assert;
+use Tester\Environment;
+use Tester\TestCase;
+
+
+require __DIR__ . '/../../../bootstrap.php';
+
+
+class PhalconTest extends TestCase
+{
+	/** @var \Phalcon\Cli\Console */
+	private $console;
+
+
+	protected function setUp()
+	{
+		parent::setUp();
+
+		Environment::lock(__CLASS__, __DIR__ . '/../../../temp');
+
+		$options = Environment::loadData();
+		$driversConfig = parse_ini_file(__DIR__ . '/../../../drivers.ini', TRUE);
+		$dbalOptions = $driversConfig[$options['driver']];
+
+        // Using the CLI factory default services container
+        $di = new \Phalcon\Di\FactoryDefault\Cli();
+
+        // DI services
+        $di->set(
+            'config',
+            new \Phalcon\Config([
+                'migrationsDir' => __DIR__ . "/../../../fixtures/$options[driver]",
+                'host' => $dbalOptions['host'],
+                'username' => $dbalOptions['username'],
+                'password' => $dbalOptions['password'],
+                'dbname' => $dbalOptions['database'],
+            ])
+        );
+        $di->set(
+            'migrationsDir',
+            function () {
+                /** @var \Phalcon\Config $config */
+                $config = $this->get('config');
+                return $config->migrationsDir;
+            }
+        );
+        $di->set(
+            'phalconAdapter',
+            function () {
+                /** @var \Phalcon\Db\Adapter\Pdo $connection */
+                $connection = $this->get('connection');
+                return new \Nextras\Migrations\Bridges\Phalcon\PhalconAdapter($connection);
+            }
+        );
+
+        if ($options['driver'] === 'mysql') {
+            $di->set(
+                'connection',
+                function () {
+                    /** @var \Phalcon\Config $config */
+                    $config = $this->get('config');
+                    return new \Phalcon\Db\Adapter\Pdo\Mysql([
+                        'host' => $config->host,
+                        'username' => $config->username,
+                        'password' => $config->password,
+                        'dbname' => $config->dbname,
+                        'dialectClass' => new \Phalcon\Db\Dialect\Mysql(),
+                    ]);
+                }
+            );
+            $di->set(
+                'driver',
+                function () {
+                    /** @var \Nextras\Migrations\Bridges\Phalcon\PhalconAdapter $phalconAdapter */
+                    $phalconAdapter = $this->get('phalconAdapter');
+                    return new \Nextras\Migrations\Drivers\MySqlDriver($phalconAdapter);
+                }
+            );
+        } else {
+            $di->set(
+                'connection',
+                function () {
+                    /** @var \Phalcon\Config $config */
+                    $config = $this->get('config');
+                    return new \Phalcon\Db\Adapter\Pdo\Postgresql([
+                        'host' => $config->host,
+                        'username' => $config->username,
+                        'password' => $config->password,
+                        'dbname' => $config->dbname,
+                        'dialectClass' => new \Phalcon\Db\Dialect\Mysql(),
+                    ]);
+                }
+            );
+            $di->set(
+                'driver',
+                function () {
+                    /** @var \Nextras\Migrations\Bridges\Phalcon\PhalconAdapter $phalconAdapter */
+                    $phalconAdapter = $this->get('phalconAdapter');
+                    return new \Nextras\Migrations\Drivers\PgSqlDriver($phalconAdapter);
+                }
+            );
+        }
+
+        // Configure Task Namespace
+        /** @var Dispatcher $dispatcher */
+        $dispatcher = $di->get('dispatcher');
+        $dispatcher->setDefaultNamespace('Nextras\\Migrations\\Bridges\\Phalcon');
+
+        // Create a console application
+        $this->console = new \Phalcon\Cli\Console();
+        $this->console->setDI($di);
+	}
+
+
+	public function testMigrationsReset()
+	{
+        Assert::noError(function () {
+            $arguments = [];
+            $arguments['task'] = 'migrations';
+            $arguments['action'] = 'main';
+            $arguments['params'] = ['reset'];
+            $this->console->handle($arguments);
+        });
+	}
+
+
+	public function testMigrationsContinue()
+	{
+        Assert::noError(function () {
+            $arguments['task'] = 'migrations';
+            $arguments['action'] = 'main';
+            $arguments['params'] = ['continue'];
+
+            $this->console->handle($arguments);
+        });
+	}
+}
+
+
+(new PhalconTest)->run();
diff --git a/tests/matrix/dbal/phalcon-3.4.sh b/tests/matrix/dbal/phalcon-3.4.sh
new file mode 100644
index 00000000..1d8c8392
--- /dev/null
+++ b/tests/matrix/dbal/phalcon-3.4.sh
@@ -0,0 +1,5 @@
+#!/usr/bin/env bash
+PHP_VERSION_MIN="50500"
+PHP_VERSION_MAX="70299"
+COMPOSER_REQUIRE="$COMPOSER_REQUIRE doctrine/dbal:~2.5"
+DBAL="doctrine"
diff --git a/tests/matrix/phalcon/phalcon-php-5.5-to-7.2.sh b/tests/matrix/phalcon/phalcon-php-5.5-to-7.2.sh
new file mode 100644
index 00000000..05bce371
--- /dev/null
+++ b/tests/matrix/phalcon/phalcon-php-5.5-to-7.2.sh
@@ -0,0 +1,5 @@
+#!/usr/bin/env bash
+PHP_VERSION_MIN="50500"
+PHP_VERSION_MAX="70299"
+DBAL="doctrine"
+PHALCON="phalcon"
diff --git a/tests/run-integration.sh b/tests/run-integration.sh
index 5fb5476d..0adbc057 100755
--- a/tests/run-integration.sh
+++ b/tests/run-integration.sh
@@ -15,6 +15,7 @@ run()
 	PHP_VERSION_MAX=""
 	COMPOSER_REQUIRE=""
 	DBAL=""
+	PHALCON=""
 
 	echo
 	echo
@@ -33,7 +34,7 @@ run()
 		return 0
 	fi
 
-	create_dbals_ini "$DBAL"
+	create_dbals_ini "$DBAL" "$PHALCON"
 
 	composer_prepare_dependencies "$COMPOSER_REQUIRE" ""
 	tester_run_integration_group "$INTEGRATION_GROUP"
@@ -51,9 +52,11 @@ run()
 create_dbals_ini()
 {
 	DBAL="$1"
+	PHALCON="$2"
 	INI_PATH="$PROJECT_DIR/tests/dbals.ini"
 
 	rm --force "$INI_PATH"
+
 	if [[ ! -z "$DBAL" ]]; then
 		echo "[$DBAL.mysql]" >> "$INI_PATH"
 		echo "dbal = $DBAL" >> "$INI_PATH"
@@ -63,6 +66,10 @@ create_dbals_ini()
 		echo "dbal = $DBAL" >> "$INI_PATH"
 		echo "driver = pgsql" >> "$INI_PATH"
 	fi
+
+	if [[ ! -z "$PHALCON" ]]; then
+		echo "extension=phalcon.so" >> "$PROJECT_DIR/tests/php.ini"
+	fi
 }
 
 

From 4d60ce00017f0634682f3980d02eb58994ef14b6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tom=C3=A1=C5=A1=20Zat=C5=99ep=C3=A1lek?=
 <tzatrepalek@inwk.com>
Date: Mon, 25 Feb 2019 15:32:11 +0100
Subject: [PATCH 5/5] PhalconAdapter fixes

---
 src/Bridges/Phalcon/PhalconAdapter.php | 73 +++++++++++++++++++++-----
 1 file changed, 61 insertions(+), 12 deletions(-)

diff --git a/src/Bridges/Phalcon/PhalconAdapter.php b/src/Bridges/Phalcon/PhalconAdapter.php
index b473561d..04a84fd8 100755
--- a/src/Bridges/Phalcon/PhalconAdapter.php
+++ b/src/Bridges/Phalcon/PhalconAdapter.php
@@ -19,62 +19,111 @@ class PhalconAdapter implements IDbal
 	/** @var Pdo */
 	private $conn;
 
-
+    /**
+     * @param Pdo $connection
+     */
 	public function __construct(Pdo $connection)
 	{
 		$this->conn = $connection;
 		$this->conn->connect();
 	}
 
-
+    /**
+     * @param  string $sql
+     * @return array list of rows represented by assoc. arrays
+     */
 	public function query($sql)
 	{
 	    return $this->conn->fetchAll($sql);
 	}
 
-
+    /**
+     * @param  string $sql
+     * @return int number of affected rows
+     */
 	public function exec($sql)
 	{
 	    $this->conn->execute($sql);
-	    $this->conn->affectedRows();
+	    return $this->conn->affectedRows();
 	}
 
 
-	public function escapeString($value)
+    /**
+     * @param  string $value
+     * @return string escaped string wrapped in quotes
+     */
+    public function escapeString($value)
 	{
 	    return $this->conn->escapeString($value);
 	}
 
-
+    /**
+     * @param  int $value
+     * @return string
+     */
 	public function escapeInt($value)
 	{
 		return (string)(int)$value;
 	}
 
 
+    /**
+     * @param  bool $value
+     * @return string
+     * @throws ExecutionException
+     */
 	public function escapeBool($value)
 	{
-        return (string)(int)$value;
-	}
+        if ($this->conn->getType() === self::TYPE_MYSQL) {
+            return (string)(int)$value;
+        }
 
+        if ($this->conn->getType() === self::TYPE_PGSQL) {
+            return (bool)$value ? 'TRUE' : 'FALSE';
+        }
 
+        throw new ExecutionException('Unsupported type of \Phalcon\Db\Adapter\Pdo driver.');
+	}
+
+    /**
+     * @param  DateTime $value
+     * @return string
+     * @throws ExecutionException
+     */
 	public function escapeDateTime(DateTime $value)
 	{
         return $this->conn->escapeString($this->formatDateTime($value));
 	}
 
-
+    /**
+     * @param  string $value
+     * @return string
+     * @throws ExecutionException
+     */
 	public function escapeIdentifier($value)
 	{
-	    return $this->conn->escapeIdentifier($value);
+        if ($this->conn->getType() === self::TYPE_MYSQL) {
+            return '`' . $value . '`';
+        }
+
+        if ($this->conn->getType() === self::TYPE_PGSQL) {
+            return '"' . $value . '"';
+        }
+
+        throw new ExecutionException('Unsupported type of \Phalcon\Db\Adapter\Pdo driver.');
 	}
 
+    /**
+     * @param DateTime $value
+     * @return string
+     * @throws ExecutionException
+     */
     private function formatDateTime(DateTime $value)
     {
         if (in_array($this->conn->getType(), [self::TYPE_MYSQL, self::TYPE_PGSQL], true)) {
             return $value->format('Y-m-d H:i:s');
-        } else {
-            throw new ExecutionException('Unsupported type of \Phalcon\Db\Adapter\Pdo driver.');
         }
+
+        throw new ExecutionException('Unsupported type of \Phalcon\Db\Adapter\Pdo driver.');
 	}
 }