Golang高性能SQL查询构建器插件库sqrl的使用

sqrl是squirrel的精简版，一个Go语言的流式SQL生成器。

简介

sqrl是squirrel的非线程安全分支，移除了额外的字母，保留了相同的便捷功能。

import "github.com/elgris/sqrl"

要求Go 1.8或更高版本

为什么选择sqrl

• 性能更高（根据基准测试）
• 保留了squirrel的所有语法糖
• 支持JOINs、子查询和别名

使用示例

sqrl不是一个ORM，它帮助你从可组合的部分构建SQL查询。注意：sqrl是非线程安全的。

基本查询

import sq "github.com/elgris/sqrl" // 也可以轻松替换为github.com/lann/squirrel

users := sq.Select("*").From("users").Join("emails USING (email_id)")

active := users.Where(sq.Eq{"deleted_at": nil})

sql, args, err := active.ToSql()

// sql == "SELECT * FROM users JOIN emails USING (email_id) WHERE deleted_at IS NULL"

插入数据

sql, args, err := sq.
    Insert("users").Columns("name", "age").
    Values("moe", 13).Values("larry", sq.Expr("? + 5", 12)).
    ToSql()

// sql == "INSERT INTO users (name,age) VALUES (?,?),(?,? + 5)"

执行查询

stooges := users.Where(sq.Eq{"username": []string{"moe", "larry", "curly", "shemp"}})
three_stooges := stooges.Limit(3)
rows, err := three_stooges.RunWith(db).Query()

// 等同于:
rows, err := db.Query("SELECT * FROM users WHERE username IN (?,?,?,?) LIMIT 3", "moe", "larry", "curly", "shemp")

条件查询

if len(q) > 0 {
    users = users.Where("name LIKE ?", q)
}

MySQL特定功能

多表删除

sql, args, err := sq.Delete("a1", "a2").
    From("z1 AS a1").
    JoinClause("INNER JOIN a2 ON a1.id = a2.ref_id").
    Where("b = ?", 1).
    ToSql()

sql, args, err := sq.Delete("a1").
    Using("a2").
    Where("a1.id = a2.ref_id AND a2.num = ?", 42).
    ToSql()

PostgreSQL特定功能

更新并返回

sql, args, err := sq.Update("a1").
    Set("foo", 1).
    From("a2").
    Where("id = a2.ref_id AND a2.num = ?", 42).
    ToSql()

删除并返回

sql, args, err := sq.Delete("a1").
    Using("a2").
    Where("id = a2.ref_id AND a2.num = ?", 42).
    ToSql()

返回子句

sql, args, err := Update("a").
    Set("foo", 1).
    Where("id = ?", 42).
    Returning("bar").
    ToSql()

JSON值

sql, args, err := sq.Insert("posts").
    Columns("content", "tags").
    Values("Lorem Ipsum", pg.JSONB([]string{"foo", "bar"})).
    ToSql()

数组值

sql, args, err := sqrl.Insert("posts").
    Columns("content", "tags").
    Values("Lorem Ipsum", pg.Array([]string{"foo", "bar"})).
    ToSql()

完整示例

下面是一个完整的示例，展示如何使用sqrl构建和执行查询：

package main

import (
	"database/sql"
	"fmt"
	"log"
	
	sq "github.com/elgris/sqrl"
	_ "github.com/lib/pq" // PostgreSQL驱动
)

func main() {
	// 连接数据库
	db, err := sql.Open("postgres", "user=postgres dbname=test sslmode=disable")
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()

	// 构建查询
	query := sq.Select("id", "name", "email").
		From("users").
		Where(sq.Eq{"active": true}).
		OrderBy("name ASC").
		Limit(10)

	// 获取SQL和参数
	sql, args, err := query.ToSql()
	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("SQL:", sql)
	fmt.Println("Args:", args)

	// 执行查询
	rows, err := query.RunWith(db).Query()
	if err != nil {
		log.Fatal(err)
	}
	defer rows.Close()

	// 处理结果
	for rows.Next() {
		var id int
		var name, email string
		if err := rows.Scan(&id, &name, &email); err != nil {
			log.Fatal(err)
		}
		fmt.Printf("ID: %d, Name: %s, Email: %s\n", id, name, email)
	}

	if err := rows.Err(); err != nil {
		log.Fatal(err)
	}
}

许可证

sqrl采用MIT许可证发布。