aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/mysqlerl_connection.erl6
1 files changed, 1 insertions, 5 deletions
diff --git a/src/mysqlerl_connection.erl b/src/mysqlerl_connection.erl
index a27c25f..35c69b2 100644
--- a/src/mysqlerl_connection.erl
+++ b/src/mysqlerl_connection.erl
@@ -43,7 +43,7 @@ code_change(_OldVsn, State, _Extra) ->
{ok, State}.
handle_call(#sql_query{q = Query}, _From, State) ->
- {reply, handle_query(State#state.ref, Query), State};
+ {reply, make_request(State#state.ref, {sql_query, Query}), State};
handle_call(Request, From, State) ->
io:format("DEBUG: got unknown call from ~p: ~p~n", [From, Request]),
{noreply, State}.
@@ -64,10 +64,6 @@ helper() ->
end,
filename:join([PrivDir, "mysqlerl"]).
-handle_query(Ref, Query) ->
- io:format("DEBUG: got query: ~p~n", [Query]),
- make_request(Ref, {sql_query, Query}).
-
make_request(Ref, Req) ->
port_command(Ref, term_to_binary(Req)),
receive