condition

Documentation

Index

• Constants
• type BaseRegularCond
  • func BuildMysqlDataBaseRegularCond(ctx *context.BaseContext, conf config.MysqlTaskConfig) BaseRegularCond
• type MysqlBaseRegularCondImpl
  • func (cond *MysqlBaseRegularCondImpl) GetTableFilterCols(table string) map[string]struct{}
  • func (cond *MysqlBaseRegularCondImpl) IsTableNeedFilter(table string) bool
  • func (cond *MysqlBaseRegularCondImpl) IsUpsert(table string) bool
• type MysqlRunTimeFilterCondImpl
  • func NewMysqlRunTimeFilterCond(ctx *context.BizContext, repo BaseRegularCond, tableDesc *dao.TableFormat) *MysqlRunTimeFilterCondImpl
  • func (cond *MysqlRunTimeFilterCondImpl) GetTableFilterCols(table string) map[string]struct{}
• type RegularTableMap

Constants

const (
	DataModeAll  = "ALL"
	DataModePart = "PART"
)

Types

type BaseRegularCond

type BaseRegularCond interface {
	IsTableNeedFilter(table string) bool
	GetTableFilterCols(table string) map[string]struct{}
	IsUpsert(table string) bool
}

func BuildMysqlDataBaseRegularCond

func BuildMysqlDataBaseRegularCond(ctx *context.BaseContext, conf config.MysqlTaskConfig) BaseRegularCond

type MysqlBaseRegularCondImpl

type MysqlBaseRegularCondImpl struct {
	DataMode        string
	IncludeTables   map[string]struct{}
	ExcludeTables   map[string]struct{}
	RegularTableMap map[string]RegularTableMap
}

func (*MysqlBaseRegularCondImpl) GetTableFilterCols

func (cond *MysqlBaseRegularCondImpl) GetTableFilterCols(table string) map[string]struct{}

func (*MysqlBaseRegularCondImpl) IsTableNeedFilter

func (cond *MysqlBaseRegularCondImpl) IsTableNeedFilter(table string) bool

func (*MysqlBaseRegularCondImpl) IsUpsert

func (cond *MysqlBaseRegularCondImpl) IsUpsert(table string) bool

type MysqlRunTimeFilterCondImpl

type MysqlRunTimeFilterCondImpl struct {
	BaseRegularCond

	TableFormat *dao.TableFormat
	// contains filtered or unexported fields
}

func NewMysqlRunTimeFilterCond

func NewMysqlRunTimeFilterCond(ctx *context.BizContext, repo BaseRegularCond, tableDesc *dao.TableFormat) *MysqlRunTimeFilterCondImpl

func (*MysqlRunTimeFilterCondImpl) GetTableFilterCols

func (cond *MysqlRunTimeFilterCondImpl) GetTableFilterCols(table string) map[string]struct{}

注意主键不删除

type RegularTableMap

type RegularTableMap struct {
	FilterCols map[string]struct{}
	IsUpsert   bool
}