From 3b482cd9749fefd875fa4b4b0fd4abce6ce35d50 Mon Sep 17 00:00:00 2001 From: Egor Vorontsov Date: Wed, 26 Nov 2025 09:26:06 +0300 Subject: [PATCH] Refactored `SELECT` detection in PG SQL. --- crates/pg/src/pg_server.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/crates/pg/src/pg_server.rs b/crates/pg/src/pg_server.rs index 860df156f25..1009a183ec4 100644 --- a/crates/pg/src/pg_server.rs +++ b/crates/pg/src/pg_server.rs @@ -182,13 +182,13 @@ where let mut result = Vec::with_capacity(sql.len()); for sql_result in sql { let header = row_desc(&sql_result.schema, &Format::UnifiedText); - if sql_result.rows.is_empty() && !query.to_uppercase().contains("SELECT") { - let tag = Tag::new(&stats(&sql_result)); - result.push(Response::Execution(tag)); - } else { + if !sql_result.schema.is_empty() { let rows = to_rows(sql_result, header.clone())?; let q = QueryResponse::new(header, rows); result.push(Response::Query(q)); + } else { + let tag = Tag::new(&stats(&sql_result)); + result.push(Response::Execution(tag)); } } Ok(result)