orm

package module
v5.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 14, 2024 License: MIT Imports: 13 Imported by: 13

README

orm Go Report Card codecov PkgGoDev Go version

目前内置了对以下数据库的支持：

数据库 驱动 状态
mysql mysql github.com/go-sql-driver/mysql Mysql
mariadb mysql github.com/go-sql-driver/mysql Mariadb
sqlite3 sqlite3 github.com/mattn/go-sqlite3 Sqlite3
sqlite sqlite3 modernc.org/sqlite Sqlite
postgres postgres github.com/lib/pq Postgres

理论上 <github.com/jackc/pgx/v4/stdlib> 也是可用于 postgres，不过其驱动的注册名称为 pgx。

sqlite 为纯 Go 代码编写，如果涉及到交叉编译的可以采用此驱动，会很方便。

其它数据库，用户可以通过实现 Dialect 接口，来实现相应的支持。 如果用到了 check 约束，则需要 mysql > 8.0.19、mariadb > 10.2.1。

初始化

默认情况下，orm 包并不会加载任何数据库的实例。所以想要用哪个数据库，需要手动初始化：

import (
    github.com/issue9/orm/v5/dialect  // sqlite3 的 dialect 声明在此处
    _ github.com/mattn/go-sqlite3     // 加载数据库驱动
)

// 初始化一个 DB
db1 := orm.NewDB("./db1", dialect.Sqlite3("sqlite3"))

// 另一个 DB 实例
db2 := orm.NewDB("./db2", dialect.Sqlite3("sqlite3"))
占位符

SQL 语句可以使用 {} 包含一个关键字，使其它成为普通列名，如：

SELECT * FROM user WHERE {group}=1

在实际执行时，相关的占位符就会被替换成与当前环境想容的实例， 如在数据库为 mysql 时，会被替换成以下语句，然后再执行：

 SELECT * FROM user WHERE `group`=1

DB.Query(),DB.Exec(),DB.Prepare().DB.Where() 及 Tx 与之对应的函数都可以使用占位符。

Model 不能指定占位符，它们默认总会使用占位符，且无法取消。

Model:

orm 包通过 struct tag 来描述 model 在数据库中的结构。大概格式如下：

type User struct {
    Id          int64      `orm:"name(id);ai;"`
    FirstName   string     `orm:"name(first_name);index(index_name)"`
    LastName    string     `orm:"name(first_name);index(index_name)"`

    // 此处group会自动加上引号，无须担心是否为关键字
    Group       string     `orm:"name(group)"`
}

func(u *User) TableName() string { return "user" }

// 通过 orm.ApplyModeler 接口，指定表的额外数据。若不需要，可不用实现该接口
func(u *User) ApplyModel(m *core.Model) error {
    m.Options["mysql_engine"] = []string{"innodb"}
    m.Options["mysql_charset"] = []string{"utf8"}
    return nil
}

目前支持以下的 struct tag：

name(fieldName):

指定当前字段在数据表中的名称，如果未指定，则和字段名相同。 只有可导出的字段才有效果。

len(l1, l2):

指定字段的长度。比如 mysql 中的int(5),varchar(255),double(1,2), 不支持该特性的数据，将会忽略该标签的内容，比如 sqlite3。 NOTE:字符串类型必须指定长度，若长度过大或是将长度设置了-1， 想使用类似于 TEXT 等不定长的形式表达。

如果是日期类型，则第一个可选参数表示日期精度。

nullable(true|false):

相当于定义表结构时的 NULL。

pk:

主键，支持联合主键，给多个字段加上 pk 的 struct tag 即可。

ai:

自增，若指定了自增列，则将自动取消其它的 pk 设置。无法指定起始值和步长。 可手动设置一个非零值来更改某条数据的 AI 行为。

unique(index_name):

唯一索引，支持联合索引，index_name 为约束名， 会将 index_name 为一样的字段定义为一个联合索引。

index(index_name):

普通的关键字索引，同 unique 一样会将名称相同的索引定义为一个联合索引。

occ(true|false)

当前列作为乐观锁字段。

作为乐观锁的字段，其值表示的是线上数据的值，在更新时，会自动给线上的值加 1。

default(value):

指定默认值。相当于定义表结构时的 DEFAULT。 当一个字段如果是个零值(reflect.Zero())时，将会使用它的默认值， 但是系统无法判断该零值是人为指定，还是未指定被默认初始化零值的， 所以在需要用到零值的字段，最好不要用 default 的 struct tag。

fk(fk_name,refTable,refColName,updateRule,deleteRule):

定义物理外键，最少需要指定 fk_name、refTable 和 refColName 三个值。分别对应约束名， 引用的表和引用的字段，updateRule,deleteRule，在不指定的情况下，使用数据库的默认值。

接口:
  • TableNamer 指定表名；
  • ApplyModeler 通过 ApplyModeler 接口可以指定一些表级别的属性值；
  • AfterFetcher 在拉到数据之后，对该对象执行的一些额外操作。如果需要根据字段做额外工作的，可以使用该接口；
  • BeforeInserter 在执行插入之前，需要执行的操作；
  • BeforeUpdater 在执行更新之前，需要执行的操作；
约束名：

index、unique、check 和 fk 都是可以指定约束名的，在当前数据库中， 约束名必须是唯一的，即便是不同类型的约束，比如已经有一个 unique 的约束名叫作 name， 那么其它类型的约束，就不能再取这个名称了。

如何使用：
Create:

可以通过 DB.Create() 或是 Tx.Create() 创建一张表。

// 创建表
db.Create(&User{})
Update:
// 将 id 为 1 的记录的 FirstName 更改为 abc；对象中的零值不会被提交。
db.Update(&User{Id:1,FirstName:"abc"})
sqlbuilder.Update(db).Table("table").Where("id=?",1).Set("FirstName", "abc").Exec()
Delete:
// 删除 id 为 1 的记录
e.Delete(&User{Id:1})
sqlbuilder.Delete(e).Table("table").Where("id=?",1).Exec()
Insert:
// 插入一条数据
db.Insert(&User{Id:1,FirstName:"abc"})
// 一次性插入多条数据
tx.InsertMany(&User{Id:1,FirstName:"abc"},&User{Id:1,FirstName:"abc"})
Select:
// 导出 id=1 的数据
_,err := sqlbuilder.Select(e, e.Dialect()).Select("*").From("{#table}").Where("id=1").QueryObj(obj)
// 导出 id 为 1 的数据，并回填到 user 实例中
user := &User{Id:1}
err := e.Select(u)
Query/Exec:
// Query 返回参数与 sql.Query 是相同的
sql := "select * from tbl_name where id=?"
rows, err := e.Query(sql, []interface{}{5})
// Exec 返回参数与 sql.Exec 是相同的
sql = "update tbl_name set name=? where id=?"
r, err := e.Exec(sql, []interface{}{"name1", 5})
多表查询
type order struct {
    ID int `orm:"name(id);ai"`
    UID int `orm:"name(uid)"`
    User *User `orm:"name(u)"` // sql 语句的 u. 开头的列导入到此对象中
}

sql := "SELECT o.*, u.id AS 'u.id',u.name AS 'u.name' FROM orders AS o LEFT JOIN  users AS u ON o.uid= u.id where id=?"

// 以下查询会将 u.name 和 u.id 导入到 User 指向的对象中
data := []*order{}
rows,err := e.Query(sql, []interface{}{5})
r, err := fetch.Object(rows, &data)
InsertLastID:

像 postgres 之类的数据库，插入语句返回的 sql.Result 并不支持 LastInsertId() 所以得通过其它方式得到该 ID，可以直接尝试使用 InsertLastID 来代码 Insert 操作。

lastID,err := db.InsertLastID(&User{FirstName:"abc"})
事务：

默认的 DB 是不支持事务的，若需要事务支持，则需要调用 DB.Begin() 返回事务对象 Tx，当然并不是所有的数据库都支持事务操作的。 Tx 拥有一组与 DB 相同的接口。

版权

本项目采用 MIT 开源授权许可证，完整的授权说明可在 LICENSE 文件中找到。

Documentation

Overview

Package orm 一个简单小巧的 orm 实现方案

目前内置了对以下数据库的支持：

  1. sqlite3: github.com/mattn/go-sqlite3
  2. mysql: github.com/go-sql-driver/mysql
  3. postgres: github.com/lib/pq

其它数据库，用户可以通过实现 Dialect 接口，来实现相应的支持。

初始化：

默认情况下，orm 包并不会加载任何数据库的实例。所以想要用哪个数据库，需要手动初始化： 

import (
    _ github.com/mattn/go-sqlite3       // 加载数据库驱动
    _ github.com/issue9/orm/v4/dialect  // sqlite3 的 dialect 声明在此处
)

// 初始化一个 DB
db1 := orm.NewDB("./db1", dialect.Sqlite3("sqlite3"))

// 另一个 DB 实例
db2 := orm.NewDB("./db2", dialect.Sqlite3("sqlite3"))

占位符

SQL 语句可以使用 {} 包含一个关键字，使其它成为普通列名，如： 

select * from user where {group}=1

在实际执行时，相关的占位符就会被替换成与当前环境想容的实例， 如在数据库为 mysql 时，会被替换成以下语句，然后再执行： 

select * from p_user where `group`=1

DB.Query(),DB.Exec(),DB.Prepare().DB.Where() 及 Tx 与之对应的函数都可以使用占位符。

Model 不能指定占位符，它们默认总会使用占位符，且无法取消。

Model:

orm 包通过 struct tag 来描述 model 在数据库中的结构。大概格式如下： 

type User struct {
    Id          int64      `orm:"name(id);ai;"`
    FirstName   string     `orm:"name(first_name);index(index_name)"`
    LastName    string     `orm:"name(first_name);index(index_name)"`

    // 此处group会自动加上引号，无须担心是否为关键字
    Group       string	   `orm:"name(group)"`
}

// 通过 orm.ApplyModeler 接口，指定表的额外数据。若不需要，可不用实现该接口
func(u *User) ApplyModel(m *core.Model) error {
    m.Name = "user"
    m.Options["engine"] = "innodb"
    m.Options["charset"] = "utf8"
    return nil
}

目前支持以下的 struct tag： 

name(fieldName): 指定当前字段在数据表中的名称，如果未指定，
则和字段名相同。只有可导出的字段才有效果。

len(l1, l2): 指定字段的长度。比如 mysql 中的int(5),varchar(255),double(1,2),
不支持该特性的数据，将会忽略该标签的内容，比如 sqlite3。
NOTE:字符串类型必须指定长度，若长度过大或是将长度设置了 -1，
想使用类似于 TEXT 等不定长的形式表达。
如果是日期类型，则第一个可选参数表示日期精度。

nullable(true|false): 相当于定义表结构时的 NULL。

pk: 主键，支持联合主键，给多个字段加上 pk 的 struct tag 即可。

ai: 自增，若指定了自增列，则将自动取消其它的 pk 设置。无法指定起始值和步长。
可手动设置一个非零值来更改某条数据的 AI 行为。

unique(index_name): 唯一索引，支持联合索引，index_name 为约束名，
会将 index_name 为一样的字段定义为一个联合索引。

index(index_name): 普通的关键字索引，同 unique 一样会将名称相同的索引定义为一个联合索引。

occ(true|false) 当前列作为乐观锁字段。

作为乐观锁的字段，其值表示的是线上数据的值，在更新时，会自动给线上的值加 1。

default(value): 指定默认值。相当于定义表结构时的 DEFAULT。
当一个字段如果是个零值(reflect.Zero())时，将会使用它的默认值，
但是系统无法判断该零值是人为指定，还是未指定被默认初始化零值的，
所以在需要用到零值的字段，最好不要用 default 的 struct tag。

fk(fk_name,refTable,refColName,updateRule,deleteRule):
定义物理外键，最少需要指定 fk_name,refTable,refColName 三个值。
分别对应约束名，引用的表和引用的字段，updateRule,deleteRule，
在不指定的情况下，使用数据库的默认值。

ApplyModeler:

用于将一个对象转换成 Model 对象时执行的函数，给予用户修改 Model 的机会， 在 ApplyModeler 中可以修改任意模型的内容，所以也可以由 ApplyModeler 代替 struct tag 的操作。

约束名：

index、unique、check 和 fk 都是可以指定约束名的，在表中，约束名必须是唯一的， 即便是不同类型的约束，比如已经有一个 unique 的约束名叫作 name，那么其它类 型的约束，就不能再取这个名称了。 部分数据库（比如 postgres）可能要求约束名是整个数据库唯一的， 为了统一，在 ORM 中所有数据都强制约束名全局（数据库）唯一。

如何使用：

Create: 可以通过 DB.Create() 或是 Tx.Create() 创建一张表。 

// 创建表
db.Create(&User{})

Update: 

// 将 id 为 1 的记录的 FirstName 更改为 abc；对象中的零值不会被提交。
db.Update(&User{Id:1,FirstName:"abc"})
sqlbuilder.Update(db).Table("table").Where("id=?",1).Set("FirstName", "abc").Exec()

Delete: 

// 删除 id 为 1 的记录
e.Delete(&User{Id:1})
sqlbuilder.Delete(e).Table("table").Where("id=?",1).Exec()

Insert: 

// 插入一条数据
db.Insert(&User{Id:1,FirstName:"abc"})
// 一次性插入多条数据
tx.InsertMany(&User{Id:1,FirstName:"abc"},&User{Id:1,FirstName:"abc"})

Select: 

// 导出 id=1 的数据
_,err := sqlbuilder.Select(e, e.Dialect()).Select("*").From("{#table}").Where("id=1").QueryObj(obj)
// 导出 id 为 1 的数据，并回填到 user 实例中
user := &User{Id:1}
err := e.Select(u)

Query/Exec: 

// Query 返回参数与 sql.Query 是相同的
sql := "select * from tbl_name where id=?"
rows, err := e.Query(sql, []interface{}{5})
// Exec 返回参数与 sql.Exec 是相同的
sql = "update tbl_name set name=? where id=?"
r, err := e.Exec(sql, []interface{}{"name1", 5})

事务：

默认的 DB 是不支持事务的，若需要事务支持，则需要调用 DB.Begin() 返回事务对象 Tx，当然并不是所有的数据库都支持事务操作的。 Tx 拥有一组与 DB 相同的接口。

Index

Constants

This section is empty.

Variables

View Source 
var ErrNeedAutoIncrementColumn = errors.New("必须存在自增列")

ErrNeedAutoIncrementColumn 当以 LastInsertID 的方式插入一条没有 AI 列的对象时，会返回此错误。

Functions

func NowNullTime 

func NowNullTime() sql.NullTime

NowNullTime 返回当前时间

Types

type AfterFetcher 

type AfterFetcher = fetch.AfterFetcher

AfterFetcher 从数据库查询到数据之后需要执行的操作

type ApplyModeler 

type ApplyModeler = core.ApplyModeler

type BeforeInserter 

type BeforeInserter interface {
	BeforeInsert() error
}

BeforeInserter 在插入之前调用的函数

type BeforeUpdater 

type BeforeUpdater interface {
	BeforeUpdate() error
}

BeforeUpdater 在更新之前调用的函数

type Column 

type Column = core.Column

Column 列结构

type DB 

type DB struct {
	*sql.DB
	// contains filtered or unexported fields
}

DB 数据库操作实例

func NewDB 

func NewDB(dsn string, dialect Dialect) (*DB, error)

NewDB 声明一个新的 DB 实例

NOTE: 不同驱动对时间的处理不尽相同，如果有在不同数据库之间移植的需求， 那么建议将保存时的时区都统一设置为 UTC：

  • postgres 已经固定为 UTC；
  • sqlite3 可以在 dsn 中通过 _loc=UTC 指定；
  • mysql 默认是 UTC，也可以在 DSN 中通过 loc=UTC 指定；

func NewDBWithStdDB 

func NewDBWithStdDB(db *sql.DB, dialect Dialect) (*DB, error)

NewDBWithStdDB 从 sql.DB 构建 DB 实例

NOTE: 请确保用于打开 db 的 driverName 参数与 dialect.DriverName() 是相同的， 否则后续操作的结果是未知的。

func (*DB) Begin 

func (db *DB) Begin() (*Tx, error)

Begin 开始一个新的事务

func (*DB) BeginTx 

func (db *DB) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

BeginTx 开始一个新的事务

func (*DB) Close 

func (db *DB) Close() error

Close 关闭连接

同时会清除缓存的模型数据

func (*DB) Create 

func (db *DB) Create(v TableNamer) error

func (*DB) Debug 

func (db *DB) Debug(l func(string))

Debug 指定调输出调试内容通道

如果 l 不为 nil，则每次 SQL 调用都会输出 SQL 语句， 预编译的语句，仅在预编译时输出； 如果为 nil，则表示关闭调试。

func (*DB) Delete 

func (db *DB) Delete(v TableNamer) (sql.Result, error)

func (*DB) Dialect 

func (db *DB) Dialect() Dialect

func (*DB) DoTransaction 

func (db *DB) DoTransaction(f func(tx *Tx) error) error

DoTransaction 将 f 中的内容以事务的方式执行

func (*DB) DoTransactionTx 

func (db *DB) DoTransactionTx(ctx context.Context, opt *sql.TxOptions, f func(tx *Tx) error) error

DoTransactionTx 将 f 中的内容以事务的方式执行

如果执行失败，自动回滚，且返回错误信息。否则会直接提交。

func (*DB) Drop 

func (db *DB) Drop(v TableNamer) error

func (*DB) Exec 

func (db *DB) Exec(query string, args ...any) (sql.Result, error)

func (*DB) ExecContext 

func (db *DB) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

func (*DB) Insert 

func (db *DB) Insert(v TableNamer) (sql.Result, error)

Insert 插入数据

NOTE: 若需一次性插入多条数据，请使用 tx.InsertMany()。

func (*DB) InsertMany 

func (db *DB) InsertMany(max int, v ...TableNamer) error

InsertMany 一次插入多条数据

会自动转换成事务进行处理。

func (*DB) LastInsertID 

func (db *DB) LastInsertID(v TableNamer) (int64, error)

func (*DB) Prefix 

func (db *DB) Prefix(p string) ModelEngine

Prefix 为所有操作的表名加上统一的前缀

如果要复用表结构，可以采此对象进行相关操作，而不是直接使用 DB 或 Tx。

func (*DB) Prepare 

func (db *DB) Prepare(query string) (*core.Stmt, error)

func (*DB) PrepareContext 

func (db *DB) PrepareContext(ctx context.Context, query string) (*core.Stmt, error)

func (*DB) Query 

func (db *DB) Query(query string, args ...any) (*sql.Rows, error)

func (*DB) QueryContext 

func (db *DB) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

func (*DB) QueryRow 

func (db *DB) QueryRow(query string, args ...any) *sql.Row

QueryRow 执行一条查询语句

如果生成语句出错，则会 panic

func (*DB) QueryRowContext 

func (db *DB) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

QueryRowContext 执行一条查询语句

如果生成语句出错，则会 panic

func (*DB) SQLBuilder 

func (db *DB) SQLBuilder() *sqlbuilder.SQLBuilder

func (*DB) Select 

func (db *DB) Select(v TableNamer) (bool, error)

func (*DB) Truncate 

func (db *DB) Truncate(v TableNamer) error

func (*DB) Update 

func (db *DB) Update(v TableNamer, cols ...string) (sql.Result, error)

func (*DB) Upgrade 

func (db *DB) Upgrade(v TableNamer) (*Upgrader, error)

Upgrade 生成 Upgrader 对象

Upgrader 提供了对现有的数据模型 v 与线上数据表之间的操作。 删除操作需要保证已经存在于数据表； 而添加操作需要保证已经存在于模型 v，又不存在于数据表。

func (*DB) Version 

func (db *DB) Version() (string, error)

Version 数据库服务端的版本号

func (*DB) Where 

func (db *DB) Where(cond string, args ...any) *WhereStmt

type Decimal 

type Decimal = types.Decimal

type Dialect 

type Dialect = core.Dialect

Dialect 数据库驱动特有的语言特性实现

type Engine 

type Engine interface {
	core.Engine
	ModelEngine

	// SQLBuilder 返回 [sqlbuilder.SQLBuilder] 实例
	SQLBuilder() *sqlbuilder.SQLBuilder
}

type ModelEngine 

type ModelEngine interface {
	// LastInsertID 插入一条数据并返回其自增 ID
	//
	// 理论上功能等同于以下两步操作：
	//  rslt, err := engine.Insert(obj)
	//  id, err := rslt.LastInsertId()
	// 但是实际上部分数据库不支持直接在 sql.Result 中获取 LastInsertId，
	// 比如 postgresql，所以使用 LastInsertID() 会是比 sql.Result
	// 更简单和安全的方法。
	//
	// NOTE: 要求 v 有定义自增列。
	LastInsertID(v TableNamer) (int64, error)

	Insert(v TableNamer) (sql.Result, error)

	// Delete 删除符合条件的数据
	//
	// 查找条件以结构体定义的主键或是唯一约束(在没有主键的情况下)来查找，
	// 若两者都不存在，则将返回 error
	Delete(v TableNamer) (sql.Result, error)

	// Update 更新数据
	//
	// 零值不会被提交，cols 指定的列，即使是零值也会被更新。
	//
	// 查找条件以结构体定义的主键或是唯一约束(在没有主键的情况下)来查找，
	// 若两者都不存在，则将返回 error
	Update(v TableNamer, cols ...string) (sql.Result, error)

	// Select 查询一个符合条件的数据
	//
	// 查找条件以结构体定义的主键或是唯一约束(在没有主键的情况下 ) 来查找，
	// 若两者都不存在，则将返回 error
	// 若没有符合条件的数据，将不会对参数 v 做任何变动。
	//
	// 查找条件的查找顺序是为 自增 > 主键 > 唯一约束，
	// 如果同时存在多个唯一约束满足条件(可能每个唯一约束查询至的结果是不一样的)，则返回错误信息。
	Select(v TableNamer) (found bool, err error)

	Create(v TableNamer) error

	Drop(v TableNamer) error

	// Truncate 清空表并重置 ai 但保留表结构
	Truncate(v TableNamer) error

	// InsertMany 插入多条相同的数据
	//
	// 若需要向某张表中插入多条记录，InsertMany() 会比 Insert() 性能上好很多。
	//
	// max 表示一次最多插入的数量，如果超过此值，会分批执行，
	// 但是依然在一个事务中完成。
	InsertMany(max int, v ...TableNamer) error

	// Where 生成 WhereStmt 语句
	Where(cond string, args ...any) *WhereStmt
}

ModelEngine 针对操作 TableNamer 接口数据的接口

type Prefix 

type Prefix string

Prefix 表名前缀

经由 Prefix 返回的 ModelEngine 对象会对所有的表名加上 Prefix 作为前缀。

func (Prefix) DB 

func (p Prefix) DB(db *DB) ModelEngine

func (Prefix) TableName 

func (p Prefix) TableName(v TableNamer) string

func (Prefix) Tx 

func (p Prefix) Tx(tx *Tx) ModelEngine

type Rat 

type Rat = types.Rat

type TableNamer 

type TableNamer = core.TableNamer

type Tx 

type Tx struct {
	*sql.Tx
	// contains filtered or unexported fields
}

Tx 事务对象

func (*Tx) Create 

func (tx *Tx) Create(v TableNamer) error

func (*Tx) Delete 

func (tx *Tx) Delete(v TableNamer) (sql.Result, error)

func (*Tx) Dialect 

func (tx *Tx) Dialect() Dialect

func (*Tx) Drop 

func (tx *Tx) Drop(v TableNamer) error

func (*Tx) Exec 

func (tx *Tx) Exec(query string, args ...any) (sql.Result, error)

func (*Tx) ExecContext 

func (tx *Tx) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

func (*Tx) ForUpdate 

func (tx *Tx) ForUpdate(v TableNamer) error

ForUpdate 读数据并锁定

func (*Tx) Insert 

func (tx *Tx) Insert(v TableNamer) (sql.Result, error)

func (*Tx) InsertMany 

func (tx *Tx) InsertMany(max int, v ...TableNamer) error

func (*Tx) LastInsertID 

func (tx *Tx) LastInsertID(v TableNamer) (int64, error)

func (*Tx) Prefix 

func (tx *Tx) Prefix(p string) ModelEngine

Prefix 为所有操作的表名加上统一的前缀

如果要复用表结构，可以采此对象进行相关操作，而不是直接使用 DB 或 Tx。

func (*Tx) Prepare 

func (tx *Tx) Prepare(query string) (*core.Stmt, error)

func (*Tx) PrepareContext 

func (tx *Tx) PrepareContext(ctx context.Context, query string) (*core.Stmt, error)

func (*Tx) Query 

func (tx *Tx) Query(query string, args ...any) (*sql.Rows, error)

func (*Tx) QueryContext 

func (tx *Tx) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

func (*Tx) QueryRow 

func (tx *Tx) QueryRow(query string, args ...any) *sql.Row

QueryRow 执行一条查询语句

如果生成语句出错，则会 panic

func (*Tx) QueryRowContext 

func (tx *Tx) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

QueryRowContext 执行一条查询语句

如果生成语句出错，则会 panic

func (*Tx) SQLBuilder 

func (tx *Tx) SQLBuilder() *sqlbuilder.SQLBuilder

func (*Tx) Select 

func (tx *Tx) Select(v TableNamer) (bool, error)

func (*Tx) Truncate 

func (tx *Tx) Truncate(v TableNamer) error

func (*Tx) Update 

func (tx *Tx) Update(v TableNamer, cols ...string) (sql.Result, error)

func (*Tx) Where 

func (tx *Tx) Where(cond string, args ...any) *WhereStmt

type Unix 

type Unix = types.Unix

Unix 表示 Unix 时间戳的数据样式

表现为 time.Time，但是保存数据库时，以 unix 时间戳的形式保存。

func NowUnix 

func NowUnix() Unix

NowUnix 返回当前时间

type Upgrader 

type Upgrader struct {
	// contains filtered or unexported fields
}

Upgrader 更新数据表对象

主要针对线上数据与本地模型不相同时，可执行的一些操作。 并没有准确的方法判断线上字段与本地定义的是否相同，比如： varchar(50) 和 text 在 sqlite3 是相同的，但是在其它数据库可能是稍微有差别的， 所以 Upgrader 并不会主动对数据表进行更新，所有更新还是要手动调用相关的函数。

func (*Upgrader) AddColumn 

func (u *Upgrader) AddColumn(name ...string) *Upgrader

AddColumn 添加表中的列

列名必须存在于表模型中。

func (*Upgrader) AddConstraint 

func (u *Upgrader) AddConstraint(name ...string) *Upgrader

AddConstraint 添加约束

约束必须存在于 model.constraints 中

func (*Upgrader) AddIndex 

func (u *Upgrader) AddIndex(name ...string) *Upgrader

AddIndex 添加索引信息

func (*Upgrader) Do 

func (u *Upgrader) Do() error

Do 执行操作

func (*Upgrader) DropColumn 

func (u *Upgrader) DropColumn(name ...string) *Upgrader

DropColumn 删除表中的列

列名可以不存在于表模型，只在数据库中的表包含该列名，就会被删除。

func (*Upgrader) DropConstraint 

func (u *Upgrader) DropConstraint(conts ...string) *Upgrader

DropConstraint 删除约束

func (*Upgrader) DropIndex 

func (u *Upgrader) DropIndex(name ...string) *Upgrader

DropIndex 删除索引

func (*Upgrader) DropPK 

func (u *Upgrader) DropPK(name string) *Upgrader

DropPK 删除主键约束

func (*Upgrader) Engine 

func (u *Upgrader) Engine() Engine

func (*Upgrader) Err 

func (u *Upgrader) Err() error

Err 返回执行过程中的错误信息

type WhereStmt 

type WhereStmt struct {
	// contains filtered or unexported fields
}

func (*WhereStmt) Count 

func (stmt *WhereStmt) Count(v TableNamer) (int64, error)

Count 返回符合条件数量

表名来自 v。

func (*WhereStmt) Delete 

func (stmt *WhereStmt) Delete(v TableNamer) (sql.Result, error)

Delete 从 v 表中删除符合条件的内容

func (*WhereStmt) Select 

func (stmt *WhereStmt) Select(strict bool, v any) (int, error)

Select 获取所有符合条件的数据

v 可能是某个对象的指针，或是一组相同对象指针数组。 表名来自 v，列名为 v 的所有列。

func (*WhereStmt) Update 

func (stmt *WhereStmt) Update(v TableNamer, cols ...string) (sql.Result, error)

Update 将 v 中内容更新到符合条件的行中

不会更新零值，除非通过 cols 指定了该列。 表名来自 v，列名为 v 的所有列或是 cols 指定的列。

Source Files

View all Source files

Directories

Path Synopsis
Package core 核心功能
 Package core 核心功能
Package dialect 提供了部分数据库对 orm.Dialect 接口的实现
 Package dialect 提供了部分数据库对 orm.Dialect 接口的实现
Package fetch 包提供了将 [sql.Rows] 导出为几种常用数据格式的方法
 Package fetch 包提供了将 [sql.Rows] 导出为几种常用数据格式的方法
internal
createtable
Package createtable 分析 create table 语句的内容
 Package createtable 分析 create table 语句的内容
model
Package model 管理数据模型
 Package model 管理数据模型
sqltest
Package sqltest 提供对 SQL 内容测试的工具
 Package sqltest 提供对 SQL 内容测试的工具
tags
Package tags 包实现对特定格式的 struct tag 字符串的分析
 Package tags 包实现对特定格式的 struct tag 字符串的分析
test
Package test 提供了整个包的基本测试数据
 Package test 提供了整个包的基本测试数据
Package sqlbuilder 提供一套通过字符串拼接来构成 SQL 语句的工具
 Package sqlbuilder 提供一套通过字符串拼接来构成 SQL 语句的工具
Package types 提供部分存取数据库的类型
 Package types 提供部分存取数据库的类型

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.