sqlrewrite

Documentation

Index

• func GenerateRewrittenSelectDML(input SQLRewriteInput) (drm.PreparedStatementCtx, error)
• type SQLRewriteInput
  • func NewStandardSQLRewriteInput(dc drm.Config, columnDescriptors []typing.RelationalColumn, ...) SQLRewriteInput
• type StandardSQLRewriteInput
  • func (ri *StandardSQLRewriteInput) GetBaseControlCounters() internaldto.TxnControlCounters
  • func (ri *StandardSQLRewriteInput) GetColumnDescriptors() []typing.RelationalColumn
  • func (ri *StandardSQLRewriteInput) GetDRMConfig() drm.Config
  • func (ri *StandardSQLRewriteInput) GetFromString() string
  • func (ri *StandardSQLRewriteInput) GetHoistedOnClauseTables() []sqlparser.SQLNode
  • func (ri *StandardSQLRewriteInput) GetIndirectContexts() []drm.PreparedStatementCtx
  • func (ri *StandardSQLRewriteInput) GetNamespaceCollection() tablenamespace.Collection
  • func (ri *StandardSQLRewriteInput) GetParameters() map[string]interface{}
  • func (ri *StandardSQLRewriteInput) GetPrepStmtOffset() int
  • func (ri *StandardSQLRewriteInput) GetRewrittenWhere() string
  • func (ri *StandardSQLRewriteInput) GetSecondaryCtrlCounters() []internaldto.TxnControlCounters
  • func (ri *StandardSQLRewriteInput) GetSelectSuffix() string
  • func (ri *StandardSQLRewriteInput) GetTableInsertionContainers() []tableinsertioncontainer.TableInsertionContainer
  • func (ri *StandardSQLRewriteInput) GetTables() taxonomy.TblMap
  • func (ri *StandardSQLRewriteInput) WithIndirectContexts(indirectContexts []drm.PreparedStatementCtx) SQLRewriteInput
  • func (ri *StandardSQLRewriteInput) WithPrepStmtOffset(offset int) SQLRewriteInput

Functions

func GenerateRewrittenSelectDML

func GenerateRewrittenSelectDML(input SQLRewriteInput) (drm.PreparedStatementCtx, error)

Types

type SQLRewriteInput

type SQLRewriteInput interface {
	GetNamespaceCollection() tablenamespace.Collection
	GetDRMConfig() drm.Config
	GetColumnDescriptors() []typing.RelationalColumn
	GetHoistedOnClauseTables() []sqlparser.SQLNode
	GetBaseControlCounters() internaldto.TxnControlCounters
	GetFromString() string
	GetIndirectContexts() []drm.PreparedStatementCtx
	GetPrepStmtOffset() int
	GetSelectSuffix() string
	GetRewrittenWhere() string
	GetSecondaryCtrlCounters() []internaldto.TxnControlCounters
	GetTables() taxonomy.TblMap
	GetTableInsertionContainers() []tableinsertioncontainer.TableInsertionContainer
	WithIndirectContexts(indirectContexts []drm.PreparedStatementCtx) SQLRewriteInput
	WithPrepStmtOffset(offset int) SQLRewriteInput
	GetParameters() map[string]interface{}
}

func NewStandardSQLRewriteInput

func NewStandardSQLRewriteInput(
	dc drm.Config,
	columnDescriptors []typing.RelationalColumn,
	baseControlCounters internaldto.TxnControlCounters,
	selectSuffix string,
	rewrittenWhere string,
	secondaryCtrlCounters []internaldto.TxnControlCounters,
	tables taxonomy.TblMap,
	fromString string,
	tableInsertionContainers []tableinsertioncontainer.TableInsertionContainer,
	namespaceCollection tablenamespace.Collection,
	hoistedOnClauseTables []sqlparser.SQLNode,
	parameters map[string]interface{},
) SQLRewriteInput

type StandardSQLRewriteInput

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

func (*StandardSQLRewriteInput) GetBaseControlCounters

func (ri *StandardSQLRewriteInput) GetBaseControlCounters() internaldto.TxnControlCounters

func (*StandardSQLRewriteInput) GetColumnDescriptors

func (ri *StandardSQLRewriteInput) GetColumnDescriptors() []typing.RelationalColumn

func (*StandardSQLRewriteInput) GetDRMConfig

func (ri *StandardSQLRewriteInput) GetDRMConfig() drm.Config

func (*StandardSQLRewriteInput) GetFromString

func (ri *StandardSQLRewriteInput) GetFromString() string

func (*StandardSQLRewriteInput) GetHoistedOnClauseTables

func (ri *StandardSQLRewriteInput) GetHoistedOnClauseTables() []sqlparser.SQLNode

func (*StandardSQLRewriteInput) GetIndirectContexts

func (ri *StandardSQLRewriteInput) GetIndirectContexts() []drm.PreparedStatementCtx

func (*StandardSQLRewriteInput) GetNamespaceCollection

func (ri *StandardSQLRewriteInput) GetNamespaceCollection() tablenamespace.Collection

func (*StandardSQLRewriteInput) GetParameters

func (ri *StandardSQLRewriteInput) GetParameters() map[string]interface{}

func (*StandardSQLRewriteInput) GetPrepStmtOffset

func (ri *StandardSQLRewriteInput) GetPrepStmtOffset() int

func (*StandardSQLRewriteInput) GetRewrittenWhere

func (ri *StandardSQLRewriteInput) GetRewrittenWhere() string

func (*StandardSQLRewriteInput) GetSecondaryCtrlCounters

func (ri *StandardSQLRewriteInput) GetSecondaryCtrlCounters() []internaldto.TxnControlCounters

func (*StandardSQLRewriteInput) GetSelectSuffix

func (ri *StandardSQLRewriteInput) GetSelectSuffix() string

func (*StandardSQLRewriteInput) GetTableInsertionContainers

func (ri *StandardSQLRewriteInput) GetTableInsertionContainers() []tableinsertioncontainer.TableInsertionContainer

func (*StandardSQLRewriteInput) GetTables

func (ri *StandardSQLRewriteInput) GetTables() taxonomy.TblMap

func (*StandardSQLRewriteInput) WithIndirectContexts

func (ri *StandardSQLRewriteInput) WithIndirectContexts(indirectContexts []drm.PreparedStatementCtx) SQLRewriteInput

func (*StandardSQLRewriteInput) WithPrepStmtOffset

func (ri *StandardSQLRewriteInput) WithPrepStmtOffset(offset int) SQLRewriteInput