db

Documentation

Index

• Constants
• 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 Database
  • func OpenDatabase(cfg config.MysqlConfig) (*Database, error)
  • 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 DeleteQuery
  • func (b *DeleteQuery) Exec() (sql.Result, error)
  • func (b *DeleteQuery) Limit(n uint64) *DeleteQuery
  • func (b *DeleteQuery) Where(query interface{}, value ...interface{}) *DeleteQuery
• type EventReceiver
  • 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 InsertQuery
  • func (b *InsertQuery) Columns(columns ...string) *InsertQuery
  • func (b *InsertQuery) Exec() (sql.Result, error)
  • func (b *InsertQuery) Record(structValue interface{}) *InsertQuery
• type SelectQuery
  • func (b *SelectQuery) Count() (count uint32, err error)
  • func (b *SelectQuery) From(table 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 UpdateQuery
  • 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

Constants

const (
	DefaultSelectLimit = 200
)

Functions

func And

func And(cond ...dbr.Builder) dbr.Builder

And creates AND from a list of conditions

func Eq

func Eq(column string, value interface{}) dbr.Builder

Eq is `=`. When value is nil, it will be translated to `IS NULL`. When value is a slice, it will be translated to `IN`. Otherwise it will be translated to `=`.

func GetLimit

func GetLimit(n uint64) uint64

func GetOffset

func GetOffset(n uint64) uint64

func Gt

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

Gt is `>`.

func Gte

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

Gte is '>='.

func Like

func Like(column string, value string) dbr.Builder

func Lt

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

Lt is '<'.

func Lte

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

Lte is `<=`.

func Neq

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

Neq is `!=`. When value is nil, it will be translated to `IS NOT NULL`. When value is a slice, it will be translated to `NOT IN`. Otherwise it will be translated to `!=`.

func Or

func Or(cond ...dbr.Builder) dbr.Builder

Or creates OR from a list of conditions

Types

type Database

type Database struct {
	*dbr.Session
}

func OpenDatabase

func OpenDatabase(cfg config.MysqlConfig) (*Database, error)

func (*Database) DeleteFrom

func (db *Database) DeleteFrom(table string) *DeleteQuery

func (*Database) InsertInto

func (db *Database) InsertInto(table string) *InsertQuery

func (*Database) Select

func (db *Database) Select(columns ...string) *SelectQuery

func (*Database) SelectAll

func (db *Database) SelectAll(columns ...string) *SelectQuery

func (*Database) SelectBySql

func (db *Database) SelectBySql(query string, value ...interface{}) *SelectQuery

func (*Database) Update

func (db *Database) Update(table string) *UpdateQuery

type DeleteQuery

type DeleteQuery struct {
	*dbr.DeleteBuilder
}

func (*DeleteQuery) Exec

func (b *DeleteQuery) Exec() (sql.Result, error)

func (*DeleteQuery) Limit

func (b *DeleteQuery) Limit(n uint64) *DeleteQuery

func (*DeleteQuery) Where

func (b *DeleteQuery) Where(query interface{}, value ...interface{}) *DeleteQuery

type EventReceiver

type EventReceiver struct{}

EventReceiver is a sentinel EventReceiver; use it if the caller doesn't supply one

func (*EventReceiver) Event

func (n *EventReceiver) Event(eventName string)

Event receives a simple notification when various events occur

func (*EventReceiver) EventErr

func (n *EventReceiver) EventErr(eventName string, err error) error

EventErr receives a notification of an error if one occurs

func (*EventReceiver) EventErrKv

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

EventErrKv receives a notification of an error if one occurs along with optional key/value data

func (*EventReceiver) EventKv

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

EventKv receives a notification when various events occur along with optional key/value data

func (*EventReceiver) Timing

func (n *EventReceiver) Timing(eventName string, nanoseconds int64)

Timing receives the time an event took to happen

func (*EventReceiver) TimingKv

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

TimingKv receives the time an event took to happen along with optional key/value data

type InsertQuery

type InsertQuery struct {
	*dbr.InsertBuilder
}

func (*InsertQuery) Columns

func (b *InsertQuery) Columns(columns ...string) *InsertQuery

func (*InsertQuery) Exec

func (b *InsertQuery) Exec() (sql.Result, error)

func (*InsertQuery) Record

func (b *InsertQuery) Record(structValue interface{}) *InsertQuery

type SelectQuery

type SelectQuery struct {
	*dbr.SelectBuilder
}

func (*SelectQuery) Count

func (b *SelectQuery) Count() (count uint32, err error)

func (*SelectQuery) From

func (b *SelectQuery) From(table string) *SelectQuery

func (*SelectQuery) Join

func (b *SelectQuery) Join(table, on interface{}) *SelectQuery

func (*SelectQuery) JoinAs

func (b *SelectQuery) JoinAs(table string, alias string, on interface{}) *SelectQuery

func (*SelectQuery) Limit

func (b *SelectQuery) Limit(n uint64) *SelectQuery

func (*SelectQuery) Load

func (b *SelectQuery) Load(value interface{}) (int, error)

func (*SelectQuery) LoadOne

func (b *SelectQuery) LoadOne(value interface{}) error

func (*SelectQuery) Offset

func (b *SelectQuery) Offset(n uint64) *SelectQuery

func (*SelectQuery) OrderDir

func (b *SelectQuery) OrderDir(col string, isAsc bool) *SelectQuery

func (*SelectQuery) Where

func (b *SelectQuery) Where(query interface{}, value ...interface{}) *SelectQuery

type UpdateQuery

type UpdateQuery struct {
	*dbr.UpdateBuilder
}

func (*UpdateQuery) Exec

func (b *UpdateQuery) Exec() (sql.Result, error)

func (*UpdateQuery) Limit

func (b *UpdateQuery) Limit(n uint64) *UpdateQuery

func (*UpdateQuery) Set

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

func (*UpdateQuery) SetMap

func (b *UpdateQuery) SetMap(m map[string]interface{}) *UpdateQuery

func (*UpdateQuery) Where

func (b *UpdateQuery) Where(query interface{}, value ...interface{}) *UpdateQuery