@@ -377,7 +377,7 @@ defmodule Postgrex.Protocol do
377
377
378
378
def handle_prepare ( % Query { } = query , opts , % { queries: nil } = s ) do
379
379
# always use unnamed if no cache
380
- handle_prepare ( % Query { query | name: "" } , opts , s )
380
+ handle_prepare ( % { query | name: "" } , opts , s )
381
381
end
382
382
383
383
def handle_prepare ( % Query { } = query , opts , s ) do
@@ -1684,11 +1684,11 @@ defmodule Postgrex.Protocol do
1684
1684
end
1685
1685
end
1686
1686
1687
- defp describe_params ( % { types: types } , query , param_oids ) do
1687
+ defp describe_params ( % { types: types } , % Query { } = query , param_oids ) do
1688
1688
with { :ok , param_info } <- fetch_type_info ( param_oids , types ) do
1689
1689
{ param_formats , param_types } = Enum . unzip ( param_info )
1690
1690
1691
- query = % Query {
1691
+ query = % {
1692
1692
query
1693
1693
| param_oids: param_oids ,
1694
1694
param_formats: param_formats ,
@@ -1716,8 +1716,8 @@ defmodule Postgrex.Protocol do
1716
1716
end
1717
1717
end
1718
1718
1719
- defp describe_result ( % { types: types } , query , nil , nil , nil ) do
1720
- query = % Query {
1719
+ defp describe_result ( % { types: types } , % Query { } = query , nil , nil , nil ) do
1720
+ query = % {
1721
1721
query
1722
1722
| ref: make_ref ( ) ,
1723
1723
types: types ,
@@ -1730,7 +1730,7 @@ defmodule Postgrex.Protocol do
1730
1730
{ :ok , query }
1731
1731
end
1732
1732
1733
- defp describe_result ( % { types: types } , query , result_oids , result_mods , columns ) do
1733
+ defp describe_result ( % { types: types } , % Query { } = query , result_oids , result_mods , columns ) do
1734
1734
with { :ok , result_info } <- fetch_type_info ( result_oids , types ) do
1735
1735
{ result_formats , result_types } = Enum . unzip ( result_info )
1736
1736
@@ -1742,7 +1742,7 @@ defmodule Postgrex.Protocol do
1742
1742
{ extension , mod } -> { extension , mod }
1743
1743
end )
1744
1744
1745
- query = % Query {
1745
+ query = % {
1746
1746
query
1747
1747
| ref: make_ref ( ) ,
1748
1748
types: types ,
@@ -3040,7 +3040,7 @@ defmodule Postgrex.Protocol do
3040
3040
case recv_ready ( s , status , buffer ) do
3041
3041
{ :ok , s } ->
3042
3042
% { connection_id: connection_id } = s
3043
- { :error , % Postgrex.Error { err | connection_id: connection_id } , s }
3043
+ { :error , % { err | connection_id: connection_id } , s }
3044
3044
3045
3045
{ :disconnect , _ , _ } = disconnect ->
3046
3046
disconnect
@@ -3113,7 +3113,7 @@ defmodule Postgrex.Protocol do
3113
3113
case done ( s , query , rows , tag ) do
3114
3114
{ % Postgrex.Result { rows: rows } = result , s } when is_list ( rows ) ->
3115
3115
# shows rows for all streamed results but we only want for last chunk.
3116
- { % Postgrex.Result { result | num_rows: length ( rows ) } , s }
3116
+ { % { result | num_rows: length ( rows ) } , s }
3117
3117
3118
3118
{ result , s } ->
3119
3119
{ result , s }
0 commit comments