database

package

Go to main page

Versions in this module

v1

v1.3.8

Apr 11, 2022

v1.3.7

Apr 11, 2022

v1.3.6

Apr 6, 2022

v1.3.5

Mar 21, 2022

v1.3.4

Mar 21, 2022

v1.3.3

Mar 2, 2022

v1.3.2

Jan 21, 2022

Changes in this version

+ func EqualLogError(assert assertion, theError error, errString string, msgAndArgs ...interface{}) bool

v1.3.1

Jan 17, 2022

Changes in this version

+ func DatabaseToApiError(primary qb.Table, dbError error) error

v1.3.0

Nov 15, 2021

Changes in this version

+ const DefaultMaxTries

type InstanceConfig

+ DeltaLockMaxCycle time.Duration

+ DeltaLockMaxTries int

+ DeltaLockMinimumCycle time.Duration

+ func (config *InstanceConfig) MaxWaitBetweenDeltaLockRetries() time.Duration

+ func (config *InstanceConfig) MinimumWaitBetweenDeltaLockRetries() time.Duration

+ func (config *InstanceConfig) NumberOfDeltaLockTries() int

v1.2.6

Aug 31, 2021

v1.2.5

Aug 31, 2021

v1.2.4

May 22, 2021

Changes in this version

type Database

+ func (db *Database) SelectList(target interface{}, query *qb.SelectQuery, options *ListOptions) errors.TracerError

+ func (db *Database) SelectListTx(tx *sqlx.Tx, target interface{}, query *qb.SelectQuery, options *ListOptions) errors.TracerError

v1.2.3

May 18, 2021

v1.2.2

Mar 17, 2021

Changes in this version

+ type TableNameResult struct

+ TableName string

v1.2.1

Feb 12, 2021

v1.2.0

Feb 9, 2021

Changes in this version

+ const TableExistenceQueryFormat

+ func AcquireDatabaseLock(db *Database, name string, timeout time.Duration) (bool, errors.TracerError)

+ func IsNotFoundError(err error) bool

+ func ReleaseDatabaseLock(db *Database, name string) errors.TracerError

+ func TableExists(db *Database, schema, name string) (bool, error)

+ type CreateTimeResult struct

+ CreateTime string

+ type StatusResult struct

+ Status int

v1.1.10

Dec 15, 2020

v1.1.9

Nov 24, 2020

v1.1.8

Nov 13, 2020

v1.1.7

Nov 13, 2020

v1.1.6

Nov 12, 2020

Changes in this version

type InstanceConfig

+ ConnectRetries int

+ ConnectRetryWait time.Duration

v1.1.5

Nov 12, 2020

Changes in this version

type InstanceConfig

+ func (config *InstanceConfig) WaitBetweenRetries() time.Duration

v1.1.4

Nov 12, 2020

Changes in this version

type Config

+ NumberOfRetries func() int

+ WaitBetweenRetries func() time.Duration

type InstanceConfig

+ func (config *InstanceConfig) NumberOfRetries() int

+ func (config *InstanceConfig) WaitSecondsBetweenRetries() time.Duration

v1.1.3

Oct 21, 2020

Changes in this version

+ type InstanceConfig struct

+ Connection string

+ Dialect string

+ func (config *InstanceConfig) DatabaseConnection() string

+ func (config *InstanceConfig) DatabaseDialect() string

v1.1.2

Oct 16, 2020

v1.1.1

Oct 12, 2020

v1.1.0

Oct 12, 2020

Changes in this version

+ const Delete

+ const Insert

+ const MaxLimit

+ const Select

+ const Update

+ func Bootstrap(db *Database, lines []string, logger log.Logger)

+ func CommitOrRollback(tx *sqlx.Tx, err error) errors.TracerError

+ func Migrate(migrations map[string]string, dbURL string)

+ func NewDataTooLongError(action SQLQueryType, stmt string, err error, logger log.Logger) errors.TracerError

+ func NewDatabaseConnectionError() errors.TracerError

+ func NewDuplicateRecordError(action SQLQueryType, stmt string, err error, logger log.Logger) errors.TracerError

+ func NewExecutionError(action SQLQueryType, stmt string, err error, logger log.Logger) errors.TracerError

+ func NewInvalidForeignKeyError(action SQLQueryType, stmt string, err error, logger log.Logger) errors.TracerError

+ func NewNotAPointerError() errors.TracerError

+ func NewNotFoundError() errors.TracerError

+ func NewSystemError(action SQLQueryType, stmt string, err error, logger log.Logger) errors.TracerError

+ func NewUniqueConstraintError(action SQLQueryType, stmt string, err error, logger log.Logger) errors.TracerError

+ func NewValidationError(msg string, subs ...interface{}) errors.TracerError

+ func Reset(migrations map[string]string, dbURL string)

+ func TranslateError(err error, action SQLQueryType, stmt string, logger log.Logger) errors.TracerError

+ type Bootstrapper interface

+ DB func() *Database

+ FailOnError func(err error)

+ Insert func(record Record) error

+ ReadYaml func(filename string, target interface{})

+ TX func() *sqlx.Tx

+ UpsertQuery func(record Record) string

+ WriteConstants func(filename string, output map[string]map[string]string)

+ WriteSQL func(filename string, output []string)

+ WriteYaml func(filename string, output interface{})

+ func NewBootstrapper(db *Database) Bootstrapper

+ type Config interface

+ DatabaseConnection func() string

+ DatabaseDialect func() string

+ type ConnectionError struct

+ func (err *ConnectionError) Error() string

+ func (err *ConnectionError) Trace() []string

+ type DataTooLongError struct

+ type Database struct

+ Logger log.Logger

+ func Initialize(config Config) *Database

+ func (db *Database) Create(obj Record) errors.TracerError

+ func (db *Database) CreateTx(obj Record, tx *sqlx.Tx) errors.TracerError

+ func (db *Database) Delete(obj Record) errors.TracerError

+ func (db *Database) DeleteTx(obj Record, tx *sqlx.Tx) errors.TracerError

+ func (db *Database) DeleteWhere(obj Record, where *qb.ConditionExpression) errors.TracerError

+ func (db *Database) DeleteWhereTx(obj Record, tx *sqlx.Tx, condition *qb.ConditionExpression) errors.TracerError

+ func (db *Database) List(def Record, obj interface{}, options *ListOptions) errors.TracerError

+ func (db *Database) ListWhere(def Record, target interface{}, condition *qb.ConditionExpression) errors.TracerError

+ func (db *Database) ListWhereTx(tx *sqlx.Tx, def Record, obj interface{}, where *qb.ConditionExpression) errors.TracerError

+ func (db *Database) Read(obj Record, pk PrimaryKeyValue) errors.TracerError

+ func (db *Database) ReadOneWhere(obj Record, condition *qb.ConditionExpression) errors.TracerError

+ func (db *Database) ReadOneWhereTx(obj Record, tx *sqlx.Tx, condition *qb.ConditionExpression) errors.TracerError

+ func (db *Database) ReadTx(obj Record, pk PrimaryKeyValue, tx *sqlx.Tx) errors.TracerError

+ func (db *Database) Select(target interface{}, query *qb.SelectQuery) errors.TracerError

+ func (db *Database) SelectTx(tx *sqlx.Tx, target interface{}, query *qb.SelectQuery) errors.TracerError

+ func (db *Database) Update(obj Record) errors.TracerError

+ func (db *Database) UpdateTx(obj Record, tx *sqlx.Tx) errors.TracerError

+ func (db *Database) UpsertTx(obj Record, tx *sqlx.Tx) errors.TracerError

+ type DefaultRecord struct

+ func (record *DefaultRecord) Key() string

+ type DuplicateRecordError struct

+ type InvalidForeignKeyError struct

+ type ListOptions struct

+ Limit uint

+ Offset uint

+ func NewListOptions(limit uint, offset uint) *ListOptions

+ type Model struct

+ Name string

+ PrimaryKey string

+ ReadColumns []string

+ WriteColumns []string

+ type NotAPointerError struct

+ func (err *NotAPointerError) Error() string

+ func (err *NotAPointerError) Trace() []string

+ type NotFoundError struct

+ func (e *NotFoundError) Error() string

+ func (e *NotFoundError) Trace() []string

+ type PrimaryKeyValue struct

+ func NewPrimaryKey(value interface{}) (pk PrimaryKeyValue)

+ func (pk PrimaryKeyValue) Value() interface{}

+ type Record interface

+ Initialize func()

+ Key func() string

+ Meta func() qb.Table

+ PrimaryKey func() PrimaryKeyValue

+ type SQLExecutionError struct

+ Action SQLQueryType

+ ErrMsg string

+ ReferenceID string

+ Stmt string

+ func (e *SQLExecutionError) Error() string

+ func (e *SQLExecutionError) Trace() []string

+ type SQLQueryType string

+ type SQLSystemError struct

+ type UniqueConstraintError struct

+ type ValidationError struct

+ func (e *ValidationError) Error() string

+ func (e *ValidationError) Trace() []string

Other modules containing this package

github.com/beaconsoftwarellc/gadget/v2

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