Skip to content

Commit f4c7498

Browse files
authored
fix(Sqlite): stop sending rows after first error (#3700)
1 parent ad1d7a8 commit f4c7498

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

sqlx-sqlite/src/connection/worker.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,8 @@ impl ConnectionWorker {
151151
match limit {
152152
None => {
153153
for res in iter {
154-
if tx.send(res).is_err() {
154+
let has_error = res.is_err();
155+
if tx.send(res).is_err() || has_error {
155156
break;
156157
}
157158
}
@@ -171,7 +172,8 @@ impl ConnectionWorker {
171172
}
172173
}
173174
}
174-
if tx.send(res).is_err() {
175+
let has_error = res.is_err();
176+
if tx.send(res).is_err() || has_error {
175177
break;
176178
}
177179
}

0 commit comments

Comments
 (0)