From 9f10251634a7b5b6d29f2fd568f9787fa302f5e4 Mon Sep 17 00:00:00 2001
From: Diego Imbert <diego@windmill.dev>
Date: Fri, 28 Nov 2025 18:55:31 +0100
Subject: [PATCH] fix sql repl for other read ops than select

---
 frontend/src/lib/components/SqlRepl.svelte | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/frontend/src/lib/components/SqlRepl.svelte b/frontend/src/lib/components/SqlRepl.svelte
index 5560871520..681dd06d10 100644
--- a/frontend/src/lib/components/SqlRepl.svelte
+++ b/frontend/src/lib/components/SqlRepl.svelte
@@ -81,6 +81,7 @@
 
 	async function run({ doPostgresRowToJsonFix }: { doPostgresRowToJsonFix?: boolean } = {}) {
 		if (isRunning || !$workspaceStore) return
+		const READ_OPS = ['SELECT', 'WITH', 'SHOW', 'EXPLAIN', 'DESCRIBE']
 		isRunning = true
 		try {
 			const statements = splitSqlStatements(pruneComments(code))
@@ -96,7 +97,7 @@
 			if (doPostgresRowToJsonFix) {
 				transformedCode = statements
 					.map((statement) => {
-						if (statement.trim().toUpperCase().startsWith('SELECT')) {
+						if (READ_OPS.some((op) => statement.trim().toUpperCase().startsWith(op))) {
 							return `SELECT row_to_json(__t__) FROM (${statement}) __t__`
 						}
 						return statement
@@ -132,7 +133,9 @@
 				result = result.map((row: any) => row['row_to_json'])
 			}
 
-			if (statements[statements.length - 1].toUpperCase().trim().startsWith('SELECT')) {
+			if (
+				READ_OPS.some((op) => statements[statements.length - 1].toUpperCase().trim().startsWith(op))
+			) {
 				runHistory.push({
 					created_at: new Date().toISOString(),
 					created_by: '',