Skip to content

Commit 6f64eea

Browse files
authored
fix(handlers): pass unhandled SET queries into datafusion (#120)
1 parent 2f2d6d4 commit 6f64eea

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

datafusion-postgres/src/handlers.rs

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -205,8 +205,15 @@ impl DfSessionService {
205205
)))
206206
}
207207
} else {
208-
// noop: skip any unsupported set statements
209-
Ok(Some(Response::Execution(Tag::new("SET"))))
208+
// pass SET query to datafusion
209+
let df = self
210+
.session_context
211+
.sql(query_lower)
212+
.await
213+
.map_err(|err| PgWireError::ApiError(Box::new(err)))?;
214+
215+
let resp = df::encode_dataframe(df, &Format::UnifiedText).await?;
216+
Ok(Some(Response::Query(resp)))
210217
}
211218
} else {
212219
Ok(None)

0 commit comments

Comments
 (0)