dbw

package module

Go to main page

Versions in this module

v0

v0.5.6

Mar 15, 2024

v0.5.5

Nov 4, 2023

v0.5.4

Nov 2, 2023

v0.5.3

Oct 25, 2023

v0.5.2

May 19, 2023

v0.5.1

Jul 21, 2022

v0.5.0

Jun 27, 2022

Changes in this version

type Table

+ func (t *Table) DoSelectRow(where string, row interface{}, args ...interface{}) error

v0.4.0

Feb 19, 2022

Changes in this version

+ func MaskPostgreSQLConnectionString(src string) string

v0.3.3

Feb 8, 2022

v0.3.2

Jan 19, 2022

v0.3.1

Jan 19, 2022

v0.3.0

Dec 26, 2021

Changes in this version

type Table

+ func (t *Table) Columns() string

v0.2.3

Dec 4, 2021

Changes in this version

+ func WithCols(cv map[string]interface{}) func(*Option)

+ func WithID(val interface{}) func(*Option)

+ func WithIgnoreConflictColumn(column ...string) func(*Option)

+ func WithReturnAll(dst interface{}) func(*Option)

+ func WithReturnDeletedAt(dst interface{}) func(*Option)

+ func WithReturnID(dst interface{}) func(*Option)

+ func WithReturnVersion(dst interface{}) func(*Option)

+ func WithRow(row interface{}) func(*Option)

+ func WithTag(tag string, rule TagExclusionRule) func(*Option)

+ func WithWhere(cond string, val ...interface{}) func(*Option)

+ func WithoutReturnAll() func(*Option)

type Table

+ func (t *Table) Delete(optFunc ...func(*Option)) error

+ func (t *Table) Update(row interface{}, optFunc ...func(*Option)) error

v0.2.2

Nov 12, 2021

Changes in this version

+ var ErrCheckConstaintViolation = errors.New("check constraint violation").StatusCode(400)

v0.2.1

Nov 4, 2021

Changes in this version

type NullTime

+ func (ns *NullTime) UnmarshalJSON(b []byte) error

+ func (ns *NullTime) UnmarshalText(b []byte) error

+ func (ns NullTime) MarshalJSON() ([]byte, error)

+ func (ns NullTime) MarshalText(b []byte) ([]byte, error)

v0.2.0

Nov 2, 2021

Changes in this version

+ var ErrConnectionDone = errors.New("database connection lost").StatusCode(503).Critical()

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

+ var ErrQueryExecFailed = errors.New("query execution failed").StatusCode(500).Critical()

+ var ErrUniqueViolation = errors.New("unique violation").StatusCode(409)

+ func WithCtx(ctx context.Context) func(*Option)

+ func WithIgnoreConflict(column ...string) func(*Option)

+ func WithReturning(returning ...interface{}) func(*Option)

+ func WithReturningAll() func(*Option)

+ func WithTx(tx *Tx) func(*Option)

+ type Option struct

type Table

+ func (t *Table) Insert(row interface{}, optFunc ...func(*Option)) error

v0.1.2

Oct 24, 2021

v0.1.1

Oct 12, 2021

Changes in this version

type Table

+ func (t *Table) DoSelectCtxTx(tx *Tx, where, order string, offset, limit int, f func() error, ...) error

+ func (t *Table) DoSelectTx(tx *Tx, where, order string, offset, limit int, f func() error, ...) error

v0.1.0

Oct 12, 2021

Changes in this version

type DB

+ func (db *DB) InTx(f func(*Tx) error) error

v0.0.2

Jul 21, 2021

v0.0.1

Jun 18, 2021

Changes in this version

+ const TagNoCache

+ const TagNoIns

+ const TagNoSeq

+ const TagNoUpd

+ const ValidateIntRange

+ const ValidateLen

+ const ValidateNotNull

+ var AutoCheckTableExistance bool = true

+ var ErrUnknownPreparedStatement = errors.New("unknown prepared statement")

+ var FieldTagLabel = "dbw"

+ var PrimaryKeyFieldName = "ID"

+ func Append(arr interface{}, elem interface{}) error

+ func BindTables(ctx context.Context, db *DB, tt map[string]TableDesc, parallel bool) map[string]error

+ func FieldAddrs(model interface{}, excludeTag string) []interface

+ func FieldNames(model interface{}, tagRules string) string

+ func HasAutoincrementFieldID(model interface{}) bool

+ func ToSnakeCase(str string) string

+ func WrapError(t interface{}, err error, params ...interface{}) error

+ func WrapErrorOld(t interface{}, err error, params ...interface{}) error

+ type DB struct

+ func Inherit(db *sql.DB) *DB

+ func Open(driverName, dataSourceName string) (*DB, error)

+ func RepetableOpen(ctx context.Context, driverName, dataSourceName string, l *zerolog.Logger, ...) (*DB, error)

+ func (db *DB) Begin() *Tx

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

+ func (db *DB) CleanUnusedStatement(d time.Duration)

+ func (db *DB) Close() error

+ func (db *DB) Exec(qry string, args ...interface{}) (sql.Result, error)

+ func (db *DB) ExecContext(ctx context.Context, qry string, args ...interface{}) (sql.Result, error)

+ func (db *DB) ExecContextTx(ctx context.Context, tx *Tx, qry string, args ...interface{}) (sql.Result, error)

+ func (db *DB) ExecTx(tx *Tx, qry string, args ...interface{}) (sql.Result, error)

+ func (db *DB) Logger() *zerolog.Logger

+ func (db *DB) Ping() error

+ func (db *DB) PingContext(ctx context.Context) error

+ func (db *DB) PlaceHolderType() ParamPlaceHolderType

+ func (db *DB) Prepare(qry string) *Stmt

+ func (db *DB) PrepareContext(ctx context.Context, qry string) *Stmt

+ func (db *DB) PrepareContextN(ctx context.Context, qry, uid string) *Stmt

+ func (db *DB) PrepareN(qry, uid string) *Stmt

+ func (db *DB) PreparedStatementCount() int

+ func (db *DB) Query(qry string, args ...interface{}) *StmtInstance

+ func (db *DB) QueryContext(ctx context.Context, qry string, args ...interface{}) *StmtInstance

+ func (db *DB) QueryContextTx(ctx context.Context, tx *Tx, qry string, args ...interface{}) *StmtInstance

+ func (db *DB) QueryRow(qry string, args ...interface{}) *StmtInstance

+ func (db *DB) QueryRowContext(ctx context.Context, qry string, args ...interface{}) *StmtInstance

+ func (db *DB) QueryRowContextTx(ctx context.Context, tx *Tx, qry string, args ...interface{}) *StmtInstance

+ func (db *DB) QueryRowTx(tx *Tx, qry string, args ...interface{}) *StmtInstance

+ func (db *DB) QueryTx(tx *Tx, qry string, args ...interface{}) *StmtInstance

+ func (db *DB) SQLDB() *sql.DB

+ func (db *DB) SetLogger(l *zerolog.Logger)

+ func (db *DB) SetPlaceHolderType(ph ParamPlaceHolderType)

+ func (db *DB) Stmt(uid string) (*Stmt, bool)

+ type DefaultStmtLogger struct

+ func NewDefaultStmtLogger() *DefaultStmtLogger

+ func (dsl *DefaultStmtLogger) After(sli *StmtInstance)

+ func (dsl *DefaultStmtLogger) ArgsFormat(args ...interface{}) string

+ func (dsl *DefaultStmtLogger) Before(sli *StmtInstance)

+ func (dsl *DefaultStmtLogger) ContextFormat(ctx context.Context) string

+ type Error struct

+ func (e *Error) SQLErrCode() string

+ func (e Error) Error() string

+ func (err Error) MarshalZerologObject(e *zerolog.Event)

+ type NullString string

+ func (ns *NullString) Scan(value interface{}) error

+ func (ns *NullString) UnmarshalJSON(b []byte) error

+ func (ns *NullString) UnmarshalText(b []byte) error

+ func (ns NullString) MarshalJSON() ([]byte, error)

+ func (ns NullString) MarshalText(b []byte) ([]byte, error)

+ func (ns NullString) String() string

+ func (ns NullString) Valid() bool

+ func (ns NullString) Value() (driver.Value, error)

+ type NullTime time.Time

+ func FieldAddrsUpdate(model interface{}, excludeTag string) (res []interface{}, updatedAt *NullTime, rowVersion *int)

+ func (ns *NullTime) Scan(value interface{}) error

+ func (ns *NullTime) SetNow()

+ func (ns NullTime) String() string

+ func (ns NullTime) Valid() bool

+ func (ns NullTime) Value() (driver.Value, error)

+ type ParamPlaceHolderType int

+ const DollarPlusPosition

+ const QuestionMark

+ type RowValidationResult map[string]int

+ type Sequence struct

+ func NewSequence(db *DB, name string) *Sequence

+ func (s *Sequence) CheckExistance() error

+ func (s *Sequence) NextVal(ctx context.Context) (int64, error)

+ type Stmt struct

+ func (s *Stmt) DB() *DB

+ func (s *Stmt) Err() error

+ func (s *Stmt) Instance() *StmtInstance

+ func (s *Stmt) InstanceTx(tx *Tx) *StmtInstance

+ func (s *Stmt) LastInstanceUnixTime() int64

+ func (s *Stmt) Text() string

+ func (s *Stmt) UID() string

+ func (ss *Stmt) Close() error

+ type StmtInstance struct

+ At time.Time

+ CtxParams string

+ Num uint64

+ QueryParams string

+ RespondedIn time.Duration

+ RowsFetched int

+ RowsFetchedIn time.Duration

+ func (si *StmtInstance) Close() error

+ func (si *StmtInstance) Debug() *StmtInstance

+ func (si *StmtInstance) Err() error

+ func (si *StmtInstance) Exec(args ...interface{}) (sql.Result, error)

+ func (si *StmtInstance) ExecContext(ctx context.Context, args ...interface{}) (sql.Result, error)

+ func (si *StmtInstance) Fetch(f func() error, dest ...interface{}) *StmtInstance

+ func (si *StmtInstance) FetchAll(arr interface{}, row interface{}, dest ...interface{}) *StmtInstance

+ func (si *StmtInstance) Query(args ...interface{}) *StmtInstance

+ func (si *StmtInstance) QueryContext(ctx context.Context, args ...interface{}) *StmtInstance

+ func (si *StmtInstance) QueryRow(args ...interface{}) *StmtInstance

+ func (si *StmtInstance) QueryRowContext(ctx context.Context, args ...interface{}) *StmtInstance

+ func (si *StmtInstance) QueryRowTx(tx *Tx, ctx context.Context, args ...interface{}) *StmtInstance

+ func (si *StmtInstance) Scan(dest ...interface{}) error

+ func (si *StmtInstance) Tx() *Tx

+ func (si *StmtInstance) ViaTx(tx *Tx) *StmtInstance

+ type StmtLogger interface

+ After func(*StmtInstance)

+ ArgsFormat func(args ...interface{}) string

+ Before func(*StmtInstance)

+ ContextFormat func(ctx context.Context) string

+ type Table struct

+ SQL struct{ ... }

+ func New(ctx context.Context, db *DB, name string, model interface{}) (*Table, error)

+ func NewTable(db *DB, name string, model interface{}) *Table

+ func (t *Table) CheckColumns() error

+ func (t *Table) CheckTableExistance() error

+ func (t *Table) ColTags() string

+ func (t *Table) Count(where string, params ...interface{}) (int, error)

+ func (t *Table) DB() *DB

+ func (t *Table) DoHardDel(where string, args ...interface{}) (sql.Result, error)

+ func (t *Table) DoHardDelTx(tx *Tx, where string, args ...interface{}) (sql.Result, error)

+ func (t *Table) DoHardDelete(id interface{}) error

+ func (t *Table) DoHardDeleteCtx(ctx context.Context, id interface{}) error

+ func (t *Table) DoHardDeleteTx(tx *Tx, id interface{}) error

+ func (t *Table) DoHardDeleteTxCtx(ctx context.Context, tx *Tx, id interface{}) error

+ func (t *Table) DoInsert(row interface{}, returning ...interface{}) error

+ func (t *Table) DoInsertCtx(ctx context.Context, row interface{}, returning ...interface{}) error

+ func (t *Table) DoInsertTx(tx *Tx, row interface{}, returning ...interface{}) error

+ func (t *Table) DoInsertTxCtx(ctx context.Context, tx *Tx, row interface{}, returning ...interface{}) error

+ func (t *Table) DoSelect(where, order string, offset, limit int, f func() error, row interface{}, ...) error

+ func (t *Table) DoSelectByID(id interface{}, row interface{}) error

+ func (t *Table) DoSelectCache(f func() error, row interface{}) error

+ func (t *Table) DoSelectCacheCtx(ctx context.Context, f func() error, row interface{}) error

+ func (t *Table) DoSelectCtx(ctx context.Context, where, order string, offset, limit int, f func() error, ...) error

+ func (t *Table) DoSoftDelete(id interface{}, deletedAt *NullTime, rowVersion *int) error

+ func (t *Table) DoSoftDeleteCtx(ctx context.Context, id interface{}, deletedAt *NullTime, rowVersion *int) error

+ func (t *Table) DoSoftDeleteTx(tx *Tx, id interface{}, deletedAt *NullTime, rowVersion *int) error

+ func (t *Table) DoSoftDeleteTxCtx(ctx context.Context, tx *Tx, id interface{}, deletedAt *NullTime, ...) error

+ func (t *Table) DoUpdate(row interface{}, tags string, rule TagExclusionRule, userID int) error

+ func (t *Table) DoUpdateCtx(ctx context.Context, row interface{}, tags string, rule TagExclusionRule, ...) error

+ func (t *Table) DoUpdateRowVersionCtx(ctx context.Context, id interface{}, updatedAt *NullTime, rowVersion *int) error

+ func (t *Table) DoUpdateRowVersionTx(tx *Tx, id interface{}, updatedAt *NullTime, rowVersion *int) error

+ func (t *Table) DoUpdateRowVersionTxCtx(ctx context.Context, tx *Tx, id interface{}, updatedAt *NullTime, ...) error

+ func (t *Table) DoUpdateTx(tx *Tx, row interface{}, tags string, rule TagExclusionRule, userID int) error

+ func (t *Table) DoUpdateTxCtx(ctx context.Context, tx *Tx, row interface{}, tags string, ...) error

+ func (t *Table) FieldAddrs(model interface{}, tags string, rule TagExclusionRule) []interface{}

+ func (t *Table) FieldAddrsSelect(model interface{}, tags string, rule TagExclusionRule) []interface{}

+ func (t *Table) FieldAddrsUpdate(model interface{}, tags string, rule TagExclusionRule) ([]interface{}, *NullTime, *int)

+ func (t *Table) FieldNames(model interface{}, tags string, rule TagExclusionRule) string

+ func (t *Table) Name() string

+ func (t *Table) SetAudit(b bool)

+ func (t *Table) SetLogger(l *zerolog.Logger)

+ func (t *Table) SnakeIt(fieldName string) string

+ func (t *Table) ValidateRow(row interface{}, mask int) RowValidationResult

+ type TableDesc struct

+ Ref **Table

+ Row interface{}

+ type TagExclusionRule int

+ const All

+ const Exclude

+ const Include

+ func (ter TagExclusionRule) String() string

+ type Tx struct

+ func (tx *Tx) Commit() *Tx

+ func (tx *Tx) Duration() time.Duration

+ func (tx *Tx) Err() error

+ func (tx *Tx) ID() uint64

+ func (tx *Tx) Rollback() *Tx

+ func (tx *Tx) SQLTx() *sql.Tx

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL