diff --git a/src/Console/Commands/Migration.php b/src/Console/Commands/Migration.php
index 1f82bfe..29f886d 100644
--- a/src/Console/Commands/Migration.php
+++ b/src/Console/Commands/Migration.php
@@ -154,6 +154,7 @@ public function run(): void
                     'version'        => $this->parser->get('version'),
                     'migrationsInDb' => $migrationsInDb,
                     'verbose'        => $this->parser->has('verbose'),
+                    'dry'            => $this->parser->has('dry'),
                 ]);
                 break;
             case 'list':
diff --git a/src/Migrations.php b/src/Migrations.php
index 96a912d..f9ee508 100644
--- a/src/Migrations.php
+++ b/src/Migrations.php
@@ -197,6 +197,7 @@ public static function run(array $options)
         $listTables = new ListTablesIterator();
         $optionStack->setOptions($options);
         $optionStack->setDefaultOption('verbose', false);
+        $optionStack->setDefaultOption('dry', false);
 
         // Define versioning type to be used
         if (!empty($options['tsBased']) || $optionStack->getOption('tsBased')) {
@@ -265,7 +266,11 @@ public static function run(array $options)
             $finalVersion = VersionCollection::maximum($versionItems);
         }
 
-        ModelMigration::setup($optionStack->getOption('config')->database, $optionStack->getOption('verbose'));
+        ModelMigration::setup(
+            $optionStack->getOption('config')->database,
+            $optionStack->getOption('verbose'),
+            $optionStack->getOption('dry')
+        );
         self::connectionSetup($optionStack->getOptions());
 
         /**
@@ -372,6 +377,9 @@ public static function run(array $options)
                 }
             }
 
+            if ($optionStack->getOption('dry')) {
+                return;
+            }
             if (ModelMigration::DIRECTION_FORWARD == $direction) {
                 self::addCurrentVersion($optionStack->getOptions(), (string)$versionItem, $migrationStartTime);
                 print Color::success('Version ' . $versionItem . ' was successfully migrated');
diff --git a/src/Mvc/Model/Migration.php b/src/Mvc/Model/Migration.php
index 93a20f1..aabfc2e 100644
--- a/src/Mvc/Model/Migration.php
+++ b/src/Mvc/Model/Migration.php
@@ -31,6 +31,7 @@
 use Phalcon\Migrations\Listeners\DbProfilerListener;
 use Phalcon\Migrations\Migration\Action\Generate as GenerateAction;
 use Phalcon\Migrations\Migrations;
+use Phalcon\Migrations\Proxy;
 use Phalcon\Migrations\Utils;
 use Phalcon\Migrations\Utils\Nullify;
 use Phalcon\Migrations\Version\ItemCollection as VersionCollection;
@@ -55,7 +56,7 @@ class Migration
     /**
      * Migration database connection
      *
-     * @var AbstractAdapter
+     * @var AbstractAdapter|Proxy
      */
     protected static $connection;
 
@@ -92,10 +93,11 @@ class Migration
      *
      * @param Config $database Database config
      * @param bool $verbose array with settings
+     * @param bool $dryRun array with settings
      * @throws DbException
      * @since 3.2.1 Using Postgresql::describeReferences and DialectPostgresql dialect class
      */
-    public static function setup(Config $database, bool $verbose = false): void
+    public static function setup(Config $database, bool $verbose = false, bool $dryRun = false): void
     {
         if (!isset($database->adapter)) {
             throw new DbException('Unspecified database Adapter in your configuration!');
@@ -120,19 +122,21 @@ public static function setup(Config $database, bool $verbose = false): void
 
         $configArray = $database->toArray();
         unset($configArray['adapter']);
-        self::$connection = new $adapter($configArray);
+        $connection = new $adapter($configArray);
         self::$databaseConfig = $database;
 
         // Connection custom dialect Dialect/DialectMysql
         if ($database->adapter == 'Mysql') {
-            self::$connection->setDialect(new DialectMysql());
+            $connection->setDialect(new DialectMysql());
         }
 
         // Connection custom dialect Dialect/DialectPostgresql
         if ($database->adapter == 'Postgresql') {
-            self::$connection->setDialect(new DialectPostgresql());
+            $connection->setDialect(new DialectPostgresql());
         }
 
+        self::$connection = new Proxy($connection, $dryRun);
+
         if (!Migrations::isConsole() || !$verbose) {
             return;
         }
@@ -140,7 +144,7 @@ public static function setup(Config $database, bool $verbose = false): void
         $eventsManager = new EventsManager();
         $eventsManager->attach('db', new DbProfilerListener());
 
-        self::$connection->setEventsManager($eventsManager);
+        $connection->setEventsManager($eventsManager);
     }
 
     /**
@@ -772,6 +776,9 @@ function ($value) {
      */
     public function getConnection()
     {
-        return self::$connection;
+        if (self::$connection instanceof AbstractAdapter) {
+            return self::$connection;
+        }
+        return self::$connection->getTarget();
     }
 }
diff --git a/src/Proxy.php b/src/Proxy.php
new file mode 100644
index 0000000..1a164b2
--- /dev/null
+++ b/src/Proxy.php
@@ -0,0 +1,74 @@
+<?php
+
+/**
+ * This file is part of the Phalcon Migrations.
+ *
+ * (c) Phalcon Team <team@phalcon.io>
+ *
+ * For the full copyright and license information, please view
+ * the LICENSE file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Phalcon\Migrations;
+
+use InvalidArgumentException;
+use Phalcon\Config;
+
+class Proxy
+{
+    private $target;
+    private $dry;
+
+    public function __construct($target, $dry = false)
+    {
+        $this->target = $target;
+        $this->dry = $dry;
+    }
+
+    protected function log($line)
+    {
+        echo "[" . $line . "]\r\n";
+    }
+
+    public function getTarget()
+    {
+        return $this->target;
+    }
+
+    public function __set($name, $value)
+    {
+        $this->target->$name = $value;
+    }
+
+    public function __get($name)
+    {
+        return $this->target->$name;
+    }
+
+    public function __isset($name)
+    {
+        return isset($this->target->$name);
+    }
+
+    public function __call($name, $arguments)
+    {
+        $dialectArray = [
+            'addColumn', 'addForeignKey', 'addIndex', 'addPrimaryKey',
+            'createTable', 'createView', 'dropColumn', 'dropForeignKey',
+            'dropIndex', 'dropPrimaryKey', 'dropTable', 'dropView', 'modifyColumn'
+        ];
+        if ($this->dry && in_array($name, $dialectArray)) {
+            $dialect = $this->target->getDialect();
+            if (method_exists($dialect, $name)) {
+                $this->log(call_user_func_array(array($dialect, $name), $arguments));
+                return true;
+            }
+        }
+        if (method_exists($this, $name)) {
+            return call_user_func_array(array($this, $name), $arguments);
+        }
+        return call_user_func_array(array($this->target, $name), $arguments);
+    }
+}