sqlDB

Apr 29, 2025

Changes in this version

+ func Initialize()

+ func NewSQLDatabaseInstance(name, databaseURL string) *sql.DB

+ func NewTransaction(isolation ...sql.IsolationLevel) transaction.Transaction

+ type PageQuery struct

+ func NewPageQuery[T any](ctx context.Context, page *types.PageRequest, query string, params ...any) *PageQuery[T]

+ func (q *PageQuery[T]) Execute() (*types.Page[T], error)

+ func (q *PageQuery[T]) ExecuteInInstance(instance *sql.DB) (*types.Page[T], error)

+ type Query struct

+ func NewCachedQuery[T any](ctx context.Context, cache *cacheDB.Cache[T], query string, params ...any) (q *Query[T])

+ func NewQuery[T any](ctx context.Context, query string, params ...any) *Query[T]

+ func (q *Query[T]) Many() ([]T, error)

+ func (q *Query[T]) ManyInInstance(instance *sql.DB) ([]T, error)

+ func (q *Query[T]) One() (*T, error)

+ func (q *Query[T]) OneInInstance(instance *sql.DB) (*T, error)

+ type SqlTxContextKey string

+ const SqlTxContext

+ type Statement struct

+ func NewStatement(ctx context.Context, query string, params ...any) *Statement

+ func (s *Statement) Execute() error

+ func (s *Statement) ExecuteInInstance(instance *sql.DB) error