dal

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 30, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AnalyzeTablePlan 

type AnalyzeTablePlan struct {
	plan.BasePlan
	Stmt         *ast.AnalyzeTableStatement
	Shards       rule.DatabaseTables
	ShardsByName map[string]rule.DatabaseTables
}

func NewAnalyzeTablePlan 

func NewAnalyzeTablePlan(
	stmt *ast.AnalyzeTableStatement,
	shards rule.DatabaseTables,
	shardsByName map[string]rule.DatabaseTables,
) *AnalyzeTablePlan

func (*AnalyzeTablePlan) ExecIn 

func (a *AnalyzeTablePlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*AnalyzeTablePlan) Type 

func (a *AnalyzeTablePlan) Type() proto.PlanType

Type get plan type

type KillPlan 

type KillPlan struct {
	plan.BasePlan

	Stmt *ast.KillStmt
	// contains filtered or unexported fields
}

func NewKillPlan 

func NewKillPlan(stmt *ast.KillStmt) *KillPlan

func (*KillPlan) ExecIn 

func (k *KillPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*KillPlan) SetDatabase 

func (k *KillPlan) SetDatabase(db string)

func (*KillPlan) Type 

func (k *KillPlan) Type() proto.PlanType

type ShowCharacterSet 

type ShowCharacterSet struct {
	plan.BasePlan
	Stmt   *ast.ShowCharset
	Shards rule.DatabaseTables
}

func NewShowCharacterSetPlan 

func NewShowCharacterSetPlan(stmt *ast.ShowCharset, shards rule.DatabaseTables) *ShowCharacterSet

NewShowCharacterSet create ShowCreate Plan

func (*ShowCharacterSet) ExecIn 

func (s *ShowCharacterSet) ExecIn(ctx context.Context, vConn proto.VConn) (proto.Result, error)

func (*ShowCharacterSet) Type 

func (s *ShowCharacterSet) Type() proto.PlanType

type ShowCollationPlan 

type ShowCollationPlan struct {
	plan.BasePlan
	Stmt *ast.ShowCollation
}

func (*ShowCollationPlan) ExecIn 

func (s *ShowCollationPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowCollationPlan) Type 

func (s *ShowCollationPlan) Type() proto.PlanType

type ShowColumnsPlan 

type ShowColumnsPlan struct {
	plan.BasePlan
	Stmt  *ast.ShowColumns
	Table string
}

func (*ShowColumnsPlan) ExecIn 

func (s *ShowColumnsPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowColumnsPlan) Type 

func (s *ShowColumnsPlan) Type() proto.PlanType

type ShowCreatePlan 

type ShowCreatePlan struct {
	plan.BasePlan
	Stmt     *ast.ShowCreate
	Database string
	Table    string
}

func NewShowCreatePlan 

func NewShowCreatePlan(stmt *ast.ShowCreate) *ShowCreatePlan

NewShowCreatePlan create ShowCreate Plan

func (*ShowCreatePlan) ExecIn 

func (st *ShowCreatePlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowCreatePlan) Type 

func (st *ShowCreatePlan) Type() proto.PlanType

type ShowCreateSequence 

type ShowCreateSequence struct {
	Stmt *ast.ShowCreateSequence
}

func NewShowCreateSequencePlan 

func NewShowCreateSequencePlan(stmt *ast.ShowCreateSequence) *ShowCreateSequence

func (*ShowCreateSequence) ExecIn 

func (su *ShowCreateSequence) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowCreateSequence) Type 

func (su *ShowCreateSequence) Type() proto.PlanType

type ShowDatabaseRulesPlan 

type ShowDatabaseRulesPlan struct {
	plan.BasePlan
	Stmt *ast.ShowDatabaseRule
	// contains filtered or unexported fields
}

func NewShowDatabaseRulesPlan 

func NewShowDatabaseRulesPlan(stmt *ast.ShowDatabaseRule) *ShowDatabaseRulesPlan

NewShowDatabaseRulesPlan create ShowDatabaseRules Plan

func (*ShowDatabaseRulesPlan) ExecIn 

func (s *ShowDatabaseRulesPlan) ExecIn(ctx context.Context, _ proto.VConn) (proto.Result, error)

func (*ShowDatabaseRulesPlan) SetRule 

func (s *ShowDatabaseRulesPlan) SetRule(rule *rule.Rule)

func (*ShowDatabaseRulesPlan) Type 

func (s *ShowDatabaseRulesPlan) Type() proto.PlanType

type ShowDatabasesPlan 

type ShowDatabasesPlan struct {
	plan.BasePlan
	Stmt *ast.ShowDatabases
}

func (*ShowDatabasesPlan) ExecIn 

func (s *ShowDatabasesPlan) ExecIn(ctx context.Context, _ proto.VConn) (proto.Result, error)

func (*ShowDatabasesPlan) Type 

func (s *ShowDatabasesPlan) Type() proto.PlanType

type ShowIndexPlan 

type ShowIndexPlan struct {
	plan.BasePlan
	Stmt   *ast.ShowIndex
	Shards rule.DatabaseTables
}

func (*ShowIndexPlan) ExecIn 

func (s *ShowIndexPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowIndexPlan) Type 

func (s *ShowIndexPlan) Type() proto.PlanType

type ShowMasterStatusPlan 

type ShowMasterStatusPlan struct {
	plan.BasePlan
	// contains filtered or unexported fields
}

func NewShowMasterStatusPlan 

func NewShowMasterStatusPlan(stmt *ast.ShowMasterStatus) *ShowMasterStatusPlan

func (*ShowMasterStatusPlan) ExecIn 

func (s *ShowMasterStatusPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowMasterStatusPlan) Type 

func (s *ShowMasterStatusPlan) Type() proto.PlanType

type ShowNodes 

type ShowNodes struct {
	Stmt *ast.ShowNodes
}

func NewShowNodesPlan 

func NewShowNodesPlan(stmt *ast.ShowNodes) *ShowNodes

NewShowNodesPlan create ShowNodes Plan

func (*ShowNodes) ExecIn 

func (st *ShowNodes) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowNodes) Type 

func (st *ShowNodes) Type() proto.PlanType

type ShowOpenTablesPlan 

type ShowOpenTablesPlan struct {
	plan.BasePlan
	Database string
	Conn     proto.DB
	Stmt     *ast.ShowOpenTables
	// contains filtered or unexported fields
}

func NewShowOpenTablesPlan 

func NewShowOpenTablesPlan(stmt *ast.ShowOpenTables) *ShowOpenTablesPlan

NewShowOpenTablesPlan create ShowTables Plan

func (*ShowOpenTablesPlan) ExecIn 

func (st *ShowOpenTablesPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowOpenTablesPlan) SetDatabase 

func (st *ShowOpenTablesPlan) SetDatabase(database string)

func (*ShowOpenTablesPlan) SetInvertedShards 

func (st *ShowOpenTablesPlan) SetInvertedShards(m map[string]string)

func (*ShowOpenTablesPlan) Type 

func (st *ShowOpenTablesPlan) Type() proto.PlanType

type ShowProcessListPlan 

type ShowProcessListPlan struct {
	plan.BasePlan

	Stmt *ast.ShowProcessList
	// contains filtered or unexported fields
}

func NewShowProcessListPlan 

func NewShowProcessListPlan(stmt *ast.ShowProcessList) *ShowProcessListPlan

func (*ShowProcessListPlan) ExecIn 

func (s *ShowProcessListPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowProcessListPlan) SetDatabase 

func (s *ShowProcessListPlan) SetDatabase(db string)

func (*ShowProcessListPlan) Type 

func (s *ShowProcessListPlan) Type() proto.PlanType

type ShowReplicaStatusPlan 

type ShowReplicaStatusPlan struct {
	plan.BasePlan
	// contains filtered or unexported fields
}

func NewShowReplicaStatusPlan 

func NewShowReplicaStatusPlan(stmt *ast.ShowReplicaStatus) *ShowReplicaStatusPlan

func (*ShowReplicaStatusPlan) ExecIn 

func (s *ShowReplicaStatusPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowReplicaStatusPlan) Type 

func (s *ShowReplicaStatusPlan) Type() proto.PlanType

type ShowReplicasPlan 

type ShowReplicasPlan struct {
	plan.BasePlan
	Stmt *ast.ShowReplicas
}

func NewShowReplicasPlan 

func NewShowReplicasPlan(stmt *ast.ShowReplicas) *ShowReplicasPlan

func (*ShowReplicasPlan) ExecIn 

func (s *ShowReplicasPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowReplicasPlan) Type 

func (s *ShowReplicasPlan) Type() proto.PlanType

type ShowShardingTable 

type ShowShardingTable struct {
	plan.BasePlan
	Stmt *ast.ShowShardingTable
	// contains filtered or unexported fields
}

func NewShowShardingTablePlan 

func NewShowShardingTablePlan(stmt *ast.ShowShardingTable) *ShowShardingTable

NewShowShardingTablePlan create ShowShardingTable Plan

func (*ShowShardingTable) ExecIn 

func (st *ShowShardingTable) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowShardingTable) SetRule 

func (st *ShowShardingTable) SetRule(rule *rule.Rule)

func (*ShowShardingTable) Type 

func (st *ShowShardingTable) Type() proto.PlanType

type ShowStatusPlan 

type ShowStatusPlan struct {
	plan.BasePlan
	Database string
	// contains filtered or unexported fields
}

func NewShowStatusPlan 

func NewShowStatusPlan(stmt *ast.ShowStatus) *ShowStatusPlan

func (*ShowStatusPlan) ExecIn 

func (s *ShowStatusPlan) ExecIn(ctx context.Context, vConn proto.VConn) (proto.Result, error)

func (*ShowStatusPlan) Type 

func (s *ShowStatusPlan) Type() proto.PlanType

type ShowTableRulesPlan 

type ShowTableRulesPlan struct {
	plan.BasePlan
	Stmt *ast.ShowTableRule
	// contains filtered or unexported fields
}

func NewShowTableRulesPlan 

func NewShowTableRulesPlan(stmt *ast.ShowTableRule) *ShowTableRulesPlan

NewShowTableRulesPlan create ShowTableRules Plan

func (*ShowTableRulesPlan) ExecIn 

func (s *ShowTableRulesPlan) ExecIn(ctx context.Context, _ proto.VConn) (proto.Result, error)

func (*ShowTableRulesPlan) SetRule 

func (s *ShowTableRulesPlan) SetRule(rule *rule.Rule)

func (*ShowTableRulesPlan) Type 

func (s *ShowTableRulesPlan) Type() proto.PlanType

type ShowTableStatusPlan 

type ShowTableStatusPlan struct {
	plan.BasePlan
	Database string
	Stmt     *ast.ShowTableStatus
	Shards   rule.DatabaseTables
}

func (*ShowTableStatusPlan) ExecIn 

func (s *ShowTableStatusPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowTableStatusPlan) Type 

func (s *ShowTableStatusPlan) Type() proto.PlanType

type ShowTablesPlan 

type ShowTablesPlan struct {
	plan.BasePlan
	Database string
	Stmt     *ast.ShowTables
	// contains filtered or unexported fields
}

func NewShowTablesPlan 

func NewShowTablesPlan(stmt *ast.ShowTables) *ShowTablesPlan

NewShowTablesPlan create ShowTables Plan

func (*ShowTablesPlan) ExecIn 

func (st *ShowTablesPlan) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowTablesPlan) SetDatabase 

func (st *ShowTablesPlan) SetDatabase(db string)

func (*ShowTablesPlan) SetInvertedShards 

func (st *ShowTablesPlan) SetInvertedShards(m map[string]string)

func (*ShowTablesPlan) SetTables 

func (st *ShowTablesPlan) SetTables(tables []string)

func (*ShowTablesPlan) Type 

func (st *ShowTablesPlan) Type() proto.PlanType

type ShowTopology 

type ShowTopology struct {
	plan.BasePlan
	Stmt *ast.ShowTopology
	// contains filtered or unexported fields
}

func NewShowTopologyPlan 

func NewShowTopologyPlan(stmt *ast.ShowTopology) *ShowTopology

NewShowTopologyPlan create ShowTopology Plan

func (*ShowTopology) ExecIn 

func (st *ShowTopology) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowTopology) SetRule 

func (st *ShowTopology) SetRule(rule *rule.Rule)

func (*ShowTopology) Type 

func (st *ShowTopology) Type() proto.PlanType

type ShowUsers 

type ShowUsers struct {
	Stmt *ast.ShowUsers
}

func NewShowUsersPlan 

func NewShowUsersPlan(stmt *ast.ShowUsers) *ShowUsers

func (*ShowUsers) ExecIn 

func (su *ShowUsers) ExecIn(ctx context.Context, conn proto.VConn) (proto.Result, error)

func (*ShowUsers) Type 

func (su *ShowUsers) Type() proto.PlanType

type ShowVariablesPlan 

type ShowVariablesPlan struct {
	plan.BasePlan
	// contains filtered or unexported fields
}

func NewShowVariablesPlan 

func NewShowVariablesPlan(stmt *ast.ShowVariables) *ShowVariablesPlan

func (*ShowVariablesPlan) ExecIn 

func (s *ShowVariablesPlan) ExecIn(ctx context.Context, vConn proto.VConn) (proto.Result, error)

func (*ShowVariablesPlan) Type 

func (s *ShowVariablesPlan) Type() proto.PlanType

type ShowWarningsPlan 

type ShowWarningsPlan struct {
	plan.BasePlan
	Stmt   *ast.ShowWarnings
	Shards rule.DatabaseTables
}

func NewShowWarningsPlan 

func NewShowWarningsPlan(stmt *ast.ShowWarnings, shards rule.DatabaseTables) *ShowWarningsPlan

func (*ShowWarningsPlan) ExecIn 

func (s *ShowWarningsPlan) ExecIn(ctx context.Context, vConn proto.VConn) (proto.Result, error)

func (*ShowWarningsPlan) Type 

func (s *ShowWarningsPlan) Type() proto.PlanType

Type get plan type

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.