dao

Documentation

Index

• type DDLClient
• type DDLDAO
  • func NewDDLDAO(client DDLClient, lgr log.Logger) *DDLDAO
  • func (d *DDLDAO) CreateTable(db, table string, schema []abstract.ColSchema) error
  • func (d *DDLDAO) CreateTableAs(baseDB, baseTable, targetDB, targetTable string) error
  • func (d *DDLDAO) DropTable(db, table string) error
  • func (d *DDLDAO) TableExists(db, table string) (bool, error)
  • func (d *DDLDAO) TruncateTable(db, table string) error
• type PartsDAO
  • func NewPartsDAO(db db.Client, lgr log.Logger) *PartsDAO
  • func (d *PartsDAO) AttachTablePartsTo(dstDB, dstTable, srcDB, srcTable string) error

Types

type DDLClient

type DDLClient interface {
	db.Client
	db.DDLExecutor
}

type DDLDAO

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

func NewDDLDAO

func NewDDLDAO(client DDLClient, lgr log.Logger) *DDLDAO

func (*DDLDAO) CreateTable

func (d *DDLDAO) CreateTable(db, table string, schema []abstract.ColSchema) error

func (*DDLDAO) CreateTableAs

func (d *DDLDAO) CreateTableAs(baseDB, baseTable, targetDB, targetTable string) error

func (*DDLDAO) DropTable

func (d *DDLDAO) DropTable(db, table string) error

func (*DDLDAO) TableExists

func (d *DDLDAO) TableExists(db, table string) (bool, error)

func (*DDLDAO) TruncateTable

func (d *DDLDAO) TruncateTable(db, table string) error

type PartsDAO

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

func NewPartsDAO

func NewPartsDAO(db db.Client, lgr log.Logger) *PartsDAO

func (*PartsDAO) AttachTablePartsTo

func (d *PartsDAO) AttachTablePartsTo(dstDB, dstTable, srcDB, srcTable string) error