ADD query pointer log.

illacloud · Feb 19, 2024 · 5d66972 · 5d66972
1 parent eb81d1f
commit 5d66972
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/src/actionruntime/mysql/service.go b/src/actionruntime/mysql/service.go
@@ -18,6 +18,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"log"
 	"time"
 
 	"github.com/go-playground/validator/v10"
@@ -140,15 +141,18 @@ func (m *MySQLConnector) Run(resourceOptions map[string]interface{}, actionOptio
 
 	// fetch data
 	if isSelectQuery && m.Action.IsSafeMode() {
+		log.Printf("[DUMP] db.QueryContext() sql: %s\n", escapedSQL)
 		rows, err := db.QueryContext(ctx, escapedSQL, sqlArgs...)
 		if err != nil {
 			return queryResult, err
 		}
+		log.Printf("[DUMP] common.RetrieveToMap start.\n")
 		mapRes, err := common.RetrieveToMap(rows)
 		if err != nil {
 			return queryResult, err
 		}
 		defer rows.Close()
+		log.Printf("[DUMP] common.RetrieveToMap done.\n")
 		queryResult.Success = true
 		queryResult.Rows = mapRes
 	} else if isSelectQuery && !m.Action.IsSafeMode() {

diff --git a/src/actionruntime/postgresql/service.go b/src/actionruntime/postgresql/service.go
@@ -18,6 +18,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"log"
 	"time"
 
 	"github.com/illacloud/builder-backend/src/actionruntime/common"
@@ -146,15 +147,19 @@ func (p *Connector) Run(resourceOptions map[string]interface{}, actionOptions ma
 
 	// fetch data
 	if isSelectQuery && p.Action.IsSafeMode() {
+		log.Printf("[DUMP] db.Query() sql: %s\n", escapedSQL)
 		rows, err := db.Query(ctx, escapedSQL, sqlArgs...)
 		if err != nil {
 			return queryResult, err
 		}
+		log.Printf("[DUMP] common.RetrieveToMap start.\n")
 		mapRes, err := RetrieveToMap(rows)
 		if err != nil {
 			return queryResult, err
 		}
 		defer rows.Close()
+		log.Printf("[DUMP] common.RetrieveToMap end.\n")
+
 		queryResult.Success = true
 		queryResult.Rows = mapRes
 	} else if isSelectQuery && !p.Action.IsSafeMode() {