修复执行sql代码bugp

functions/query_json.go

@@ -19,20 +19,21 @@ func QueryParamsNameToJSON(db *sqlx.DB, sql string, params map[string]interface{
 	}
 
 	// 处理命名参数
-	query, args, err := sqlx.Named(sql, params)
-	if err != nil {
-		return createErrorResult(fmt.Sprintf("Failed to process named parameters: %v", err), startTime)
-	}
+	//query, args, err := sqlx.Named(sql, params)
+	//if err != nil {
+	//	return createErrorResult(fmt.Sprintf("Failed to process named parameters: %v", err), startTime)
+	//}
 
 	// 执行查询
-	rows, err := db.Query(sqlx.Rebind(sqlx.DOLLAR, query), args...)
+	//rows, err := db.Query(sqlx.Rebind(sqlx.DOLLAR, query), args...)
+	rows, err := sqlx.NamedQuery(db, sql, params)
 	if err != nil {
 		return createErrorResult(fmt.Sprintf("Query execution failed: %v", err), startTime)
 	}
 	defer rows.Close()
 
 	// 处理结果集
-	return processQueryResult(rows, startTime)
+	return processQueryResult(rows.Rows, startTime)
 }
 
 // QueryPositionalToJSON 执行带位置参数的查询