|
@@ -89,7 +89,7 @@ close(C) ->
|
|
get_parameter(C, Name) ->
|
|
get_parameter(C, Name) ->
|
|
pgsql_sock:get_parameter(C, Name).
|
|
pgsql_sock:get_parameter(C, Name).
|
|
|
|
|
|
--spec squery(connection(), string()) ->
|
|
|
|
|
|
+-spec squery(connection(), string() | iodata()) ->
|
|
ok_reply(squery_row()) | {error, query_error()}.
|
|
ok_reply(squery_row()) | {error, query_error()}.
|
|
squery(C, Sql) ->
|
|
squery(C, Sql) ->
|
|
gen_server:call(C, {squery, Sql}, infinity).
|
|
gen_server:call(C, {squery, Sql}, infinity).
|
|
@@ -107,7 +107,7 @@ equery(C, Sql, Parameters) ->
|
|
Error
|
|
Error
|
|
end.
|
|
end.
|
|
|
|
|
|
--spec equery(connection(), string(), string(), [bind_param()]) ->
|
|
|
|
|
|
+-spec equery(connection(), string(), string() | iodata(), [bind_param()]) ->
|
|
ok_reply(equery_row()) | {error, query_error()}.
|
|
ok_reply(equery_row()) | {error, query_error()}.
|
|
equery(C, Name, Sql, Parameters) ->
|
|
equery(C, Name, Sql, Parameters) ->
|
|
case parse(C, Name, Sql, []) of
|
|
case parse(C, Name, Sql, []) of
|
|
@@ -126,7 +126,7 @@ parse(C, Sql) ->
|
|
parse(C, Sql, Types) ->
|
|
parse(C, Sql, Types) ->
|
|
parse(C, "", Sql, Types).
|
|
parse(C, "", Sql, Types).
|
|
|
|
|
|
--spec parse(connection(), iolist(), string(), [epgsql_type()]) ->
|
|
|
|
|
|
+-spec parse(connection(), iolist(), string() | iodata(), [epgsql_type()]) ->
|
|
{ok, #statement{}} | {error, query_error()}.
|
|
{ok, #statement{}} | {error, query_error()}.
|
|
parse(C, Name, Sql, Types) ->
|
|
parse(C, Name, Sql, Types) ->
|
|
sync_on_error(C, gen_server:call(C, {parse, Name, Sql, Types}, infinity)).
|
|
sync_on_error(C, gen_server:call(C, {parse, Name, Sql, Types}, infinity)).
|