db

Documentation

Index

• func InitDatabase(db *sql.DB, params StateInitParams) error
• func IsConflict(err error) bool
• func IsNull(err error) bool
• func Open(dburl string) (*sql.DB, error)
• func TransformBatchRow[T any, R any, PtrT BatchRowTransformable[T, R]](row R) T
• func TransformRow[T any, R any, PtrT RowTransformable[T, R]](row R) T
• type BatchRowTransformable
• type MigrationState
  • func Migrate(db *sql.DB) (*MigrationState, error)
• type RowTransformable
• type StateInitParams
• type TxWrapper
  • func (tx *TxWrapper) Commit() error
  • func (tx *TxWrapper) Rollback() error
• type Wrapper
  • func NewWrapper(db *sql.DB) *Wrapper
  • func (db *Wrapper) BeginTx(ctx context.Context) (*TxWrapper, error)

Functions

func InitDatabase

func InitDatabase(db *sql.DB, params StateInitParams) error

func IsConflict

func IsConflict(err error) bool

func IsNull

func IsNull(err error) bool

func Open

func Open(dburl string) (*sql.DB, error)

func TransformBatchRow

func TransformBatchRow[T any, R any, PtrT BatchRowTransformable[T, R]](row R) T

func TransformRow

func TransformRow[T any, R any, PtrT RowTransformable[T, R]](row R) T

Types

type BatchRowTransformable

type BatchRowTransformable[T any, R any] interface {
	*T
	FromBatchRow(row R)
}

type MigrationState

type MigrationState struct {
	Version uint
	Dirty   bool
	Updated bool
}

func Migrate

func Migrate(db *sql.DB) (*MigrationState, error)

type RowTransformable

type RowTransformable[T any, R any] interface {
	*T
	FromRow(row R)
}

type StateInitParams

type StateInitParams struct {
	RootUserName     string
	RootUserPassword string
	RestRootPassword bool
}

type TxWrapper

type TxWrapper struct {
	db_gen.Queries
	// contains filtered or unexported fields
}

func (*TxWrapper) Commit

func (tx *TxWrapper) Commit() error

func (*TxWrapper) Rollback

func (tx *TxWrapper) Rollback() error

type Wrapper

type Wrapper struct {
	db_gen.Queries
	// contains filtered or unexported fields
}

func NewWrapper

func NewWrapper(db *sql.DB) *Wrapper

func (*Wrapper) BeginTx

func (db *Wrapper) BeginTx(ctx context.Context) (*TxWrapper, error)