When the mysql import fails, make db:import fail as well

netz98 · Dec 21, 2020 · a5f0b9d · a5f0b9d
1 parent 33d5a59
commit a5f0b9d
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/src/N98/Magento/Command/Database/ImportCommand.php b/src/N98/Magento/Command/Database/ImportCommand.php
@@ -160,11 +160,13 @@ protected function execute(InputInterface $input, OutputInterface $output)
             $dbHelper->dropTables($output);
         }
 
-        $this->doImport($output, $fileName, $exec);
+        $success = $this->doImport($output, $fileName, $exec);
 
         if ($input->getOption('optimize')) {
             unlink($fileName);
         }
+
+        return $success ? 0 : 1;
     }
 
     public function asText()
@@ -194,10 +196,12 @@ protected function checkFilename(InputInterface $input)
      * @param string $fileName
      * @param string $exec
      *
-     * @return void
+     * @return bool
      */
-    protected function doImport(OutputInterface $output, $fileName, $exec)
+    protected function doImport(OutputInterface $output, $fileName, $exec): bool
     {
+        $success = true;
+
         $returnValue = null;
         $commandOutput = null;
         $output->writeln(
@@ -207,7 +211,10 @@ protected function doImport(OutputInterface $output, $fileName, $exec)
         exec($exec, $commandOutput, $returnValue);
         if ($returnValue != 0) {
             $output->writeln('<error>' . implode(PHP_EOL, $commandOutput) . '</error>');
+            $success = false;
         }
         $output->writeln('<info>Finished</info>');
+
+        return $success;
     }
 }