Add target database connection and fix mysqldump port param

Author: Witti

README.md

@@ -63,6 +63,11 @@ Set a comma seperate list of tables NOT to export in `REMOTE_DATABASE_IGNORE_TAB
 
 To generate a SQL with a custom file name `REMOTE_DEFAULT_FILE_NAME`
 
+To specify a different local database connection:
+```
+LOCAL_DATABASE_CONNECTION=different_mysql_connection
+```
+
 ## Usage
 
 To export a remote database to OVERRIDE your local database by running:

config/dbsync.php

@@ -61,4 +61,9 @@
      * Sets the default name for SQL file if --filename is not provided
      */
     'defaultFileName' => env('REMOTE_DEFAULT_FILE_NAME', 'file.sql'),
+
+    /*
+     * Sets the target databse connection
+     */
+    'targetConnection' => env('LOCAL_TARGET_CONNECTION', 'mysql'),
 ];

src/Console/DbSyncCommand.php

@@ -35,6 +35,8 @@ public function handle(): bool
         $removeFileAfterImport = config('dbsync.removeFileAfterImport');
         $fileName              = $this->option('filename') ?? config('dbsync.defaultFileName');
 
+        $targetConnection      = config('dbsync.targetConnection');
+
         if (empty($host) || empty($username) || empty($database)) {
             $this->error('DB credentials not set, have you published the config and set ENV variables?');
 
@@ -49,15 +51,15 @@ public function handle(): bool
             }
 
             if ($useSsh === true) {
-                exec("ssh $sshUsername@$host -p$sshPort mysqldump --port$port -u$username -p$password $database $ignoreString > $fileName", $output);
+                exec("ssh $sshUsername@$host -p$sshPort mysqldump -P$port -u$username -p$password $database $ignoreString > $fileName", $output);
             } else {
-                exec("mysqldump -h$host --port$port -u$username -p$password $database $ignoreString --column-statistics=0 > $fileName", $output);
+                exec("mysqldump -h$host -P$port -u$username -p$password $database $ignoreString --column-statistics=0 > $fileName", $output);
             }
 
             $this->comment(implode(PHP_EOL, $output));
 
             if ($importSqlFile === true) {
-                DB::unprepared(file_get_contents(base_path($fileName)));
+                DB::connection($targetConnection)->unprepared(file_get_contents(base_path($fileName)));
             }
 
             if ($removeFileAfterImport === true) {