go 使用sqlx

98 阅读 0 评论 65 点赞

我是靠谱客的博主壮观背包，这篇文章主要介绍go 使用sqlx，现在分享给大家，希望可以做个参考。

引入sqlx包

复制代码

1
2
3
4
5
import （
"fmt"
"github.com/jmoiron/sqlx"
）

定义数据库参数配置

复制代码

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
var (
sqlxdbConfig = DBConfig{
Host:
"127.0.0.1", // ip
Port:
5432,
// psql
5432
UserName: "zyf",
// 用户名
Password: "123",
// 密码
DBName:
"sqlxdb",
// 数据库
}
sqlxdb
*sqlx.DB
)
// 数据库配置
type DBConfig struct {
Host
string
Port
int32
UserName string
Password string
DBName
string
}

函数处理

复制代码

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
type Req struct{
id
int
`json:"id" db:"id"`
}
// main函数
func main(){
// 调链接数据库函数
sqlxdb = postgres(sqlxdbConfig)
// 一条sqlx使用查询实例
sqlxReq := make([]Req, 0)
sql := "select * from sqlx"
if err := sqlxdb.Unsafe().Select(&sqlxReq, sql2); err != nil {
fmt.Printf(" err:%vn", err)
return
}
}
//ToString 表示连接数据库的字符串
func (c DBConfig) ToString() string {
return fmt.Sprintf("host=%s port=%d user=%s "+
"password=%s dbname=%s sslmode=disable", c.Host, c.Port,
c.UserName, c.Password, c.DBName,
)
}
func postgres(dbconfig DBConfig) *sqlx.DB {
// 链接数据库
db, err := sqlx.Open("postgres", dbconfig.ToString())
if err != nil {
fmt.Printf(err)
}
// 最大链接数
db.SetMaxIdleConns(10)
return db
}