修复执行sql代码bugp

functions/query_csv.go

 	"database/sql"
 	"encoding/csv"
 	"fmt"
-	"log"
 	"strings"
 
 	"github.com/jmoiron/sqlx"
 		return nil, fmt.Errorf("SQL query cannot be empty")
 	}
 
-	log.Printf("QueryRequest 参数:\n%s", sql)
-	log.Printf("QueryRequest 参数:\n%s", params)
-	//query, args, err := sqlx.NamedQuery(sql, params)
-	//if err != nil {
-	//	return nil, fmt.Errorf("failed to bind named parameters: %v", err)
-	//	}
+	query, args, err := sqlx.Named(sql, params)
+	if err != nil {
+		return nil, fmt.Errorf("failed to bind named parameters: %v", err)
+	}
 
-	//query = db.Rebind(query)
-	rows, err := sqlx.NamedQuery(db, sql, params)
+	query = db.Rebind(query)
+	rows, err := db.Query(query, args...)
 	if err != nil {
 		return nil, fmt.Errorf("query execution failed: %v", err)
 	}
-	defer rows.Close()
 
-	log.Printf("QueryRequest err:\n%s", err)
-	return rowsToCSV(rows.Rows)
+	return rowsToCSV(rows)
 }
 
 // / rowsToCSV 公共方法：将查询结果转换为 CSV 字节数据

functions/query_json.go

 	"database/sql"
 	"encoding/json"
 	"fmt"
-	"log"
 	"time"
 
 	"git.x2erp.com/qdy/go-base/types"
 		return createErrorResult("SQL query cannot be empty", startTime)
 	}
 
-	log.Printf("QueryRequest sql:\n%s", sql)
-	log.Printf("QueryRequest 参数:\n%s", params)
 	// 处理命名参数
 	query, args, err := sqlx.Named(sql, params)
 	if err != nil {
 		return createErrorResult(fmt.Sprintf("Failed to process named parameters: %v", err), startTime)
 	}
 
-	log.Printf("QueryRequest query:\n%s", query)
-	log.Printf("QueryRequest query args:\n%s", args)
-
 	// 执行查询
 	rows, err := db.Query(sqlx.Rebind(sqlx.DOLLAR, query), args...)
 	//rows, err := sqlx.NamedQuery(db, sql, params)
 	}
 	defer rows.Close()
 
-	log.Printf("QueryRequest rows:\n%s", "ok")
 	// 处理结果集
 	return processQueryResult(rows, startTime)
 }
 
 // QueryPositionalToJSON 执行带位置参数的查询
-func QueryPositionalToJSON(db *sqlx.DB, sql string, positionalParams []interface{}) *types.QueryResult {
+func QueryPositionalToJSON(db *sqlx.DB, sql string, positionalParams ...interface{}) *types.QueryResult {
 	startTime := time.Now()
 
 	if sql == "" {
 	}
 
 	// 执行查询
-	rows, err := db.Query(sql, positionalParams)
+	rows, err := db.Query(sql, positionalParams...)
 	if err != nil {
 		return createErrorResult(fmt.Sprintf("Query execution failed: %v", err), startTime)
 	}