executor

package

v0.4.0 Latest Latest Go to latest Published: Aug 13, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cectc/dbpack

Links

Open Source Insights

Documentation ¶

Index ¶

func NewReadWriteSplittingExecutor(conf *config.Executor) (proto.Executor, error)
func NewShardingExecutor(conf *config.Executor) (proto.Executor, error)
func NewSingleDBExecutor(conf *config.Executor) (proto.Executor, error)
type ReadWriteSplittingExecutor
type ShardingExecutor
type SingleDBExecutor

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewReadWriteSplittingExecutor ¶

func NewReadWriteSplittingExecutor(conf *config.Executor) (proto.Executor, error)

func NewShardingExecutor ¶

func NewShardingExecutor(conf *config.Executor) (proto.Executor, error)

func NewSingleDBExecutor ¶

func NewSingleDBExecutor(conf *config.Executor) (proto.Executor, error)

Types ¶

type ReadWriteSplittingExecutor ¶

type ReadWriteSplittingExecutor struct {
	PreFilters  []proto.DBPreFilter
	PostFilters []proto.DBPostFilter
	// contains filtered or unexported fields
}

func (*ReadWriteSplittingExecutor) ConnectionClose ¶

func (executor *ReadWriteSplittingExecutor) ConnectionClose(ctx context.Context)

func (*ReadWriteSplittingExecutor) ExecuteFieldList ¶

func (executor *ReadWriteSplittingExecutor) ExecuteFieldList(ctx context.Context, table, wildcard string) ([]proto.Field, error)

ExecuteFieldList https://dev.mysql.com/doc/internals/en/com-field-list.html As of MySQL 5.7.11, COM_FIELD_LIST is deprecated and will be removed in a future version of MySQL. Instead, use mysql_query() to execute a SHOW COLUMNS statement.

func (*ReadWriteSplittingExecutor) ExecuteMode ¶

func (executor *ReadWriteSplittingExecutor) ExecuteMode() config.ExecuteMode

func (*ReadWriteSplittingExecutor) ExecuteUseDB ¶

func (executor *ReadWriteSplittingExecutor) ExecuteUseDB(ctx context.Context, db string) error

func (*ReadWriteSplittingExecutor) ExecutorComQuery ¶

func (executor *ReadWriteSplittingExecutor) ExecutorComQuery(
	ctx context.Context, sqlText string) (result proto.Result, warns uint16, err error)

func (*ReadWriteSplittingExecutor) ExecutorComStmtExecute ¶

func (executor *ReadWriteSplittingExecutor) ExecutorComStmtExecute(
	ctx context.Context, stmt *proto.Stmt) (result proto.Result, warns uint16, err error)

func (*ReadWriteSplittingExecutor) GetPostFilters ¶

func (executor *ReadWriteSplittingExecutor) GetPostFilters() []proto.DBPostFilter

func (*ReadWriteSplittingExecutor) GetPreFilters ¶

func (executor *ReadWriteSplittingExecutor) GetPreFilters() []proto.DBPreFilter

func (*ReadWriteSplittingExecutor) InGlobalTransaction ¶

func (executor *ReadWriteSplittingExecutor) InGlobalTransaction(ctx context.Context) bool

func (*ReadWriteSplittingExecutor) InLocalTransaction ¶

func (executor *ReadWriteSplittingExecutor) InLocalTransaction(ctx context.Context) bool

func (*ReadWriteSplittingExecutor) ProcessDistributedTransaction ¶

func (executor *ReadWriteSplittingExecutor) ProcessDistributedTransaction() bool

type ShardingExecutor ¶

type ShardingExecutor struct {
	PreFilters  []proto.DBPreFilter
	PostFilters []proto.DBPostFilter
	// contains filtered or unexported fields
}

func (*ShardingExecutor) ConnectionClose ¶

func (executor *ShardingExecutor) ConnectionClose(ctx context.Context)

func (*ShardingExecutor) ExecuteFieldList ¶

func (executor *ShardingExecutor) ExecuteFieldList(ctx context.Context, table, wildcard string) ([]proto.Field, error)

ExecuteFieldList https://dev.mysql.com/doc/internals/en/com-field-list.html As of MySQL 5.7.11, COM_FIELD_LIST is deprecated and will be removed in a future version of MySQL. Instead, use mysql_query() to execute a SHOW COLUMNS statement.

func (*ShardingExecutor) ExecuteMode ¶

func (executor *ShardingExecutor) ExecuteMode() config.ExecuteMode

func (*ShardingExecutor) ExecuteUseDB ¶

func (executor *ShardingExecutor) ExecuteUseDB(ctx context.Context, db string) error

func (*ShardingExecutor) ExecutorComQuery ¶

func (executor *ShardingExecutor) ExecutorComQuery(ctx context.Context, sql string) (result proto.Result, warn uint16, err error)

func (*ShardingExecutor) ExecutorComStmtExecute ¶

func (executor *ShardingExecutor) ExecutorComStmtExecute(
	ctx context.Context, stmt *proto.Stmt) (result proto.Result, warns uint16, err error)

func (*ShardingExecutor) GetPostFilters ¶

func (executor *ShardingExecutor) GetPostFilters() []proto.DBPostFilter

func (*ShardingExecutor) GetPreFilters ¶

func (executor *ShardingExecutor) GetPreFilters() []proto.DBPreFilter

func (*ShardingExecutor) InGlobalTransaction ¶

func (executor *ShardingExecutor) InGlobalTransaction(ctx context.Context) bool

func (*ShardingExecutor) InLocalTransaction ¶

func (executor *ShardingExecutor) InLocalTransaction(ctx context.Context) bool

func (*ShardingExecutor) ProcessDistributedTransaction ¶

func (executor *ShardingExecutor) ProcessDistributedTransaction() bool

type SingleDBExecutor ¶

type SingleDBExecutor struct {
	PreFilters  []proto.DBPreFilter
	PostFilters []proto.DBPostFilter
	// contains filtered or unexported fields
}

func (*SingleDBExecutor) ConnectionClose ¶

func (executor *SingleDBExecutor) ConnectionClose(ctx context.Context)

func (*SingleDBExecutor) ExecuteFieldList ¶

func (executor *SingleDBExecutor) ExecuteFieldList(ctx context.Context, table, wildcard string) ([]proto.Field, error)

func (*SingleDBExecutor) ExecuteMode ¶

func (executor *SingleDBExecutor) ExecuteMode() config.ExecuteMode

func (*SingleDBExecutor) ExecuteUseDB ¶

func (executor *SingleDBExecutor) ExecuteUseDB(ctx context.Context, schema string) error

func (*SingleDBExecutor) ExecutorComQuery ¶

func (executor *SingleDBExecutor) ExecutorComQuery(
	ctx context.Context, sqlText string) (result proto.Result, warns uint16, err error)

func (*SingleDBExecutor) ExecutorComStmtExecute ¶

func (executor *SingleDBExecutor) ExecutorComStmtExecute(
	ctx context.Context, stmt *proto.Stmt) (result proto.Result, warns uint16, err error)

func (*SingleDBExecutor) GetPostFilters ¶

func (executor *SingleDBExecutor) GetPostFilters() []proto.DBPostFilter

func (*SingleDBExecutor) GetPreFilters ¶

func (executor *SingleDBExecutor) GetPreFilters() []proto.DBPreFilter

func (*SingleDBExecutor) InGlobalTransaction ¶

func (executor *SingleDBExecutor) InGlobalTransaction(ctx context.Context) bool

func (*SingleDBExecutor) InLocalTransaction ¶

func (executor *SingleDBExecutor) InLocalTransaction(ctx context.Context) bool

func (*SingleDBExecutor) ProcessDistributedTransaction ¶

func (executor *SingleDBExecutor) ProcessDistributedTransaction() bool

Source Files ¶

View all Source files

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