go语言sqlx操作数据库

使用sqlx做单条数据查询

var db *sqlx.DB
func initDB() (err error) {
dsn := "root:yaochizaocan@tcp(192.168.11.236:3306)/sql_test"
db, err = sqlx.Connect("mysql", dsn)
if err != nil {
fmt.Printf("connect DB failed,err:%vn", err)
return err
}
db.SetMaxOpenConns(30) //最大连接数
db.SetMaxIdleConns(20) //最大闲置连接数
return
}
type user struct {
ID
int
Name string
Age
int
}
//创建一个查询函数
func queryRowDemo() {
sqlStr := "select id,name,age from user where id = ?"
var u user
err := db.Get(&u, sqlStr, 3) //这里说明下,前面的&u是一整个完整的结构体,不需要独立进行声明.这个是不是有点点弊端?如果查询结果不完成咋办?
if err != nil {
fmt.Printf("get failed ,err:%vn", err)
return
}
fmt.Printf("id:%d,name:%s,age:%dn", u.ID, u.Name, u.Age)
}
//main函数首先初始化数据库连接.
func main() {
err := initDB()
if err != nil {
fmt.Printf("数据库初始化失败.err:%sn", err)
return
}
queryRowDemo()
defer db.Close()
}
输出结果
D:GoGosrccode.oldboy.comstudygolang5lesson513sqlx>13sqlx.exe
id:3,name:zhangsan,age:40

多条语句查询

var db *sqlx.DB
func initDB() (err error) {
dsn := "root:yaochizaocan@tcp(192.168.11.236:3306)/sql_test"
db, err = sqlx.Connect("mysql", dsn)
if err != nil {
fmt.Printf("connect DB failed,err:%vn", err)
return err
}
db.SetMaxOpenConns(30) //最大连接数
db.SetMaxIdleConns(20) //最大闲置连接数
return
}
type user struct {
ID
int
Name string
Age
int
}
//多条语句查询
func queryMultiRowDemo() {
sqlStr := "select id ,name ,age from user where id > ?"
var users []user
err := db.Select(&users, sqlStr, 0)
if err != nil {
fmt.Printf("query failed,err:%vn", err)
return
}
for i := 0; i < len(users); i++ {
fmt.Println(users[i])
}
}
输出结果
C:Users34826AppDataLocalTemp___go_build_main_go__3_.exe #gosetup
{2 monkey 30}
{3 zhangsan 40}
{4 老王 33}
{5 大魔王 12}
{6 3魔王 12}
说明一下
这里使用多条语句进行查询的时候需要将原本的结构体变换成一个切片类型[]用于存放最终的查询结果.
最终的查询结果是根据结果在切片中连续存在的,所以最终取值的时候需要循环取值,即可将切片中的数据单条取出.

使用sqlx做增删改查

var db *sqlx.DB
func initDB() (err error) {
dsn := "root:yaochizaocan@tcp(192.168.11.236:3306)/sql_test"
db, err = sqlx.Connect("mysql", dsn)
if err != nil {
fmt.Printf("connect DB failed,err:%vn", err)
return err
}
db.SetMaxOpenConns(30) //最大连接数
db.SetMaxIdleConns(20) //最大闲置连接数
return
}
type user struct {
ID
int
Name string
Age
int
}
//插入数据
func insertRowDemo(insName string, insAge int) {
sqlStr := "insert into user(name,age) values(?,?)"
ret, err := db.Exec(sqlStr, insName, insAge)
if err != nil {
fmt.Printf("insert failed err:%vn", err)
return
}
theID, err := ret.LastInsertId() //新插入数据的id号码
if err != nil {
fmt.Printf("get lastinsert id failed err:%vn", err)
return
}
fmt.Printf("insert sussess ,the id is %d.n", theID)
}
//更新数据
func updateRowDemo(updAge int, updID int) {
sqlStr := "update user set age= ? where id = ?"
ret, err := db.Exec(sqlStr, updAge, updID)
if err != nil {
fmt.Printf("update failed err:%vn", err)
return
}
n, err := ret.RowsAffected() //更改了多少行
if err != nil {
fmt.Printf("get update rows failed err:%vn", err)
return
}
fmt.Printf("update success ,affected rows:%dn", n) //最终影响了多少行
}
//删除数据
func deleteRowDemo(ID int) {
sqlStr := "delete from user where id = ?"
ret, err := db.Exec(sqlStr, ID)
if err != nil {
fmt.Printf("update failed err :%vn", err)
return
}
n, err := ret.RowsAffected() //影响操作的行数
if err != nil {
fmt.Printf("get delete rowsaffected failed err:%vn", err)
return
}
fmt.Printf("delete success ,affected rows:%dn", n)
}
//多条语句查询
func queryMultiRowDemo() {
sqlStr := "select id ,name ,age from user where id > ?"
var users []user
err := db.Select(&users, sqlStr, 0)
if err != nil {
fmt.Printf("query failed,err:%vn", err)
return
}
for i := 0; i < len(users); i++ {
fmt.Println(users[i])
}
}
func main() {
err := initDB()
if err != nil {
fmt.Printf("数据库初始化失败.err:%sn", err)
return
}
//queryRowDemo()
insertRowDemo("小屁孩", 55)
updateRowDemo(66, 3)
deleteRowDemo(2)
queryMultiRowDemo()
defer db.Close()
}
输出结果
D:GoGosrccode.oldboy.comstudygolang5lesson513sqlx>13sqlx.exe
insert sussess ,the id is 7.
update success ,affected rows:1
delete success ,affected rows:1
{3 zhangsan 66}
{4 老王 33}
{5 大魔王 12}
{6 3魔王 12}
{7 小屁孩 55}

使用sqlxnameexec来绑定键值与查询字段的关系

var db *sqlx.DB
func initDB() (err error) {
dsn := "root:yaochizaocan@tcp(192.168.11.236:3306)/sql_test"
db, err = sqlx.Connect("mysql", dsn)
if err != nil {
fmt.Printf("connect DB failed,err:%vn", err)
return err
}
db.SetMaxOpenConns(30) //最大连接数
db.SetMaxIdleConns(20) //最大闲置连接数
return
}
type user struct {
ID
int
Name string
Age
int
}
func insertUserDemo() (err error) {
sqlStr := "insert into user(name,age) values(:name,:age)"
_, err = db.NamedExec(sqlStr, map[string]interface{}{
"name": "qimi",
"age":
33,
})
return
}
func main() {
err := initDB()
if err != nil {
fmt.Printf("数据库连接初始化失败,err:%vn", err)
return
}
insertUserDemo()
}
查询结果
MySQL [sql_test]> select id , name , age from user;
+----+-----------+------+
| id | name
| age
|
+----+-----------+------+
|
3 | zhangsan
|
66 |
|
4 | 老王
|
33 |
|
5 | 大魔王
|
12 |
|
6 | 3魔王
|
12 |
|
7 | 小屁孩
|
55 |
|
8 | qimi
|
33 |
+----+-----------+------+
6 rows in set (0.00 sec)

最后

以上就是懦弱蛋挞为你收集整理的go语言sqlx操作数据库的全部内容，希望文章能够帮你解决go语言sqlx操作数据库所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。