forks/esqlite
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #7 from arjan/parametrized-exec

Browse Source 
Add parametrized exec's (esqlite3:exec/3 and esqlite3:exec/4)
This commit is contained in:
Maas-Maarten Zeeman
2014-01-19 23:49:29 -08:00
parent 8be2c9ec35 9ca051542d
commit a27c508e87
2 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
c_src/esqlite3_nif.c
View File

@@ -20,6 +20,7 @@
#include <erl_nif.h>
#include <string.h>
#include <stdio.h>
#include "queue.h"
#include "sqlite3.h"
@@ -491,12 +492,7 @@ do_step(ErlNifEnv *env, sqlite3 *db, sqlite3_stmt *stmt)
if(rc == SQLITE_BUSY)
return make_atom(env, "$busy");
if(rc == SQLITE_ERROR)
return make_sqlite3_error_tuple(env, rc, db);
if(rc == SQLITE_MISUSE)
return make_error_tuple(env, "misuse");
return make_error_tuple(env, "unexpected_return_value");
}
static ERL_NIF_TERM

13
src/esqlite3.erl
View File

@@ -198,7 +198,18 @@ exec(Sql, Connection) ->
exec(Sql, {connection, _Ref, Connection}, Timeout) ->
Ref = make_ref(),
ok = esqlite3_nif:exec(Connection, Ref, self(), Sql),
receive_answer(Ref, Timeout).
receive_answer(Ref, Timeout);
%% @spec exec(iolist(), list(term()), connection()) -> integer() | {error, error_message()}
exec(Sql, Params, {connection, _, _}=Connection) when is_list(Params) ->
exec(Sql, Params, Connection, ?DEFAULT_TIMEOUT).
%% @spec exec(iolist(), list(term()), connection(), timeout()) -> integer() | {error, error_message()}
exec(Sql, Params, {connection, _, _}=Connection, Timeout) when is_list(Params) ->
{ok, Statement} = prepare(Sql, Connection, Timeout),
bind(Statement, Params),
step(Statement, Timeout).
%% @doc Insert records, returns the last rowid.
%%