Packages

jamdb_oracle

0.4.6
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 - 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).

-vsn("0.4.6").

-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]).



%% 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, _Tout) ->

	sql_query(Pid, Query).

	

sql_query(Pid, Query) ->

    call_infinity(Pid, {sql_query, Query}).



%% gen_server callbacks

init(Opts) ->

    case jamdb_oracle_conn:connect(Opts) of

        {ok, State} ->

            case State of

                Opts -> {stop, Opts};

                _ -> {ok, State}

            end;

        {ok, Result, _State} ->

            {stop, Result};

        {error, Type, Result, _State} ->

            {stop, {Type, Result}}

    end.



%% Error types: socket, remote, local

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

%% io:format("~p~n", [Query]),

    try jamdb_oracle_conn:sql_query(State, Query) of

        {ok, Result, State2} -> 

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

        {error, Type, Reason, State2} ->

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

    catch

        error:Reason ->

            {reply, {error, local, Reason}, State}

    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).