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 ff70bc3 commit fbd8b51Copy full SHA for fbd8b51
datafusion-postgres/src/handlers.rs
@@ -94,9 +94,13 @@ impl SimpleQueryHandler for DfSessionService {
94
.map_err(|e| PgWireError::ApiError(Box::new(e)))?;
95
96
// Extract count field from the first batch
97
- let rows_affected = result.first()
+ let rows_affected = result
98
+ .first()
99
.and_then(|batch| batch.column_by_name("count"))
- .and_then(|col| col.as_any().downcast_ref::<datafusion::arrow::array::UInt64Array>())
100
+ .and_then(|col| {
101
+ col.as_any()
102
+ .downcast_ref::<datafusion::arrow::array::UInt64Array>()
103
+ })
104
.map_or(0, |array| array.value(0) as usize);
105
106
// Create INSERT tag with the affected row count
0 commit comments