db

package

Go to main page

Versions in this module

v0

v0.3.7

May 26, 2024

v0.3.6

May 22, 2024

Changes in this version

+ type ValueKey string

+ const ValueKeyNow

+ func (k ValueKey) String(driver SupportedDriver) string

v0.3.5

May 17, 2024

v0.3.4

May 17, 2024

v0.3.3

May 17, 2024

v0.3.2

May 16, 2024

v0.3.1

May 16, 2024

v0.3.0

May 15, 2024

Changes in this version

+ var ErrorRecordAlreadyExists error = NewError(409, "record already exists")

+ var ErrorRecordNotFound error = NewError(404, "record not found")

+ type Error struct

+ Code int

+ Message string

+ func NewError(code int, message string) Error

+ func (e Error) Error() string

+ func (e Error) ErrorCode() int

type Manager

+ func NewNoop() Manager

+ DSN func() string

v0.2.1

Jan 16, 2024

Changes in this version

type Option

+ func WithTelemetry(v telemetry.Manager) Option

+ func WithTelemetryEnabled(v bool) Option

v0.2.0

Jan 16, 2024

v0.1.2

Jan 16, 2024

v0.1.1

Jan 16, 2024

v0.1.0

Jan 15, 2024

v0.0.2

Jan 15, 2024

v0.0.1

Jan 8, 2024

Changes in this version

+ const DefaultLimit

+ const DefaultOffset

+ const DefaultPage

+ var EmptyJsonArray = &JsonArray

+ var EmptyJsonObject = &JsonObject

+ func BuildPlaceholder(count int) string

+ func PlaceholderRepeat(placeholder string, repeat int) []string

+ func ToDriverValueFromStringArray(collection []string) []driver.Value

+ type FilterIn struct

+ Field string

+ Values []interface{}

+ type FilterIns []FilterIn

+ type FilterItem struct

+ Field string

+ Op Operator

+ Value interface{}

+ type FilterItems []FilterItem

+ type Filters struct

+ Ands FilterItems

+ In *FilterIn

+ Ins FilterIns

+ Ors FilterItems

+ func (f *Filters) Build(separator string) (string, []interface{})

+ func (f *Filters) BuildWithWherePrefix(separator string) (string, []interface{})

+ func (f *Filters) FindField(fl string, fb FindBy) Filters

+ type FindBy string

+ const FindByExact

+ const FindByPrefix

+ func (t FindBy) Match(input, target string) bool

+ type IHelper interface

+ BuildSqlAndArgs func() (string, []interface{})

+ BuildSqlAndArgsFilterOnly func() (string, []interface{})

+ BuildSqlAndArgsFilterOnlyWithWherePrefix func() (string, []interface{})

+ BuildSqlAndArgsWithWherePrefix func() (string, []interface{})

+ Filters func() *Filters

+ OrdersBy func() OrdersBy

+ Pagination func() *Pagination

+ func NewHelper(separator Separator, opts ...IHelperOption) IHelper

+ type IHelperOption interface

+ func WithFilters(v Filters) IHelperOption

+ func WithOrderBy(v OrderBy) IHelperOption

+ func WithOrdersBy(v OrdersBy) IHelperOption

+ func WithPagination(page, limit int) IHelperOption

+ type JsonArray struct

+ Valid bool

+ func ToJsonArray(v []interface{}) *JsonArray

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

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

+ type JsonObject struct

+ Valid bool

+ func ToJsonObjectFromInterface(v interface{}) *JsonObject

+ func ToJsonObjectFromMap(v map[string]interface{}) *JsonObject

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

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

+ type Manager interface

+ Begin func(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)

+ Connect func(ctx context.Context) error

+ Driver func() SupportedDriver

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

+ MustBegin func(ctx context.Context, opts *sql.TxOptions) *sqlx.Tx

+ MustConnect func(ctx context.Context) Manager

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

+ NamedExec func(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ NamedQuery func(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)

+ Ping func() error

+ Prepare func(ctx context.Context, query string) (*sqlx.Stmt, error)

+ PrepareNamed func(ctx context.Context, query string) (*sqlx.NamedStmt, error)

+ Query func(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

+ QueryRow func(ctx context.Context, query string, args ...interface{}) *sqlx.Row

+ Rebind func(query string) string

+ SetTelemetry func(tm telemetry.Manager) Manager

+ SqlMock func() sqlmock.Sqlmock

+ func New(driver SupportedDriver, dsn string, telemetryEnabled bool, opts ...Option) Manager

+ func NewWithMock() Manager

+ type NullableTime sql.NullTime

+ func (a *NullableTime) Scan(src interface{}) error

+ func (a *NullableTime) Value() (driver.Value, error)

+ func (a NullableTime) Base() *sql.NullTime

+ func (a NullableTime) From(dt *time.Time) NullableTime

+ func (a NullableTime) GetTime() *time.Time

+ type Operator string

+ const OpEq

+ const OpGt

+ const OpGte

+ const OpLike

+ const OpLt

+ const OpLte

+ const OpNotEq

+ type Option interface

+ func WithMaxIdleConnection(v int) Option

+ func WithMaxOpenConnection(v int) Option

+ func WithOTelConnect(v bool) Option

+ func WithScope(v string) Option

+ type OrderBy struct

+ Field string

+ Sort Sort

+ type OrdersBy []OrderBy

+ func (o OrdersBy) Build() string

+ func (o OrdersBy) BuildWithSpacePrefix() string

+ func (o OrdersBy) FindField(fl string, fb FindBy) OrdersBy

+ type Pagination struct

+ Limit int

+ Page int

+ func (p Pagination) Build() string

+ func (p Pagination) BuildWithSpacePrefix() string

+ type PqArrayOfString pq.StringArray

+ func (a *PqArrayOfString) Scan(src interface{}) error

+ func (a PqArrayOfString) Value() (driver.Value, error)

+ type Separator string

+ const SeparatorAND

+ const SeparatorOR

+ func (s Separator) String() string

+ func (s Separator) StringWithSpace() string

+ type Sort string

+ const SortAsc

+ const SortDesc

+ const SortNone

+ func (t Sort) String() string

+ func (t Sort) Valid() bool

+ type SupportedDriver string

+ const DriverMock

+ const DriverMySQL

+ const DriverPostgreSQL

+ const DriverSqlServer

+ func (d SupportedDriver) String() string

+ func (d SupportedDriver) ToSqlBuilderFlavor() sqlbuilder.Flavor

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