schema

Documentation

Index

• func BuildLockKey(lockKeyRecords *TableRecords) string
• type ColumnMeta
• type Field
• type IndexMeta
• type IndexType
• type KeyType
• type Row
  • func (row *Row) NonPrimaryKeys() []*Field
  • func (row *Row) PrimaryKeys() []*Field
• type RowLock
• type TableMeta
  • func (meta TableMeta) GetPKName() string
  • func (meta TableMeta) GetPrimaryKeyMap() map[string]ColumnMeta
  • func (meta TableMeta) GetPrimaryKeyOnlyName() []string
• type TableRecords
  • func BuildBinaryRecords(meta TableMeta, result *mysql.Result) *TableRecords
  • func BuildTextRecords(meta TableMeta, result *mysql.Result) *TableRecords
  • func NewTableRecords(meta TableMeta) *TableRecords
  • func (records *TableRecords) PKFields() []*Field

Functions

func BuildLockKey

func BuildLockKey(lockKeyRecords *TableRecords) string

Types

type ColumnMeta

type ColumnMeta struct {
	TableCat        string
	TableSchemeName string
	TableName       string
	ColumnName      string
	DataType        int32
	DataTypeName    string
	ColumnSize      int64
	DecimalDigits   int64
	NumPrecRadix    int64
	Nullable        int32
	Remarks         string
	ColumnDef       string
	SqlDataType     int32
	SqlDatetimeSub  int32
	CharOctetLength int64
	OrdinalPosition int64
	IsNullable      string
	IsAutoIncrement string
}

type Field

type Field struct {
	Name    string
	KeyType KeyType
	Type    int32
	Value   interface{}
}

type IndexMeta

type IndexMeta struct {
	Values          []ColumnMeta
	NonUnique       bool
	IndexQualifier  string
	IndexName       string
	ColumnName      string
	Type            int16
	IndexType       IndexType
	AscOrDesc       string
	Cardinality     int32
	OrdinalPosition int32
}

type IndexType

type IndexType byte

const (
	IndexTypePrimary IndexType = iota
	IndexTypeNormal
	IndexTypeUnique
	IndexTypeFullText
)

type KeyType

type KeyType byte

const (
	Null KeyType = iota
	PrimaryKey
)

type Row

type Row struct {
	Fields []*Field
}

func (*Row) NonPrimaryKeys

func (row *Row) NonPrimaryKeys() []*Field

func (*Row) PrimaryKeys

func (row *Row) PrimaryKeys() []*Field

type RowLock

type RowLock struct {
	XID      string
	BranchID int64
	RowKey   string
}

type TableMeta

type TableMeta struct {
	SchemaName string
	TableName  string
	Columns    []string
	AllColumns map[string]ColumnMeta
	AllIndexes map[string]IndexMeta
}

func (TableMeta) GetPKName

func (meta TableMeta) GetPKName() string

func (TableMeta) GetPrimaryKeyMap

func (meta TableMeta) GetPrimaryKeyMap() map[string]ColumnMeta

func (TableMeta) GetPrimaryKeyOnlyName

func (meta TableMeta) GetPrimaryKeyOnlyName() []string

type TableRecords

type TableRecords struct {
	TableMeta TableMeta `json:"-"`
	TableName string
	Rows      []*Row
}

func BuildBinaryRecords

func BuildBinaryRecords(meta TableMeta, result *mysql.Result) *TableRecords

func BuildTextRecords

func BuildTextRecords(meta TableMeta, result *mysql.Result) *TableRecords

func NewTableRecords

func NewTableRecords(meta TableMeta) *TableRecords

func (*TableRecords) PKFields

func (records *TableRecords) PKFields() []*Field