修复执行sql代码bugp

factory/db_factory.go

@@ -118,7 +118,7 @@ func (f *DBFactory) QueryToJSON(sql string) *types.QueryResult {
 }
 
 // QueryParamsToJSON 位置参数查询并返回 JSON 字节数据
-func (f *DBFactory) QueryPositionalToJSON(sql string, params ...interface{}) *types.QueryResult {
+func (f *DBFactory) QueryPositionalToJSON(sql string, params []interface{}) *types.QueryResult {
 
 	return functions.QueryPositionalToJSON(f.db, sql, params)
 }
@@ -136,7 +136,7 @@ func (f *DBFactory) QueryToCSV(sql string) ([]byte, error) {
 }
 
 // QueryParamsToCSV 位置参数查询并返回 CSV 字节数据
-func (f *DBFactory) QueryPositionalToCSV(sql string, params ...interface{}) ([]byte, error) {
+func (f *DBFactory) QueryPositionalToCSV(sql string, params []interface{}) ([]byte, error) {
 
 	return functions.QueryPositionalToCSV(f.db, sql, params)
 }

functions/query_csv.go

@@ -24,12 +24,12 @@ func QueryToCSV(db *sqlx.DB, sql string) ([]byte, error) {
 }
 
 // QueryParamsToCSV 位置参数查询并返回 CSV 字节数据
-func QueryPositionalToCSV(db *sqlx.DB, sql string, positionalParams ...interface{}) ([]byte, error) {
+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, positionalParams)
+	rows, err := db.Query(sql, params...)
 	if err != nil {
 		return nil, fmt.Errorf("query execution failed: %v", err)
 	}

functions/query_json.go

@@ -37,17 +37,17 @@ func QueryParamsNameToJSON(db *sqlx.DB, sql string, params map[string]interface{
 }
 
 // QueryPositionalToJSON 执行带位置参数的查询
-func QueryPositionalToJSON(db *sqlx.DB, sql string, positionalParams ...interface{}) *types.QueryResult {
+func QueryPositionalToJSON(db *sqlx.DB, sql string, params []interface{}) *types.QueryResult {
 	startTime := time.Now()
 
-	fmt.Printf("positionalParams: %s", positionalParams)
+	fmt.Printf("positionalParams: %s", params)
 	fmt.Printf("sql: %s", sql)
 	if sql == "" {
 		return createErrorResult("SQL query cannot be empty", startTime)
 	}
 
 	// 执行查询
-	rows, err := db.Query(sql, positionalParams...)
+	rows, err := db.Query(sql, params...)
 	if err != nil {
 		return createErrorResult(fmt.Sprintf("Query execution failed: %v", err), startTime)
 	}