xdb

Jun 5, 2024

Changes in this version

+ func ExecuteQueryWithPagination[T any, TPointer RowPointer[T]](ctx context.Context, sql DB, res Result[T, TPointer], query string, ...) error

+ func ExecuteQuery[T any, TPointer RowPointer[T]](ctx context.Context, sql DB, res Result[T, TPointer], query string, ...) error

+ func PageParam(p any) uint32

+ type HasQueryParams interface

+ QueryParams func() QueryParams

+ type Pageable interface

+ Page func() (limit uint32, offset uint32)

+ type QueryParams interface

+ Args func() []any

+ GetEnum func(pos uint32) (int32, bool)

+ GetFlags func() []int32

+ IsSet func(pos uint32) bool

+ Name func() string

+ func GetQueryParams(args ...any) QueryParams

+ type QueryParamsBuilder struct

+ func NewQueryParams(queryName string) *QueryParamsBuilder

+ func (b *QueryParamsBuilder) AddArgs(v ...any)

+ func (b *QueryParamsBuilder) Args() []any

+ func (b *QueryParamsBuilder) GetEnum(pos uint32) (int32, bool)

+ func (b *QueryParamsBuilder) GetFlags() []int32

+ func (b *QueryParamsBuilder) IsSet(pos uint32) bool

+ func (b *QueryParamsBuilder) Name() string

+ func (b *QueryParamsBuilder) Page() (limit uint32, offset uint32)

+ func (b *QueryParamsBuilder) Reset()

+ func (b *QueryParamsBuilder) Set(pos uint32, v any)

+ func (b *QueryParamsBuilder) SetEnum(pos uint32, v int32)

+ func (b *QueryParamsBuilder) SetFlags(v ...int32)

+ func (b *QueryParamsBuilder) SetPage(limit, offset uint32)

type Result

+ SetResult func(rows []TPointer, nextOffset uint32, hasNextPage bool)

May 16, 2024

Changes in this version

type Bool

+ func (v Bool) Bool() bool

type Float

+ func (v Float) Float() float64

type Int32

+ func (v Int32) Int32() int32

+ func (v Int32) Int64() int64

type Int64

+ func (v Int64) Int64() int64

Apr 2, 2024

Changes in this version

type IDArray

+ func NewIDArray(vals []uint64) IDArray

+ func (n IDArray) Add(id ID) IDArray

+ func (n IDArray) Concat(other IDArray) IDArray

+ func (n IDArray) List() []uint64

type Metadata

+ func (n *Metadata) Merge(m Metadata) *Metadata

type NULLString

+ func (ns NULLString) String() string

type UUID

+ func (ns UUID) String() string

Dec 22, 2023

Changes in this version

+ type UUID string

+ func (ns *UUID) Scan(value any) error

+ func (ns UUID) Value() (driver.Value, error)

Nov 30, 2023

Changes in this version

+ type Int64 int64

+ func (v *Int64) Scan(value any) error

+ func (v *Int64) UnmarshalJSON(data []byte) error

+ func (v Int64) MarshalJSON() ([]byte, error)

+ func (v Int64) String() string

+ func (v Int64) Value() (driver.Value, error)

Nov 26, 2023

Changes in this version

+ var DefaultTimeFormat = "2006-01-02T15:04:05.999Z07:00"

+ var DefaultTrucate = time.Microsecond

+ type Bool bool

+ func (v *Bool) Scan(value any) error

+ func (v *Bool) UnmarshalJSON(data []byte) error

+ func (v Bool) MarshalJSON() ([]byte, error)

+ func (v Bool) String() string

+ func (v Bool) Value() (driver.Value, error)

+ type Float float64

+ func (v *Float) Scan(value any) error

+ func (v *Float) UnmarshalJSON(data []byte) error

+ func (v Float) MarshalJSON() ([]byte, error)

+ func (v Float) String() string

+ func (v Float) Value() (driver.Value, error)

type ID

+ func TryParseID(val string) ID

+ type ID32 uint32

+ func (v *ID32) Scan(value any) error

+ func (v *ID32) UnmarshalJSON(data []byte) error

+ func (v ID32) MarshalJSON() ([]byte, error)

+ func (v ID32) String() string

+ func (v ID32) Value() (driver.Value, error)

+ type Int32 int32

+ func (v *Int32) Scan(value any) error

+ func (v *Int32) UnmarshalJSON(data []byte) error

+ func (v Int32) MarshalJSON() ([]byte, error)

+ func (v Int32) String() string

+ func (v Int32) Value() (driver.Value, error)

Nov 21, 2023

Changes in this version

+ func ExecuteListQuery[T any, TPointer RowPointer[T]](ctx context.Context, sql DB, query string, args ...any) ([]TPointer, error)

type Result

+ func (p *Result[T, RowPointer]) Execute(ctx context.Context, sql DB, query string, args ...any) error

Nov 18, 2023

Changes in this version

+ func QueryRow[T any, TPointer RowPointer[T]](ctx context.Context, sql DB, query string, args ...any) (TPointer, error)

type Provider

+ Name func() string

type Result

+ Limit uint32

type SQLProvider

+ func (p *SQLProvider) Name() string

Nov 17, 2023

Changes in this version

+ const DefaultPageSize

+ var MergeOpts = mergo.WithTransformers(transformers{})

+ func Merge(dst any, src any) error

Oct 30, 2023

Changes in this version

+ type Source struct

+ Database string

+ Driver string

+ Host string

+ Params map[string]string

+ Password string

+ Source string

+ User string

+ func ParseConnectionString(dataSourceName, driver string) (*Source, error)

type TableInfo

+ func (t *TableInfo) AliasedColumns(prefix string, nulls map[string]bool) string

+ func (t *TableInfo) AllColumns() string

Oct 22, 2023

Changes in this version

type IDGenerator

+ IDTime func(id uint64) time.Time

type SQLProvider

+ func (p *SQLProvider) Commit() error

+ func (p *SQLProvider) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

+ func (p *SQLProvider) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ func (p *SQLProvider) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

+ func (p *SQLProvider) Rollback() error

Oct 19, 2023

Changes in this version

+ const MaxLenForEmail

+ const MaxLenForName

+ const MaxLenForShortURL

+ func IDString(id uint64) string

+ func IsNotFoundError(err error) bool

+ func NullTime(val *time.Time) sql.NullTime

+ func Open(driverName string, dataSourceName, database string) (*sql.DB, string, error)

+ func ParseUint(id string) (uint64, error)

+ func RunListQuery(ctx context.Context, sql DB, take uint32, query string, args ...any) ([]TPointer, error)

+ func RunListQueryWithOffset(ctx context.Context, sql DB, offset, take uint32, query string, args ...any) ([]TPointer, uint32, error)

+ func String(val *string) string

+ func TimePtr(val Time) *time.Time

+ func Validate(m interface{}) error

+ type DB interface

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ type ID struct

+ func MustID(val string) ID

+ func NewID(id uint64) ID

+ func ParseID(val string) ID

+ func (v *ID) Reset()

+ func (v *ID) Scan(value any) error

+ func (v *ID) Set(val string) error

+ func (v *ID) UnmarshalJSON(data []byte) error

+ func (v ID) Invalid() bool

+ func (v ID) IsZero() bool

+ func (v ID) MarshalJSON() ([]byte, error)

+ func (v ID) String() string

+ func (v ID) UInt64() uint64

+ func (v ID) Valid() bool

+ func (v ID) Value() (driver.Value, error)

+ type IDArray []ID

+ func (n *IDArray) Scan(value any) error

+ func (n IDArray) Strings() []string

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

+ type IDGenerator interface

+ NextID func() ID

+ type Metadata map[string]string

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

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

+ type MigrationConfig struct

+ ForceVersion int

+ MigrateVersion int

+ Source string

+ type NULLString string

+ func (ns *NULLString) Scan(value interface{}) error

+ func (ns NULLString) Value() (driver.Value, error)

+ type Provider interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (Provider, error)

+ Close func() (err error)

+ DB func() DB

+ Tx func() Tx

+ func NewProvider(provider, dataSourceName, dbName string, idGen flake.IDGenerator, ...) (Provider, error)

+ type Result struct

+ NextOffset uint32

+ Rows []TPointer

+ func (p *Result[T, RowPointer]) RunQueryResult(ctx context.Context, sql DB, offset, take uint32, query string, args ...any) error

+ type Row interface

+ Err func() error

+ Scan func(dest ...any) error

+ type RowPointer interface

+ type RowScanner interface

+ ScanRow func(rows Row) error

+ type Rows interface

+ Next func() bool

+ NextResultSet func() bool

+ type SQLProvider struct

+ func New(db *sql.DB, idGen flake.IDGenerator) (*SQLProvider, error)

+ func (p *SQLProvider) BeginTx(ctx context.Context, _ *sql.TxOptions) (Provider, error)

+ func (p *SQLProvider) Close() (err error)

+ func (p *SQLProvider) DB() DB

+ func (p *SQLProvider) IDTime(id uint64) time.Time

+ func (p *SQLProvider) NextID() ID

+ func (p *SQLProvider) Tx() Tx

+ type Strings []string

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

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

+ type TableInfo struct

+ Columns []string

+ Indexes []string

+ Name string

+ PrimaryKey string

+ Schema string

+ SchemaName string

+ func (t *TableInfo) ColumnsList() string

+ type Time time.Time

+ func FromNow(after time.Duration) Time

+ func FromUnixMilli(tm int64) Time

+ func Now() Time

+ func ParseTime(val string) Time

+ func UTC(t time.Time) Time

+ func (ns *Time) Scan(value interface{}) error

+ func (ns *Time) UnmarshalJSON(data []byte) error

+ func (ns Time) Add(after time.Duration) Time

+ func (ns Time) IsNil() bool

+ func (ns Time) IsZero() bool

+ func (ns Time) MarshalJSON() ([]byte, error)

+ func (ns Time) Ptr() *time.Time

+ func (ns Time) String() string

+ func (ns Time) UTC() time.Time

+ func (ns Time) UnixMilli() int64

+ func (ns Time) Value() (driver.Value, error)

+ type Tx interface

+ Commit func() error

+ Rollback func() error

+ type Validator interface

+ Validate func() error