db

type Config struct {
	Uri      string
	User     string
	Password string
	Path     string
	Logger   *logrus.Logger
}

type Entity struct {
	Id          uint64       `db:"id"`
	MessageType string       `db:"message_type"`
	SpaceType   string       `db:"space_type"`
	ReceiverId  uint64       `db:"receiver_id"`
	LogData     *string      `db:"log_data,omitempty"`
	CreateTime  sql.NullTime `db:"create_time"`
}

type Repository interface {
	UseDatabase()
	Insert(e Entity) (rowsAffected int)
	GetAll() (entities []Entity)
	GetDuplicatesJoin() (entities []Entity)
	GetDuplicatesCte() (entities []Entity)
	DeleteDuplicatesJoin() (rowsAffected int)
	DeleteDuplicatesCte() (rowsAffected int)
	Truncate() (rowsAffected int)
}