We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2b9a11c commit defcb3dCopy full SHA for defcb3d
datafusion-postgres/src/handlers.rs
@@ -471,7 +471,7 @@ impl SimpleQueryHandler for DfSessionService {
471
}
472
473
let mut results = vec![];
474
- for statement in statements {
+ 'stmt: for statement in statements {
475
// TODO: improve statement check by using statement directly
476
let query = statement.to_string();
477
let query_lower = query.to_lowercase().trim().to_string();
@@ -495,7 +495,8 @@ impl SimpleQueryHandler for DfSessionService {
495
.handle_query(&statement, &self.session_context, client)
496
.await
497
{
498
- return result.map(|response| vec![response]);
+ results.push(result?);
499
+ break 'stmt;
500
501
502
0 commit comments