File tree 1 file changed +13
-15
lines changed
1 file changed +13
-15
lines changed Original file line number Diff line number Diff line change @@ -202,22 +202,20 @@ object DbApi {
202
202
.asInstanceOf [R ]
203
203
else if (qr.isExecuteUpdate(query)) updateSql(flattened).asInstanceOf [R ]
204
204
else {
205
- try {
206
- val res = stream(query, fetchSize, queryTimeoutSeconds)(
207
- qr.asInstanceOf [Queryable [Q , Seq [_]]],
208
- fileName,
209
- lineNum
205
+ val res = stream(query, fetchSize, queryTimeoutSeconds)(
206
+ qr.asInstanceOf [Queryable [Q , Seq [_]]],
207
+ fileName,
208
+ lineNum
209
+ )
210
+ if (qr.isSingleRow(query)) {
211
+ val results = res.take(2 ).toVector
212
+ assert(
213
+ results.size == 1 ,
214
+ s " Single row query must return 1 result, not ${results.size}"
210
215
)
211
- if (qr.isSingleRow(query)) {
212
- val results = res.take(2 ).toVector
213
- assert(
214
- results.size == 1 ,
215
- s " Single row query must return 1 result, not ${results.size}"
216
- )
217
- results.head.asInstanceOf [R ]
218
- } else {
219
- res.toVector.asInstanceOf [R ]
220
- }
216
+ results.head.asInstanceOf [R ]
217
+ } else {
218
+ res.toVector.asInstanceOf [R ]
221
219
}
222
220
}
223
221
}
You can’t perform that action at this time.
0 commit comments