executor

package

v0.39.0 Latest Latest Go to latest Published: Sep 3, 2026 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/viant/datly

Links

Documentation ¶

Index ¶

type DBOption
- func WithLogger(log *logger.Adapter) DBOption
- func WithTx(tx *sql.Tx) DBOption
type DBOptions
type DBSource
type Executor
- func New() *Executor
- func (e *Executor) BuildBuffered(ctx context.Context, sess *Session) ([]any, error)
- func (e *Executor) Exec(ctx context.Context, sess *Session, options ...DBOption) error
- func (e *Executor) Execute(ctx context.Context, aView *view.View, options ...Option) error
- func (e *Executor) ExecuteStmts(ctx context.Context, dbSource DBSource, it StmtIterator, options ...DBOption) error
type Option
- func WithParameter(name string, value interface{}) Option
type Options
- func (o Options) Apply(session *Session) error
type Session
- func NewSession(sessionState *vsession.Session, aView *view.View) (*Session, error)
- func NewSessionWithCustomHandler(state *vsession.Session, aView *view.View, handler *extension.Session) (*Session, error)
- func (s *Session) Lookup(aView *view.View) *structology.State
type SqlBuilder
- func NewBuilder() *SqlBuilder
- func (s *SqlBuilder) Build(ctx context.Context, aView *view.View, templateState *structology.State, ...) (*expand2.State, []*expand2.SQLStatment, error)
type StmtIterator
type TemplateStmtIterator
- func NewTemplateStmtIterator(dataUnit *expand.DataUnit, data []*expand.SQLStatment) *TemplateStmtIterator
- func (t *TemplateStmtIterator) HasAny() bool
- func (t *TemplateStmtIterator) HasNext() bool
- func (t *TemplateStmtIterator) Next() interface{}
type Tx
type TxTransient
- func (t *TxTransient) Commit() error
- func (t *TxTransient) Rollback() error
type ViewDBSource
- func NewViewDBSource(view *view.View) *ViewDBSource
- func (v *ViewDBSource) CanBatch(table string) bool
- func (v *ViewDBSource) CanBatchGlobally() bool
- func (v *ViewDBSource) Db(_ context.Context) (*sql.DB, error)
- func (v *ViewDBSource) Dialect(ctx context.Context) (*info.Dialect, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DBOption ¶

type DBOption func(options *DBOptions)

func WithLogger ¶

func WithLogger(log *logger.Adapter) DBOption

func WithTx ¶

func WithTx(tx *sql.Tx) DBOption

type DBOptions ¶

type DBOptions struct {
	// contains filtered or unexported fields
}

type DBSource ¶

type DBSource interface {
	Db(ctx context.Context) (*sql.DB, error)
	Dialect(ctx context.Context) (*info.Dialect, error)
}

type Executor ¶

type Executor struct {
	// contains filtered or unexported fields
}

func New ¶

func New() *Executor

func (*Executor) BuildBuffered ¶ added in v0.39.0

func (e *Executor) BuildBuffered(ctx context.Context, sess *Session) ([]any, error)

BuildBuffered materializes a template execution sequence without executing its DML. Root-owned units of work use the returned order at final completion.

func (*Executor) Exec ¶

func (e *Executor) Exec(ctx context.Context, sess *Session, options ...DBOption) error

TODO: remove reflection TODO: customize global batch collector

func (*Executor) Execute ¶

func (e *Executor) Execute(ctx context.Context, aView *view.View, options ...Option) error

Execute executes view dql

func (*Executor) ExecuteStmts ¶

func (e *Executor) ExecuteStmts(ctx context.Context, dbSource DBSource, it StmtIterator, options ...DBOption) error

type Option ¶

type Option func(session *Session) error

Option represents executor session option

func WithParameter ¶

func WithParameter(name string, value interface{}) Option

WithParameter return parameter option

type Options ¶

type Options []Option

Options represents options

func (Options) Apply ¶

func (o Options) Apply(session *Session) error

apply applies session option

type Session ¶

type Session struct {
	Session        *vsession.Session
	SessionHandler *extension.Session
	View           *view.View
	TemplateState  *expand.State
	DataUnit       *expand.DataUnit
	// contains filtered or unexported fields
}

func NewSession ¶

func NewSession(sessionState *vsession.Session, aView *view.View) (*Session, error)

func NewSessionWithCustomHandler ¶

func NewSessionWithCustomHandler(state *vsession.Session, aView *view.View, handler *extension.Session) (*Session, error)

func (*Session) Lookup ¶

func (s *Session) Lookup(aView *view.View) *structology.State

type SqlBuilder ¶

type SqlBuilder struct{}

func NewBuilder ¶

func NewBuilder() *SqlBuilder

func (*SqlBuilder) Build ¶

func (s *SqlBuilder) Build(ctx context.Context, aView *view.View, templateState *structology.State, session *extension.Session, dataUnit *expand2.DataUnit) (*expand2.State, []*expand2.SQLStatment, error)

type StmtIterator ¶

type StmtIterator interface {
	HasNext() bool
	Next() interface{}
	HasAny() bool
}

type TemplateStmtIterator ¶

type TemplateStmtIterator struct {
	DataUnit *expand.DataUnit
	Data     []*expand.SQLStatment
	// contains filtered or unexported fields
}

func NewTemplateStmtIterator ¶

func NewTemplateStmtIterator(dataUnit *expand.DataUnit, data []*expand.SQLStatment) *TemplateStmtIterator

func (*TemplateStmtIterator) HasAny ¶

func (t *TemplateStmtIterator) HasAny() bool

func (*TemplateStmtIterator) HasNext ¶

func (t *TemplateStmtIterator) HasNext() bool

func (*TemplateStmtIterator) Next ¶

func (t *TemplateStmtIterator) Next() interface{}

type Tx ¶

type Tx interface {
	Rollback() error
	Commit() error
}

type TxTransient ¶

type TxTransient struct{}

func (*TxTransient) Commit ¶

func (t *TxTransient) Commit() error

func (*TxTransient) Rollback ¶

func (t *TxTransient) Rollback() error

type ViewDBSource ¶

type ViewDBSource struct {
	// contains filtered or unexported fields
}

func NewViewDBSource ¶

func NewViewDBSource(view *view.View) *ViewDBSource

func (*ViewDBSource) CanBatch ¶

func (v *ViewDBSource) CanBatch(table string) bool

func (*ViewDBSource) CanBatchGlobally ¶

func (v *ViewDBSource) CanBatchGlobally() bool

func (*ViewDBSource) Db ¶

func (v *ViewDBSource) Db(_ context.Context) (*sql.DB, error)

func (*ViewDBSource) Dialect ¶

func (v *ViewDBSource) Dialect(ctx context.Context) (*info.Dialect, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
expand
extension
handler
locator
mbus
parser
sequencer
uow Package uow owns one invocation-scoped mutation unit of work.	Package uow owns one invocation-scoped mutation unit of work.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL