增加sql带参数的查询方法

factory/db_factory.go

@@ -2,7 +2,6 @@ package factory
 
 import (
 	"fmt"
-	"io"
 	"sync"
 
 	"git.x2erp.com/qdy/go-base/config"
@@ -118,29 +117,35 @@ func (f *DBFactory) QueryToJSON(sql string) *types.QueryResult {
 	return functions.QueryToJSON(f.db, sql)
 }
 
+// QueryParamsToJSON 位置参数查询并返回 JSON 字节数据
+func (f *DBFactory) QueryPositionalToJSON(db *sqlx.DB, sql string, params ...interface{}) *types.QueryResult {
+
+	return functions.QueryPositionalToJSON(f.db, sql, params)
+}
+
+// QueryParamsNameToJSON 命名参数查询并返回 JSON 字节数据
+// params 可以是 map[string]interface{} 或结构体
+func (f *DBFactory) QueryParamsNameToJSON(db *sqlx.DB, sql string, params map[string]interface{}) *types.QueryResult {
+
+	return functions.QueryParamsNameToJSON(f.db, sql, params)
+}
+
 // QueryToCSV 快捷查询，直接返回 CSV 字符串（包含表头）
 func (f *DBFactory) QueryToCSV(sql string) ([]byte, error) {
 	return functions.QueryToCSV(f.db, sql)
 }
 
-// QueryWithColumns 快捷查询，返回完整结果（含列信息）
-func (f *DBFactory) QueryWithColumns(sql string) *types.QueryResult {
-	return functions.QueryWithColumns(f.db, sql)
-}
+// QueryParamsToCSV 位置参数查询并返回 CSV 字节数据
+func (f *DBFactory) QueryPositionalToCSV(db *sqlx.DB, sql string, params ...interface{}) ([]byte, error) {
 
-// QueryDataOnly 快捷查询，返回纯数据（性能优先）
-func (f *DBFactory) QueryDataOnly(sql string) *types.QueryResult {
-	return functions.QueryDataOnly(f.db, sql)
+	return functions.QueryPositionalToCSV(f.db, sql, params)
 }
 
-// QueryCSV 快捷查询，返回 CSV 格式结果（支持自定义是否包含表头）
-func (f *DBFactory) QueryCSV(sql string, includeHeader bool) *types.QueryResult {
-	return functions.QueryCSV(f.db, sql, includeHeader)
-}
+// QueryParamsNameToCSV 命名参数查询并返回 CSV 字节数据
+// params 可以是 map[string]interface{} 或结构体
+func (f *DBFactory) QueryParamsNameToCSV(db *sqlx.DB, sql string, params ...interface{}) ([]byte, error) {
 
-// QueryCSVStream 快捷流式输出 CSV（直接写入 io.Writer，适合大文件）
-func (f *DBFactory) QueryCSVStream(sql string, w io.Writer, includeHeader bool) (int, error) {
-	return functions.QueryCSVStream(f.db, sql, w, includeHeader)
+	return functions.QueryParamsNameToCSV(f.db, sql, params)
 }
 
 // ExecuteDDL 快捷执行DDL语句

functions/query.go

@@ -1,507 +0,0 @@
-package functions
-
-import (
-	"encoding/csv"
-	"encoding/json"
-	"fmt"
-	"io"
-	"strings"
-	"time"
-
-	"git.x2erp.com/qdy/go-base/types"
-	"github.com/jmoiron/sqlx"
-)
-
-// QueryToJSON 执行查询并返回JSON格式数据（统一返回QueryResult）
-func QueryToJSON(db *sqlx.DB, sql string) *types.QueryResult {
-	startTime := time.Now()
-	result := &types.QueryResult{}
-
-	if sql == "" {
-		result.Success = false
-		result.Error = "SQL query cannot be empty"
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	rows, err := db.Query(sql)
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Query execution failed: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-	defer rows.Close()
-
-	columns, err := rows.Columns()
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Failed to get columns: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	var results []map[string]interface{}
-	count := 0
-
-	for rows.Next() {
-		count++
-		values := make([]interface{}, len(columns))
-		valuePtrs := make([]interface{}, len(columns))
-		for i := range columns {
-			valuePtrs[i] = &values[i]
-		}
-
-		if err := rows.Scan(valuePtrs...); err != nil {
-			result.Success = false
-			result.Error = fmt.Sprintf("Failed to scan row: %v", err)
-			result.Time = time.Since(startTime).String()
-			return result
-		}
-
-		resultMap := make(map[string]interface{})
-		for i, col := range columns {
-			// 完全不处理类型，直接赋值，让 json.Marshal 自己处理
-			resultMap[col] = values[i]
-		}
-		results = append(results, resultMap)
-	}
-
-	if err := rows.Err(); err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Row iteration error: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	jsonData, err := json.Marshal(results)
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("JSON marshal failed: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	result.Success = true
-	result.Data = map[string]interface{}{
-		"json":  string(jsonData),
-		"rows":  results,
-		"count": count,
-	}
-	result.Count = count
-	result.Time = time.Since(startTime).String()
-	return result
-}
-
-// QueryToCSV 查询并返回 CSV 字节数据（包含表头）
-func QueryToCSV(db *sqlx.DB, sql string) ([]byte, error) {
-
-	if sql == "" {
-		return nil, fmt.Errorf("SQL query cannot be empty")
-	}
-
-	rows, err := db.Query(sql)
-	if err != nil {
-		return nil, fmt.Errorf("query execution failed: %v", err)
-	}
-	defer rows.Close()
-
-	columns, err := rows.Columns()
-	if err != nil {
-		return nil, fmt.Errorf("failed to get columns: %v", err)
-	}
-
-	var builder strings.Builder
-	writer := csv.NewWriter(&builder)
-
-	// 写入表头
-	//if err := writer.Write(columns); err != nil {
-	//	return nil, fmt.Errorf("failed to write CSV header: %v", err)
-	//}
-
-	count := 0
-	for rows.Next() {
-		count++
-		values := make([]interface{}, len(columns))
-		valuePtrs := make([]any, len(columns))
-		for i := range columns {
-			valuePtrs[i] = &values[i]
-		}
-
-		if err := rows.Scan(valuePtrs...); err != nil {
-			return nil, fmt.Errorf("failed to scan row: %v", err)
-		}
-
-		// 所有值转为字符串
-		row := make([]string, len(columns))
-		for i, val := range values {
-			if val == nil {
-				row[i] = ""
-			} else {
-				row[i] = fmt.Sprintf("%v", val)
-			}
-		}
-
-		if err := writer.Write(row); err != nil {
-			return nil, fmt.Errorf("failed to write CSV row: %v", err)
-		}
-	}
-
-	writer.Flush()
-	if err := writer.Error(); err != nil {
-		return nil, fmt.Errorf("failed to flush CSV: %v", err)
-	}
-
-	if err := rows.Err(); err != nil {
-		return nil, fmt.Errorf("row iteration error: %v", err)
-	}
-
-	return []byte(builder.String()), nil
-}
-
-// ExecuteQueryWithColumns 执行查询并返回完整结果（包含列信息）
-func QueryWithColumns(db *sqlx.DB, sql string) *types.QueryResult {
-	startTime := time.Now()
-	result := &types.QueryResult{}
-
-	if sql == "" {
-		result.Success = false
-		result.Error = "SQL query cannot be empty"
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	rows, err := db.Query(sql)
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Query execution failed: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-	defer rows.Close()
-
-	columns, err := rows.Columns()
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Failed to get columns: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	var results []map[string]interface{}
-	count := 0
-
-	for rows.Next() {
-		count++
-
-		values := make([]interface{}, len(columns))
-		valuePtrs := make([]interface{}, len(columns))
-		for i := range columns {
-			valuePtrs[i] = &values[i]
-		}
-
-		if err := rows.Scan(valuePtrs...); err != nil {
-			result.Success = false
-			result.Error = fmt.Sprintf("Failed to scan row: %v", err)
-			result.Time = time.Since(startTime).String()
-			return result
-		}
-
-		resultRow := make(map[string]interface{})
-		for i, col := range columns {
-			val := values[i]
-			switch v := val.(type) {
-			case []byte:
-				resultRow[col] = string(v)
-			case time.Time:
-				resultRow[col] = v.Format(time.RFC3339)
-			default:
-				resultRow[col] = v
-			}
-		}
-
-		results = append(results, resultRow)
-	}
-
-	if err := rows.Err(); err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Row iteration error: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	result.Success = true
-	result.Data = results
-	result.Count = count
-	result.Time = time.Since(startTime).String()
-
-	return result
-}
-
-// ExecuteQueryDataOnly 执行查询并返回纯数据（不包含列信息，性能更高）
-func QueryDataOnly(db *sqlx.DB, sql string) *types.QueryResult {
-	startTime := time.Now()
-	result := &types.QueryResult{}
-
-	if sql == "" {
-		result.Success = false
-		result.Error = "SQL query cannot be empty"
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	rows, err := db.Query(sql)
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Query execution failed: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-	defer rows.Close()
-
-	columns, err := rows.Columns()
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Failed to get columns: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	var results []interface{}
-	count := 0
-
-	for rows.Next() {
-		count++
-
-		values := make([]interface{}, len(columns))
-		valuePtrs := make([]interface{}, len(columns))
-		for i := range columns {
-			valuePtrs[i] = &values[i]
-		}
-
-		if err := rows.Scan(valuePtrs...); err != nil {
-			result.Success = false
-			result.Error = fmt.Sprintf("Failed to scan row: %v", err)
-			result.Time = time.Since(startTime).String()
-			return result
-		}
-
-		resultRow := make([]interface{}, len(columns))
-		for i, val := range values {
-			switch v := val.(type) {
-			case []byte:
-				resultRow[i] = string(v)
-			case time.Time:
-				resultRow[i] = v.Format(time.RFC3339)
-			default:
-				resultRow[i] = v
-			}
-		}
-
-		results = append(results, resultRow)
-	}
-
-	if err := rows.Err(); err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Row iteration error: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	result.Success = true
-	result.Data = map[string]interface{}{
-		"rows":  results,
-		"count": count,
-	}
-	result.Count = count
-	result.Time = time.Since(startTime).String()
-
-	return result
-}
-
-// ExecuteQueryCSV 执行查询并返回CSV格式数据
-func QueryCSV(db *sqlx.DB, sql string, includeHeader bool) *types.QueryResult {
-	startTime := time.Now()
-	result := &types.QueryResult{}
-
-	if sql == "" {
-		result.Success = false
-		result.Error = "SQL query cannot be empty"
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	rows, err := db.Query(sql)
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Query execution failed: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-	defer rows.Close()
-
-	columns, err := rows.Columns()
-	if err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Failed to get columns: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	var csvBuilder strings.Builder
-	writer := csv.NewWriter(&csvBuilder)
-
-	if includeHeader {
-		if err := writer.Write(columns); err != nil {
-			result.Success = false
-			result.Error = fmt.Sprintf("Failed to write CSV header: %v", err)
-			result.Time = time.Since(startTime).String()
-			return result
-		}
-	}
-
-	count := 0
-
-	for rows.Next() {
-		count++
-
-		values := make([]interface{}, len(columns))
-		valuePtrs := make([]interface{}, len(columns))
-		for i := range columns {
-			valuePtrs[i] = &values[i]
-		}
-
-		if err := rows.Scan(valuePtrs...); err != nil {
-			result.Success = false
-			result.Error = fmt.Sprintf("Failed to scan row: %v", err)
-			result.Time = time.Since(startTime).String()
-			return result
-		}
-
-		rowData := make([]string, len(columns))
-		for i, val := range values {
-			if val == nil {
-				rowData[i] = ""
-				continue
-			}
-
-			switch v := val.(type) {
-			case []byte:
-				rowData[i] = string(v)
-			case string:
-				rowData[i] = v
-			case int, int8, int16, int32, int64:
-				rowData[i] = fmt.Sprintf("%d", v)
-			case uint, uint8, uint16, uint32, uint64:
-				rowData[i] = fmt.Sprintf("%d", v)
-			case float32, float64:
-				rowData[i] = fmt.Sprintf("%f", v)
-			case bool:
-				if v {
-					rowData[i] = "true"
-				} else {
-					rowData[i] = "false"
-				}
-			case time.Time:
-				rowData[i] = v.Format(time.RFC3339)
-			default:
-				rowData[i] = fmt.Sprintf("%v", v)
-			}
-		}
-
-		if err := writer.Write(rowData); err != nil {
-			result.Success = false
-			result.Error = fmt.Sprintf("Failed to write CSV row: %v", err)
-			result.Time = time.Since(startTime).String()
-			return result
-		}
-	}
-
-	if err := rows.Err(); err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Row iteration error: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	writer.Flush()
-	if err := writer.Error(); err != nil {
-		result.Success = false
-		result.Error = fmt.Sprintf("Failed to flush CSV: %v", err)
-		result.Time = time.Since(startTime).String()
-		return result
-	}
-
-	result.Success = true
-	result.Data = map[string]interface{}{
-		"csv":           csvBuilder.String(),
-		"count":         count,
-		"includeHeader": includeHeader,
-	}
-	result.Count = count
-	result.Time = time.Since(startTime).String()
-
-	return result
-}
-
-// ExecuteQueryCSVStream 流式返回CSV数据
-func QueryCSVStream(db *sqlx.DB, sql string, w io.Writer, includeHeader bool) (int, error) {
-
-	rows, err := db.Query(sql)
-	if err != nil {
-		return 0, err
-	}
-	defer rows.Close()
-
-	columns, err := rows.Columns()
-	if err != nil {
-		return 0, err
-	}
-
-	writer := csv.NewWriter(w)
-	count := 0
-
-	if includeHeader {
-		if err := writer.Write(columns); err != nil {
-			return 0, err
-		}
-	}
-
-	for rows.Next() {
-		count++
-
-		values := make([]interface{}, len(columns))
-		valuePtrs := make([]interface{}, len(columns))
-		for i := range columns {
-			valuePtrs[i] = &values[i]
-		}
-
-		if err := rows.Scan(valuePtrs...); err != nil {
-			return count, err
-		}
-
-		rowData := make([]string, len(columns))
-		for i, val := range values {
-			if val == nil {
-				rowData[i] = ""
-				continue
-			}
-			rowData[i] = fmt.Sprintf("%v", val)
-		}
-
-		if err := writer.Write(rowData); err != nil {
-			return count, err
-		}
-	}
-
-	writer.Flush()
-	if err := writer.Error(); err != nil {
-		return count, err
-	}
-
-	if err := rows.Err(); err != nil {
-		return count, err
-	}
-
-	return count, nil
-}

functions/query_csv.go

@@ -0,0 +1,114 @@
+package functions
+
+import (
+	"database/sql"
+	"encoding/csv"
+	"fmt"
+	"strings"
+
+	"github.com/jmoiron/sqlx"
+)
+
+// QueryToCSV 无参数查询并返回 CSV 字节数据
+func QueryToCSV(db *sqlx.DB, sql string) ([]byte, error) {
+	if sql == "" {
+		return nil, fmt.Errorf("SQL query cannot be empty")
+	}
+
+	rows, err := db.Query(sql)
+	if err != nil {
+		return nil, fmt.Errorf("query execution failed: %v", err)
+	}
+
+	return rowsToCSV(rows)
+}
+
+// QueryParamsToCSV 位置参数查询并返回 CSV 字节数据
+func QueryPositionalToCSV(db *sqlx.DB, sql string, params ...interface{}) ([]byte, error) {
+	if sql == "" {
+		return nil, fmt.Errorf("SQL query cannot be empty")
+	}
+
+	rows, err := db.Query(sql, params...)
+	if err != nil {
+		return nil, fmt.Errorf("query execution failed: %v", err)
+	}
+
+	return rowsToCSV(rows)
+}
+
+// QueryParamsNameToCSV 命名参数查询并返回 CSV 字节数据
+// params 可以是 map[string]interface{} 或结构体
+func QueryParamsNameToCSV(db *sqlx.DB, sql string, params interface{}) ([]byte, error) {
+	if sql == "" {
+		return nil, fmt.Errorf("SQL query cannot be empty")
+	}
+
+	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 := db.Query(query, args...)
+	if err != nil {
+		return nil, fmt.Errorf("query execution failed: %v", err)
+	}
+
+	return rowsToCSV(rows)
+}
+
+// / rowsToCSV 公共方法：将查询结果转换为 CSV 字节数据
+func rowsToCSV(rows *sql.Rows) ([]byte, error) {
+	defer rows.Close()
+
+	columns, err := rows.Columns()
+	if err != nil {
+		return nil, fmt.Errorf("failed to get columns: %v", err)
+	}
+
+	var builder strings.Builder
+	writer := csv.NewWriter(&builder)
+
+	// 写入表头
+	if err := writer.Write(columns); err != nil {
+		return nil, fmt.Errorf("failed to write CSV header: %v", err)
+	}
+
+	for rows.Next() {
+		values := make([]interface{}, len(columns))
+		valuePtrs := make([]any, len(columns))
+		for i := range columns {
+			valuePtrs[i] = &values[i]
+		}
+
+		if err := rows.Scan(valuePtrs...); err != nil {
+			return nil, fmt.Errorf("failed to scan row: %v", err)
+		}
+
+		// 所有值转为字符串
+		row := make([]string, len(columns))
+		for i, val := range values {
+			if val == nil {
+				row[i] = ""
+			} else {
+				row[i] = fmt.Sprintf("%v", val)
+			}
+		}
+
+		if err := writer.Write(row); err != nil {
+			return nil, fmt.Errorf("failed to write CSV row: %v", err)
+		}
+	}
+
+	writer.Flush()
+	if err := writer.Error(); err != nil {
+		return nil, fmt.Errorf("failed to flush CSV: %v", err)
+	}
+
+	if err := rows.Err(); err != nil {
+		return nil, fmt.Errorf("row iteration error: %v", err)
+	}
+
+	return []byte(builder.String()), nil
+}

functions/query_json.go

@@ -0,0 +1,152 @@
+package functions
+
+import (
+	"database/sql"
+	"encoding/json"
+	"fmt"
+	"time"
+
+	"git.x2erp.com/qdy/go-base/types"
+	"github.com/jmoiron/sqlx"
+)
+
+// QueryParamsNameToJSON 执行带命名参数的查询
+func QueryParamsNameToJSON(db *sqlx.DB, sql string, params map[string]interface{}) *types.QueryResult {
+	startTime := time.Now()
+
+	if sql == "" {
+		return createErrorResult("SQL query cannot be empty", 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...)
+	if err != nil {
+		return createErrorResult(fmt.Sprintf("Query execution failed: %v", err), startTime)
+	}
+	defer rows.Close()
+
+	// 处理结果集
+	return processQueryResult(rows, startTime)
+}
+
+// QueryPositionalToJSON 执行带位置参数的查询
+func QueryPositionalToJSON(db *sqlx.DB, sql string, params ...interface{}) *types.QueryResult {
+	startTime := time.Now()
+
+	if sql == "" {
+		return createErrorResult("SQL query cannot be empty", startTime)
+	}
+
+	// 执行查询
+	rows, err := db.Query(sql, params...)
+	if err != nil {
+		return createErrorResult(fmt.Sprintf("Query execution failed: %v", err), startTime)
+	}
+	defer rows.Close()
+
+	// 处理结果集
+	return processQueryResult(rows, startTime)
+}
+
+// QueryToJSON 执行无参数的查询
+func QueryToJSON(db *sqlx.DB, sql string) *types.QueryResult {
+	startTime := time.Now()
+
+	if sql == "" {
+		return createErrorResult("SQL query cannot be empty", startTime)
+	}
+
+	// 执行查询
+	rows, err := db.Query(sql)
+	if err != nil {
+		return createErrorResult(fmt.Sprintf("Query execution failed: %v", err), startTime)
+	}
+	defer rows.Close()
+
+	// 处理结果集
+	return processQueryResult(rows, startTime)
+}
+
+// processQueryResult 处理查询结果（公共部分）
+func processQueryResult(rows *sql.Rows, startTime time.Time) *types.QueryResult {
+	result := &types.QueryResult{}
+
+	// 获取列信息
+	columns, err := rows.Columns()
+	if err != nil {
+		result.Success = false
+		result.Error = fmt.Sprintf("Failed to get columns: %v", err)
+		result.Time = time.Since(startTime).String()
+		return result
+	}
+
+	var results []map[string]interface{}
+	count := 0
+
+	// 遍历所有行
+	for rows.Next() {
+		count++
+		values := make([]interface{}, len(columns))
+		valuePtrs := make([]interface{}, len(columns))
+		for i := range columns {
+			valuePtrs[i] = &values[i]
+		}
+
+		if err := rows.Scan(valuePtrs...); err != nil {
+			result.Success = false
+			result.Error = fmt.Sprintf("Failed to scan row: %v", err)
+			result.Time = time.Since(startTime).String()
+			return result
+		}
+
+		resultMap := make(map[string]interface{})
+		for i, col := range columns {
+			// 完全不处理类型，直接赋值，让 json.Marshal 自己处理
+			resultMap[col] = values[i]
+		}
+		results = append(results, resultMap)
+	}
+
+	// 检查行遍历错误
+	if err := rows.Err(); err != nil {
+		result.Success = false
+		result.Error = fmt.Sprintf("Row iteration error: %v", err)
+		result.Time = time.Since(startTime).String()
+		return result
+	}
+
+	// 转换为JSON
+	jsonData, err := json.Marshal(results)
+	if err != nil {
+		result.Success = false
+		result.Error = fmt.Sprintf("JSON marshal failed: %v", err)
+		result.Time = time.Since(startTime).String()
+		return result
+	}
+
+	// 构建成功结果
+	result.Success = true
+	result.Data = map[string]interface{}{
+		"json":  string(jsonData),
+		"rows":  results,
+		"count": count,
+	}
+	result.Count = count
+	result.Time = time.Since(startTime).String()
+	return result
+}
+
+// createErrorResult 创建错误结果的辅助函数
+func createErrorResult(errorMsg string, startTime time.Time) *types.QueryResult {
+	return &types.QueryResult{
+		Success: false,
+		Error:   errorMsg,
+		Time:    time.Since(startTime).String(),
+	}
+}