logic

Documentation

Index

• Constants
• type PingLogic
  • func NewPingLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PingLogic
  • func (s *PingLogic) CreateTable(tableNameCK, engine, partition, orderFiled, tableName string) error
  • func (s *PingLogic) Exchange(tableName, tableNameCK, rename string) error
  • func (s *PingLogic) GetCreateTableSql(tableNameCK, engine, partition, orderFiled, tableName string) string
  • func (s *PingLogic) GetInsertTableSql(tableNameCK, tableName, where string) string
  • func (s *PingLogic) InsertTable(tableName, tableNameCK string, whereCus string) error
  • func (s *PingLogic) Run(tables []string) error
  • func (s *PingLogic) Sync(v config.Table) error

Constants

const CreateTableSql = "CREATE TABLE IF NOT EXISTS %s ENGINE = %s %s ORDER BY %s AS "

const InsertTableSql = "INSERT INTO %s "

const MysqlHost = "SELECT %s FROM mysql('%s:%d','%s','%s', '%s', '%s') %s;"

Types

type PingLogic

type PingLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewPingLogic

func NewPingLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PingLogic

func (*PingLogic) CreateTable

func (s *PingLogic) CreateTable(tableNameCK, engine, partition, orderFiled, tableName string) error

func (*PingLogic) Exchange

func (s *PingLogic) Exchange(tableName, tableNameCK, rename string) error

func (*PingLogic) GetCreateTableSql

func (s *PingLogic) GetCreateTableSql(tableNameCK, engine, partition, orderFiled, tableName string) string

func (*PingLogic) GetInsertTableSql

func (s *PingLogic) GetInsertTableSql(tableNameCK, tableName, where string) string

func (*PingLogic) InsertTable

func (s *PingLogic) InsertTable(tableName, tableNameCK string, whereCus string) error

func (*PingLogic) Run

func (s *PingLogic) Run(tables []string) error

func (*PingLogic) Sync

func (s *PingLogic) Sync(v config.Table) error