Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

fjord

package module

Go to main page

Versions in this module

v1

v1.0.1

Jun 11, 2017

v1.0.0

Jun 11, 2017

Changes in this version

type Connection

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

type Session

+ func (sess *Session) BeginTx(options *sql.TxOptions) (*Tx, error)

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

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

type Tx

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

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

v0

v0.9.4

Apr 10, 2017

v0.9.3

Apr 10, 2017

v0.9.2

Apr 9, 2017

v0.9.1

Apr 9, 2017

v0.9.0

Apr 9, 2017

Changes in this version

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

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

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

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

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

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

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

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

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

+ var Now = nowSentinel

+ func InterpolateForDialect(query string, value []interface{}, d Dialect) (string, 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 Eq(column string, value interface{}) Builder

+ func Expr(query string, value ...interface{}) 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

+ type Connection struct

+ Dialect Dialect

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

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

+ type DeleteBuilder struct

+ Dialect Dialect

+ LimitCount int64

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

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

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

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

+ type DeleteStmt struct

+ Table string

+ WhereCond []Builder

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

+ func DeleteFrom(table string) *DeleteStmt

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

+ func (b *DeleteStmt) Where(query interface{}, value ...interface{}) *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

+ Placeholder func(n int) string

+ QuoteIdent func(id string) string

+ 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 I string

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

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

+ type InsertBuilder struct

+ Dialect Dialect

+ RecordID reflect.Value

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

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

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

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

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

+ type InsertStmt struct

+ Column []string

+ Table string

+ Value [][]interface{}

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

+ func InsertInto(table string) *InsertStmt

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

+ func (b *InsertStmt) Columns(column ...string) *InsertStmt

+ func (b *InsertStmt) Record(structValue interface{}) *InsertStmt

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

+ type NullBool struct

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

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

+ func (n NullBool) MarshalJSON() ([]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 NewNullFloat64(v interface{}) (n NullFloat64)

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

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

+ type NullInt64 struct

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

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

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

+ type NullString struct

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

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

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

+ type NullTime struct

+ Time time.Time

+ Valid bool

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

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

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

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

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

+ type SelectBuilder struct

+ Dialect Dialect

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

+ func (b *SelectBuilder) From(table interface{}) *SelectBuilder

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

+ func (b *SelectBuilder) GroupBy(col ...string) *SelectBuilder

+ func (b *SelectBuilder) Having(query interface{}, value ...interface{}) *SelectBuilder

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

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

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

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

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

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

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

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

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

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

+ type SelectStmt struct

+ Column []interface{}

+ Group []Builder

+ HavingCond []Builder

+ IsDistinct bool

+ JoinTable []Builder

+ LimitCount int64

+ OffsetCount int64

+ Order []Builder

+ Table interface{}

+ WhereCond []Builder

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

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

+ func (b *SelectStmt) As(alias string) Builder

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

+ func (b *SelectStmt) Distinct() *SelectStmt

+ func (b *SelectStmt) From(table interface{}) *SelectStmt

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

+ func (b *SelectStmt) GroupBy(col ...string) *SelectStmt

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

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

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

+ func (b *SelectStmt) Limit(n uint64) *SelectStmt

+ func (b *SelectStmt) Offset(n uint64) *SelectStmt

+ func (b *SelectStmt) OrderAsc(col string) *SelectStmt

+ func (b *SelectStmt) OrderDesc(col string) *SelectStmt

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

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

+ type Session struct

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

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

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

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

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

+ func (sess *Session) Select(column ...interface{}) *SelectBuilder

+ func (sess *Session) SelectBySql(query string, value ...interface{}) *SelectBuilder

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

+ func (sess *Session) UpdateBySql(query string, value ...interface{}) *UpdateBuilder

+ type SessionRunner interface

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

+ DeleteFrom func(table string) *DeleteBuilder

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

+ InsertInto func(table string) *InsertBuilder

+ Select func(column ...interface{}) *SelectBuilder

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

+ Update func(table string) *UpdateBuilder

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

+ type Tx struct

+ Dialect Dialect

+ func (tx *Tx) Commit() error

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

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

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

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

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) RollbackUnlessCommitted()

+ func (tx *Tx) Select(column ...interface{}) *SelectBuilder

+ func (tx *Tx) SelectBySql(query string, value ...interface{}) *SelectBuilder

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

+ func (tx *Tx) UpdateBySql(query string, value ...interface{}) *UpdateBuilder

+ type UpdateBuilder struct

+ Dialect Dialect

+ LimitCount int64

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

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

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

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

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

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

+ type UpdateStmt struct

+ Table string

+ Value map[string]interface{}

+ WhereCond []Builder

+ func Update(table string) *UpdateStmt

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

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

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

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

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