mysql

func Bools ¶

func Bools(values []bool) []Expression

func Count ¶

func Count(ctx context.Context, db qrm.DB, fn func(count SelectStatement) SelectStatement) (int64, error)

Count 返回记录数

// 导入模块
import (
	jet "github.com/go-jet/jet/v2/mysql"
	"github.com/noble-gase/neon/sqlkit/mysql"
)

// 执行方法
mysql.Count(ctx, db, func(count jet.SelectStatement) jet.SelectStatement {
	return count.FROM(table.Demo.Table).WHERE(table.Demo.Name.LIKE(jet.String("%hello%")))
})

func Decimals ¶

func Decimals(values []string) []Expression

func Delete ¶

func Delete(ctx context.Context, db qrm.DB, stmt DeleteStatement) (int64, error)

Delete 删除记录

// 导入模块
import (
	jet "github.com/go-jet/jet/v2/mysql"
	"github.com/noble-gase/neon/sqlkit/mysql"
)

// 语句示例
table.Demo.DELETE().WHERE(table.Demo.ID.EQ(jet.Int64(1)))

// 执行方法
mysql.Delete(ctx, db, stmt)

func Exprs ¶

func Exprs[T any](values []T, fn func(T) Expression) []Expression

Exprs 将一组值转换为 Expression 列表，常用于 IN 查询

func FindAll ¶

func FindAll[T any](ctx context.Context, db qrm.DB, stmt SelectStatement) ([]T, error)

FindAll 查询多条记录

// 导入模块
import (
	jet "github.com/go-jet/jet/v2/mysql"
	"github.com/noble-gase/neon/sqlkit/mysql"
)

// 语句示例
table.Demo.SELECT(table.Demo.AllColumns).WHERE(table.Demo.Name.LIKE(jet.String("%hello%")))
// or
jet.SELECT(table.Demo.AllColumns).FROM(table.Demo).WHERE(table.Demo.Name.LIKE(jet.String("%hello%")))

// 执行方法
mysql.FindAll[*model.Demo](ctx, db, stmt)

func FindOne ¶

func FindOne[T any](ctx context.Context, db qrm.DB, stmt SelectStatement) (*T, error)

FindOne 查询一条记录

注意：参数 T 必须为非指针类型

// 导入模块
import (
	jet "github.com/go-jet/jet/v2/mysql"
	"github.com/noble-gase/neon/sqlkit/mysql"
)

// 语句示例
table.Demo.SELECT(table.Demo.AllColumns).WHERE(table.Demo.ID.EQ(jet.Int64(1)))
// or
jet.SELECT(table.Demo.AllColumns).FROM(table.Demo).WHERE(table.Demo.ID.EQ(jet.Int64(1)))

// 执行方法
mysql.FindOne[model.Demo](ctx, db, stmt)

func Floats ¶

func Floats(values []float64) []Expression

func Insert ¶

func Insert(ctx context.Context, db qrm.DB, stmt InsertStatement) (int64, error)

Insert 插入记录

// 导入模块
import (
	jet "github.com/go-jet/jet/v2/mysql"
	"github.com/noble-gase/neon/sqlkit/mysql"
)

// 语句示例
table.Demo.INSERT(table.Demo.Name).VALUES("hello")
// or
table.Demo.INSERT(table.Demo.Name).MODEL(model.Demo{Name: "hello"})

// 批量插入
table.Demo.INSERT(table.Demo.Name).
	VALUES("hello").
	VALUES("world")
// or
table.Demo.INSERT(table.Demo.Name).MODELS([]model.Demo{
	{Name: "hello"},
	{Name: "world"},
})

// 执行方法
mysql.Insert(ctx, db, stmt)

func Int8s ¶

func Int8s(values []int8) []Expression

func Int16s ¶

func Int16s(values []int16) []Expression

func Int32s ¶

func Int32s(values []int32) []Expression

func Int64s ¶

func Int64s(values []int64) []Expression

func Ints ¶

func Ints(values []int) []Expression

func Paginate ¶

func Paginate[T any](ctx context.Context, db qrm.DB, fn func(query SelectStatement) SelectStatement, page, size int, cols ColumnList, orderBy ...OrderByClause) ([]T, int64, error)

Paginate 分页查询

// 导入模块
import (
	jet "github.com/go-jet/jet/v2/mysql"
	"github.com/noble-gase/neon/sqlkit/mysql"
)

// 执行方法
mysql.Paginate[*model.Demo](ctx, db, func(query jet.SelectStatement) jet.SelectStatement {
	return query.FROM(table.Demo.Table).WHERE(table.Demo.Name.LIKE(jet.String("%hello%")))
}, page, size, table.Demo.AllColumns, table.Demo.ID.DESC())

func Strings ¶

func Strings(values []string) []Expression

func Uint8s ¶

func Uint8s(values []uint8) []Expression

func Uint16s ¶

func Uint16s(values []uint16) []Expression

func Uint32s ¶

func Uint32s(values []uint32) []Expression

func Uint64s ¶

func Uint64s(values []uint64) []Expression

func Uints ¶

func Uints(values []uint) []Expression

func Update ¶

func Update(ctx context.Context, db qrm.DB, stmt UpdateStatement) (int64, error)

Update 更新记录

// 导入模块
import (
	jet "github.com/go-jet/jet/v2/mysql"
	"github.com/noble-gase/neon/sqlkit/mysql"
)

// 语句示例
table.Demo.UPDATE(table.Demo.Name).SET("hello").WHERE(table.Demo.ID.EQ(jet.Int64(1)))
// or
table.Demo.UPDATE(table.Demo.Name).MODEL(model.Demo{Name: "hello"}).WHERE(table.Demo.ID.EQ(jet.Int64(1)))

// 执行方法
mysql.Update(ctx, db, stmt)