fix timeout

Author: greg-rychlewski

lib/ecto/adapters/myxql.ex

@@ -425,7 +425,7 @@ defmodule Ecto.Adapters.MyXQL do
           config[:database]
         ]
 
-        case run_with_port("mysql", config, args, contents) do
+        case run_with_port("mysql", config, args, path) do
           {_output, 0} -> {:ok, path}
           {output, _} -> {:error, output}
         end
@@ -543,7 +543,7 @@ defmodule Ecto.Adapters.MyXQL do
   # intent of using file redirection for passing dumps
   # into the mysql client so that users don't run into
   # shell limits when files are too large
-  defp run_with_port(cmd, opts, opt_args, contents, cmd_opts \\ []) do
+  defp run_with_port(cmd, opts, opt_args, path, cmd_opts \\ []) do
     unless System.find_executable(cmd) do
       raise "could not find executable `#{cmd}` in path, " <>
               "please guarantee it is available before running ecto commands"
@@ -561,9 +561,10 @@ defmodule Ecto.Adapters.MyXQL do
 
     port_opts = port_opts(cmd_opts, args: args)
     port = Port.open({:spawn_executable, cmd}, port_opts)
-    IO.inspect port
-    IO.inspect Port.command(port, contents)
-    IO.inspect Port.command(port, "\n")
+    File.stream!(path, [], 64 * 1024)
+    |> Enum.each(fn chunk ->
+      true = Port.command(port, chunk)
+    end)
 
     {initial, fun} = Collectable.into("")