internal

Documentation

Index

• func GetConn(ctx context.Context, tdname string) *sql.DB
• type TdDestination
  • func NewTdDestination() *TdDestination
  • func (s *TdDestination) CreateStables() (err error)
  • func (s *TdDestination) CreateTables() (err error)
  • func (s *TdDestination) DropStable(stable string) (err error)
  • func (s *TdDestination) DropTable(table string) (err error)
  • func (s *TdDestination) InsertData() (err error)
• type TdSource
  • func NewTdSource() *TdSource
  • func (s *TdSource) Count(table string) (total int, err error)
  • func (s *TdSource) Data(table string, pageNum, pageSize int) (rs gdb.Result, err error)
  • func (s *TdSource) GetAll(sql string, args ...any) (rs gdb.Result, err error)
  • func (s *TdSource) ShowCreateStable() (stables, createSql []string, err error)
  • func (s *TdSource) ShowCreateTable() (tables, createSql []string, err error)
  • func (s *TdSource) Stables() (rs gdb.Result, err error)
  • func (s *TdSource) Tables() (rs gdb.Result, err error)
  • func (s *TdSource) Time(v *g.Var) (rs *g.Var)

Functions

func GetConn

func GetConn(ctx context.Context, tdname string) *sql.DB

Types

type TdDestination

type TdDestination struct {
	// contains filtered or unexported fields
}

func NewTdDestination

func NewTdDestination() *TdDestination

func (*TdDestination) CreateStables

func (s *TdDestination) CreateStables() (err error)

func (*TdDestination) CreateTables

func (s *TdDestination) CreateTables() (err error)

func (*TdDestination) DropStable

func (s *TdDestination) DropStable(stable string) (err error)

func (*TdDestination) DropTable

func (s *TdDestination) DropTable(table string) (err error)

func (*TdDestination) InsertData

func (s *TdDestination) InsertData() (err error)

type TdSource

type TdSource struct {
	// contains filtered or unexported fields
}

func NewTdSource

func NewTdSource() *TdSource

func (*TdSource) Count

func (s *TdSource) Count(table string) (total int, err error)

func (*TdSource) Data

func (s *TdSource) Data(table string, pageNum, pageSize int) (rs gdb.Result, err error)

func (*TdSource) GetAll

func (s *TdSource) GetAll(sql string, args ...any) (rs gdb.Result, err error)

超级表查询，多条数据

func (*TdSource) ShowCreateStable

func (s *TdSource) ShowCreateStable() (stables, createSql []string, err error)

func (*TdSource) ShowCreateTable

func (s *TdSource) ShowCreateTable() (tables, createSql []string, err error)

func (*TdSource) Stables

func (s *TdSource) Stables() (rs gdb.Result, err error)

func (*TdSource) Tables

func (s *TdSource) Tables() (rs gdb.Result, err error)

func (*TdSource) Time

func (s *TdSource) Time(v *g.Var) (rs *g.Var)

REST连接时区处理