dbop

Documentation

Index

• type AsmParam
• type DalContext
  • func NewDalContext(ctx context.Context) *DalContext
  • func (d *DalContext) Context() context.Context
• type OperationType
  • func (t OperationType) String() string
• type PreparedQuery
• type QueryResult
• type ResultSource
  • func (s ResultSource) String() string
• type ResultType
  • func (t ResultType) String() string

Types

type AsmParam

type AsmParam struct {
	Api          string
	Param        []any
	Session      metadata.SessionContext
	AutoFilter   []metadata.AutoFilter
	AutoPopulate []metadata.AutoPopulate
}

type DalContext

type DalContext struct {

	// Container for transaction management.
	// Ensures that accessing the same database during a single API request uses the same connection,
	// and automatically commits or rolls back transactions when the request ends.
	Container *sync.Map

	DebugInfo []map[string]any
	// contains filtered or unexported fields
}

func NewDalContext

func NewDalContext(ctx context.Context) *DalContext

func (*DalContext) Context

func (d *DalContext) Context() context.Context

type OperationType

type OperationType int

const (
	InvalidAction OperationType = iota
	CreateOneAction
	CreateManyAction
	ReadManyAction
	ReadOneAction
	ReadValueAction
	UpdateOneAction
	UpdateManyAction
	DeleteOneAction
	DeleteManyAction
	TransactionAction
	DDLAction
)

func (OperationType) String

func (t OperationType) String() string

type PreparedQuery

type PreparedQuery struct {
	QueryType string `json:"queryType"`
	Query     string `json:"query"`
	Bind      []any  `json:"bind"`

	// Query purpose, only used for subqueries like CheckPoint/ResultEnricher
	// Possible values: "uk_conflict", "fk_exists", "fk_restrict", "count", etc.
	Purpose string `json:"purpose,omitempty"`

	// Field names involved, used for generating error messages
	// For UK conflicts: unique key fields
	// For FK checks: foreign key fields
	Column []string `json:"columns,omitempty"`

	CheckPoint     []PreparedQuery `json:"checkPoint,omitempty"`
	ResultEnricher []PreparedQuery `json:"resultEnricher,omitempty"`
}

type QueryResult

type QueryResult struct {
	ResultName   string
	ResultSource ResultSource
	ResultType   ResultType
	LastInsertId int64
	RowsAffected int64
	Row          map[string]any
	Rows         []map[string]any
	CheckPoint   []*QueryResult
	Enricher     []*QueryResult
}

type ResultSource

type ResultSource int

const (
	SourceMainQuery ResultSource = iota
	SourceCheckpoint
	SourceEnricher
)

func (ResultSource) String

func (s ResultSource) String() string

type ResultType

type ResultType int

const (
	None ResultType = iota
	MultiRows
	SingleRow
	AutoSingleColumn
	SingleValue
	LastInsertId
	RowsAffected
	Transaction
)

func (ResultType) String

func (t ResultType) String() string