factory

Documentation

Index

• func GetCreateTableSQL(params *request.LogTableRequest) []string
• func GetDropTableSQL(params *request.LogTableRequest) []string
• func GetUpdateTableSQLByFields(params *request.LogTableRequest, old []request.Field) []string
• type BufferTableFactory
  • func (b *BufferTableFactory) CreateTableSQL(params *request.LogTableRequest) string
  • func (b *BufferTableFactory) DropTableSQL(params *request.LogTableRequest) string
• type LogTableFactory
  • func (l *LogTableFactory) CreateDistributedTableSQL(params *request.LogTableRequest) string
  • func (l *LogTableFactory) CreateTableSQL(params *request.LogTableRequest) string
  • func (l *LogTableFactory) DropDistributedTableSQL(params *request.LogTableRequest) string
  • func (l *LogTableFactory) DropTableSQL(params *request.LogTableRequest) string
  • func (l *LogTableFactory) UpdateTableSQL(params *request.LogTableRequest, old []request.Field, distributed bool) string
• type NullTableFactory
  • func (n *NullTableFactory) CreateTableSQL(params *request.LogTableRequest) string
  • func (n *NullTableFactory) DropTableSQL(params *request.LogTableRequest) string
• type SQLFactory
• type ViewTableFactory
  • func (v *ViewTableFactory) CreateTableSQL(params *request.LogTableRequest) string
  • func (v *ViewTableFactory) DropTableSQL(params *request.LogTableRequest) string

Functions

func GetCreateTableSQL

func GetCreateTableSQL(params *request.LogTableRequest) []string

func GetDropTableSQL

func GetDropTableSQL(params *request.LogTableRequest) []string

func GetUpdateTableSQLByFields

func GetUpdateTableSQLByFields(params *request.LogTableRequest, old []request.Field) []string

Delete view first, then adjust log, and then create view The distributed table adjusts the local table first, and then the distributed table.

Types

type BufferTableFactory

type BufferTableFactory struct {
}

func (*BufferTableFactory) CreateTableSQL

func (b *BufferTableFactory) CreateTableSQL(params *request.LogTableRequest) string

func (*BufferTableFactory) DropTableSQL

func (b *BufferTableFactory) DropTableSQL(params *request.LogTableRequest) string

type LogTableFactory

type LogTableFactory struct {
}

func (*LogTableFactory) CreateDistributedTableSQL

func (l *LogTableFactory) CreateDistributedTableSQL(params *request.LogTableRequest) string

func (*LogTableFactory) CreateTableSQL

func (l *LogTableFactory) CreateTableSQL(params *request.LogTableRequest) string

CreateTableSQL implements Factory.

func (*LogTableFactory) DropDistributedTableSQL

func (l *LogTableFactory) DropDistributedTableSQL(params *request.LogTableRequest) string

func (*LogTableFactory) DropTableSQL

func (l *LogTableFactory) DropTableSQL(params *request.LogTableRequest) string

DropTableSQL implements Factory.

func (*LogTableFactory) UpdateTableSQL

func (l *LogTableFactory) UpdateTableSQL(params *request.LogTableRequest, old []request.Field, distributed bool) string

type NullTableFactory

type NullTableFactory struct {
}

func (*NullTableFactory) CreateTableSQL

func (n *NullTableFactory) CreateTableSQL(params *request.LogTableRequest) string

func (*NullTableFactory) DropTableSQL

func (n *NullTableFactory) DropTableSQL(params *request.LogTableRequest) string

type SQLFactory

type SQLFactory interface {
	CreateTableSQL(params *request.LogTableRequest) string
	DropTableSQL(params *request.LogTableRequest) string
}

type ViewTableFactory

type ViewTableFactory struct {
}

func (*ViewTableFactory) CreateTableSQL

func (v *ViewTableFactory) CreateTableSQL(params *request.LogTableRequest) string

func (*ViewTableFactory) DropTableSQL

func (v *ViewTableFactory) DropTableSQL(params *request.LogTableRequest) string