|
|
@@ -44,18 +44,19 @@ func QueryParamsNameToCSV(db *sqlx.DB, sql string, params map[string]interface{}
|
|
44
|
44
|
return nil, fmt.Errorf("SQL query cannot be empty")
|
|
45
|
45
|
}
|
|
46
|
46
|
|
|
47
|
|
- query, args, err := sqlx.Named(sql, params)
|
|
48
|
|
- if err != nil {
|
|
49
|
|
- return nil, fmt.Errorf("failed to bind named parameters: %v", err)
|
|
50
|
|
- }
|
|
|
47
|
+ //query, args, err := sqlx.NamedQuery(sql, params)
|
|
|
48
|
+ //if err != nil {
|
|
|
49
|
+ // return nil, fmt.Errorf("failed to bind named parameters: %v", err)
|
|
|
50
|
+ // }
|
|
51
|
51
|
|
|
52
|
|
- query = db.Rebind(query)
|
|
53
|
|
- rows, err := db.Query(query, args...)
|
|
|
52
|
+ //query = db.Rebind(query)
|
|
|
53
|
+ rows, err := sqlx.NamedQuery(db, sql, params)
|
|
54
|
54
|
if err != nil {
|
|
55
|
55
|
return nil, fmt.Errorf("query execution failed: %v", err)
|
|
56
|
56
|
}
|
|
|
57
|
+ defer rows.Close()
|
|
57
|
58
|
|
|
58
|
|
- return rowsToCSV(rows)
|
|
|
59
|
+ return rowsToCSV(rows.Rows)
|
|
59
|
60
|
}
|
|
60
|
61
|
|
|
61
|
62
|
// / rowsToCSV 公共方法:将查询结果转换为 CSV 字节数据
|