command

Documentation

Index

• Constants
• Variables
• func DataToSQLData(data any, datatype DataType, semtype string) (*string, error)
• func DataTypeToSQL(dtype DataType, typeSize int64) string
• type Command
  • func NewCommand(dedup *log.MessageSet, ce *change.Event, ...) (*Command, bool, error)
  • func (c *Command) AddChild(child *Command)
  • func (c *Command) String() string
• type CommandColumn
  • func PrimaryKeyColumns(columns []CommandColumn) []CommandColumn
• type CommandGraph
  • func NewCommandGraph() *CommandGraph
• type DataType
  • func InferTypeFromString(data string) DataType
  • func MakeDataType(dataType string) (DataType, int64)
  • func (d DataType) String() string
• type Operation
  • func (o Operation) String() string

Constants

const (
	UnknownType     = 0
	BooleanType     = 1
	DateType        = 2
	FloatType       = 3
	IntegerType     = 4
	JSONType        = 5
	NumericType     = 6
	TimeType        = 7
	TimestampType   = 8
	TimestamptzType = 9
	TimetzType      = 10
	UUIDType        = 11
	TextType        = 12
)

Variables

var ReshareTenants []string

var FolioTenant string

Functions

func DataToSQLData

func DataToSQLData(data any, datatype DataType, semtype string) (*string, error)

DataToSQLData converts data to a string ready for encoding to SQL.

func DataTypeToSQL

func DataTypeToSQL(dtype DataType, typeSize int64) string

DataTypeToSQL convert a data type and type size to a database type.

Types

type Command

type Command struct {
	Op              Operation
	SchemaName      string
	TableName       string
	Transformed     bool
	ParentTable     dbx.Table
	Origin          string
	Column          []CommandColumn
	SourceTimestamp string
	Subcommands     *list.List
}

func NewCommand

func NewCommand(dedup *log.MessageSet, ce *change.Event, schemaPassFilter, schemaStopFilter,
	tableStopFilter []*regexp.Regexp, trimSchemaPrefix, addSchemaPrefix string) (*Command, bool, error)

func (*Command) AddChild

func (c *Command) AddChild(child *Command)

func (*Command) String

func (c *Command) String() string

type CommandColumn

type CommandColumn struct {
	Name        string
	DType       DataType
	DTypeSize   int64
	Data        interface{}
	SQLData     *string
	PrimaryKey  int
	Unavailable bool
}

func PrimaryKeyColumns

func PrimaryKeyColumns(columns []CommandColumn) []CommandColumn

type CommandGraph

type CommandGraph struct {
	Commands *list.List
}

func NewCommandGraph

func NewCommandGraph() *CommandGraph

type DataType

type DataType int

func InferTypeFromString

func InferTypeFromString(data string) DataType

func MakeDataType

func MakeDataType(dataType string) (DataType, int64)

func (DataType) String

func (d DataType) String() string

type Operation

type Operation int

const (
	MergeOp Operation = iota
	DeleteOp
	TruncateOp
)

func (Operation) String

func (o Operation) String() string