Don't desync the stream on error in quick_query
This commit is contained in:
parent
8ae9636422
commit
d72c607b6d
@ -654,8 +654,10 @@ impl InnerPostgresConnection {
|
|||||||
result.push(row.move_iter().map(|opt|
|
result.push(row.move_iter().map(|opt|
|
||||||
opt.map(|b| str::from_utf8_owned(b).unwrap()))
|
opt.map(|b| str::from_utf8_owned(b).unwrap()))
|
||||||
.collect()),
|
.collect()),
|
||||||
ErrorResponse { fields } =>
|
ErrorResponse { fields } => {
|
||||||
return Err(PgDbError(PostgresDbError::new(fields))),
|
if_ok!(self.wait_for_ready());
|
||||||
|
return Err(PgDbError(PostgresDbError::new(fields)));
|
||||||
|
}
|
||||||
_ => {}
|
_ => {}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user