Versions in this module Expand all Collapse all v0 v0.0.310 Jun 15, 2022 Changes in this version + const DefaultSelectLimit + var ErrCantConvertToTime = dbr.ErrCantConvertToTime + var ErrColumnNotSpecified = dbr.ErrColumnNotSpecified + var ErrInvalidPointer = dbr.ErrInvalidPointer + var ErrInvalidSliceLength = dbr.ErrInvalidSliceLength + var ErrInvalidTimestring = dbr.ErrInvalidTimestring + var ErrNotFound = dbr.ErrNotFound + var ErrNotSupported = dbr.ErrNotSupported + var ErrPlaceholderCount = dbr.ErrPlaceholderCount + var ErrTableNotSpecified = dbr.ErrTableNotSpecified + func And(cond ...dbr.Builder) dbr.Builder + func Eq(column string, value interface{}) dbr.Builder + func GetLimit(n uint64) uint64 + func GetOffset(n uint64) uint64 + func Gt(column string, value interface{}) dbr.Builder + func Gte(column string, value interface{}) dbr.Builder + func Like(column string, value string) dbr.Builder + func Lt(column string, value interface{}) dbr.Builder + func Lte(column string, value interface{}) dbr.Builder + func Neq(column string, value interface{}) dbr.Builder + func Or(cond ...dbr.Builder) dbr.Builder + type Client struct + func NewMySQLClient(options *Options, stopCh <-chan struct{}) (*Client, error) + func NewMySQLClientOrDie(options *Options, stopCh <-chan struct{}) *Client + func (m *Client) Database() *Database + type Database struct + DeleteHook DeleteHook + InsertHook InsertHook + UpdateHook UpdateHook + func (db *Database) DeleteFrom(table string) *DeleteQuery + func (db *Database) InsertInto(table string) *InsertQuery + func (db *Database) Select(columns ...string) *SelectQuery + func (db *Database) SelectAll(columns ...string) *SelectQuery + func (db *Database) SelectBySql(query string, value ...interface{}) *SelectQuery + func (db *Database) Update(table string) *UpdateQuery + type DeleteHook func(query *DeleteQuery) + type DeleteQuery struct + Hook DeleteHook + func (b *DeleteQuery) Exec() (sql.Result, error) + func (b *DeleteQuery) Limit(n uint64) *DeleteQuery + func (b *DeleteQuery) Where(query interface{}, value ...interface{}) *DeleteQuery + type EqCondition struct + Column string + Value interface{} + type EventReceiver struct + func (n *EventReceiver) Event(eventName string) + func (n *EventReceiver) EventErr(eventName string, err error) error + func (n *EventReceiver) EventErrKv(eventName string, err error, kvs map[string]string) error + func (n *EventReceiver) EventKv(eventName string, kvs map[string]string) + func (n *EventReceiver) Timing(eventName string, nanoseconds int64) + func (n *EventReceiver) TimingKv(eventName string, nanoseconds int64, kvs map[string]string) + type InsertHook func(query *InsertQuery) + type InsertQuery struct + Hook InsertHook + func (b *InsertQuery) Columns(columns ...string) *InsertQuery + func (b *InsertQuery) Exec() (sql.Result, error) + func (b *InsertQuery) Record(structValue interface{}) *InsertQuery + type Options struct + Host string + MaxConnectionLifeTime time.Duration + MaxIdleConnections int + MaxOpenConnections int + Password string + Username string + func NewMySQLOptions() *Options + func (m *Options) AddFlags(fs *pflag.FlagSet, c *Options) + func (m *Options) ApplyTo(options *Options) + func (m *Options) Validate() []error + type SelectQuery struct + JoinCount int + func (b *SelectQuery) Count() (count uint32, err error) + func (b *SelectQuery) Distinct() *SelectQuery + func (b *SelectQuery) From(table string) *SelectQuery + func (b *SelectQuery) GroupBy(col ...string) *SelectQuery + func (b *SelectQuery) Join(table, on interface{}) *SelectQuery + func (b *SelectQuery) JoinAs(table string, alias string, on interface{}) *SelectQuery + func (b *SelectQuery) Limit(n uint64) *SelectQuery + func (b *SelectQuery) Load(value interface{}) (int, error) + func (b *SelectQuery) LoadOne(value interface{}) error + func (b *SelectQuery) Offset(n uint64) *SelectQuery + func (b *SelectQuery) OrderDir(col string, isAsc bool) *SelectQuery + func (b *SelectQuery) Where(query interface{}, value ...interface{}) *SelectQuery + type UpdateHook func(query *UpdateQuery) + type UpdateQuery struct + Hook UpdateHook + func (b *UpdateQuery) Exec() (sql.Result, error) + func (b *UpdateQuery) Limit(n uint64) *UpdateQuery + func (b *UpdateQuery) Set(column string, value interface{}) *UpdateQuery + func (b *UpdateQuery) SetMap(m map[string]interface{}) *UpdateQuery + func (b *UpdateQuery) Where(query interface{}, value ...interface{}) *UpdateQuery + type UpsertQuery struct