handle process dying gracefully

Author: greg-rychlewski

integration_test/myxql/storage_test.exs

@@ -121,6 +121,17 @@ defmodule Ecto.Integration.StorageTest do
     drop_database()
   end
 
+  test "structure load will fail on SQL errors" do
+    File.mkdir_p!(tmp_path())
+    error_path = Path.join(tmp_path(), "error.sql")
+    File.write!(error_path, "SELECT 1; SELECKT 1; SELECT 2;")
+
+    {:error, message} =
+      Ecto.Adapters.MyXQL.structure_load(tmp_path(), [dump_path: error_path] ++ params())
+
+    assert message =~ ~r/ERROR.*SELECKT/
+  end
+
   test "storage status is up when database is created" do
     create_database()
     assert :up == Ecto.Adapters.MyXQL.storage_status(params())

lib/ecto/adapters/myxql.ex

@@ -587,7 +587,8 @@ defmodule Ecto.Adapters.MyXQL do
       env: validate_env(env),
       args: args
     ]
-
+    # Trap exits in case mysql dies in the middle of execution so that we can surface the error
+    Process.flag(:trap_exit, true)
     port = Port.open({:spawn_executable, abs_cmd}, port_opts)
     Port.command(port, contents)
     # Use this as a signal to close the port since we cannot
@@ -653,6 +654,9 @@ defmodule Ecto.Adapters.MyXQL do
           collect_output(port, acc)
         end
 
+      {:EXIT, ^port, _reason} ->
+        {acc, 1}
+
       {^port, {:exit_status, status}} ->
         {acc, status}
     end