Golang SQL查询构建器gosql的使用指南

gosql是一个专注于更好空值处理的Golang SQL查询构建器库，它提供了简洁的API和强大的空值处理能力。下面我将详细介绍gosql的主要功能和使用方法。

安装gosql

go get github.com/ilibs/gosql

基本使用方法

初始化连接

import (
    "github.com/ilibs/gosql"
    _ "github.com/go-sql-driver/mysql"
)

func init() {
    configs := make(map[string]*gosql.Config)
    
    configs["default"] = &gosql.Config{
        Enable:  true,
        Driver:  "mysql",
        Dsn:     "root:123456@tcp(127.0.0.1:3306)/test?charset=utf8",
        ShowSql: true,
    }
    
    gosql.Connect(configs)
}

基本查询

// 查询单条记录
var user struct {
    Id       int    `db:"id"`
    Name     string `db:"name"`
    Age      int    `db:"age"`
    NullName gosql.NullString `db:"null_name"`
}

err := gosql.QueryRow(&user, "select * from users where id = ?", 1)
if err != nil {
    log.Fatal(err)
}
fmt.Println(user)

// 查询多条记录
var users []struct {
    Id   int    `db:"id"`
    Name string `db:"name"`
}

err := gosql.Query(&users, "select * from users where age > ?", 18)
if err != nil {
    log.Fatal(err)
}
fmt.Println(users)

空值处理

gosql提供了专门的Null类型来处理数据库中的NULL值：

• gosql.NullString
• gosql.NullInt64
• gosql.NullFloat64
• gosql.NullBool
• gosql.NullTime

type User struct {
    Id        int             `db:"id"`
    Name      string          `db:"name"`
    Age       gosql.NullInt64 `db:"age"`
    CreatedAt gosql.NullTime  `db:"created_at"`
}

var user User
err := gosql.QueryRow(&user, "select * from users where id = ?", 1)
if err != nil {
    log.Fatal(err)
}

// 检查是否有值
if user.Age.Valid {
    fmt.Println("Age:", user.Age.Int64)
} else {
    fmt.Println("Age is NULL")
}

查询构建器

gosql提供了流畅的查询构建API：

// 简单查询
rows, err := gosql.Queryx("users").Where("id > ?", 1).Limit(10).Get()

// 复杂查询
query := gosql.Queryx("users u").
    Select("u.id, u.name, p.title as post_title").
    Join("posts p", "p.user_id = u.id").
    Where("u.age > ?", 18).
    Where("p.status = ?", 1).
    OrderBy("u.id desc").
    Limit(10).
    Offset(0)

var results []map[string]interface{}
err := query.Get(&results)

事务处理

tx, err := gosql.Begin()
if err != nil {
    log.Fatal(err)
}

defer func() {
    if err != nil {
        tx.Rollback()
    } else {
        tx.Commit()
    }
}()

_, err = tx.Exec("update users set name = ? where id = ?", "newname", 1)
if err != nil {
    return err
}

_, err = tx.Exec("update profiles set avatar = ? where user_id = ?", "newavatar", 1)
if err != nil {
    return err
}

return nil

插入和更新

// 插入数据
user := map[string]interface{}{
    "name": "John",
    "age":  30,
    "null_name": gosql.NullString{String: "", Valid: false}, // 显式设置为NULL
}

id, err := gosql.Table("users").Insert(user)
if err != nil {
    log.Fatal(err)
}

// 更新数据
data := map[string]interface{}{
    "name": "John Doe",
    "age":  gosql.NullInt64{Int64: 0, Valid: false}, // 设置为NULL
}

_, err = gosql.Table("users").Where("id = ?", id).Update(data)
if err != nil {
    log.Fatal(err)
}

高级功能

批量插入

users := []map[string]interface{}{
    {"name": "user1", "age": 20},
    {"name": "user2", "age": 21},
    {"name": "user3", "age": gosql.NullInt64{Valid: false}}, // age为NULL
}

_, err := gosql.Table("users").BatchInsert(users)
if err != nil {
    log.Fatal(err)
}

使用结构体

type User struct {
    Id       int             `db:"id,primary"` // 主键
    Name     string          `db:"name"`
    Age      gosql.NullInt64 `db:"age"`
    NullName gosql.NullString `db:"null_name"`
}

// 插入
user := &User{
    Name: "John",
    Age:  gosql.NullInt64{Int64: 30, Valid: true},
    NullName: gosql.NullString{Valid: false},
}

id, err := gosql.Model(user).Insert()
if err != nil {
    log.Fatal(err)
}

// 更新
user.Name = "John Doe"
user.Age.Valid = false // 设置为NULL
_, err = gosql.Model(user).Update()
if err != nil {
    log.Fatal(err)
}

gosql通过提供专门的Null类型和简洁的API，使得Golang中的SQL操作和空值处理变得更加简单和安全。它的查询构建器功能强大但又不失灵活性，是处理数据库操作的优秀选择。