context

Documentation

Index

• Constants
• func Bootstrap(db *sqlx.DB) *initiator
• func BootstrapDual(write *sqlx.DB, read *sqlx.DB) *initiator
• func NewDefaultQueryClient(identifier string, queryMap *entity.QueryMap, ...) *defaultQueryClient
• type ApplicationContext
  • func GetApplicationContext() ApplicationContext
• type QueryClient
  • func NewQueryClient(identifier string, filePath string) (QueryClient, errors.Error)
• type ReadOnlyQueryClient
  • func NewReadOnlyQueryClient(identifier string, filePath string) (ReadOnlyQueryClient, errors.Error)
• type TxBlock
• type TxBlockAuto
• type TxConsumer
• type TxManager
  • func NewTxManager(writeDB *sqlx.DB) TxManager

Constants

const DBManager dBManager = 1

DBManager Developers get raw DB struct

Functions

func Bootstrap

func Bootstrap(db *sqlx.DB) *initiator

func BootstrapDual

func BootstrapDual(write *sqlx.DB, read *sqlx.DB) *initiator

func NewDefaultQueryClient

func NewDefaultQueryClient(identifier string, queryMap *entity.QueryMap, statementMap map[entity.Path]*sqlx.NamedStmt, readOnly bool) *defaultQueryClient

Types

type ApplicationContext

type ApplicationContext interface {
	GetQueryClient(identifier string) (QueryClient, errors.Error)
	GetReadOnlyQueryClient(identifier string) (ReadOnlyQueryClient, errors.Error)
	RegisterQueryClient(client QueryClient) errors.Error
	GetDBs() *entity.DbSet
	GetDB(readDB bool) *sqlx.DB
	GetTxManager() TxManager
}

func GetApplicationContext

func GetApplicationContext() ApplicationContext

type QueryClient

type QueryClient interface {
	ReadOnlyQueryClient
	InsertOne(ctx context.Context, tagName string, args map[string]any, conditions ...entity.PredicateConditions) errors.Error
	InsertOneTx(ctx context.Context, tx *sqlx.Tx, tagName string, args map[string]any, conditions ...entity.PredicateConditions) errors.Error

	Delete(ctx context.Context, tagName string, args map[string]any, conditions ...entity.PredicateConditions) (int64, errors.Error)
	DeleteTx(ctx context.Context, tx *sqlx.Tx, tagName string, args map[string]any, conditions ...entity.PredicateConditions) (int64, errors.Error)

	Update(ctx context.Context, tagName string, args map[string]any, conditions ...entity.PredicateConditions) (int64, errors.Error)
	UpdateTx(ctx context.Context, tx *sqlx.Tx, tagName string, args map[string]any, conditions ...entity.PredicateConditions) (int64, errors.Error)
}

func NewQueryClient

func NewQueryClient(identifier string, filePath string) (QueryClient, errors.Error)

type ReadOnlyQueryClient

type ReadOnlyQueryClient interface {
	BeginTx(ctx context.Context) (*sqlx.Tx, errors.Error)
	RollbackTx(ctx context.Context, tx *sqlx.Tx) errors.Error
	CommitTx(ctx context.Context, tx *sqlx.Tx) errors.Error

	GetOne(ctx context.Context, tagName string, dest any, args map[string]any, conditions ...entity.PredicateConditions) errors.Error
	GetOneTx(ctx context.Context, tx *sqlx.Tx, tagName string, dest any, args map[string]any, conditions ...entity.PredicateConditions) errors.Error
	Get(ctx context.Context, tagName string, dest any, args map[string]any, conditions ...entity.PredicateConditions) errors.Error
	GetTx(ctx context.Context, tx *sqlx.Tx, tagName string, dest any, args map[string]any, conditions ...entity.PredicateConditions) errors.Error

	Id() string
	ReadOnly() bool
}

func NewReadOnlyQueryClient

func NewReadOnlyQueryClient(identifier string, filePath string) (ReadOnlyQueryClient, errors.Error)

type TxBlock

type TxBlock func(ctx context.Context, tx *sqlx.Tx) error

type TxBlockAuto

type TxBlockAuto func(ctx context.Context) error

type TxConsumer

type TxConsumer func(tx *sqlx.Tx) error

type TxManager

type TxManager interface {
	Txx(ctx context.Context, txBlock TxBlockAuto) error
	TxxWithOpt(ctx context.Context, opts *sql.TxOptions, txBlock TxBlockAuto) error
	Tx(ctx context.Context, txBlock TxBlock) error
	TxWithOpt(ctx context.Context, opts *sql.TxOptions, txBlock TxBlock) error
}

func NewTxManager

func NewTxManager(writeDB *sqlx.DB) TxManager