sqlize

Jun 18, 2023

Changes in this version

+ func Begin(q Querier) (tx *sql.Tx, ok bool, err error)

+ func BeginTx(q Querier, ctx context.Context, opts *sql.TxOptions) (*sql.Tx, bool, error)

+ func CommitOrRollbackOn(err *error, tx *sql.Tx)

+ func LogDriver(name string, drv driver.Driver, logTo Logger, flags LogFlag)

+ func MustBegin(q Querier) (tx *sql.Tx, ok bool)

+ func MustBeginTx(q Querier, ctx context.Context, opts *sql.TxOptions) (*sql.Tx, bool)

+ func XactionTx(q Querier, ctx context.Context, opts *sql.TxOptions, do func(*sql.Tx) error) (err error)

+ type CallRef struct

+ ID any

+ Name string

+ type LogFlag uint

+ const LogAll

+ const LogBeginTx

+ const LogConnect

+ const LogDefault

+ const LogExec

+ const LogInsertId

+ const LogPing

+ const LogPrepare

+ const LogQuery

+ const LogRowsAffected

+ const LogRowsClose

+ const LogRowsNext

+ const LogStmtClose

+ const LogStmtExec

+ const LogStmtQuery

+ const LogTxCommit

+ const LogTxRollback

+ type Logger interface

+ Call func(name string, args ...any) CallRef

+ Result func(ref CallRef, err error, args ...any)

+ func NewStdLogger(l *log.Logger) Logger

Dec 15, 2022

Changes in this version

+ type DataDict interface

+ Tables func(db *sql.DB, match string) ([]string, error)

type Entity

+ IDScanner func() sql.Scanner

type EntityBase

+ func (eb *EntityBase[E, ID]) SQLizeReader() Reader[E, ID]

+ func (eb *EntityBase[E, ID]) SetSQLizeReader(rd Reader[E, ID])

type Ref

+ func (ref *Ref[E, ID]) Scanner(r Reader[E, ID]) refScanner[E, ID]

May 9, 2022

Changes in this version

type DB

+ Ping func() error

May 3, 2022

Changes in this version

type DataSource

+ Log bool

+ type RepoConfig struct

+ CreateQuery any

+ DeleteQuery any

+ ReadQuery any

+ UpdateQuery any

May 1, 2022

Changes in this version

type Reader

+ Read func(q Querier, id ID, reuse E) (E, error)

type Repo

+ Create func(q Querier, entity E) (E, error)

+ Delete func(q Querier, entity E) error

+ Update func(q Querier, entity E) error

Apr 26, 2022

Changes in this version

type Entity

+ IsZero func() bool

+ Zero func() Entity[ID]

+ type Repo interface

+ CreateEntity func(q Querier, entity E) (E, error)

+ DeleteEntity func(q Querier, entity E) error

+ UpdateEntity func(q Querier, entity E) error

Apr 18, 2022

Changes in this version

+ func Xaction(conn Querier, recovr bool, do func(tx Tx) error) error

+ func XactionContext(ctx context.Context, conn Querier, opts *sql.TxOptions, recovr bool, ...) error

type DB

+ Begin func() (*sql.Tx, error)

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

+ type DataSource struct

+ Name string

+ Password string

+ User string

+ func (ds *DataSource) Flags()

+ type Entity interface

+ EntityID func() ID

+ type EntityBase struct

+ func (eb *EntityBase[E, ID]) SetReader(rd Reader[E, ID])

+ func (eb *EntityBase[_, ID]) IDScanner() sql.Scanner

+ func (eb EntityBase[_, ID]) EntityID() ID

+ type EntityID interface

+ type Querier interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ Prepare func(query string) (*sql.Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ type Reader interface

+ ReadEntity func(q Querier, id ID, reuse *E) (*E, error)

+ type Ref struct

+ func RefEntity(entity *E) Ref[E, ID]

+ func RefID(r Reader[E, ID], id ID) Ref[E, ID]

+ func (ref *Ref[E, ID]) Get(db Querier) (entity *E, err error)

+ func (ref *Ref[E, ID]) Nil() bool

+ func (ref *Ref[E, ID]) Resolved() (is bool, entity *E)

+ func (ref *Ref[E, ID]) Scan(src interface{}) error

+ func (ref *Ref[E, ID]) Set(entity *E)

+ func (ref *Ref[E, ID]) SetID(r Reader[E, ID], id ID)

+ func (ref *Ref[E, ID]) SetReader(r Reader[E, ID])

+ func (ref *Ref[E, ID]) SetRef(r Ref[E, ID])

+ func (ref Ref[E, ID]) ID() ID

+ func (ref Ref[E, ID]) Value() (driver.Value, error)

+ func (ref Ref[E, ID]) WithReader(r Reader[E, ID]) (res Ref[E, ID])

type Ref32

+ func (ref *Ref32) SetReader(rsv Reader32)

+ func (ref *Ref32) SetRef(r Ref32)

+ func (ref Ref32) WithReader(rsv Reader32) Ref32

type Ref64

+ func (ref *Ref64) SetReader(rsv Reader64)

+ func (ref *Ref64) SetRef(r Ref64)

+ func (ref Ref64) WithReader(rsv Reader64) Ref64

type Tx

+ Stmt func(stmt *sql.Stmt) *sql.Stmt

Sep 18, 2021

Changes in this version

+ const IDSeqMax32

+ const IDSeqMax64

+ const IDTypeMax32

+ const IDTypeMax64

+ const NoID

+ func Delete32(repo Repo32, db SQL, entity Entity32) error

+ func Delete64(repo Repo64, db SQL, entity Entity64) error

+ func NotNoRows(err error) error

+ func RunScript(db SQL, rd io.Reader) error

+ func RunScriptFile(db SQL, file string) error

+ func Transact(conn SQL, do func(tx Tx) error) (err error)

+ func TransactContext(ctx context.Context, conn SQL, opts *sql.TxOptions, do func(tx Tx) error) (err error)

+ func Update32(repo Repo32, db SQL, entity Entity32) error

+ func Update64(repo Repo64, db SQL, entity Entity64) error

+ type Beginner interface

+ SqlizedBegin func() (Tx, error)

+ SqlizedBeginTx func(context.Context, *sql.TxOptions) (Tx, error)

+ type DB interface

+ Close func() error

+ type Entity32 interface

+ EntityID func() ID32

+ func Create32(repo Repo32, db SQL, entity Entity32) (Entity32, error)

+ type Entity64 interface

+ EntityID func() ID64

+ func Create64(repo Repo64, db SQL, entity Entity64) (Entity64, error)

+ type EntityBase32 struct

+ func (e *EntityBase32) SetEntityRepo(r Repo32, id ID32)

+ func (e EntityBase32) EntityID() ID32

+ func (e EntityBase32) EntityRepo() Repo32

+ type ID32 int32

+ func MakeID32(t TypeID, s uint32) (ID32, error)

+ func MustMakeID32(t TypeID, s uint32) ID32

+ func NoRowsNoErr32(id ID32, err error) (ID32, error)

+ func (id *ID32) Scan(src interface{}) error

+ func (id ID32) Type() TypeID

+ func (id ID32) Value() (driver.Value, error)

+ type ID64 int64

+ func MakeID64(t TypeID, s uint64) (ID64, error)

+ func MustMakeID64(t TypeID, s uint64) ID64

+ func NoRowsNoErr64(id ID64, err error) (ID64, error)

+ func (id *ID64) Scan(src interface{}) error

+ func (id ID64) Type() TypeID

+ func (id ID64) Value() (driver.Value, error)

+ type NormSpace string

+ func (ns NormSpace) String() string

+ type Reader32 interface

+ ReadEntity func(db SQL, id ID32, entity Entity32) (Entity32, error)

+ type Reader64 interface

+ ReadEntity func(db SQL, id ID64, entity Entity64) (Entity64, error)

+ type Ref32 struct

+ func RefEntity32(e Entity32) Ref32

+ func RefID32(rsv Reader32, id ID32) Ref32

+ func (ref *Ref32) Get(db SQL) (entity Entity32, err error)

+ func (ref *Ref32) Resolved() (is bool, entity Entity32)

+ func (ref *Ref32) Scan(src interface{}) error

+ func (ref *Ref32) Set(e Entity32)

+ func (ref *Ref32) SetID(rsv Reader32, id ID32)

+ func (ref Ref32) ID() ID32

+ func (ref Ref32) Nil() bool

+ func (ref Ref32) Value() (driver.Value, error)

+ func (ref Ref32) WithResolver(rsv Reader32) Ref32

+ type Ref64 struct

+ func RefEntity64(e Entity64) Ref64

+ func RefID64(rsv Reader64, id ID64) Ref64

+ func (ref *Ref64) Get(db SQL) (entity Entity64, err error)

+ func (ref *Ref64) Resolved() (is bool, entity Entity64)

+ func (ref *Ref64) Scan(src interface{}) error

+ func (ref *Ref64) Set(e Entity64)

+ func (ref *Ref64) SetID(rsv Reader64, id ID64)

+ func (ref Ref64) ID() ID64

+ func (ref Ref64) Nil() bool

+ func (ref Ref64) Value() (driver.Value, error)

+ func (ref Ref64) WithResolver(rsv Reader64) Ref64

+ type Repo32 interface

+ CreateEntity func(tx Tx, entity Entity32) (Entity32, error)

+ DeleteEntity func(tx Tx, entity Entity32) error

+ UpdateEntity func(tx Tx, entity Entity32) error

+ type Repo64 interface

+ CreateEntity func(tx Tx, entity Entity64) (Entity64, error)

+ DeleteEntity func(tx Tx, entity Entity64) error

+ UpdateEntity func(tx Tx, entity Entity64) error

+ type RollbackError struct

+ Cause error

+ Rollback error

+ func (ce RollbackError) Error() string

+ func (ce RollbackError) Unwrap() error

+ type SQL interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Prepare func(query string) (*sql.Stmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ func SqlDB(conn SQL) (*sql.DB, SQL)

+ func SqlTx(conn SQL) (*sql.Tx, SQL)

+ func StdLogDB(conn SQL) SQL

+ type Tx interface

+ Commit func() error

+ Rollback func() error

+ type TypeID = uint16

+ type TypeTable struct

+ func NewTypeTable(conn SQL, table string) (res TypeTable, err error)

+ func (idt TypeTable) ForEach(do func(tid TypeID, tag string) (done bool)) (hasDone bool)

+ func (idt TypeTable) ID(tag string) TypeID

+ func (idt TypeTable) Tag(tid TypeID) string

+ type Wrapper interface

+ Unwrap func() SQL