mysql

Jun 23, 2024

Changes in this version

type DB

+ func (db *DB) Exec(ctx context.Context, query string, args ...interface{}) (int64, error)

Jun 23, 2024

Changes in this version

type Field

+ IsUnsigned bool

Jun 22, 2024

Changes in this version

+ var ErrDuplicateKey = errors.New("duplicate key")

May 21, 2024

Changes in this version

type Schema

+ func (sc *Schema[T]) SelectPage(ctx context.Context, page_idx, page_size int64, where string, args ...any) ([]*T, int64, int64, int64, error)

May 21, 2024

Changes in this version

+ func DeserializeField(t uint8, data string, v *interface{})

+ func SerializeField(t uint8, data interface{}) interface

+ type Entity struct

+ func GetEntity[T struct{}, S struct{}](schema *Schema[S]) *Entity[T]

+ func (ent *Entity[T]) Select(ctx context.Context, where string, args ...any) ([]*T, error)

+ func (ent *Entity[T]) SelectOne(ctx context.Context, where string, args ...any) (*T, error)

+ func (ent *Entity[T]) SelectPage(ctx context.Context, page_idx, page_size int64, where string, args ...any) ([]*T, int64, int64, int64, error)

type Field

+ EntityIndex int

+ Indices []*FieldIndexDecl

+ IsAutoIncrement bool

+ IsNullable bool

+ IsPrimaryKey bool

+ SerializeMethod uint8

+ func (fd *Field) CompleteWithType(t reflect.Type)

+ func (fd *Field) FromTag(tag string)

+ type FieldIndexDecl struct

+ IndexName string

+ IndexType uint8

type Schema

+ FieldsByColumn map[string]*Field

+ func NewSchema[T struct{}](dbr *DB, dbw *DB, name string) *Schema[T]

May 20, 2024

Changes in this version

type Schema

+ func (sc *Schema) DeleteEntity(ctx context.Context, v any) (int64, error)

May 20, 2024

Changes in this version

+ func EachOf[T interface{}](ctx context.Context, sc *Schema, cb func(*T) bool, where string, args ...any) error

type Schema

+ func (sc *Schema) Delete(ctx context.Context, v any, where string, args ...interface{}) (int64, error)

May 19, 2024

Changes in this version

+ const INDEX

+ const JSON

+ const NONE

+ const PRIMARY_KEY

+ const UNIQUE

+ const YAML

+ var ErrInvalidData = errors.New("invalid data")

+ var ErrNoDataInfo = errors.New("dataInfo is missing, call Reflect on Schema first")

+ var ErrNoPrimaryKey = errors.New("no primary key")

+ var ErrNoRowsAffected = errors.New("no rows affected")

+ var ErrNotFound = errors.New("not found")

+ var ErrNotReady = errors.New("stmtInsert is not ready, call Prepare on Schema first")

+ func PrepareStmt(db *DB, query string) *sql.Stmt

+ func SelectOne[T interface{}](ctx context.Context, sc *Schema, where string, args ...any) (*T, error)

+ func Select[T interface{}](ctx context.Context, sc *Schema, where string, args ...any) ([]T, error)

+ type Config struct

+ Addr string

+ DataBase string

+ Password string

+ Username string

+ type DB struct

+ Ctx *sql.DB

+ func NewDB(cfg *Config) (*DB, error)

+ func (db *DB) Close() error

+ func (db *DB) Tx(ctx context.Context, f func(context.Context, *sql.Tx) error) error

+ type Field struct

+ AutoIncrement bool

+ Comment string

+ DefaultValue string

+ Name string

+ Nullable bool

+ Type string

+ func (fd *Field) Equal(other *Field) bool

+ type Index struct

+ Columns []string

+ Name string

+ Primary bool

+ Unique bool

+ func (idx *Index) Equal(other *Index) bool

+ type Schema struct

+ Collate string

+ Comment string

+ Engine string

+ Fields []*Field

+ Indices []*Index

+ Name string

+ func InitSchema(dbr *DB, dbw *DB, name string, v any) *Schema

+ func (sc *Schema) Columns() []string

+ func (sc *Schema) Count(ctx context.Context, where string, args ...any) (int64, error)

+ func (sc *Schema) CreateSchema(ctx context.Context, db *DB) error

+ func (sc *Schema) Field(name string) *Field

+ func (sc *Schema) Get(ctx context.Context, v any) error

+ func (sc *Schema) Index(name string) *Index

+ func (sc *Schema) Insert(ctx context.Context, v any) error

+ func (sc *Schema) LoadSchema(ctx context.Context, db *DB) error

+ func (sc *Schema) Prepare(dbRead *DB, dbWrite *DB) error

+ func (sc *Schema) Reflect(v any) bool

+ func (sc *Schema) Select(ctx context.Context, slice_ptr any, where string, args ...any) error

+ func (sc *Schema) SelectOne(ctx context.Context, v any, where string, args ...any) error

+ func (sc *Schema) Update(ctx context.Context, v any, columns ...string) (int64, error)

+ func (sc *Schema) UpdateSchema(ctx context.Context, db *DB) error