dao

Documentation

Index

• func InitMysqlDirectUpload(ctx context.Context)
• type InputDataDao
  • func NewInputDataDao(ctx context.Context) *InputDataDao
  • func (d *InputDataDao) BatchCreateInputData(in []*model.InputData) (err error)
  • func (d *InputDataDao) CreateInputData(in *model.InputData) (err error)
  • func (d *InputDataDao) ListInputData() (in []*model.InputData, err error)
  • func (d *InputDataDao) UpdateInputDataByIds(ids []int64) (err error)
• type MySqlDirectUpload
  • func NewMySqlDirectUpload(ctx context.Context, task *types.Task) *MySqlDirectUpload
  • func (d *MySqlDirectUpload) Finish()
  • func (d *MySqlDirectUpload) Push(records *model.InputData) int
  • func (d *MySqlDirectUpload) StreamUpload() (count int, err error)

Functions

func InitMysqlDirectUpload

func InitMysqlDirectUpload(ctx context.Context)

Types

type InputDataDao

type InputDataDao struct {
	*gorm.DB
}

func NewInputDataDao

func NewInputDataDao(ctx context.Context) *InputDataDao

func (*InputDataDao) BatchCreateInputData

func (d *InputDataDao) BatchCreateInputData(in []*model.InputData) (err error)

func (*InputDataDao) CreateInputData

func (d *InputDataDao) CreateInputData(in *model.InputData) (err error)

func (*InputDataDao) ListInputData

func (d *InputDataDao) ListInputData() (in []*model.InputData, err error)

func (*InputDataDao) UpdateInputDataByIds

func (d *InputDataDao) UpdateInputDataByIds(ids []int64) (err error)

type MySqlDirectUpload

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

var GobalMysqlDirectUpload *MySqlDirectUpload

func NewMySqlDirectUpload

func NewMySqlDirectUpload(ctx context.Context, task *types.Task) *MySqlDirectUpload

NewMySqlDirectUpload 新建一个上传的对象

func (*MySqlDirectUpload) Finish

func (d *MySqlDirectUpload) Finish()

func (*MySqlDirectUpload) Push

func (d *MySqlDirectUpload) Push(records *model.InputData) int

func (*MySqlDirectUpload) StreamUpload

func (d *MySqlDirectUpload) StreamUpload() (count int, err error)