Browse Source

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

qdy 3 months ago
parent
commit
6ece100d77
2 changed files with 2 additions and 2 deletions
  1. 1
    1
      factory/db_factory.go
  2. 1
    1
      functions/query_csv.go

+ 1
- 1
factory/db_factory.go View File

143
 
143
 
144
 // QueryParamsNameToCSV 命名参数查询并返回 CSV 字节数据
144
 // QueryParamsNameToCSV 命名参数查询并返回 CSV 字节数据
145
 // params 可以是 map[string]interface{} 或结构体
145
 // params 可以是 map[string]interface{} 或结构体
146
-func (f *DBFactory) QueryParamsNameToCSV(db *sqlx.DB, sql string, params ...interface{}) ([]byte, error) {
146
+func (f *DBFactory) QueryParamsNameToCSV(db *sqlx.DB, sql string, params map[string]interface{}) ([]byte, error) {
147
 
147
 
148
 	return functions.QueryParamsNameToCSV(f.db, sql, params)
148
 	return functions.QueryParamsNameToCSV(f.db, sql, params)
149
 }
149
 }

+ 1
- 1
functions/query_csv.go View File

39
 
39
 
40
 // QueryParamsNameToCSV 命名参数查询并返回 CSV 字节数据
40
 // QueryParamsNameToCSV 命名参数查询并返回 CSV 字节数据
41
 // params 可以是 map[string]interface{} 或结构体
41
 // params 可以是 map[string]interface{} 或结构体
42
-func QueryParamsNameToCSV(db *sqlx.DB, sql string, params interface{}) ([]byte, error) {
42
+func QueryParamsNameToCSV(db *sqlx.DB, sql string, params map[string]interface{}) ([]byte, error) {
43
 	if sql == "" {
43
 	if sql == "" {
44
 		return nil, fmt.Errorf("SQL query cannot be empty")
44
 		return nil, fmt.Errorf("SQL query cannot be empty")
45
 	}
45
 	}

Loading…
Cancel
Save