fix(core): error on empty query

kndndrj · Apr 23, 2024 · 205cd25 · 205cd25
1 parent 940d726
commit 205cd25
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/dbee/core/connection.go b/dbee/core/connection.go
@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"strings"
 
 	"github.com/google/uuid"
 )
@@ -102,6 +103,9 @@ func (c *Connection) GetParams() *ConnectionParams {
 
 func (c *Connection) Execute(query string, onEvent func(CallState, *Call)) *Call {
 	exec := func(ctx context.Context) (ResultStream, error) {
+		if strings.TrimSpace(query) == "" {
+			return nil, errors.New("empty query")
+		}
 		return c.driver.Query(ctx, query)
 	}