dbr

package module

Go to main page

Versions in this module

v1

v1.2.0

May 25, 2023

Changes in this version

+ var ErrCantConvertToTime = errors.New("dbr: can't convert to time.Time")

+ var ErrColumnNotSpecified = errors.New("dbr: column not specified")

+ var ErrInvalidPointer = errors.New("dbr: attempt to load into an invalid pointer")

+ var ErrInvalidTimestring = errors.New("dbr: invalid time string")

+ var ErrNotSupported = errors.New("dbr: not supported")

+ var ErrPlaceholderCount = errors.New("dbr: wrong placeholder count")

+ var ErrPrewhereNotSupported = errors.New("dbr: PREWHERE statement is not supported")

+ var ErrTableNotSpecified = errors.New("dbr: table not specified")

+ func InterpolateForDialect(query string, value []interface{}, d Dialect) (string, error)

+ func Load(rows *sql.Rows, value interface{}) (int, error)

+ func Union(builder ...Builder) interface

+ func UnionAll(builder ...Builder) interface

+ type Buffer interface

+ String func() string

+ Value func() []interface{}

+ WriteString func(s string) (n int, err error)

+ WriteValue func(v ...interface{}) (err error)

+ func NewBuffer() Buffer

+ type BuildFunc func(Dialect, Buffer) error

+ func (b BuildFunc) Build(d Dialect, buf Buffer) error

+ type Builder interface

+ Build func(Dialect, Buffer) error

+ func And(cond ...Builder) Builder

+ func Gt(column string, value interface{}) Builder

+ func Gte(column string, value interface{}) Builder

+ func Lt(column string, value interface{}) Builder

+ func Lte(column string, value interface{}) Builder

+ func Neq(column string, value interface{}) Builder

+ func Or(cond ...Builder) Builder

+ func Proposed(column string) Builder

+ type ConflictStmt interface

+ Action func(column string, action interface{}) ConflictStmt

type Connection

+ Dialect Dialect

+ func Open(driver, dsn string, log EventReceiver) (*Connection, error)

+ func (conn *Connection) NewSessionContext(ctx context.Context, log EventReceiver) *Session

+ type DeleteStmt interface

+ Where func(query interface{}, value ...interface{}) DeleteStmt

+ func DeleteBySql(query string, value ...interface{}) DeleteStmt

+ func DeleteFrom(table string) DeleteStmt

+ type Dialect interface

+ EncodeBool func(b bool) string

+ EncodeBytes func(b []byte) string

+ EncodeString func(s string) string

+ EncodeTime func(t time.Time) string

+ Limit func(offset, limit int64) string

+ OnConflict func(constraint string) string

+ Placeholder func(n int) string

+ Prewhere func() string

+ Proposed func(column string) string

+ QuoteIdent func(id string) string

+ type Executer interface

+ Exec func() (sql.Result, error)

+ ExecContext func(ctx context.Context) (sql.Result, error)

+ type I string

+ func (i I) As(alias string) Builder

+ func (i I) Build(d Dialect, buf Buffer) error

type InsertBuilder

+ OnConflict func(constraint string) ConflictStmt

+ OnConflictMap func(constraint string, actions map[string]interface{}) InsertBuilder

+ type InsertStmt interface

+ Columns func(column ...string) InsertStmt

+ OnConflict func(constraint string) ConflictStmt

+ OnConflictMap func(constraint string, actions map[string]interface{}) InsertStmt

+ Record func(structValue interface{}) InsertStmt

+ Values func(value ...interface{}) InsertStmt

+ func InsertBySql(query string, value ...interface{}) InsertStmt

+ func InsertInto(table string) InsertStmt

type NullBool

+ func NewNullBool(v interface{}) (n NullBool)

type NullFloat64

+ func NewNullFloat64(v interface{}) (n NullFloat64)

type NullInt64

+ func NewNullInt64(v interface{}) (n NullInt64)

type NullString

+ func NewNullString(v interface{}) (n NullString)

type NullTime

+ Time time.Time

+ Valid bool

+ func NewNullTime(v interface{}) (n NullTime)

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

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

type SelectBuilder

+ As func(alias string) Builder

+ Comment func(text string) SelectBuilder

+ ForUpdate func() SelectBuilder

+ FullJoin func(table, on interface{}) SelectBuilder

+ GetRows func() (*sql.Rows, error)

+ GetRowsContext func(context.Context) (*sql.Rows, error)

+ InTimezone func(loc *time.Location) SelectBuilder

+ Join func(table, on interface{}) SelectBuilder

+ LeftJoin func(table, on interface{}) SelectBuilder

+ OrderAsc func(col string) SelectBuilder

+ OrderDesc func(col string) SelectBuilder

+ Prewhere func(query interface{}, value ...interface{}) SelectBuilder

+ RightJoin func(table, on interface{}) SelectBuilder

+ SkipLocked func() SelectBuilder

+ type SelectStmt interface

+ AddComment func(text string) SelectStmt

+ As func(alias string) Builder

+ Distinct func() SelectStmt

+ ForUpdate func() SelectStmt

+ From func(table interface{}) SelectStmt

+ FullJoin func(table, on interface{}) SelectStmt

+ GroupBy func(col ...string) SelectStmt

+ Having func(query interface{}, value ...interface{}) SelectStmt

+ Join func(table, on interface{}) SelectStmt

+ LeftJoin func(table, on interface{}) SelectStmt

+ Limit func(n uint64) SelectStmt

+ Offset func(n uint64) SelectStmt

+ OrderAsc func(col string) SelectStmt

+ OrderDesc func(col string) SelectStmt

+ Prewhere func(query interface{}, value ...interface{}) SelectStmt

+ RightJoin func(table, on interface{}) SelectStmt

+ SkipLocked func() SelectStmt

+ Where func(query interface{}, value ...interface{}) SelectStmt

+ func Select(column ...interface{}) SelectStmt

+ func SelectBySql(query string, value ...interface{}) SelectStmt

type Session

+ func (sess *Session) BeginWithOpts(opts *sql.TxOptions) (*Tx, error)

+ func (sess *Session) DeleteBySql(query string, value ...interface{}) DeleteBuilder

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

+ func (sess *Session) InsertBySql(query string, value ...interface{}) InsertBuilder

+ func (sess *Session) NewSession(log EventReceiver) *Session

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

type SessionRunner

+ DeleteBySql func(query string, value ...interface{}) DeleteBuilder

+ InsertBySql func(query string, value ...interface{}) InsertBuilder

+ type TracingEventReceiver interface

+ SpanError func(ctx context.Context, err error)

+ SpanFinish func(ctx context.Context)

+ SpanStart func(ctx context.Context, eventName, query string) context.Context

type Tx

+ Dialect Dialect

+ func (tx *Tx) DeleteBySql(query string, value ...interface{}) DeleteBuilder

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

+ func (tx *Tx) InsertBySql(query string, value ...interface{}) InsertBuilder

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

+ type UpdateStmt interface

+ Set func(column string, value interface{}) UpdateStmt

+ SetMap func(m map[string]interface{}) UpdateStmt

+ SetRecord func(structValue interface{}) UpdateStmt

+ Where func(query interface{}, value ...interface{}) UpdateStmt

+ func Update(table string) UpdateStmt

+ func UpdateBySql(query string, value ...interface{}) UpdateStmt

v1.1.0

Jun 21, 2015

Changes in this version

+ var ErrArgumentMismatch = errors.New("mismatch between ? (placeholders) and arguments")

+ var ErrInvalidSliceLength = errors.New("length of slice is 0. length must be >= 1")

+ var ErrInvalidSliceValue = errors.New("trying to interpolate invalid slice value into query")

+ var ErrInvalidValue = errors.New("trying to interpolate invalid value into query")

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

+ var ErrNotUTF8 = errors.New("invalid UTF-8")

+ var NameMapping = camelCaseToSnakeCase

+ var Now = nowSentinel

+ var Quoter = MysqlQuoter

+ func Expr(sql string, values ...interface{}) *expr

+ func Interpolate(sql string, vals []interface{}) (string, error)

+ type Connection struct

+ Db *sql.DB

+ func NewConnection(db *sql.DB, log EventReceiver) *Connection

+ func (cxn *Connection) NewSession(log EventReceiver) *Session

+ type DeleteBuilder struct

+ From string

+ LimitCount uint64

+ LimitValid bool

+ OffsetCount uint64

+ OffsetValid bool

+ OrderBys []string

+ WhereFragments []*whereFragment

+ func (b *DeleteBuilder) Exec() (sql.Result, error)

+ func (b *DeleteBuilder) Limit(limit uint64) *DeleteBuilder

+ func (b *DeleteBuilder) Offset(offset uint64) *DeleteBuilder

+ func (b *DeleteBuilder) OrderBy(ord string) *DeleteBuilder

+ func (b *DeleteBuilder) OrderDir(ord string, isAsc bool) *DeleteBuilder

+ func (b *DeleteBuilder) ToSql() (string, []interface{})

+ func (b *DeleteBuilder) Where(whereSqlOrMap interface{}, args ...interface{}) *DeleteBuilder

+ type Eq map[string]interface

+ type EventReceiver interface

+ Event func(eventName string)

+ EventErr func(eventName string, err error) error

+ EventErrKv func(eventName string, err error, kvs map[string]string) error

+ EventKv func(eventName string, kvs map[string]string)

+ Timing func(eventName string, nanoseconds int64)

+ TimingKv func(eventName string, nanoseconds int64, kvs map[string]string)

+ type InsertBuilder struct

+ Cols []string

+ Into string

+ Recs []interface{}

+ Vals [][]interface{}

+ func (b *InsertBuilder) Columns(columns ...string) *InsertBuilder

+ func (b *InsertBuilder) Exec() (sql.Result, error)

+ func (b *InsertBuilder) Pair(column string, value interface{}) *InsertBuilder

+ func (b *InsertBuilder) Record(record interface{}) *InsertBuilder

+ func (b *InsertBuilder) ToSql() (string, []interface{})

+ func (b *InsertBuilder) Values(vals ...interface{}) *InsertBuilder

+ type MysqlQuoter struct

+ type NullBool struct

+ func (n *NullBool) MarshalJSON() ([]byte, error)

+ func (n *NullBool) UnmarshalJSON(b []byte) error

+ type NullEventReceiver struct

+ func (n *NullEventReceiver) Event(eventName string)

+ func (n *NullEventReceiver) EventErr(eventName string, err error) error

+ func (n *NullEventReceiver) EventErrKv(eventName string, err error, kvs map[string]string) error

+ func (n *NullEventReceiver) EventKv(eventName string, kvs map[string]string)

+ func (n *NullEventReceiver) Timing(eventName string, nanoseconds int64)

+ func (n *NullEventReceiver) TimingKv(eventName string, nanoseconds int64, kvs map[string]string)

+ type NullFloat64 struct

+ func (n *NullFloat64) MarshalJSON() ([]byte, error)

+ func (n *NullFloat64) UnmarshalJSON(b []byte) error

+ type NullInt64 struct

+ func (n *NullInt64) MarshalJSON() ([]byte, error)

+ func (n *NullInt64) UnmarshalJSON(b []byte) error

+ type NullString struct

+ func (n *NullString) MarshalJSON() ([]byte, error)

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

+ type NullTime struct

+ func (n *NullTime) MarshalJSON() ([]byte, error)

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

+ type SelectBuilder struct

+ Columns []string

+ FromTable string

+ GroupBys []string

+ HavingFragments []*whereFragment

+ IsDistinct bool

+ LimitCount uint64

+ LimitValid bool

+ OffsetCount uint64

+ OffsetValid bool

+ OrderBys []string

+ RawArguments []interface{}

+ RawFullSql string

+ WhereFragments []*whereFragment

+ func (b *SelectBuilder) Distinct() *SelectBuilder

+ func (b *SelectBuilder) From(from string) *SelectBuilder

+ func (b *SelectBuilder) GroupBy(group string) *SelectBuilder

+ func (b *SelectBuilder) Having(whereSqlOrMap interface{}, args ...interface{}) *SelectBuilder

+ func (b *SelectBuilder) Limit(limit uint64) *SelectBuilder

+ func (b *SelectBuilder) LoadStruct(dest interface{}) error

+ func (b *SelectBuilder) LoadStructs(dest interface{}) (int, error)

+ func (b *SelectBuilder) LoadValue(dest interface{}) error

+ func (b *SelectBuilder) LoadValues(dest interface{}) (int, error)

+ func (b *SelectBuilder) Offset(offset uint64) *SelectBuilder

+ func (b *SelectBuilder) OrderBy(ord string) *SelectBuilder

+ func (b *SelectBuilder) OrderDir(ord string, isAsc bool) *SelectBuilder

+ func (b *SelectBuilder) Paginate(page, perPage uint64) *SelectBuilder

+ func (b *SelectBuilder) ReturnInt64() (int64, error)

+ func (b *SelectBuilder) ReturnInt64s() ([]int64, error)

+ func (b *SelectBuilder) ReturnString() (string, error)

+ func (b *SelectBuilder) ReturnStrings() ([]string, error)

+ func (b *SelectBuilder) ReturnUint64() (uint64, error)

+ func (b *SelectBuilder) ReturnUint64s() ([]uint64, error)

+ func (b *SelectBuilder) ToSql() (string, []interface{})

+ func (b *SelectBuilder) Where(whereSqlOrMap interface{}, args ...interface{}) *SelectBuilder

+ type Session struct

+ func (sess *Session) Begin() (*Tx, error)

+ func (sess *Session) DeleteFrom(from string) *DeleteBuilder

+ func (sess *Session) InsertInto(into string) *InsertBuilder

+ func (sess *Session) Select(cols ...string) *SelectBuilder

+ func (sess *Session) SelectBySql(sql string, args ...interface{}) *SelectBuilder

+ func (sess *Session) Update(table string) *UpdateBuilder

+ func (sess *Session) UpdateBySql(sql string, args ...interface{}) *UpdateBuilder

+ type SessionRunner interface

+ DeleteFrom func(from string) *DeleteBuilder

+ InsertInto func(into string) *InsertBuilder

+ Select func(cols ...string) *SelectBuilder

+ SelectBySql func(sql string, args ...interface{}) *SelectBuilder

+ Update func(table string) *UpdateBuilder

+ UpdateBySql func(sql string, args ...interface{}) *UpdateBuilder

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) DeleteFrom(from string) *DeleteBuilder

+ func (tx *Tx) InsertInto(into string) *InsertBuilder

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) RollbackUnlessCommitted()

+ func (tx *Tx) Select(cols ...string) *SelectBuilder

+ func (tx *Tx) SelectBySql(sql string, args ...interface{}) *SelectBuilder

+ func (tx *Tx) Update(table string) *UpdateBuilder

+ func (tx *Tx) UpdateBySql(sql string, args ...interface{}) *UpdateBuilder

+ type UpdateBuilder struct

+ LimitCount uint64

+ LimitValid bool

+ OffsetCount uint64

+ OffsetValid bool

+ OrderBys []string

+ RawArguments []interface{}

+ RawFullSql string

+ SetClauses []*setClause

+ Table string

+ WhereFragments []*whereFragment

+ func (b *UpdateBuilder) Exec() (sql.Result, error)

+ func (b *UpdateBuilder) Limit(limit uint64) *UpdateBuilder

+ func (b *UpdateBuilder) Offset(offset uint64) *UpdateBuilder

+ func (b *UpdateBuilder) OrderBy(ord string) *UpdateBuilder

+ func (b *UpdateBuilder) OrderDir(ord string, isAsc bool) *UpdateBuilder

+ func (b *UpdateBuilder) Set(column string, value interface{}) *UpdateBuilder

+ func (b *UpdateBuilder) SetMap(clauses map[string]interface{}) *UpdateBuilder

+ func (b *UpdateBuilder) ToSql() (string, []interface{})

+ func (b *UpdateBuilder) Where(whereSqlOrMap interface{}, args ...interface{}) *UpdateBuilder

Incompatible versions in this module

v3.0.0+incompatible

Apr 5, 2018

v2.1.0+incompatible

Aug 2, 2016

v2.0.0+incompatible

Sep 19, 2015

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