db

package
v1.0.3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InKeys added in v1.0.3 

func InKeys(numArgs int) string

InKeys 根据长度生成SQL中 IN "(?,?,...)" 引号中的部分 InKeys return IN后面的Key变量的SQL

func MakeDao added in v1.0.3 

func MakeDao(outputPath string, conn *db.DB, conf *DaoConfig, logger *log.Logger) error

func MakeER added in v1.0.3 

func MakeER(groups []ERGroup, outputFile *string, tplFile *string, logger *log.Logger) error

MakeER 创建ER图文件

func MakeTable added in v1.0.3 

func MakeTable(conn *db.DB, table *TableStruct, logger *log.Logger) ([]string, error)

Types

type DB 

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

func GetDB 

func GetDB(name *string, logger *log.Logger) *DB

GetDB 获得数据库连接 GetDB name 连接配置名称，如果不提供名称则使用默认连接 GetDB return 数据库连接，对象内置连接池操作，完成后无需手动关闭连接

func (*DB) Begin 

func (db *DB) Begin() *Tx

Begin 开始事务 Begin return 事务对象，事务中的操作都在事务对象上操作，请务必在返回的事务对象上执行commit或rollback

func (*DB) Delete 

func (db *DB) Delete(table string, wheres string, args ...interface{}) (ExecResult, error)

Delete 删除数据 Delete return 返回影响的行数

func (*DB) Destroy added in v1.0.3 

func (db *DB) Destroy() error

Destroy 关闭连接池

func (*DB) Exec 

func (db *DB) Exec(requestSql string, args ...interface{}) (ExecResult, error)

Exec 执行SQL * requestSql SQL语句 * args SQL语句中问号变量的值，按顺序放在请求参数中 Exec return 如果是INSERT到含有自增字段的表中返回插入的自增ID，否则返回影响的行数

func (*DB) Insert 

func (db *DB) Insert(table string, data map[string]interface{}) (ExecResult, error)

Insert 插入数据 * table 表名 * data 数据对象（Key-Value格式） Insert return 如果是INSERT到含有自增字段的表中返回插入的自增ID，否则返回影响的行数

func (*DB) Make added in v1.0.3 

func (db *DB) Make(groups []ERGroup) ([]string, error)

Make 创建表格，如果表格已经存在则更新表结构 Make return 已执行的SQL列表

func (*DB) MakeDao added in v1.0.3 

func (db *DB) MakeDao(outputPath *string, conf *DaoConfig) error

MakeDao 创建实体对象 MakeDao outputPath 实体文件输出目录，为空时输出到当前目录下以数据库为目录名

func (*DB) MakeER added in v1.0.3 

func (db *DB) MakeER(groups []ERGroup, outputFile *string, tplFile *string) error

MakeER 创建ER图

func (*DB) MakeId 

func (db *DB) MakeId(table string, idField string, idSize uint) (string, error)

MakeId 生成指定字段不唯一的ID MakeId idField ID字段 MakeId idSize ID长度 MakeId return 新的ID

func (*DB) Query 

func (db *DB) Query(requestSql string, args ...interface{}) (QueryResult, error)

Query 查询 Query return 返回查询到的数据，对象数组格式

func (*DB) Query1 

func (db *DB) Query1(requestSql string, args ...interface{}) (map[string]interface{}, error)

Query1 查询 Query1 return 返回查询到的第一行数据，对象格式

func (*DB) Query11 

func (db *DB) Query11(requestSql string, args ...interface{}) (interface{}, error)

Query11 查询 Query11 return 返回查询到的第一行第一列数据，字段类型对应的格式

func (*DB) Query1a 

func (db *DB) Query1a(requestSql string, args ...interface{}) ([]interface{}, error)

Query1a 查询 Query1a return 返回查询到的第一列数据，数组格式

func (*DB) Replace 

func (db *DB) Replace(table string, data map[string]interface{}) (ExecResult, error)

Replace 替换数据 Replace return 如果是REPLACE到含有自增字段的表中返回插入的自增ID，否则返回影响的行数

func (*DB) Update 

func (db *DB) Update(table string, data map[string]interface{}, wheres string, args ...interface{}) (ExecResult, error)

Update 更新数据 * wheres 条件（SQL中WHERE后面的部分） Update return 返回影响的行数

type DaoConfig added in v1.0.3 

type DaoConfig struct {
	VersionField string
	ValidFields  []ValidFieldConfig
}

type DaoData added in v1.0.3 

type DaoData struct {
	DBName       string
	FixedDBName  string
	RandomTag    string
	VersionField string
	//TableNames   []string
	Tables      []TableData
	FixedTables []string
}

type ERGroup added in v1.0.3 

type ERGroup struct {
	Group   string
	Comment string
	Tables  []TableStruct
}

type ExecResult added in v1.0.3 

type ExecResult struct {
	Id      int64
	Changes int64
	Version uint64
	Sql     string
	SqlArgs []interface{}
}

type FieldData added in v1.0.3 

type FieldData struct {
	Name    string
	Type    string
	Default string
	Options map[string]string
}

type IndexField added in v1.0.3 

type IndexField struct {
	Name       string
	Where      string
	Args       string
	Params     string
	ItemArgs   string
	StringArgs string
}

type QueryResult added in v1.0.3 

type QueryResult struct {
	Result  []map[string]interface{}
	Sql     string
	SqlArgs []interface{}
}

type TableData added in v1.0.3 

type TableData struct {
	DBName          string
	TableName       string
	FixedTableName  string
	IsAutoId        bool
	AutoIdField     string
	AutoIdFieldType string
	PrimaryKey      *IndexField
	UniqueKeys      map[string]*IndexField
	IndexKeys       map[string]*IndexField
	Fields          []FieldData
	PointFields     []FieldData
	//FieldsWithoutAutoId []FieldData
	SelectFields          string
	ValidFieldConfig      ValidFieldConfig
	ValidField            string
	ValidWhere            string
	ValidSet              string
	InvalidSet            string
	VersionField          string
	HasVersion            bool
	AutoGenerated         []string
	AutoGeneratedOnUpdate []string
}

type TableDesc added in v1.0.3 

type TableDesc struct {
	Field   string
	Type    string
	Null    string
	Key     string
	Default string
	Extra   string
	After   string
}

type TableField added in v1.0.3 

type TableField struct {
	Name       string
	Type       string
	Index      string
	IndexGroup string
	Default    string
	Comment    string
	IsNull     bool
	Extra      string

	Null string
	// contains filtered or unexported fields
}

func (*TableField) Parse added in v1.0.3 

func (field *TableField) Parse(tableType string)

type TableFieldDesc added in v1.0.3 

type TableFieldDesc struct {
	Field   string
	Type    string
	Null    string
	Key     string
	Default string
	Extra   string
	After   string
}

type TableIndex added in v1.0.3 

type TableIndex struct {
	Non_unique   int
	Key_name     string
	Seq_in_index int
	Column_name  string
}

type TableKeyDesc added in v1.0.3 

type TableKeyDesc struct {
	Key_name    string
	Column_name string
}

type TableStruct added in v1.0.3 

type TableStruct struct {
	Name    string
	Comment string
	Fields  []TableField
}

type Tx 

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

func (*Tx) CheckFinished 

func (tx *Tx) CheckFinished() error

CheckFinished 检查事务是否已经提交或回滚，如果事务没有结束则执行回滚操作

func (*Tx) Commit 

func (tx *Tx) Commit() error

Commit 提交事务

func (*Tx) Delete 

func (tx *Tx) Delete(table string, wheres string, args ...interface{}) (ExecResult, error)

func (*Tx) Exec 

func (tx *Tx) Exec(requestSql string, args ...interface{}) (ExecResult, error)

func (*Tx) Finish 

func (tx *Tx) Finish(ok bool) error

Finish 根据传入的成功标识提交或回滚事务 Finish ok 事务是否执行成功

func (*Tx) Insert 

func (tx *Tx) Insert(table string, data map[string]interface{}) (ExecResult, error)

func (*Tx) Query 

func (tx *Tx) Query(requestSql string, args ...interface{}) (QueryResult, error)

func (*Tx) Query1 

func (tx *Tx) Query1(requestSql string, args ...interface{}) (map[string]interface{}, error)

func (*Tx) Query11 

func (tx *Tx) Query11(requestSql string, args ...interface{}) (interface{}, error)

func (*Tx) Query1a 

func (tx *Tx) Query1a(requestSql string, args ...interface{}) ([]interface{}, error)

func (*Tx) Replace 

func (tx *Tx) Replace(table string, data map[string]interface{}) (ExecResult, error)

func (*Tx) Rollback 

func (tx *Tx) Rollback() error

Rollback 回滚事务

func (*Tx) Update 

func (tx *Tx) Update(table string, data map[string]interface{}, wheres string, args ...interface{}) (ExecResult, error)

type ValidFieldConfig added in v1.0.3 

type ValidFieldConfig struct {
	Field              string
	Type               string
	ValidOperator      string
	ValidValue         string
	ValidSetOperator   string
	ValidSetValue      string
	InvalidSetOperator string
	InvalidSetValue    string
}

Source Files

View all Source files

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.