1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
package utils
import (
// import mysql
_ "github.com/go-sql-driver/mysql"
)
//var (
// db *sql.DB
// err error
//)
//
//// NewPayConn is 连接支付库
//func NewPayConn() (*sql.DB, error) {
// if db == nil {
// db, err = sql.Open("mysql", beego.AppConfig.String("PayURL"))
// return db, err
// }
// return db, nil
//}
// GetResultRow is 获取返回值， 获取一条
//func GetResultRow(rows *sql.Rows) map[string]string {
// columns, _ := rows.Columns()
// scanArgs := make([]interface{}, len(columns))
// values := make([][]byte, len(columns))
// for j := range values {
// scanArgs[j] = &values[j]
// }
// record := make(map[string]string)
// for rows.Next() {
// rows.Scan(scanArgs...)
// for i, v := range values {
// if v != nil {
// record[columns[i]] = string(v)
// }
// }
// }
// return record
//}
// GetResultRows is 获取所有
//func GetResultRows(rows *sql.Rows) map[int]map[string]string {
// columns, _ := rows.Columns()
// values := make([][]byte, len(columns))
// scans := make([]interface{}, len(columns))
// for k, _ := range values {
// scans[k] = &values[k]
// }
// i := 0
// result := make(map[int]map[string]string)
// for rows.Next() {
// rows.Scan(scans...)
// row := make(map[string]string)
// for k, v := range values {
// key := columns[k]
// row[key] = string(v)
// }
// result[i] = row
// i++
// }
// return result
//}
//// CloseTx is 有错误则关闭事务、没错则提交事务
//func CloseTx(tx *sql.Tx, err error) {
// if err != nil {
// tx.Rollback()
// }
// tx.Commit()
//}