sql

Documentation

Index

• type SqlRepository
  • func NewSqlRepository(dataBaseConnections *gorm.DB) *SqlRepository
  • func (r *SqlRepository) CheckDuplicate(ctx context.Context, userQuota, dataQuota string) (bool, error)
  • func (r *SqlRepository) Create(ctx context.Context, user entity.User) error
  • func (r *SqlRepository) GetData(ctx context.Context, dataQuota string) (entity.User, error)
  • func (r *SqlRepository) GetSync(ctx context.Context, date time.Time) ([]entity.User, error)
  • func (r *SqlRepository) GetUnSync() ([]entity.User, error)
  • func (r *SqlRepository) GetUser(ctx context.Context, userQuota string) (entity.User, error)
  • func (r *SqlRepository) Update(ctx context.Context, user entity.User) error

Types

type SqlRepository

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

func NewSqlRepository

func NewSqlRepository(dataBaseConnections *gorm.DB) *SqlRepository

func (*SqlRepository) CheckDuplicate

func (r *SqlRepository) CheckDuplicate(ctx context.Context, userQuota, dataQuota string) (bool, error)

func (*SqlRepository) Create

func (r *SqlRepository) Create(ctx context.Context, user entity.User) error

write

func (*SqlRepository) GetData

func (r *SqlRepository) GetData(ctx context.Context, dataQuota string) (entity.User, error)

func (*SqlRepository) GetSync

func (r *SqlRepository) GetSync(ctx context.Context, date time.Time) ([]entity.User, error)

func (*SqlRepository) GetUnSync

func (r *SqlRepository) GetUnSync() ([]entity.User, error)

func (*SqlRepository) GetUser

func (r *SqlRepository) GetUser(ctx context.Context, userQuota string) (entity.User, error)

read

func (*SqlRepository) Update

func (r *SqlRepository) Update(ctx context.Context, user entity.User) error