sqlite

Jun 3, 2024

Changes in this version

type Database

+ func (db *Database) ReInitialise() error

+ func (db *Database) RunAllMigrations() error

+ type Migrator struct

+ func NewMigrator(db *Database) (*Migrator, error)

+ func (m *Migrator) Close()

+ func (m *Migrator) CurrentSchemaVersion() uint

+ func (m *Migrator) RequiredSchemaVersion() uint

+ func (m *Migrator) RunMigration(ctx context.Context, newVersion uint) error

Mar 5, 2024

Changes in this version

+ const TimestampFormat

type BlobStore

+ func (qb *BlobStore) EntryExists(ctx context.Context, checksum string) (bool, error)

type BlobStoreOptions

+ SupplementaryPaths []string

type SceneStore

+ func (qb *SceneStore) AddO(ctx context.Context, id int, dates []time.Time) ([]time.Time, error)

+ func (qb *SceneStore) AddViews(ctx context.Context, id int, dates []time.Time) ([]time.Time, error)

+ func (qb *SceneStore) CountAllViews(ctx context.Context) (int, error)

+ func (qb *SceneStore) CountUniqueViews(ctx context.Context) (int, error)

+ func (qb *SceneStore) CountViews(ctx context.Context, id int) (int, error)

+ func (qb *SceneStore) DeleteAllViews(ctx context.Context, id int) (int, error)

+ func (qb *SceneStore) DeleteO(ctx context.Context, id int, dates []time.Time) ([]time.Time, error)

+ func (qb *SceneStore) DeleteViews(ctx context.Context, id int, dates []time.Time) ([]time.Time, error)

+ func (qb *SceneStore) GetAllOCount(ctx context.Context) (int, error)

+ func (qb *SceneStore) GetManyLastViewed(ctx context.Context, ids []int) ([]*time.Time, error)

+ func (qb *SceneStore) GetManyOCount(ctx context.Context, ids []int) ([]int, error)

+ func (qb *SceneStore) GetManyODates(ctx context.Context, ids []int) ([][]time.Time, error)

+ func (qb *SceneStore) GetManyViewCount(ctx context.Context, ids []int) ([]int, error)

+ func (qb *SceneStore) GetManyViewDates(ctx context.Context, ids []int) ([][]time.Time, error)

+ func (qb *SceneStore) GetOCount(ctx context.Context, id int) (int, error)

+ func (qb *SceneStore) GetODates(ctx context.Context, id int) ([]time.Time, error)

+ func (qb *SceneStore) GetUniqueOCount(ctx context.Context) (int, error)

+ func (qb *SceneStore) GetViewDates(ctx context.Context, id int) ([]time.Time, error)

+ func (qb *SceneStore) LastView(ctx context.Context, id int) (*time.Time, error)

+ func (qb *SceneStore) ResetO(ctx context.Context, id int) (int, error)

+ type UTCTimestamp struct

+ func (t UTCTimestamp) Value() (driver.Value, error)

Dec 27, 2023

Changes in this version

type Database

+ func (db *Database) Repository() models.Repository

type FileStore

+ func (qb *FileStore) DestroyFingerprints(ctx context.Context, fileID models.FileID, types []string) error

+ func (qb *FileStore) ModifyFingerprints(ctx context.Context, fileID models.FileID, fingerprints []models.Fingerprint) error

type ImageStore

+ func (qb *ImageStore) OCount(ctx context.Context) (int, error)

Oct 10, 2023

Changes in this version

type GalleryStore

+ func (qb *GalleryStore) GetURLs(ctx context.Context, galleryID int) ([]string, error)

type ImageStore

+ func (qb *ImageStore) GetURLs(ctx context.Context, imageID int) ([]string, error)

type TagStore

+ func (qb *TagStore) CountByChildTagID(ctx context.Context, childID int) (int, error)

+ func (qb *TagStore) CountByParentTagID(ctx context.Context, parentID int) (int, error)

Aug 11, 2023

Changes in this version

type Database

+ GalleryChapter *GalleryChapterStore

+ SavedFilter *SavedFilterStore

+ SceneMarker *SceneMarkerStore

+ func (db *Database) Analyze(ctx context.Context) error

+ func (db *Database) ExecSQL(ctx context.Context, query string, args []interface{}) (*int64, *int64, error)

+ func (db *Database) Optimise(ctx context.Context) error

+ func (db *Database) QuerySQL(ctx context.Context, query string, args []interface{}) ([]string, [][]interface{}, error)

+ type Date struct

+ Date time.Time

+ func (d *Date) Scan(value interface{}) error

+ func (d Date) Value() (driver.Value, error)

type FileStore

+ func (qb *FileStore) CountByFolderID(ctx context.Context, folderID file.FolderID) (int, error)

+ func (qb *FileStore) FindByFileInfo(ctx context.Context, info fs.FileInfo, size int64) ([]file.File, error)

+ type GalleryChapterStore struct

+ func NewGalleryChapterStore() *GalleryChapterStore

+ func (qb *GalleryChapterStore) Create(ctx context.Context, newObject *models.GalleryChapter) error

+ func (qb *GalleryChapterStore) Destroy(ctx context.Context, id int) error

+ func (qb *GalleryChapterStore) Find(ctx context.Context, id int) (*models.GalleryChapter, error)

+ func (qb *GalleryChapterStore) FindByGalleryID(ctx context.Context, galleryID int) ([]*models.GalleryChapter, error)

+ func (qb *GalleryChapterStore) FindMany(ctx context.Context, ids []int) ([]*models.GalleryChapter, error)

+ func (qb *GalleryChapterStore) Update(ctx context.Context, updatedObject *models.GalleryChapter) error

+ func (qb *GalleryChapterStore) UpdatePartial(ctx context.Context, id int, partial models.GalleryChapterPartial) (*models.GalleryChapter, error)

+ type MovieStore struct

+ func NewMovieStore(blobStore *BlobStore) *MovieStore

+ func (qb *MovieStore) All(ctx context.Context) ([]*models.Movie, error)

+ func (qb *MovieStore) Count(ctx context.Context) (int, error)

+ func (qb *MovieStore) CountByPerformerID(ctx context.Context, performerID int) (int, error)

+ func (qb *MovieStore) CountByStudioID(ctx context.Context, studioID int) (int, error)

+ func (qb *MovieStore) Create(ctx context.Context, newObject *models.Movie) error

+ func (qb *MovieStore) Destroy(ctx context.Context, id int) error

+ func (qb *MovieStore) DestroyImage(ctx context.Context, id int, blobCol string) error

+ func (qb *MovieStore) Find(ctx context.Context, id int) (*models.Movie, error)

+ func (qb *MovieStore) FindByName(ctx context.Context, name string, nocase bool) (*models.Movie, error)

+ func (qb *MovieStore) FindByNames(ctx context.Context, names []string, nocase bool) ([]*models.Movie, error)

+ func (qb *MovieStore) FindByPerformerID(ctx context.Context, performerID int) ([]*models.Movie, error)

+ func (qb *MovieStore) FindByStudioID(ctx context.Context, studioID int) ([]*models.Movie, error)

+ func (qb *MovieStore) FindMany(ctx context.Context, ids []int) ([]*models.Movie, error)

+ func (qb *MovieStore) GetBackImage(ctx context.Context, movieID int) ([]byte, error)

+ func (qb *MovieStore) GetFrontImage(ctx context.Context, movieID int) ([]byte, error)

+ func (qb *MovieStore) GetImage(ctx context.Context, id int, blobCol string) ([]byte, error)

+ func (qb *MovieStore) HasBackImage(ctx context.Context, movieID int) (bool, error)

+ func (qb *MovieStore) HasFrontImage(ctx context.Context, movieID int) (bool, error)

+ func (qb *MovieStore) HasImage(ctx context.Context, id int, blobCol string) (bool, error)

+ func (qb *MovieStore) Query(ctx context.Context, movieFilter *models.MovieFilterType, ...) ([]*models.Movie, int, error)

+ func (qb *MovieStore) QueryCount(ctx context.Context, movieFilter *models.MovieFilterType, ...) (int, error)

+ func (qb *MovieStore) Update(ctx context.Context, updatedObject *models.Movie) error

+ func (qb *MovieStore) UpdateBackImage(ctx context.Context, movieID int, backImage []byte) error

+ func (qb *MovieStore) UpdateFrontImage(ctx context.Context, movieID int, frontImage []byte) error

+ func (qb *MovieStore) UpdateImage(ctx context.Context, id int, blobCol string, image []byte) error

+ func (qb *MovieStore) UpdatePartial(ctx context.Context, id int, partial models.MoviePartial) (*models.Movie, error)

+ type NullDate struct

+ Date time.Time

+ Valid bool

+ func NullDateFromDatePtr(d *models.Date) NullDate

+ func (d *NullDate) DatePtr() *models.Date

+ func (d *NullDate) Scan(value interface{}) error

+ func (d NullDate) Value() (driver.Value, error)

+ type NullTimestamp struct

+ Timestamp time.Time

+ Valid bool

+ func NullTimestampFromTimePtr(t *time.Time) NullTimestamp

+ func (t *NullTimestamp) Scan(value interface{}) error

+ func (t NullTimestamp) TimePtr() *time.Time

+ func (t NullTimestamp) Value() (driver.Value, error)

+ type SavedFilterStore struct

+ func NewSavedFilterStore() *SavedFilterStore

+ func (qb *SavedFilterStore) All(ctx context.Context) ([]*models.SavedFilter, error)

+ func (qb *SavedFilterStore) Create(ctx context.Context, newObject *models.SavedFilter) error

+ func (qb *SavedFilterStore) Destroy(ctx context.Context, id int) error

+ func (qb *SavedFilterStore) Find(ctx context.Context, id int) (*models.SavedFilter, error)

+ func (qb *SavedFilterStore) FindByMode(ctx context.Context, mode models.FilterMode) ([]*models.SavedFilter, error)

+ func (qb *SavedFilterStore) FindDefault(ctx context.Context, mode models.FilterMode) (*models.SavedFilter, error)

+ func (qb *SavedFilterStore) FindMany(ctx context.Context, ids []int, ignoreNotFound bool) ([]*models.SavedFilter, error)

+ func (qb *SavedFilterStore) SetDefault(ctx context.Context, obj *models.SavedFilter) error

+ func (qb *SavedFilterStore) Update(ctx context.Context, updatedObject *models.SavedFilter) error

+ type SceneMarkerStore struct

+ func NewSceneMarkerStore() *SceneMarkerStore

+ func (qb *SceneMarkerStore) All(ctx context.Context) ([]*models.SceneMarker, error)

+ func (qb *SceneMarkerStore) Count(ctx context.Context) (int, error)

+ func (qb *SceneMarkerStore) CountByTagID(ctx context.Context, tagID int) (int, error)

+ func (qb *SceneMarkerStore) Create(ctx context.Context, newObject *models.SceneMarker) error

+ func (qb *SceneMarkerStore) Destroy(ctx context.Context, id int) error

+ func (qb *SceneMarkerStore) Find(ctx context.Context, id int) (*models.SceneMarker, error)

+ func (qb *SceneMarkerStore) FindBySceneID(ctx context.Context, sceneID int) ([]*models.SceneMarker, error)

+ func (qb *SceneMarkerStore) FindMany(ctx context.Context, ids []int) ([]*models.SceneMarker, error)

+ func (qb *SceneMarkerStore) GetMarkerStrings(ctx context.Context, q *string, sort *string) ([]*models.MarkerStringsResultType, error)

+ func (qb *SceneMarkerStore) GetTagIDs(ctx context.Context, id int) ([]int, error)

+ func (qb *SceneMarkerStore) Query(ctx context.Context, sceneMarkerFilter *models.SceneMarkerFilterType, ...) ([]*models.SceneMarker, int, error)

+ func (qb *SceneMarkerStore) QueryCount(ctx context.Context, sceneMarkerFilter *models.SceneMarkerFilterType, ...) (int, error)

+ func (qb *SceneMarkerStore) Update(ctx context.Context, updatedObject *models.SceneMarker) error

+ func (qb *SceneMarkerStore) UpdatePartial(ctx context.Context, id int, partial models.SceneMarkerPartial) (*models.SceneMarker, error)

+ func (qb *SceneMarkerStore) UpdateTags(ctx context.Context, id int, tagIDs []int) error

+ func (qb *SceneMarkerStore) Wall(ctx context.Context, q *string) ([]*models.SceneMarker, error)

type SceneStore

+ func (qb *SceneStore) GetURLs(ctx context.Context, sceneID int) ([]string, error)

+ func (qb *SceneStore) OCount(ctx context.Context) (int, error)

+ func (qb *SceneStore) PlayCount(ctx context.Context) (int, error)

+ func (qb *SceneStore) PlayDuration(ctx context.Context) (float64, error)

+ func (qb *SceneStore) QueryCount(ctx context.Context, sceneFilter *models.SceneFilterType, ...) (int, error)

+ func (qb *SceneStore) UniqueScenePlayCount(ctx context.Context) (int, error)

+ type StudioStore struct

+ func NewStudioStore(blobStore *BlobStore) *StudioStore

+ func (qb *StudioStore) All(ctx context.Context) ([]*models.Studio, error)

+ func (qb *StudioStore) Count(ctx context.Context) (int, error)

+ func (qb *StudioStore) Create(ctx context.Context, newObject *models.Studio) error

+ func (qb *StudioStore) Destroy(ctx context.Context, id int) error

+ func (qb *StudioStore) DestroyImage(ctx context.Context, id int, blobCol string) error

+ func (qb *StudioStore) Find(ctx context.Context, id int) (*models.Studio, error)

+ func (qb *StudioStore) FindByName(ctx context.Context, name string, nocase bool) (*models.Studio, error)

+ func (qb *StudioStore) FindBySceneID(ctx context.Context, sceneID int) (*models.Studio, error)

+ func (qb *StudioStore) FindByStashID(ctx context.Context, stashID models.StashID) ([]*models.Studio, error)

+ func (qb *StudioStore) FindByStashIDStatus(ctx context.Context, hasStashID bool, stashboxEndpoint string) ([]*models.Studio, error)

+ func (qb *StudioStore) FindChildren(ctx context.Context, id int) ([]*models.Studio, error)

+ func (qb *StudioStore) FindMany(ctx context.Context, ids []int) ([]*models.Studio, error)

+ func (qb *StudioStore) GetAliases(ctx context.Context, studioID int) ([]string, error)

+ func (qb *StudioStore) GetImage(ctx context.Context, studioID int) ([]byte, error)

+ func (qb *StudioStore) GetStashIDs(ctx context.Context, studioID int) ([]models.StashID, error)

+ func (qb *StudioStore) HasImage(ctx context.Context, studioID int) (bool, error)

+ func (qb *StudioStore) Query(ctx context.Context, studioFilter *models.StudioFilterType, ...) ([]*models.Studio, int, error)

+ func (qb *StudioStore) QueryForAutoTag(ctx context.Context, words []string) ([]*models.Studio, error)

+ func (qb *StudioStore) Update(ctx context.Context, updatedObject *models.Studio) error

+ func (qb *StudioStore) UpdateImage(ctx context.Context, studioID int, image []byte) error

+ func (qb *StudioStore) UpdatePartial(ctx context.Context, input models.StudioPartial) (*models.Studio, error)

+ type TagStore struct

+ func NewTagStore(blobStore *BlobStore) *TagStore

+ func (qb *TagStore) All(ctx context.Context) ([]*models.Tag, error)

+ func (qb *TagStore) Count(ctx context.Context) (int, error)

+ func (qb *TagStore) Create(ctx context.Context, newObject *models.Tag) error

+ func (qb *TagStore) Destroy(ctx context.Context, id int) error

+ func (qb *TagStore) DestroyImage(ctx context.Context, id int, blobCol string) error

+ func (qb *TagStore) Find(ctx context.Context, id int) (*models.Tag, error)

+ func (qb *TagStore) FindAllAncestors(ctx context.Context, tagID int, excludeIDs []int) ([]*models.TagPath, error)

+ func (qb *TagStore) FindAllDescendants(ctx context.Context, tagID int, excludeIDs []int) ([]*models.TagPath, error)

+ func (qb *TagStore) FindByChildTagID(ctx context.Context, parentID int) ([]*models.Tag, error)

+ func (qb *TagStore) FindByGalleryID(ctx context.Context, galleryID int) ([]*models.Tag, error)

+ func (qb *TagStore) FindByImageID(ctx context.Context, imageID int) ([]*models.Tag, error)

+ func (qb *TagStore) FindByName(ctx context.Context, name string, nocase bool) (*models.Tag, error)

+ func (qb *TagStore) FindByNames(ctx context.Context, names []string, nocase bool) ([]*models.Tag, error)

+ func (qb *TagStore) FindByParentTagID(ctx context.Context, parentID int) ([]*models.Tag, error)

+ func (qb *TagStore) FindByPerformerID(ctx context.Context, performerID int) ([]*models.Tag, error)

+ func (qb *TagStore) FindBySceneID(ctx context.Context, sceneID int) ([]*models.Tag, error)

+ func (qb *TagStore) FindBySceneMarkerID(ctx context.Context, sceneMarkerID int) ([]*models.Tag, error)

+ func (qb *TagStore) FindMany(ctx context.Context, ids []int) ([]*models.Tag, error)

+ func (qb *TagStore) GetAliases(ctx context.Context, tagID int) ([]string, error)

+ func (qb *TagStore) GetImage(ctx context.Context, tagID int) ([]byte, error)

+ func (qb *TagStore) HasImage(ctx context.Context, tagID int) (bool, error)

+ func (qb *TagStore) Merge(ctx context.Context, source []int, destination int) error

+ func (qb *TagStore) Query(ctx context.Context, tagFilter *models.TagFilterType, ...) ([]*models.Tag, int, error)

+ func (qb *TagStore) QueryForAutoTag(ctx context.Context, words []string) ([]*models.Tag, error)

+ func (qb *TagStore) Update(ctx context.Context, updatedObject *models.Tag) error

+ func (qb *TagStore) UpdateAliases(ctx context.Context, tagID int, aliases []string) error

+ func (qb *TagStore) UpdateChildTags(ctx context.Context, tagID int, childIDs []int) error

+ func (qb *TagStore) UpdateImage(ctx context.Context, tagID int, image []byte) error

+ func (qb *TagStore) UpdateParentTags(ctx context.Context, tagID int, parentIDs []int) error

+ func (qb *TagStore) UpdatePartial(ctx context.Context, id int, partial models.TagPartial) (*models.Tag, error)

+ type Timestamp struct

+ Timestamp time.Time

+ func (t *Timestamp) Scan(value interface{}) error

+ func (t Timestamp) Value() (driver.Value, error)

Jun 13, 2023

Changes in this version

type ImageStore

+ func (qb *ImageStore) OCountByPerformerID(ctx context.Context, performerID int) (int, error)

type SceneStore

+ func (qb *SceneStore) OCountByPerformerID(ctx context.Context, performerID int) (int, error)

Mar 29, 2023

Changes in this version

+ var GalleryChapterReaderWriter = &galleryChapterQueryBuilder

+ type BlobStore struct

+ func NewBlobStore(options BlobStoreOptions) *BlobStore

+ func (qb *BlobStore) Count(ctx context.Context) (int, error)

+ func (qb *BlobStore) Delete(ctx context.Context, checksum string) error

+ func (qb *BlobStore) FindBlobs(ctx context.Context, n uint, lastChecksum string) ([]string, error)

+ func (qb *BlobStore) MigrateBlob(ctx context.Context, checksum string, deleteOld bool) error

+ func (qb *BlobStore) Read(ctx context.Context, checksum string) ([]byte, error)

+ func (qb *BlobStore) Write(ctx context.Context, data []byte) (string, error)

+ type BlobStoreOptions struct

+ Path string

+ UseDatabase bool

+ UseFilesystem bool

+ type ChecksumBlobNotExistError struct

+ Checksum string

+ func (e *ChecksumBlobNotExistError) Error() string

+ type ChecksumNotFoundError struct

+ Checksum string

+ func (e *ChecksumNotFoundError) Error() string

+ type CustomSQLiteConn struct

+ func (c *CustomSQLiteConn) Close() error

+ type CustomSQLiteDriver struct

+ func (d *CustomSQLiteDriver) Open(dsn string) (driver.Conn, error)

type Database

+ Blobs *BlobStore

+ Movie *movieQueryBuilder

+ Studio *studioQueryBuilder

+ Tag *tagQueryBuilder

+ func (db *Database) SetBlobStoreOptions(options BlobStoreOptions)

+ func (db *Database) Vacuum(ctx context.Context) error

type PerformerStore

+ func (qb *PerformerStore) HasImage(ctx context.Context, id int, blobCol string) (bool, error)

type SceneStore

+ func (qb *SceneStore) DestroyImage(ctx context.Context, id int, blobCol string) error

+ func (qb *SceneStore) GetImage(ctx context.Context, id int, blobCol string) ([]byte, error)

+ func (qb *SceneStore) HasCover(ctx context.Context, sceneID int) (bool, error)

+ func (qb *SceneStore) HasImage(ctx context.Context, id int, blobCol string) (bool, error)

+ func (qb *SceneStore) UpdateImage(ctx context.Context, id int, blobCol string, image []byte) error

Feb 13, 2023

Changes in this version

+ type Anonymiser struct

+ func NewAnonymiser(db *Database, outPath string) (*Anonymiser, error)

+ func (db *Anonymiser) Anonymise(ctx context.Context) error

type Database

+ func (db *Database) Anonymise(outPath string) error

+ func (db *Database) AnonymousDatabasePath(backupDirectoryPath string) string

+ func (db *Database) Remove() error

type FileStore

+ func (qb *FileStore) FindAllByPath(ctx context.Context, p string) ([]file.File, error)

type PerformerStore

+ func (qb *PerformerStore) GetAliases(ctx context.Context, performerID int) ([]string, error)

+ func (qb *PerformerStore) QueryCount(ctx context.Context, performerFilter *models.PerformerFilterType, ...) (int, error)

Nov 29, 2022

Changes in this version

type Database

+ Performer *PerformerStore

+ type PerformerStore struct

+ func NewPerformerStore() *PerformerStore

+ func (qb *PerformerStore) All(ctx context.Context) ([]*models.Performer, error)

+ func (qb *PerformerStore) Count(ctx context.Context) (int, error)

+ func (qb *PerformerStore) CountByTagID(ctx context.Context, tagID int) (int, error)

+ func (qb *PerformerStore) Create(ctx context.Context, newObject *models.Performer) error

+ func (qb *PerformerStore) Destroy(ctx context.Context, id int) error

+ func (qb *PerformerStore) DestroyImage(ctx context.Context, performerID int) error

+ func (qb *PerformerStore) Find(ctx context.Context, id int) (*models.Performer, error)

+ func (qb *PerformerStore) FindByGalleryID(ctx context.Context, galleryID int) ([]*models.Performer, error)

+ func (qb *PerformerStore) FindByImageID(ctx context.Context, imageID int) ([]*models.Performer, error)

+ func (qb *PerformerStore) FindByNames(ctx context.Context, names []string, nocase bool) ([]*models.Performer, error)

+ func (qb *PerformerStore) FindBySceneID(ctx context.Context, sceneID int) ([]*models.Performer, error)

+ func (qb *PerformerStore) FindByStashID(ctx context.Context, stashID models.StashID) ([]*models.Performer, error)

+ func (qb *PerformerStore) FindByStashIDStatus(ctx context.Context, hasStashID bool, stashboxEndpoint string) ([]*models.Performer, error)

+ func (qb *PerformerStore) FindMany(ctx context.Context, ids []int) ([]*models.Performer, error)

+ func (qb *PerformerStore) GetImage(ctx context.Context, performerID int) ([]byte, error)

+ func (qb *PerformerStore) GetStashIDs(ctx context.Context, performerID int) ([]models.StashID, error)

+ func (qb *PerformerStore) GetTagIDs(ctx context.Context, id int) ([]int, error)

+ func (qb *PerformerStore) Query(ctx context.Context, performerFilter *models.PerformerFilterType, ...) ([]*models.Performer, int, error)

+ func (qb *PerformerStore) QueryForAutoTag(ctx context.Context, words []string) ([]*models.Performer, error)

+ func (qb *PerformerStore) Update(ctx context.Context, updatedObject *models.Performer) error

+ func (qb *PerformerStore) UpdateImage(ctx context.Context, performerID int, image []byte) error

+ func (qb *PerformerStore) UpdatePartial(ctx context.Context, id int, updatedObject models.PerformerPartial) (*models.Performer, error)

+ func (qb *PerformerStore) UpdateStashIDs(ctx context.Context, performerID int, stashIDs []models.StashID) error

+ func (qb *PerformerStore) UpdateTags(ctx context.Context, id int, tagIDs []int) error

type SceneStore

+ func (qb *SceneStore) AssignFiles(ctx context.Context, sceneID int, fileIDs []file.ID) error

+ func (qb *SceneStore) IncrementWatchCount(ctx context.Context, id int) (int, error)

+ func (qb *SceneStore) SaveActivity(ctx context.Context, id int, resumeTime *float64, playDuration *float64) (bool, error)

Oct 18, 2022

Changes in this version

+ var ErrDatabaseNotInitialized = errors.New("database not initialized")

+ var FingerprintReaderWriter = &fingerprintQueryBuilder

+ var MovieReaderWriter = &movieQueryBuilder

+ var PerformerReaderWriter = &performerQueryBuilder

+ var SavedFilterReaderWriter = &savedFilterQueryBuilder

+ var SceneMarkerReaderWriter = &sceneMarkerQueryBuilder

+ var ScrapedItemReaderWriter = &scrapedItemQueryBuilder

+ var StudioReaderWriter = &studioQueryBuilder

+ var TagReaderWriter = &tagQueryBuilder

+ func RegisterPostMigration(schemaVersion uint, fn customMigrationFunc)

+ func RegisterPreMigration(schemaVersion uint, fn customMigrationFunc)

+ type Database struct

+ File *FileStore

+ Folder *FolderStore

+ Gallery *GalleryStore

+ Image *ImageStore

+ Scene *SceneStore

+ func NewDatabase() *Database

+ func (db *Database) AppSchemaVersion() uint

+ func (db *Database) Backup(backupPath string) error

+ func (db *Database) Begin(ctx context.Context) (context.Context, error)

+ func (db *Database) Close() error

+ func (db *Database) Commit(ctx context.Context) error

+ func (db *Database) DatabaseBackupPath(backupDirectoryPath string) string

+ func (db *Database) DatabasePath() string

+ func (db *Database) IsLocked(err error) bool

+ func (db *Database) Open(dbPath string) error

+ func (db *Database) Ready() error

+ func (db *Database) Reset() error

+ func (db *Database) RestoreFromBackup(backupPath string) error

+ func (db *Database) Rollback(ctx context.Context) error

+ func (db *Database) RunMigrations() error

+ func (db *Database) TxnRepository() models.Repository

+ func (db *Database) Version() uint

+ func (db *Database) WithDatabase(ctx context.Context) (context.Context, error)

+ type FileStore struct

+ func NewFileStore() *FileStore

+ func (qb *FileStore) CountAllInPaths(ctx context.Context, p []string) (int, error)

+ func (qb *FileStore) Create(ctx context.Context, f file.File) error

+ func (qb *FileStore) Destroy(ctx context.Context, id file.ID) error

+ func (qb *FileStore) Find(ctx context.Context, ids ...file.ID) ([]file.File, error)

+ func (qb *FileStore) FindAllInPaths(ctx context.Context, p []string, limit, offset int) ([]file.File, error)

+ func (qb *FileStore) FindByFingerprint(ctx context.Context, fp file.Fingerprint) ([]file.File, error)

+ func (qb *FileStore) FindByPath(ctx context.Context, p string) (file.File, error)

+ func (qb *FileStore) FindByZipFileID(ctx context.Context, zipFileID file.ID) ([]file.File, error)

+ func (qb *FileStore) GetCaptions(ctx context.Context, fileID file.ID) ([]*models.VideoCaption, error)

+ func (qb *FileStore) IsPrimary(ctx context.Context, fileID file.ID) (bool, error)

+ func (qb *FileStore) Query(ctx context.Context, options models.FileQueryOptions) (*models.FileQueryResult, error)

+ func (qb *FileStore) Update(ctx context.Context, f file.File) error

+ func (qb *FileStore) UpdateCaptions(ctx context.Context, fileID file.ID, captions []*models.VideoCaption) error

+ type FolderStore struct

+ func NewFolderStore() *FolderStore

+ func (qb *FolderStore) CountAllInPaths(ctx context.Context, p []string) (int, error)

+ func (qb *FolderStore) Create(ctx context.Context, f *file.Folder) error

+ func (qb *FolderStore) Destroy(ctx context.Context, id file.FolderID) error

+ func (qb *FolderStore) Find(ctx context.Context, id file.FolderID) (*file.Folder, error)

+ func (qb *FolderStore) FindAllInPaths(ctx context.Context, p []string, limit, offset int) ([]*file.Folder, error)

+ func (qb *FolderStore) FindByParentFolderID(ctx context.Context, parentFolderID file.FolderID) ([]*file.Folder, error)

+ func (qb *FolderStore) FindByPath(ctx context.Context, p string) (*file.Folder, error)

+ func (qb *FolderStore) FindByZipFileID(ctx context.Context, zipFileID file.ID) ([]*file.Folder, error)

+ func (qb *FolderStore) Update(ctx context.Context, updatedObject *file.Folder) error

+ type GalleryStore struct

+ func NewGalleryStore(fileStore *FileStore, folderStore *FolderStore) *GalleryStore

+ func (qb *GalleryStore) AddFileID(ctx context.Context, id int, fileID file.ID) error

+ func (qb *GalleryStore) AddImages(ctx context.Context, galleryID int, imageIDs ...int) error

+ func (qb *GalleryStore) All(ctx context.Context) ([]*models.Gallery, error)

+ func (qb *GalleryStore) Count(ctx context.Context) (int, error)

+ func (qb *GalleryStore) CountByFileID(ctx context.Context, fileID file.ID) (int, error)

+ func (qb *GalleryStore) CountByImageID(ctx context.Context, imageID int) (int, error)

+ func (qb *GalleryStore) Create(ctx context.Context, newObject *models.Gallery, fileIDs []file.ID) error

+ func (qb *GalleryStore) Destroy(ctx context.Context, id int) error

+ func (qb *GalleryStore) Find(ctx context.Context, id int) (*models.Gallery, error)

+ func (qb *GalleryStore) FindByChecksum(ctx context.Context, checksum string) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindByChecksums(ctx context.Context, checksums []string) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindByFileID(ctx context.Context, fileID file.ID) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindByFingerprints(ctx context.Context, fp []file.Fingerprint) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindByFolderID(ctx context.Context, folderID file.FolderID) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindByImageID(ctx context.Context, imageID int) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindByPath(ctx context.Context, p string) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindBySceneID(ctx context.Context, sceneID int) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindMany(ctx context.Context, ids []int) ([]*models.Gallery, error)

+ func (qb *GalleryStore) FindUserGalleryByTitle(ctx context.Context, title string) ([]*models.Gallery, error)

+ func (qb *GalleryStore) GetFiles(ctx context.Context, id int) ([]file.File, error)

+ func (qb *GalleryStore) GetImageIDs(ctx context.Context, galleryID int) ([]int, error)

+ func (qb *GalleryStore) GetManyFileIDs(ctx context.Context, ids []int) ([][]file.ID, error)

+ func (qb *GalleryStore) GetPerformerIDs(ctx context.Context, id int) ([]int, error)

+ func (qb *GalleryStore) GetSceneIDs(ctx context.Context, id int) ([]int, error)

+ func (qb *GalleryStore) GetTagIDs(ctx context.Context, id int) ([]int, error)

+ func (qb *GalleryStore) Query(ctx context.Context, galleryFilter *models.GalleryFilterType, ...) ([]*models.Gallery, int, error)

+ func (qb *GalleryStore) QueryCount(ctx context.Context, galleryFilter *models.GalleryFilterType, ...) (int, error)

+ func (qb *GalleryStore) RemoveImages(ctx context.Context, galleryID int, imageIDs ...int) error

+ func (qb *GalleryStore) Update(ctx context.Context, updatedObject *models.Gallery) error

+ func (qb *GalleryStore) UpdateImages(ctx context.Context, galleryID int, imageIDs []int) error

+ func (qb *GalleryStore) UpdatePartial(ctx context.Context, id int, partial models.GalleryPartial) (*models.Gallery, error)

+ type ImageStore struct

+ func NewImageStore(fileStore *FileStore) *ImageStore

+ func (qb *ImageStore) AddFileID(ctx context.Context, id int, fileID file.ID) error

+ func (qb *ImageStore) All(ctx context.Context) ([]*models.Image, error)

+ func (qb *ImageStore) Count(ctx context.Context) (int, error)

+ func (qb *ImageStore) CountByFileID(ctx context.Context, fileID file.ID) (int, error)

+ func (qb *ImageStore) CountByGalleryID(ctx context.Context, galleryID int) (int, error)

+ func (qb *ImageStore) Create(ctx context.Context, newObject *models.ImageCreateInput) error

+ func (qb *ImageStore) DecrementOCounter(ctx context.Context, id int) (int, error)

+ func (qb *ImageStore) Destroy(ctx context.Context, id int) error

+ func (qb *ImageStore) Find(ctx context.Context, id int) (*models.Image, error)

+ func (qb *ImageStore) FindByChecksum(ctx context.Context, checksum string) ([]*models.Image, error)

+ func (qb *ImageStore) FindByFileID(ctx context.Context, fileID file.ID) ([]*models.Image, error)

+ func (qb *ImageStore) FindByFingerprints(ctx context.Context, fp []file.Fingerprint) ([]*models.Image, error)

+ func (qb *ImageStore) FindByFolderID(ctx context.Context, folderID file.FolderID) ([]*models.Image, error)

+ func (qb *ImageStore) FindByGalleryID(ctx context.Context, galleryID int) ([]*models.Image, error)

+ func (qb *ImageStore) FindByZipFileID(ctx context.Context, zipFileID file.ID) ([]*models.Image, error)

+ func (qb *ImageStore) FindMany(ctx context.Context, ids []int) ([]*models.Image, error)

+ func (qb *ImageStore) GetFiles(ctx context.Context, id int) ([]*file.ImageFile, error)

+ func (qb *ImageStore) GetGalleryIDs(ctx context.Context, imageID int) ([]int, error)

+ func (qb *ImageStore) GetManyFileIDs(ctx context.Context, ids []int) ([][]file.ID, error)

+ func (qb *ImageStore) GetPerformerIDs(ctx context.Context, imageID int) ([]int, error)

+ func (qb *ImageStore) GetTagIDs(ctx context.Context, imageID int) ([]int, error)

+ func (qb *ImageStore) IncrementOCounter(ctx context.Context, id int) (int, error)

+ func (qb *ImageStore) Query(ctx context.Context, options models.ImageQueryOptions) (*models.ImageQueryResult, error)

+ func (qb *ImageStore) QueryCount(ctx context.Context, imageFilter *models.ImageFilterType, ...) (int, error)

+ func (qb *ImageStore) ResetOCounter(ctx context.Context, id int) (int, error)

+ func (qb *ImageStore) Size(ctx context.Context) (float64, error)

+ func (qb *ImageStore) Update(ctx context.Context, updatedObject *models.Image) error

+ func (qb *ImageStore) UpdatePartial(ctx context.Context, id int, partial models.ImagePartial) (*models.Image, error)

+ func (qb *ImageStore) UpdatePerformers(ctx context.Context, imageID int, performerIDs []int) error

+ func (qb *ImageStore) UpdateTags(ctx context.Context, imageID int, tagIDs []int) error

+ type MigrationNeededError struct

+ CurrentSchemaVersion uint

+ RequiredSchemaVersion uint

+ func (e *MigrationNeededError) Error() string

+ type MismatchedSchemaVersionError struct

+ CurrentSchemaVersion uint

+ RequiredSchemaVersion uint

+ func (e *MismatchedSchemaVersionError) Error() string

+ type NotFoundError struct

+ ID int

+ Table string

+ func (e *NotFoundError) Error() string

+ type SceneStore struct

+ func NewSceneStore(fileStore *FileStore) *SceneStore

+ func (qb *SceneStore) AddFileID(ctx context.Context, id int, fileID file.ID) error

+ func (qb *SceneStore) AddGalleryIDs(ctx context.Context, sceneID int, galleryIDs []int) error

+ func (qb *SceneStore) All(ctx context.Context) ([]*models.Scene, error)

+ func (qb *SceneStore) Count(ctx context.Context) (int, error)

+ func (qb *SceneStore) CountByFileID(ctx context.Context, fileID file.ID) (int, error)

+ func (qb *SceneStore) CountByMovieID(ctx context.Context, movieID int) (int, error)

+ func (qb *SceneStore) CountByPerformerID(ctx context.Context, performerID int) (int, error)

+ func (qb *SceneStore) CountByStudioID(ctx context.Context, studioID int) (int, error)

+ func (qb *SceneStore) CountByTagID(ctx context.Context, tagID int) (int, error)

+ func (qb *SceneStore) CountMissingChecksum(ctx context.Context) (int, error)

+ func (qb *SceneStore) CountMissingOSHash(ctx context.Context) (int, error)

+ func (qb *SceneStore) Create(ctx context.Context, newObject *models.Scene, fileIDs []file.ID) error

+ func (qb *SceneStore) DecrementOCounter(ctx context.Context, id int) (int, error)

+ func (qb *SceneStore) Destroy(ctx context.Context, id int) error

+ func (qb *SceneStore) DestroyCover(ctx context.Context, sceneID int) error

+ func (qb *SceneStore) Duration(ctx context.Context) (float64, error)

+ func (qb *SceneStore) Find(ctx context.Context, id int) (*models.Scene, error)

+ func (qb *SceneStore) FindByChecksum(ctx context.Context, checksum string) ([]*models.Scene, error)

+ func (qb *SceneStore) FindByFileID(ctx context.Context, fileID file.ID) ([]*models.Scene, error)

+ func (qb *SceneStore) FindByFingerprints(ctx context.Context, fp []file.Fingerprint) ([]*models.Scene, error)

+ func (qb *SceneStore) FindByGalleryID(ctx context.Context, galleryID int) ([]*models.Scene, error)

+ func (qb *SceneStore) FindByMovieID(ctx context.Context, movieID int) ([]*models.Scene, error)

+ func (qb *SceneStore) FindByOSHash(ctx context.Context, oshash string) ([]*models.Scene, error)

+ func (qb *SceneStore) FindByPath(ctx context.Context, p string) ([]*models.Scene, error)

+ func (qb *SceneStore) FindByPerformerID(ctx context.Context, performerID int) ([]*models.Scene, error)

+ func (qb *SceneStore) FindByPrimaryFileID(ctx context.Context, fileID file.ID) ([]*models.Scene, error)

+ func (qb *SceneStore) FindDuplicates(ctx context.Context, distance int) ([][]*models.Scene, error)

+ func (qb *SceneStore) FindMany(ctx context.Context, ids []int) ([]*models.Scene, error)

+ func (qb *SceneStore) GetCover(ctx context.Context, sceneID int) ([]byte, error)

+ func (qb *SceneStore) GetFiles(ctx context.Context, id int) ([]*file.VideoFile, error)

+ func (qb *SceneStore) GetGalleryIDs(ctx context.Context, id int) ([]int, error)

+ func (qb *SceneStore) GetManyFileIDs(ctx context.Context, ids []int) ([][]file.ID, error)

+ func (qb *SceneStore) GetMovies(ctx context.Context, id int) (ret []models.MoviesScenes, err error)

+ func (qb *SceneStore) GetPerformerIDs(ctx context.Context, id int) ([]int, error)

+ func (qb *SceneStore) GetStashIDs(ctx context.Context, sceneID int) ([]models.StashID, error)

+ func (qb *SceneStore) GetTagIDs(ctx context.Context, id int) ([]int, error)

+ func (qb *SceneStore) IncrementOCounter(ctx context.Context, id int) (int, error)

+ func (qb *SceneStore) Query(ctx context.Context, options models.SceneQueryOptions) (*models.SceneQueryResult, error)

+ func (qb *SceneStore) ResetOCounter(ctx context.Context, id int) (int, error)

+ func (qb *SceneStore) Size(ctx context.Context) (float64, error)

+ func (qb *SceneStore) Update(ctx context.Context, updatedObject *models.Scene) error

+ func (qb *SceneStore) UpdateCover(ctx context.Context, sceneID int, image []byte) error

+ func (qb *SceneStore) UpdatePartial(ctx context.Context, id int, partial models.ScenePartial) (*models.Scene, error)

+ func (qb *SceneStore) Wall(ctx context.Context, q *string) ([]*models.Scene, error)

Jul 1, 2021

Changes in this version

+ func NewSavedFilterReaderWriter(tx dbi) *savedFilterQueryBuilder

type ReadTransaction

+ func (t *ReadTransaction) SavedFilter() models.SavedFilterReader

Feb 22, 2021

Changes in this version

+ func NewGalleryReaderWriter(tx dbi) *galleryQueryBuilder

+ func NewImageReaderWriter(tx dbi) *imageQueryBuilder

+ func NewMovieReaderWriter(tx dbi) *movieQueryBuilder

+ func NewPerformerReaderWriter(tx dbi) *performerQueryBuilder

+ func NewSceneMarkerReaderWriter(tx dbi) *sceneMarkerQueryBuilder

+ func NewSceneReaderWriter(tx dbi) *sceneQueryBuilder

+ func NewScrapedItemReaderWriter(tx dbi) *scrapedItemQueryBuilder

+ func NewStudioReaderWriter(tx dbi) *studioQueryBuilder

+ func NewTagReaderWriter(tx dbi) *tagQueryBuilder

+ type ReadTransaction struct

+ func (t *ReadTransaction) Begin() error

+ func (t *ReadTransaction) Commit() error

+ func (t *ReadTransaction) Gallery() models.GalleryReader

+ func (t *ReadTransaction) Image() models.ImageReader

+ func (t *ReadTransaction) Movie() models.MovieReader

+ func (t *ReadTransaction) Performer() models.PerformerReader

+ func (t *ReadTransaction) Repository() models.ReaderRepository

+ func (t *ReadTransaction) Rollback() error

+ func (t *ReadTransaction) Scene() models.SceneReader

+ func (t *ReadTransaction) SceneMarker() models.SceneMarkerReader

+ func (t *ReadTransaction) ScrapedItem() models.ScrapedItemReader

+ func (t *ReadTransaction) Studio() models.StudioReader

+ func (t *ReadTransaction) Tag() models.TagReader

+ type TransactionManager struct

+ func NewTransactionManager() *TransactionManager

+ func (t *TransactionManager) WithReadTxn(ctx context.Context, fn func(r models.ReaderRepository) error) error

+ func (t *TransactionManager) WithTxn(ctx context.Context, fn func(r models.Repository) error) error