database

Documentation

Overview

Package database is responsible for all database logic. It handles connecting to the database and performing queries.

Index

• type Database
  • func NewDatabase(driver, connectionString string) (*Database, error)
  • func (db *Database) CreateFileUpload(filename, sha256Sum string, uploadedAt time.Time) (*models.FileUpload, error)
  • func (db *Database) CreateJob(jobType models.JobType, uploadID uint) (*models.Job, error)
  • func (db *Database) CreateUpload(source, version, maintainer, changedBy string) (*models.Upload, error)
  • func (db *Database) GetAllFileUploadsByUploadID(uploadID uint) ([]*models.FileUpload, error)
  • func (db *Database) GetAllJobs() ([]*models.Job, error)
  • func (db *Database) GetAllUploads() ([]*models.Upload, error)
  • func (db *Database) GetFileUpload(id uint) (*models.FileUpload, error)
  • func (db *Database) GetFileUploadByFileNameSHASumCompleted(filename, sha256Sum string, completed bool) (*models.FileUpload, error)
  • func (db *Database) GetJob(id uint) (*models.Job, error)
  • func (db *Database) GetNextJob() (*models.Job, error)
  • func (db *Database) GetUpload(id uint) (*models.Upload, error)
  • func (db *Database) UpdateFileUpload(fileUpload *models.FileUpload) error
  • func (db *Database) UpdateJob(job *models.Job) error

Types

type Database

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

Database is an implementation of the app.Datastore interface

func NewDatabase

func NewDatabase(driver, connectionString string) (*Database, error)

NewDatabase creates a new database connection

func (*Database) CreateFileUpload

func (db *Database) CreateFileUpload(filename, sha256Sum string, uploadedAt time.Time) (*models.FileUpload, error)

CreateFileUpload will create a FileUpload

func (*Database) CreateJob

func (db *Database) CreateJob(jobType models.JobType, uploadID uint) (*models.Job, error)

CreateJob will create a job

func (*Database) CreateUpload

func (db *Database) CreateUpload(source, version, maintainer, changedBy string) (*models.Upload, error)

CreateUpload will create an upload

func (*Database) GetAllFileUploadsByUploadID

func (db *Database) GetAllFileUploadsByUploadID(uploadID uint) ([]*models.FileUpload, error)

GetAllFileUploadsByUploadID returns all file uploads for an Upload

func (*Database) GetAllJobs

func (db *Database) GetAllJobs() ([]*models.Job, error)

GetAllJobs returns all jobs

func (*Database) GetAllUploads

func (db *Database) GetAllUploads() ([]*models.Upload, error)

GetAllUploads returns all uploads

func (*Database) GetFileUpload

func (db *Database) GetFileUpload(id uint) (*models.FileUpload, error)

GetFileUpload returns the FileUpload with the given id

func (*Database) GetFileUploadByFileNameSHASumCompleted

func (db *Database) GetFileUploadByFileNameSHASumCompleted(filename, sha256Sum string, completed bool) (*models.FileUpload, error)

GetFileUploadByFileNameSHASumCompleted returns the first FileUpload that matches

func (*Database) GetJob

func (db *Database) GetJob(id uint) (*models.Job, error)

GetJob returns the Job with the given id

func (*Database) GetNextJob

func (db *Database) GetNextJob() (*models.Job, error)

GetNextJob will return the next job to run

func (*Database) GetUpload

func (db *Database) GetUpload(id uint) (*models.Upload, error)

GetUpload returns the Upload with the given id

func (*Database) UpdateFileUpload

func (db *Database) UpdateFileUpload(fileUpload *models.FileUpload) error

UpdateFileUpload will update a file upload

func (*Database) UpdateJob

func (db *Database) UpdateJob(job *models.Job) error

UpdateJob will update a job