db

package module

Go to main page

Versions in this module

v4

v4.5.4

Jun 17, 2022

Changes in this version

type Settings

+ ConnMaxIdleTime func() time.Duration

+ SetConnMaxIdleTime func(time.Duration)

v4.5.3

Jun 17, 2022

v4.5.2

Mar 8, 2022

v4.5.1

Mar 3, 2022

Changes in this version

+ type QueryStatus struct

+ Args []interface{}

+ Context context.Context

+ End time.Time

+ Err error

+ LastInsertID *int64

+ RawQuery string

+ RowsAffected *int64

+ SessID uint64

+ Start time.Time

+ TxID uint64

+ func (q *QueryStatus) Query() string

+ func (q *QueryStatus) Stack() []string

+ func (q *QueryStatus) String() string

v4.5.0

Jan 3, 2022

v4.5.0-rc3

Jan 3, 2022

v4.5.0-rc2

Jan 3, 2022

v4.5.0-rc1

Dec 11, 2021

v4.5.0-alpha.2

Jul 13, 2021

v4.5.0-alpha.1

Jul 13, 2021

v4.2.1

Jul 12, 2021

Changes in this version

type Comparison

+ func AnyOf(value interface{}) *Comparison

+ func NotAnyOf(value interface{}) *Comparison

v4.2.0

Jun 29, 2021

v4.1.0

Jan 9, 2021

v4.0.2

Dec 21, 2020

v4.0.1

Sep 17, 2020

v4.0.0

Aug 27, 2020

Changes in this version

+ var ErrAlreadyWithinTransaction = errors.New(`upper: already within a transaction`)

+ var ErrCollectionDoesNotExist = errors.New(`upper: collection does not exist`)

+ var ErrExpectingNonNilModel = errors.New(`upper: expecting non nil model`)

+ var ErrExpectingPointerToStruct = errors.New(`upper: expecting pointer to struct`)

+ var ErrGivingUpTryingToConnect = errors.New(`upper: giving up trying to connect: too many clients`)

+ var ErrInvalidCollection = errors.New(`upper: invalid collection`)

+ var ErrMissingAdapter = errors.New(`upper: missing adapter`)

+ var ErrMissingCollectionName = errors.New(`upper: missing collection name`)

+ var ErrMissingConditions = errors.New(`upper: missing selector conditions`)

+ var ErrMissingConnURL = errors.New(`upper: missing DSN`)

+ var ErrMissingDatabaseName = errors.New(`upper: missing database name`)

+ var ErrMissingPrimaryKeys = errors.New(`upper: collection has no primary keys`)

+ var ErrNilRecord = errors.New(`upper: invalid item (nil)`)

+ var ErrNoMoreRows = errors.New(`upper: no more rows in this result set`)

+ var ErrNotConnected = errors.New(`upper: not connected to a database`)

+ var ErrNotImplemented = errors.New(`upper: call not implemented`)

+ var ErrNotSupportedByAdapter = errors.New(`upper: not supported by adapter`)

+ var ErrNotWithinTransaction = errors.New(`upper: not within transaction`)

+ var ErrQueryIsPending = errors.New(`upper: can't execute this instruction while the result set is still open`)

+ var ErrQueryLimitParam = errors.New(`upper: a query can accept only one limit parameter`)

+ var ErrQueryOffsetParam = errors.New(`upper: a query can accept only one offset parameter`)

+ var ErrQuerySortParam = errors.New(`upper: a query can accept only one order-by parameter`)

+ var ErrRecordIDIsZero = errors.New(`upper: item ID is not defined`)

+ var ErrSockerOrHost = errors.New(...)

+ var ErrTooManyClients = errors.New(`upper: can't connect to database server: too many clients`)

+ var ErrTransactionAborted = errors.New(`upper: transaction was aborted`)

+ var ErrUndefined = errors.New(`upper: value is undefined`)

+ var ErrUnknownConditionType = errors.New(`upper: arguments of type %T can't be used as constraints`)

+ var ErrUnsupported = errors.New(`upper: action is not supported by the DBMS`)

+ var ErrUnsupportedDestination = errors.New(`upper: unsupported destination type`)

+ var ErrUnsupportedType = errors.New(`upper: type does not support marshaling`)

+ var ErrUnsupportedValue = errors.New(`upper: value does not support unmarshaling`)

+ var ErrWarnSlowQuery = errors.New(`upper: slow query`)

+ func RegisterAdapter(name string, adapter Adapter)

+ type Adapter interface

+ Open func(ConnectionURL) (Session, error)

+ func LookupAdapter(name string) Adapter

+ type AfterCreateHook interface

+ AfterCreate func(Session) error

+ type AfterDeleteHook interface

+ AfterDelete func(Session) error

+ type AfterUpdateHook interface

+ AfterUpdate func(Session) error

+ type AndExpr struct

+ func And(conds ...LogicalExpr) *AndExpr

+ func (a *AndExpr) And(andConds ...LogicalExpr) *AndExpr

+ func (a *AndExpr) Empty() bool

+ type BatchInserter interface

+ Done func()

+ Err func() error

+ NextResult func(dst interface{}) bool

+ Values func(...interface{}) BatchInserter

+ Wait func() error

+ type BeforeCreateHook interface

+ BeforeCreate func(Session) error

+ type BeforeDeleteHook interface

+ BeforeDelete func(Session) error

+ type BeforeUpdateHook interface

+ BeforeUpdate func(Session) error

+ type Collection interface

+ Count func() (uint64, error)

+ Exists func() (bool, error)

+ Find func(...interface{}) Result

+ Insert func(interface{}) (*InsertResult, error)

+ InsertReturning func(interface{}) error

+ Name func() string

+ Session func() Session

+ Truncate func() error

+ UpdateReturning func(interface{}) error

+ type Comparison struct

+ func After(value time.Time) *Comparison

+ func Before(value time.Time) *Comparison

+ func Between(lowerBound interface{}, upperBound interface{}) *Comparison

+ func Eq(value interface{}) *Comparison

+ func Gt(value interface{}) *Comparison

+ func Gte(value interface{}) *Comparison

+ func In(value ...interface{}) *Comparison

+ func Is(value interface{}) *Comparison

+ func IsNot(value interface{}) *Comparison

+ func IsNotNull() *Comparison

+ func IsNull() *Comparison

+ func Like(value string) *Comparison

+ func Lt(value interface{}) *Comparison

+ func Lte(value interface{}) *Comparison

+ func NotBetween(lowerBound interface{}, upperBound interface{}) *Comparison

+ func NotEq(value interface{}) *Comparison

+ func NotIn(value ...interface{}) *Comparison

+ func NotLike(value string) *Comparison

+ func NotRegExp(value string) *Comparison

+ func OnOrAfter(value time.Time) *Comparison

+ func OnOrBefore(value time.Time) *Comparison

+ func Op(customOperator string, value interface{}) *Comparison

+ func RegExp(value string) *Comparison

+ type Cond map[interface{}]interface

+ func (c Cond) Constraints() []adapter.Constraint

+ func (c Cond) Empty() bool

+ func (c Cond) Expressions() []LogicalExpr

+ func (c Cond) Operator() LogicalOperator

+ type ConnectionURL interface

+ String func() string

+ type Deleter interface

+ Amend func(func(queryIn string) (queryOut string)) Deleter

+ And func(conds ...interface{}) Deleter

+ Arguments func() []interface{}

+ Limit func(int) Deleter

+ Where func(...interface{}) Deleter

+ type FuncExpr = adapter.FuncExpr

+ func Func(name string, args ...interface{}) *FuncExpr

+ type HasConstraints interface

+ Constraints func() Cond

+ type ID interface

+ type InsertResult struct

+ func NewInsertResult(id interface{}) *InsertResult

+ func (r *InsertResult) ID() ID

+ func (r InsertResult) Value() (driver.Value, error)

+ type Inserter interface

+ Amend func(func(queryIn string) (queryOut string)) Inserter

+ Arguments func() []interface{}

+ Batch func(size int) BatchInserter

+ Columns func(...string) Inserter

+ Iterator func() Iterator

+ IteratorContext func(ctx context.Context) Iterator

+ Returning func(columns ...string) Inserter

+ Values func(...interface{}) Inserter

+ type Iterator interface

+ Close func() error

+ Err func() error

+ Next func(dest ...interface{}) bool

+ NextScan func(dest ...interface{}) error

+ Scan func(dest ...interface{}) error

+ ScanOne func(dest ...interface{}) error

+ type LogLevel int8

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelFatal

+ const LogLevelInfo

+ const LogLevelPanic

+ const LogLevelTrace

+ const LogLevelWarn

+ func (ll LogLevel) String() string

+ type Logger interface

+ Fatal func(v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Panic func(v ...interface{})

+ Panicf func(format string, v ...interface{})

+ Print func(v ...interface{})

+ Printf func(format string, v ...interface{})

+ type LoggingCollector interface

+ Debug func(v ...interface{})

+ Debugf func(format string, v ...interface{})

+ Enabled func(LogLevel) bool

+ Error func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Fatal func(v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Info func(v ...interface{})

+ Infof func(format string, v ...interface{})

+ Level func() LogLevel

+ Panic func(v ...interface{})

+ Panicf func(format string, v ...interface{})

+ SetLevel func(LogLevel)

+ SetLogger func(Logger)

+ Trace func(v ...interface{})

+ Tracef func(format string, v ...interface{})

+ Warn func(v ...interface{})

+ Warnf func(format string, v ...interface{})

+ func LC() LoggingCollector

+ type LogicalExpr = adapter.LogicalExpr

+ type LogicalOperator = adapter.LogicalOperator

+ type Marshaler interface

+ MarshalDB func() (interface{}, error)

+ type OrExpr struct

+ func Or(conds ...LogicalExpr) *OrExpr

+ func (o *OrExpr) Empty() bool

+ func (o *OrExpr) Or(orConds ...LogicalExpr) *OrExpr

+ type Paginator interface

+ Arguments func() []interface{}

+ Cursor func(cursorColumn string) Paginator

+ Iterator func() Iterator

+ IteratorContext func(ctx context.Context) Iterator

+ NextPage func(cursorValue interface{}) Paginator

+ Page func(uint) Paginator

+ PrevPage func(cursorValue interface{}) Paginator

+ TotalEntries func() (uint64, error)

+ TotalPages func() (uint, error)

+ type RawExpr = adapter.RawExpr

+ func Raw(value string, args ...interface{}) *RawExpr

+ type Record interface

+ Store func(sess Session) Store

+ type Result interface

+ All func(sliceOfStructs interface{}) error

+ And func(...interface{}) Result

+ Close func() error

+ Count func() (uint64, error)

+ Cursor func(cursorColumn string) Result

+ Delete func() error

+ Err func() error

+ Exists func() (bool, error)

+ GroupBy func(...interface{}) Result

+ Limit func(int) Result

+ Next func(ptrToStruct interface{}) bool

+ NextPage func(cursorValue interface{}) Result

+ Offset func(int) Result

+ One func(ptrToStruct interface{}) error

+ OrderBy func(...interface{}) Result

+ Page func(pageNumber uint) Result

+ Paginate func(pageSize uint) Result

+ PrevPage func(cursorValue interface{}) Result

+ Select func(...interface{}) Result

+ String func() string

+ TotalEntries func() (uint64, error)

+ TotalPages func() (uint, error)

+ Update func(interface{}) error

+ type ResultMapper interface

+ All func(destSlice interface{}) error

+ One func(dest interface{}) error

+ type SQL interface

+ DeleteFrom func(table string) Deleter

+ Exec func(query interface{}, args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, query interface{}, args ...interface{}) (sql.Result, error)

+ InsertInto func(table string) Inserter

+ Iterator func(query interface{}, args ...interface{}) Iterator

+ IteratorContext func(ctx context.Context, query interface{}, args ...interface{}) Iterator

+ NewIterator func(rows *sql.Rows) Iterator

+ NewIteratorContext func(ctx context.Context, rows *sql.Rows) Iterator

+ Prepare func(query interface{}) (*sql.Stmt, error)

+ PrepareContext func(ctx context.Context, query interface{}) (*sql.Stmt, error)

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

+ QueryContext func(ctx context.Context, query interface{}, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query interface{}, args ...interface{}) (*sql.Row, error)

+ QueryRowContext func(ctx context.Context, query interface{}, args ...interface{}) (*sql.Row, error)

+ Select func(columns ...interface{}) Selector

+ SelectFrom func(table ...interface{}) Selector

+ Update func(table string) Updater

+ type SQLEngine interface

+ Exec func(string, ...interface{}) (sql.Result, error)

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ Prepare func(string) (*sql.Stmt, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ Query func(string, ...interface{}) (*sql.Rows, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRow func(string, ...interface{}) *sql.Row

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ type SQLExecer interface

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

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

+ type SQLGetter interface

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

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

+ QueryRow func() (*sql.Row, error)

+ QueryRowContext func(ctx context.Context) (*sql.Row, error)

+ type SQLPreparer interface

+ Prepare func() (*sql.Stmt, error)

+ PrepareContext func(context.Context) (*sql.Stmt, error)

+ type Selector interface

+ Amend func(func(queryIn string) (queryOut string)) Selector

+ And func(conds ...interface{}) Selector

+ Arguments func() []interface{}

+ As func(string) Selector

+ Columns func(columns ...interface{}) Selector

+ CrossJoin func(...interface{}) Selector

+ Distinct func(columns ...interface{}) Selector

+ From func(tables ...interface{}) Selector

+ FullJoin func(...interface{}) Selector

+ GroupBy func(columns ...interface{}) Selector

+ Iterator func() Iterator

+ IteratorContext func(ctx context.Context) Iterator

+ Join func(table ...interface{}) Selector

+ LeftJoin func(...interface{}) Selector

+ Limit func(int) Selector

+ Offset func(int) Selector

+ On func(...interface{}) Selector

+ OrderBy func(columns ...interface{}) Selector

+ Paginate func(uint) Paginator

+ RightJoin func(...interface{}) Selector

+ Using func(...interface{}) Selector

+ Where func(conds ...interface{}) Selector

+ type Session interface

+ Close func() error

+ Collection func(name string) Collection

+ Collections func() ([]Collection, error)

+ ConnectionURL func() ConnectionURL

+ Context func() context.Context

+ Delete func(record Record) error

+ Driver func() interface{}

+ Get func(record Record, cond interface{}) error

+ Name func() string

+ Ping func() error

+ Reset func()

+ SQL func() SQL

+ Save func(record Record) error

+ Tx func(fn func(sess Session) error) error

+ TxContext func(ctx context.Context, fn func(sess Session) error, opts *sql.TxOptions) error

+ WithContext func(ctx context.Context) Session

+ func Open(adapterName string, settings ConnectionURL) (Session, error)

+ type Settings interface

+ ConnMaxLifetime func() time.Duration

+ MaxIdleConns func() int

+ MaxOpenConns func() int

+ MaxTransactionRetries func() int

+ PreparedStatementCacheEnabled func() bool

+ SetConnMaxLifetime func(time.Duration)

+ SetMaxIdleConns func(int)

+ SetMaxOpenConns func(int)

+ SetMaxTransactionRetries func(int)

+ SetPreparedStatementCache func(bool)

+ var DefaultSettings Settings = &settings{ ... }

+ func NewSettings() Settings

+ type Store interface

+ type StoreCreator interface

+ Create func(record Record) error

+ type StoreDeleter interface

+ Delete func(record Record) error

+ type StoreGetter interface

+ Get func(record Record, id interface{}) error

+ type StoreSaver interface

+ Save func(record Record) error

+ type StoreUpdater interface

+ Update func(record Record) error

+ type Unmarshaler interface

+ UnmarshalDB func(interface{}) error

+ type Updater interface

+ Amend func(func(queryIn string) (queryOut string)) Updater

+ And func(conds ...interface{}) Updater

+ Arguments func() []interface{}

+ Limit func(int) Updater

+ Set func(...interface{}) Updater

+ Where func(...interface{}) Updater

+ type Validator interface

+ Validate func() error

v4.0.0-rc.1

Aug 27, 2020

v4.0.0-alpha.3

Aug 25, 2020

v4.0.0-alpha.2

Aug 24, 2020

v4.0.0-alpha.1

Jul 15, 2020

Other modules containing this package

github.com/upper/db

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