handler

Documentation

Index

• func GetRegistry(runtimeCtx dto.RuntimeCtx) (anysdk.RegistryAPI, error)
• type HandlerContext
  • func GetHandlerCtx(cmdString string, runtimeCtx dto.RuntimeCtx, lruCache *lrucache.LRUCache, ...) (HandlerContext, error)

Functions

func GetRegistry

func GetRegistry(runtimeCtx dto.RuntimeCtx) (anysdk.RegistryAPI, error)

Types

type HandlerContext

type HandlerContext interface {
	Clone() HandlerContext
	//
	GetASTFormatter() sqlparser.NodeFormatter
	GetAuthContext(providerName string) (*dto.AuthCtx, error)
	GetDBMSInternalRouter() dbmsinternal.Router
	GetProvider(providerName string) (provider.IProvider, error)
	GetSupportedProviders(extended bool) (map[string]map[string]interface{}, error)
	LogHTTPResponseMap(target interface{})
	//
	GetRawQuery() string
	GetQuery() string
	GetRuntimeContext() dto.RuntimeCtx
	GetProviders() map[string]provider.IProvider
	GetControlAttributes() sqlcontrol.ControlAttributes
	GetCurrentProvider() string
	GetAuthContexts() map[string]*dto.AuthCtx
	GetRegistry() anysdk.RegistryAPI
	GetErrorPresentation() string
	GetOutfile() io.Writer
	GetOutErrFile() io.Writer
	GetLRUCache() *lrucache.LRUCache
	GetSQLDataSource(name string) (sql_datasource.SQLDataSource, bool)
	GetSQLEngine() sqlengine.SQLEngine
	GetSQLSystem() sql_system.SQLSystem
	GetGarbageCollector() garbagecollector.GarbageCollector
	GetDrmConfig() drm.Config
	SetTxnCounterMgr(txncounter.Manager)
	GetTxnCounterMgr() txncounter.Manager
	GetTxnStore() kstore.KStore
	GetNamespaceCollection() tablenamespace.Collection
	GetFormatter() sqlparser.NodeFormatter
	GetPGInternalRouter() dbmsinternal.Router
	//
	SetCurrentProvider(string)
	SetOutfile(io.Writer)
	SetOutErrFile(io.Writer)
	SetQuery(string)
	SetRawQuery(string)
	//
	GetTxnCoordinatorCtx() txn_context.ITransactionCoordinatorContext

	GetTypingConfig() typing.Config
	GetIsolationLevel() constants.IsolationLevel
	UpdateIsolationLevel(isolationLevelStr string) error

	GetRollbackType() constants.RollbackType
	UpdateRollbackType(rollbackTypeStr string) error

	GetTSM() (tsm.TSM, bool)
	SetTSM(tsm.TSM)

	SetExportNamespace(string)
	GetExportNamespace() string
}

func GetHandlerCtx

func GetHandlerCtx(
	cmdString string,
	runtimeCtx dto.RuntimeCtx,
	lruCache *lrucache.LRUCache,
	inputBundle bundle.Bundle,
) (HandlerContext, error)