|
@@ -91,7 +91,7 @@ execute(C, S, N) ->
|
|
|
|
|
|
execute(C, S, PortalName, N) ->
|
|
execute(C, S, PortalName, N) ->
|
|
Ref = ipgsql:execute(C, S, PortalName, N),
|
|
Ref = ipgsql:execute(C, S, PortalName, N),
|
|
- receive_extended_result(C, Ref).
|
|
|
|
|
|
+ receive_extended_result(C, Ref, []).
|
|
|
|
|
|
execute_batch(C, Batch) ->
|
|
execute_batch(C, Batch) ->
|
|
Ref = ipgsql:execute_batch(C, Batch),
|
|
Ref = ipgsql:execute_batch(C, Batch),
|
|
@@ -176,9 +176,6 @@ receive_result(C, Ref, Cols, Rows) ->
|
|
throw({error, closed})
|
|
throw({error, closed})
|
|
end.
|
|
end.
|
|
|
|
|
|
-receive_extended_result(C, Ref)->
|
|
|
|
- receive_extended_result(C, Ref, []).
|
|
|
|
-
|
|
|
|
receive_extended_result(C, Ref, Rows) ->
|
|
receive_extended_result(C, Ref, Rows) ->
|
|
receive
|
|
receive
|
|
{C, Ref, {data, Row}} ->
|
|
{C, Ref, {data, Row}} ->
|