pg

Dec 11, 2019

Changes in this version

+ type AfterDeleteHook = orm.AfterDeleteHook

+ type AfterInsertHook = orm.AfterInsertHook

+ type AfterScanHook = orm.AfterScanHook

+ type AfterSelectHook = orm.AfterSelectHook

+ type AfterUpdateHook = orm.AfterUpdateHook

+ type BeforeDeleteHook = orm.BeforeDeleteHook

+ type BeforeInsertHook = orm.BeforeInsertHook

+ type BeforeScanHook = orm.BeforeScanHook

+ type BeforeUpdateHook = orm.BeforeUpdateHook

Nov 27, 2019

Changes in this version

+ var ErrTxDone = errors.New("pg: transaction has already been committed or rolled back")

Oct 30, 2019

Changes in this version

+ var Discard orm.Discard

+ var ErrMultiRows = internal.ErrMultiRows

+ var ErrNoRows = internal.ErrNoRows

+ func Array(v interface{}) *types.Array

+ func F(field string) types.ValueAppender

+ func Hstore(v interface{}) *types.Hstore

+ func In(slice interface{}) types.ValueAppender

+ func InMulti(values ...interface{}) types.ValueAppender

+ func Model(model ...interface{}) *orm.Query

+ func ModelContext(c context.Context, model ...interface{}) *orm.Query

+ func Q(query string, params ...interface{}) types.ValueAppender

+ func SafeQuery(query string, params ...interface{}) *orm.SafeQueryAppender

+ func Scan(values ...interface{}) orm.ColumnScanner

+ func SetLogger(logger *log.Logger)

+ type Conn struct

+ func (db *Conn) Context() context.Context

+ func (db *Conn) WithContext(ctx context.Context) *Conn

+ func (db *Conn) WithParam(param string, value interface{}) *Conn

+ func (db *Conn) WithTimeout(d time.Duration) *Conn

+ func (db Conn) AddQueryHook(hook QueryHook)

+ func (db Conn) Begin() (*Tx, error)

+ func (db Conn) Close() error

+ func (db Conn) CopyFrom(r io.Reader, query interface{}, params ...interface{}) (res Result, err error)

+ func (db Conn) CopyTo(w io.Writer, query interface{}, params ...interface{}) (res Result, err error)

+ func (db Conn) CreateComposite(model interface{}, opt *orm.CreateCompositeOptions) error

+ func (db Conn) CreateTable(model interface{}, opt *orm.CreateTableOptions) error

+ func (db Conn) Delete(model interface{}) error

+ func (db Conn) DropComposite(model interface{}, opt *orm.DropCompositeOptions) error

+ func (db Conn) DropTable(model interface{}, opt *orm.DropTableOptions) error

+ func (db Conn) Exec(query interface{}, params ...interface{}) (res Result, err error)

+ func (db Conn) ExecContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) ExecOne(query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) ExecOneContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) ForceDelete(model interface{}) error

+ func (db Conn) Formatter() orm.QueryFormatter

+ func (db Conn) Insert(model ...interface{}) error

+ func (db Conn) Model(model ...interface{}) *orm.Query

+ func (db Conn) ModelContext(c context.Context, model ...interface{}) *orm.Query

+ func (db Conn) Param(param string) interface{}

+ func (db Conn) PoolStats() *PoolStats

+ func (db Conn) Prepare(q string) (*Stmt, error)

+ func (db Conn) Query(model, query interface{}, params ...interface{}) (res Result, err error)

+ func (db Conn) QueryContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) QueryOne(model, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) QueryOneContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) RunInTransaction(fn func(*Tx) error) error

+ func (db Conn) Select(model interface{}) error

+ func (db Conn) Update(model interface{}) error

+ type DB struct

+ func Connect(opt *Options) *DB

+ func (db *DB) Conn() *Conn

+ func (db *DB) Context() context.Context

+ func (db *DB) Listen(channels ...string) *Listener

+ func (db *DB) Options() *Options

+ func (db *DB) String() string

+ func (db *DB) WithContext(ctx context.Context) *DB

+ func (db *DB) WithParam(param string, value interface{}) *DB

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

+ func (db DB) AddQueryHook(hook QueryHook)

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

+ func (db DB) Close() error

+ func (db DB) CopyFrom(r io.Reader, query interface{}, params ...interface{}) (res Result, err error)

+ func (db DB) CopyTo(w io.Writer, query interface{}, params ...interface{}) (res Result, err error)

+ func (db DB) CreateComposite(model interface{}, opt *orm.CreateCompositeOptions) error

+ func (db DB) CreateTable(model interface{}, opt *orm.CreateTableOptions) error

+ func (db DB) Delete(model interface{}) error

+ func (db DB) DropComposite(model interface{}, opt *orm.DropCompositeOptions) error

+ func (db DB) DropTable(model interface{}, opt *orm.DropTableOptions) error

+ func (db DB) Exec(query interface{}, params ...interface{}) (res Result, err error)

+ func (db DB) ExecContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) ExecOne(query interface{}, params ...interface{}) (Result, error)

+ func (db DB) ExecOneContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) ForceDelete(model interface{}) error

+ func (db DB) Formatter() orm.QueryFormatter

+ func (db DB) Insert(model ...interface{}) error

+ func (db DB) Model(model ...interface{}) *orm.Query

+ func (db DB) ModelContext(c context.Context, model ...interface{}) *orm.Query

+ func (db DB) Param(param string) interface{}

+ func (db DB) PoolStats() *PoolStats

+ func (db DB) Prepare(q string) (*Stmt, error)

+ func (db DB) Query(model, query interface{}, params ...interface{}) (res Result, err error)

+ func (db DB) QueryContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) QueryOne(model, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) QueryOneContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) RunInTransaction(fn func(*Tx) error) error

+ func (db DB) Select(model interface{}) error

+ func (db DB) Update(model interface{}) error

+ type Error interface

+ Field func(byte) string

+ IntegrityViolation func() bool

+ type Ident = types.Ident

+ type IntSet map[int64]struct

+ func (IntSet) AddColumnScanner(_ orm.ColumnScanner) error

+ func (set *IntSet) Init() error

+ func (set *IntSet) NextColumnScanner() orm.ColumnScanner

+ func (set *IntSet) ScanColumn(colIdx int, colName string, rd types.Reader, n int) error

+ type Ints []int64

+ func (Ints) AddColumnScanner(_ orm.ColumnScanner) error

+ func (ints *Ints) Init() error

+ func (ints *Ints) NextColumnScanner() orm.ColumnScanner

+ func (ints *Ints) ScanColumn(colIdx int, colName string, rd types.Reader, n int) error

+ func (ints Ints) AppendValue(dst []byte, quote int) ([]byte, error)

+ type Listener struct

+ func (ln *Listener) Channel() <-chan *Notification

+ func (ln *Listener) ChannelSize(size int) <-chan *Notification

+ func (ln *Listener) Close() error

+ func (ln *Listener) Listen(channels ...string) error

+ func (ln *Listener) Receive() (channel string, payload string, err error)

+ func (ln *Listener) ReceiveTimeout(timeout time.Duration) (channel, payload string, err error)

+ func (ln *Listener) String() string

+ type Notification struct

+ Channel string

+ Payload string

+ type NullTime = types.NullTime

+ type Options struct

+ Addr string

+ ApplicationName string

+ Database string

+ DialTimeout time.Duration

+ Dialer func(ctx context.Context, network, addr string) (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxConnAge time.Duration

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ Network string

+ OnConnect func(*Conn) error

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ RetryStatementTimeout bool

+ TLSConfig *tls.Config

+ User string

+ WriteTimeout time.Duration

+ func ParseURL(sURL string) (*Options, error)

+ type PoolStats pool.Stats

+ type QueryEvent struct

+ DB orm.DB

+ Err error

+ Model interface{}

+ Params []interface{}

+ Query interface{}

+ Result Result

+ StartTime time.Time

+ Stash map[interface{}]interface{}

+ func (ev *QueryEvent) FormattedQuery() (string, error)

+ func (ev *QueryEvent) UnformattedQuery() (string, error)

+ type QueryHook interface

+ AfterQuery func(context.Context, *QueryEvent) error

+ BeforeQuery func(context.Context, *QueryEvent) (context.Context, error)

+ type Result = orm.Result

+ type Safe = types.Safe

+ type Stmt struct

+ func (stmt *Stmt) Close() error

+ func (stmt *Stmt) Exec(params ...interface{}) (Result, error)

+ func (stmt *Stmt) ExecContext(c context.Context, params ...interface{}) (Result, error)

+ func (stmt *Stmt) ExecOne(params ...interface{}) (Result, error)

+ func (stmt *Stmt) ExecOneContext(c context.Context, params ...interface{}) (Result, error)

+ func (stmt *Stmt) Query(model interface{}, params ...interface{}) (Result, error)

+ func (stmt *Stmt) QueryContext(c context.Context, model interface{}, params ...interface{}) (Result, error)

+ func (stmt *Stmt) QueryOne(model interface{}, params ...interface{}) (Result, error)

+ func (stmt *Stmt) QueryOneContext(c context.Context, model interface{}, params ...interface{}) (Result, error)

+ type Strings []string

+ func (Strings) AddColumnScanner(_ orm.ColumnScanner) error

+ func (strings *Strings) Init() error

+ func (strings *Strings) NextColumnScanner() orm.ColumnScanner

+ func (strings *Strings) ScanColumn(colIdx int, _ string, rd types.Reader, n int) error

+ func (strings Strings) AppendValue(dst []byte, quote int) ([]byte, error)

+ type Tx struct

+ func (tx *Tx) Begin() (*Tx, error)

+ func (tx *Tx) Close() error

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Context() context.Context

+ func (tx *Tx) CopyFrom(r io.Reader, query interface{}, params ...interface{}) (res Result, err error)

+ func (tx *Tx) CopyTo(w io.Writer, query interface{}, params ...interface{}) (res Result, err error)

+ func (tx *Tx) CreateTable(model interface{}, opt *orm.CreateTableOptions) error

+ func (tx *Tx) Delete(model interface{}) error

+ func (tx *Tx) DropTable(model interface{}, opt *orm.DropTableOptions) error

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

+ func (tx *Tx) ExecContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) ExecOne(query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) ExecOneContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) ForceDelete(model interface{}) error

+ func (tx *Tx) Formatter() orm.QueryFormatter

+ func (tx *Tx) Insert(model ...interface{}) error

+ func (tx *Tx) Model(model ...interface{}) *orm.Query

+ func (tx *Tx) ModelContext(c context.Context, model ...interface{}) *orm.Query

+ func (tx *Tx) Prepare(q string) (*Stmt, error)

+ func (tx *Tx) Query(model interface{}, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) QueryContext(c context.Context, model interface{}, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) QueryOne(model interface{}, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) QueryOneContext(c context.Context, model interface{}, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) RunInTransaction(fn func(*Tx) error) error

+ func (tx *Tx) Select(model interface{}) error

+ func (tx *Tx) Stmt(stmt *Stmt) *Stmt

+ func (tx *Tx) Update(model interface{}) error