feat: pgwire 0.33 api change for #198 (#199)

sunng87 · web-flow · commit 24368e489ada · 2025-10-02T11:43:40.000-07:00
diff --git a/datafusion-postgres/src/handlers.rs b/datafusion-postgres/src/handlers.rs
@@ -686,7 +686,7 @@ impl ExtendedQueryHandler for DfSessionService {
     }
 }
 
-async fn map_rows_affected_for_insert<'a>(df: &DataFrame) -> PgWireResult<Response<'a>> {
+async fn map_rows_affected_for_insert(df: &DataFrame) -> PgWireResult<Response> {
     // For INSERT queries, we need to execute the query to get the row count
     // and return an Execution response with the proper tag
     let result = df

Original file line number	Diff line number	Diff line change
`@@ -686,7 +686,7 @@ impl ExtendedQueryHandler for DfSessionService {`
`686`	`686`	`}`
`687`	`687`	`}`
`688`	`688`
`689`		`-async fn map_rows_affected_for_insert<'a>(df: &DataFrame) -> PgWireResult<Response<'a>> {`
	`689`	`+async fn map_rows_affected_for_insert(df: &DataFrame) -> PgWireResult<Response> {`
`690`	`690`	`// For INSERT queries, we need to execute the query to get the row count`
`691`	`691`	`// and return an Execution response with the proper tag`
`692`	`692`	`let result = df`