Added initial timeout handling. paired: Jae

lib/mssqlex/odbc.ex

@@ -44,8 +44,12 @@ defmodule Mssqlex.ODBC do
                                            | {:updated, non_neg_integer()}}
                                            | {:error, Exception.t}
   def query(pid, statement, params) do
-    GenServer.call(pid,
-      {:query, %{statement: IO.iodata_to_binary(statement), params: params}})
+    if Process.alive?(pid) do
+      GenServer.call(pid,
+        {:query, %{statement: IO.iodata_to_binary(statement), params: params}})
+    else
+      {:error, :no_connection}
+    end
   end
 
   @doc """
@@ -58,7 +62,11 @@ defmodule Mssqlex.ODBC do
   """
   @spec commit(pid()) :: :ok | {:error, Exception.t}
   def commit(pid) do
-    GenServer.call(pid, :commit)
+    if Process.alive?(pid) do
+      GenServer.call(pid, :commit)
+    else
+      {:error, %Mssqlex.Error{message: :no_connection} }
+    end
   end
 
   @doc """
@@ -68,7 +76,11 @@ defmodule Mssqlex.ODBC do
   """
   @spec rollback(pid()) :: :ok | {:error, Exception.t}
   def rollback(pid) do
-    GenServer.call(pid, :rollback)
+    if Process.alive?(pid) do
+      GenServer.call(pid, :rollback)
+    else
+      {:error, %Mssqlex.Error{message: :no_connection} }
+    end
   end
 
   @doc """

mix.exs

@@ -3,7 +3,7 @@ defmodule Mssqlex.Mixfile do
 
   def project do
     [app: :mssqlex,
-     version: "0.4.1",
+     version: "0.4.2",
      description: "Adapter to Microsoft SQL Server. Using DBConnection and ODBC.",
      elixir: "~> 1.4",
      build_embedded: Mix.env == :prod,

test/mssqlex/transaction_test.exs

@@ -66,6 +66,14 @@ defmodule Mssqlex.TransactionTest do
       Mssqlex.query(pid, "SELECT * from #{table_name};", [])
   end
 
+  test "failing transaction timeout test", %{pid: pid} do
+    assert_raise Mssqlex.Error, fn ->
+    DBConnection.transaction(pid, fn _ ->
+        :timer.sleep(1000)
+      end, [timeout: 0])
+    end
+  end
+
   test "manual rollback transaction test", %{pid: pid} do
     table_name = "transaction_test.dbo.roll_back"
     assert {:error, :rollback} =