forks/erlang-sqlite3
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Restored correct error handling

Browse Source
This commit is contained in:
Alexey Romanov
2010-10-21 12:03:17 +04:00
parent 8548bbac69
commit c7444dc5aa
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/sqlite3.erl
View File

@@ -621,6 +621,7 @@ create_port_cmd(Dbase) ->
atom_to_list(?DRIVER_NAME) ++ " " ++ Dbase. atom_to_list(?DRIVER_NAME) ++ " " ++ Dbase.
do_handle_sql_exec(SQL, #state{port = Port} = State) -> do_handle_sql_exec(SQL, #state{port = Port} = State) ->
% ?debugFmt("~s~n", [SQL]),
Reply = exec(Port, {sql_exec, SQL}), Reply = exec(Port, {sql_exec, SQL}),
{reply, Reply, State}. {reply, Reply, State}.
@@ -638,9 +639,13 @@ wait_result(Port) ->
{Port, Reply} -> {Port, Reply} ->
% ?debugFmt("Reply: ~p~n", [Reply]), % ?debugFmt("Reply: ~p~n", [Reply]),
Reply; Reply;
{error, Reason} ->
error_logger:error_msg("sqlite3 driver port closed with reason~p~n", [Reason]),
% ?debugFmt("Error: ~p~n", [Reason]),
{error, Reason};
{'EXIT', Port, Reason} -> {'EXIT', Port, Reason} ->
error_logger:error_msg("sqlite3 driver port closed with reason~p~n", [Reason]), error_logger:error_msg("sqlite3 driver port closed with reason~p~n", [Reason]),
?debugFmt("Error: ~p~n", [Reason]), % ?debugFmt("Error: ~p~n", [Reason]),
{error, Reason} {error, Reason}
%% ; %% ;
%% _Else -> %% _Else ->