增加sql带参数的查询方法,map

factory/db_factory.go

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

functions/query_csv.go

 }
 
 // QueryParamsToCSV 位置参数查询并返回 CSV 字节数据
-func QueryPositionalToCSV(db *sqlx.DB, sql string, params ...interface{}) ([]byte, error) {
+func QueryPositionalToCSV(db *sqlx.DB, sql string, positionalParams []interface{}) ([]byte, error) {
 	if sql == "" {
 		return nil, fmt.Errorf("SQL query cannot be empty")
 	}
 
-	rows, err := db.Query(sql, params...)
+	rows, err := db.Query(sql, positionalParams)
 	if err != nil {
 		return nil, fmt.Errorf("query execution failed: %v", err)
 	}

functions/query_json.go

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

go.mod

 
 require (
 	filippo.io/edwards25519 v1.1.0 // indirect
-	git.x2erp.com/qdy/go-base v0.1.23
+	git.x2erp.com/qdy/go-base v0.1.25
 	github.com/go-redis/redis/v8 v8.11.5
 	github.com/go-resty/resty/v2 v2.17.0
 	github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 // indirect