Merge pull request #185 from keboola/jv-SUPPORT-7637-mysql-ex-debug-mode

Update `keboola/db-extractor-config` lib to allow debug mode in SSH node to be set

composer.json

@@ -16,7 +16,7 @@
         "ext-pdo": "*",
         "keboola/db-extractor-adapter": "^1.14",
         "keboola/db-extractor-common": "^17.1",
-        "keboola/db-extractor-config": "^1.15",
+        "keboola/db-extractor-config": "^1.16",
         "keboola/db-extractor-table-format": "^3.8",
         "keboola/php-component": "^10.1",
         "keboola/php-datatypes": "^7.2",

tests/functional/run-ssh-debug/expected-code

@@ -0,0 +1 @@
+0

tests/functional/run-ssh-debug/expected-stderr

@@ -0,0 +1 @@
+Query result set is empty. Exported "0" rows to "in.c-main.simple".

tests/functional/run-ssh-debug/expected-stdout

@@ -0,0 +1,4 @@
+Creating SSH tunnel to 'sshproxy' on local port '1234'
+SSH tunnel opened
+Creating PDO connection to "mysql:%a".
+Exporting to "in.c-main.simple".

tests/functional/run-ssh-debug/expected/data/out/tables/in.c-main.simple.csv.manifest

@@ -0,0 +1,54 @@
+{
+    "destination": "in.c-main.simple",
+    "incremental": false,
+    "columns": [
+        "id",
+        "name"
+    ],
+    "column_metadata": {
+        "id": [
+            {
+                "key": "KBC.datatype.nullable",
+                "value": true
+            },
+            {
+                "key": "KBC.datatype.basetype",
+                "value": "string"
+            },
+            {
+                "key": "KBC.sourceName",
+                "value": "id"
+            },
+            {
+                "key": "KBC.sanitizedName",
+                "value": "id"
+            },
+            {
+                "key": "KBC.uniqueKey",
+                "value": false
+            }
+        ],
+        "name": [
+            {
+                "key": "KBC.datatype.nullable",
+                "value": true
+            },
+            {
+                "key": "KBC.datatype.basetype",
+                "value": "string"
+            },
+            {
+                "key": "KBC.sourceName",
+                "value": "name"
+            },
+            {
+                "key": "KBC.sanitizedName",
+                "value": "name"
+            },
+            {
+                "key": "KBC.uniqueKey",
+                "value": false
+            }
+        ]
+    }
+}

tests/functional/run-ssh-debug/setUp.php

@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+use Keboola\DbExtractor\FunctionalTests\DatabaseManager;
+use Keboola\DbExtractor\FunctionalTests\DatadirTest;
+
+return static function (DatadirTest $test): void {
+    $manager = new DatabaseManager($test->getConnection());
+    $manager->createSimpleTable();
+};

tests/functional/run-ssh-debug/source/data/config.json

@@ -0,0 +1,26 @@
+{
+  "parameters": {
+    "query": "SELECT * FROM simple",
+    "outputTable": "in.c-main.simple",
+    "db": {
+      "host": "%env(string:MYSQL_DB_HOST)%",
+      "port": "%env(string:MYSQL_DB_PORT)%",
+      "user": "%env(string:MYSQL_DB_USER)%",
+      "#password": "%env(string:MYSQL_DB_PASSWORD)%",
+      "database": "%env(string:MYSQL_DB_DATABASE)%",
+      "ssh": {
+        "enabled": true,
+        "keys": {
+          "#private": "%env(string:SSH_PRIVATE_KEY)%",
+          "public": "%env(string:SSH_PUBLIC_KEY)%"
+        },
+        "user": "root",
+        "sshHost": "sshproxy",
+        "remoteHost": "MYSQL",
+        "remotePort": "1433",
+        "localPort": "1234",
+        "debug": true
+      }
+    }
+  }
+}