sqlx库基本使用

目录

• • 
    
• ​​连接数据库​​
• ​​查询​​
• ​​增删改​​
• ​​NamedExec​​
• ​​NamedQuery​​
  • 
    

原生的数据库操作太过麻烦,​​sqlx​​简化了大量操作

安装​​sqlx​​库

go get github.com/jmoiron/sqlx

连接数据库

package main

import (
  _ "github.com/go-sql-driver/mysql"
  "github.com/jmoiron/sqlx"
)
var(
  db *sqlx.DB
)
func initDB() (err error) {
  dsn := "root:123456@tcp(127.0.0.1:3306)/gos?charset=utf8mb4&parseTime=True"
  db = sqlx.MustConnect("mysql", dsn)  //若出现错误,会panic

  db.SetMaxOpenConns(20)  //设置最大连接数
  db.SetMaxIdleConns(10) //最大闲置连接数
  return
}
func main(){
  initDB()
}

查询

单条查询

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, 1)
  if err != nil {
    fmt.Printf("get failed, err:%v\n", err)
    return
  }
  fmt.Printf("id:%d name:%s age:%d\n", u.Id, u.Name, u.Age)
}

多行查询

使用​​DB.Select​​直接返回对象数组

// 查询单条数据示例
func queryRowDemo() {
  sqlStr := "select id, name, age from user where id!=?"
  var users []user
  err := db.Select(&users, sqlStr, -1)
  if err != nil {
    fmt.Printf("get failed, err:%v\n", err)
    return
  }
  fmt.Printf("%#v\n", users)
}

增删改

都是调用​​ret,err := DB.exec(sql,...arg)​​进行操作

其中返回的​​ret​​​有一些关于此次操作的属性,比如影响行数(​​ret.RowsAffected()​​)之类的

// 插入数据
func insertRowDemo() {
  sqlStr := "insert into user(name, age) values (?,?)"
  ret, err := db.Exec(sqlStr, "沙河小王子", 19)
  if err != nil {
    fmt.Printf("insert failed, err:%v\n", err)
    return
  }
  theID, err := ret.LastInsertId() // 新插入数据的id
  if err != nil {
    fmt.Printf("get lastinsert ID failed, err:%v\n", err)
    return
  }
  fmt.Printf("insert success, the id is %d.\n", theID)
}

// 更新数据
func updateRowDemo() {
  sqlStr := "update user set age=? where id = ?"
  ret, err := db.Exec(sqlStr, 39, 6)
  if err != nil {
    fmt.Printf("update failed, err:%v\n", err)
    return
  }
  n, err := ret.RowsAffected() // 操作影响的行数
  if err != nil {
    fmt.Printf("get RowsAffected failed, err:%v\n", err)
    return
  }
  fmt.Printf("update success, affected rows:%d\n", n)
}

// 删除数据
func deleteRowDemo() {
  sqlStr := "delete from user where id = ?"
  ret, err := db.Exec(sqlStr, 6)
  if err != nil {
    fmt.Printf("delete failed, err:%v\n", err)
    return
  }
  n, err := ret.RowsAffected() // 操作影响的行数
  if err != nil {
    fmt.Printf("get RowsAffected failed, err:%v\n", err)
    return
  }
  fmt.Printf("delete success, affected rows:%d\n", n)
}

NamedExec

上面的​​DB.exec(sql,...arg)​​​传递参数必须要和​​sql​​​语句中的占位符​​?​​一一对应

使用​​NamedExec​​​可以把参数整合为一个​​map​​​或​​struct​​传递

func insertUserDemo()(err error){
  sqlStr := "INSERT INTO user (name,age) VALUES (:name,:age)" //此处占位符变成:字段的形式(填写的字段和struct中的字段名相对应)
  var u user
  u = user{ Name:"上跟绫香",Age: 17}
//  u = map[string]interface{}{  //改成map的形式也是一样的
//      "name": "上根绫香",
//      "age": 18,
//    }
  _, err = db.NamedExec(sqlStr,u)
  return
}

NamedQuery

和​​NamedExec​​​类似,返回一个可使用​​Next()​​迭代的对象

func namedQuery(){
  sqlStr := "SELECT * FROM user WHERE name=:name"
  // 使用map做命名查询
  rows, err := db.NamedQuery(sqlStr, map[string]interface{}{"name": "小由纪同学"})
  if err != nil {
    fmt.Printf("db.NamedQuery failed, err:%v\n", err)
    return
  }
  defer rows.Close()

  for rows.Next(){
    var u user
    err := rows.StructScan(&u)
    if err != nil {
      fmt.Printf("scan failed, err:%v\n", err)
      continue
    }
    fmt.Printf("user:%#v\n", u)
  }

  u := user{
    Name: "cl",
  }
  // 使用结构体命名查询，根据结构体字段的 db tag进行映射
  rows, err = db.NamedQuery(sqlStr, u)
  if err != nil {
    fmt.Printf("db.NamedQuery failed, err:%v\n", err)
    return
  }
  defer rows.Close()
  for rows.Next(){
    var u user
    err := rows.StructScan(&u)
    if err != nil {
      fmt.Printf("scan failed, err:%v\n", err)
      continue
    }
    fmt.Printf("user:%#v\n", u)
  }
}