@@ -20,7 +20,11 @@ fn query_prepared() {
20
20
let mut client = Client :: connect ( "host=localhost port=5433 user=postgres" , NoTls ) . unwrap ( ) ;
21
21
22
22
let stmt = client. prepare ( "SELECT $1::TEXT" ) . unwrap ( ) ;
23
- let rows = client. query ( & stmt, & [ & "hello" ] ) . unwrap ( ) . to_vec ( ) . unwrap ( ) ;
23
+ let rows = client
24
+ . query ( & stmt, & [ & "hello" ] )
25
+ . unwrap ( )
26
+ . into_vec ( )
27
+ . unwrap ( ) ;
24
28
assert_eq ! ( rows. len( ) , 1 ) ;
25
29
assert_eq ! ( rows[ 0 ] . get:: <_, & str >( 0 ) , "hello" ) ;
26
30
}
@@ -32,7 +36,7 @@ fn query_unprepared() {
32
36
let rows = client
33
37
. query ( "SELECT $1::TEXT" , & [ & "hello" ] )
34
38
. unwrap ( )
35
- . to_vec ( )
39
+ . into_vec ( )
36
40
. unwrap ( ) ;
37
41
assert_eq ! ( rows. len( ) , 1 ) ;
38
42
assert_eq ! ( rows[ 0 ] . get:: <_, & str >( 0 ) , "hello" ) ;
@@ -57,7 +61,7 @@ fn transaction_commit() {
57
61
let rows = client
58
62
. query ( "SELECT * FROM foo" , & [ ] )
59
63
. unwrap ( )
60
- . to_vec ( )
64
+ . into_vec ( )
61
65
. unwrap ( ) ;
62
66
assert_eq ! ( rows. len( ) , 1 ) ;
63
67
assert_eq ! ( rows[ 0 ] . get:: <_, i32 >( 0 ) , 1 ) ;
@@ -82,7 +86,7 @@ fn transaction_rollback() {
82
86
let rows = client
83
87
. query ( "SELECT * FROM foo" , & [ ] )
84
88
. unwrap ( )
85
- . to_vec ( )
89
+ . into_vec ( )
86
90
. unwrap ( ) ;
87
91
assert_eq ! ( rows. len( ) , 0 ) ;
88
92
}
@@ -106,7 +110,7 @@ fn transaction_drop() {
106
110
let rows = client
107
111
. query ( "SELECT * FROM foo" , & [ ] )
108
112
. unwrap ( )
109
- . to_vec ( )
113
+ . into_vec ( )
110
114
. unwrap ( ) ;
111
115
assert_eq ! ( rows. len( ) , 0 ) ;
112
116
}
@@ -136,7 +140,7 @@ fn nested_transactions() {
136
140
let rows = transaction
137
141
. query ( "SELECT id FROM foo ORDER BY id" , & [ ] )
138
142
. unwrap ( )
139
- . to_vec ( )
143
+ . into_vec ( )
140
144
. unwrap ( ) ;
141
145
assert_eq ! ( rows. len( ) , 1 ) ;
142
146
assert_eq ! ( rows[ 0 ] . get:: <_, i32 >( 0 ) , 1 ) ;
@@ -160,7 +164,7 @@ fn nested_transactions() {
160
164
let rows = client
161
165
. query ( "SELECT id FROM foo ORDER BY id" , & [ ] )
162
166
. unwrap ( )
163
- . to_vec ( )
167
+ . into_vec ( )
164
168
. unwrap ( ) ;
165
169
assert_eq ! ( rows. len( ) , 3 ) ;
166
170
assert_eq ! ( rows[ 0 ] . get:: <_, i32 >( 0 ) , 1 ) ;
@@ -187,7 +191,7 @@ fn copy_in() {
187
191
let rows = client
188
192
. query ( "SELECT id, name FROM foo ORDER BY id" , & [ ] )
189
193
. unwrap ( )
190
- . to_vec ( )
194
+ . into_vec ( )
191
195
. unwrap ( ) ;
192
196
193
197
assert_eq ! ( rows. len( ) , 2 ) ;
@@ -246,7 +250,7 @@ fn portal() {
246
250
let rows = transaction
247
251
. query_portal ( & portal, 2 )
248
252
. unwrap ( )
249
- . to_vec ( )
253
+ . into_vec ( )
250
254
. unwrap ( ) ;
251
255
assert_eq ! ( rows. len( ) , 2 ) ;
252
256
assert_eq ! ( rows[ 0 ] . get:: <_, i32 >( 0 ) , 1 ) ;
@@ -255,7 +259,7 @@ fn portal() {
255
259
let rows = transaction
256
260
. query_portal ( & portal, 2 )
257
261
. unwrap ( )
258
- . to_vec ( )
262
+ . into_vec ( )
259
263
. unwrap ( ) ;
260
264
assert_eq ! ( rows. len( ) , 1 ) ;
261
265
assert_eq ! ( rows[ 0 ] . get:: <_, i32 >( 0 ) , 3 ) ;
0 commit comments