Packages

jamdb_oracle

0.0.2
0.5.12 0.5.11 0.5.10 0.5.9 0.5.8 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 retired 0.5.1 retired 0.5.0 retired 0.4.12 retired 0.4.11 retired 0.4.10 retired 0.4.9 retired 0.4.8 retired 0.4.7 retired 0.4.6 retired 0.4.5 retired 0.4.4 retired 0.4.3 retired 0.4.2 retired 0.4.1 retired 0.4.0 retired 0.3.10 retired 0.3.9 retired 0.3.8 retired 0.3.7 retired 0.3.6 retired 0.3.5 retired 0.3.4 retired 0.3.3 retired 0.3.2 retired 0.3.1 retired 0.3.0 retired 0.2.7 retired 0.2.6 retired 0.2.5 retired 0.2.4 retired 0.2.3 retired 0.2.2 retired 0.2.1 retired 0.2.0 retired 0.1.6 retired 0.1.5 retired 0.1.4 retired 0.1.3 retired 0.1.2 retired 0.1.1 retired 0.1.0 retired 0.0.10 retired 0.0.9 retired 0.0.8 retired 0.0.7 retired 0.0.6 retired 0.0.5 retired 0.0.4 retired 0.0.3 retired 0.0.2 retired 0.0.1 retired

Erlang driver and Ecto adapter for Oracle

Retired package: Deprecated
HexDocs

Current section

Files

Jump to
Readme
62 Versions
1 Dependency
Dependants
Files
Activity
jamdb_oracle src jamdb_oracle.erl
Raw

src/jamdb_oracle.erl 

-module(jamdb_oracle).

-behaviour(gen_server).



%% API

-export([start_link/1, start/1]).

-export([stop/1]).

-export([sql_query/2, sql_query/3]).



%% gen_server callbacks

-export([init/1, terminate/2]).

-export([handle_call/3, handle_cast/2, handle_info/2]).

-export([code_change/3]).



-include("jamdb_oracle_defaults.hrl").



%% API

-spec start_link(jamdb_oracle_conn:options()) -> {ok, pid()} | {error, term()}.

start_link(Opts) when is_list(Opts) ->

    gen_server:start_link(?MODULE, Opts, []).



-spec start(jamdb_oracle_conn:options()) -> {ok, pid()} | {error, term()}.

start(Opts) when is_list(Opts) ->

    gen_server:start(?MODULE, Opts, []).



-spec stop(pid()) -> ok.

stop(Pid) ->

    call_infinity(Pid, stop).



sql_query(Pid, Query) ->

    sql_query(Pid, Query, ?DEF_TIMEOUT).



sql_query(Pid, Query, Timeout) ->

    call_infinity(Pid, {sql_query, Query, Timeout}).



%% gen_server callbacks

init(Opts) ->

    {ok, State} = jamdb_oracle_conn:connect(Opts),

    {ok, State}.



%% Error types: socket, remote, local

handle_call({sql_query, Query, Timeout}, _From, State) ->

    try jamdb_oracle_conn:sql_query(State, Query, Timeout) of

        {ok, Result, State2} -> 

            {reply, {ok, Result}, State2};

        {error, socket, Reason, State2} ->

            {ok, State3} = jamdb_oracle_conn:reconnect(State2), %% TODO error

            {reply, {error, socket, Reason}, State3};

        {error, Type, Reason, State2} ->

            {reply, {error, Type, Reason}, State2}

    catch

        _Class:Reason ->

            Stacktrace = erlang:get_stacktrace(),

            ErrDesc = [

                {reason, Reason},

                {stacktrace, Stacktrace}

            ],

            {ok, State2} = jamdb_oracle_conn:reconnect(State),

            {reply, {error, local, {unknown_error, ErrDesc}}, State2}

    end;

%handle_call({prepare, Query}, _From, State) ->

%handle_call({execute, Query}, _From, State) ->

handle_call(stop, _From, State) ->

    {ok, _InitOpts} = jamdb_oracle_conn:disconnect(State),

    {stop, normal, ok, State};

handle_call(_Request, _From, State) ->

    {reply, ok, State}.



handle_cast(_Msg, State) ->

    {noreply, State}.



handle_info(_Info, State) ->

    {noreply, State}.



terminate(_Reason, _State) ->

    ok.



code_change(_OldVsn, State, _Extra) ->

    {ok, State}.



%% internal

call_infinity(Pid, Msg) ->

    gen_server:call(Pid, Msg, infinity).