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 81d0f42 commit a373572Copy full SHA for a373572
datafusion-postgres/src/handlers.rs
@@ -40,13 +40,6 @@ pub trait QueryHook: Send + Sync {
40
) -> Option<PgWireResult<Vec<Response>>>;
41
}
42
43
-#[derive(Debug, Clone, Copy, PartialEq)]
44
-pub enum TransactionState {
45
- None,
46
- Active,
47
- Failed,
48
-}
49
-
50
// Metadata keys for session-level settings
51
const METADATA_STATEMENT_TIMEOUT: &str = "statement_timeout_ms";
52
@@ -653,7 +646,7 @@ impl ExtendedQueryHandler for DfSessionService {
653
646
.sql_parser
654
647
.parse(sql)
655
648
.map_err(|e| PgWireError::ApiError(Box::new(e)))?;
656
649
+
657
650
if let Some(statement) = statements.into_iter().next() {
658
651
let wrapped_statement = Statement::Statement(Box::new(statement));
659
652
if let Some(result) = hook
0 commit comments