cgosqlite

package module
v0.0.0-...-094e1e4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 6, 2024 License: MIT Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CommitAndRollback 

func CommitAndRollback(tx *sql.Tx, err error) error

func New 

func New(dataSourceName string) (dao.Database, error)

Types

type DB 

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

func (*DB) BranchCount 

func (db *DB) BranchCount(ctx context.Context) (int, error)

func (*DB) BranchInfo 

func (db *DB) BranchInfo(ctx context.Context, branchName string) (branch dao.Branch, err error)

func (*DB) BranchList 

func (db *DB) BranchList(ctx context.Context) (branches []dao.IBranch, err error)

func (*DB) CheckExists 

func (db *DB) CheckExists(ctx context.Context, driverId uint64, dirPath []string, checks []dao.DirItemCheck, hashList []string) error

func (*DB) Close 

func (db *DB) Close() error

func (*DB) Create 

func (db *DB) Create() error

func (*DB) DataSourceName 

func (db *DB) DataSourceName() string

func (*DB) DeleteBranch 

func (db *DB) DeleteBranch(ctx context.Context, branchName string) error

func (*DB) DeleteDevice 

func (db *DB) DeleteDevice(ctx context.Context, deviceId string) error

func (*DB) DeleteDriver 

func (db *DB) DeleteDriver(ctx context.Context, driverId uint64) error

func (*DB) DirCount 

func (db *DB) DirCount(ctx context.Context) (int, error)

func (*DB) DirItemCount 

func (db *DB) DirItemCount(ctx context.Context) (int, error)

func (*DB) FileCount 

func (db *DB) FileCount(ctx context.Context) (int, error)

func (*DB) GetDriver 

func (db *DB) GetDriver(ctx context.Context, driverId uint64) (driver dao.Driver, err error)

func (*DB) GetDriverDirCalculatedInfo 

func (db *DB) GetDriverDirCalculatedInfo(ctx context.Context, driverId uint64, filePath []string) (info dao.DirCalculatedInfo, err error)

func (*DB) GetDriverFile 

func (db *DB) GetDriverFile(ctx context.Context, driverId uint64, filePath []string) (file dao.DriverFile, err error)

func (*DB) GetDriverLocalFile 

func (db *DB) GetDriverLocalFile(ctx context.Context, driverId uint64) (driver *dao.Driver, err error)

func (*DB) GetDriverSync 

func (db *DB) GetDriverSync(ctx context.Context, driverId uint64) (driver dao.Driver, err error)

func (*DB) GetDriverToken 

func (db *DB) GetDriverToken(ctx context.Context, driverId uint64) (driver dao.Driver, err error)

func (*DB) GetEarliestCrated 

func (db *DB) GetEarliestCrated(ctx context.Context, hash string) (t int64, err error)

func (*DB) GetFileHashMode 

func (db *DB) GetFileHashMode(ctx context.Context, branchName string, splitPath []string) (hash string, mode os.FileMode, err error)

func (*DB) GetFileType 

func (db *DB) GetFileType(ctx context.Context, hash string) (fileType dao.FileType, err error)

func (*DB) GetLivePhotoByLivp 

func (db *DB) GetLivePhotoByLivp(ctx context.Context, livpHash string) (movHash string, heicHash string, err error)

func (*DB) GetMetadata 

func (db *DB) GetMetadata(ctx context.Context, hash string) (metadata dao.Metadata, err error)

func (*DB) InsertBranchWithTxOrDb 

func (db *DB) InsertBranchWithTxOrDb(ctx context.Context, txOrDb dbBase.TxOrDb, branch dao.Branch) error

func (*DB) InsertCommitWithTxOrDb 

func (db *DB) InsertCommitWithTxOrDb(ctx context.Context, txOrDb dbBase.TxOrDb, commit *dao.Commit) error

func (*DB) InsertDCIMMetadataTime 

func (db *DB) InsertDCIMMetadataTime(ctx context.Context, hash string, t int64) (exist bool, err error)

func (*DB) InsertDevice 

func (db *DB) InsertDevice(ctx context.Context, id string, name string, os string, userAgent string, hostname string) error

func (*DB) InsertDriver 

func (db *DB) InsertDriver(ctx context.Context, driverName string, description string) (exist bool, err error)

func (*DB) InsertDriverBaiduPhoto 

func (db *DB) InsertDriverBaiduPhoto(ctx context.Context, driverName string, description string, accessToken string, refreshToken string) (exist bool, err error)

func (*DB) InsertDriverLocalFile 

func (db *DB) InsertDriverLocalFile(ctx context.Context, driverName string, description string, deviceId string, srcPath string, ignores string, encoder string) (exist bool, err error)

func (*DB) InsertExif 

func (db *DB) InsertExif(ctx context.Context, hash string, e dao.Exif) (exist bool, err error)

func (*DB) InsertFile 

func (db *DB) InsertFile(ctx context.Context, hash string, size uint64) error

func (*DB) InsertFileMd5 

func (db *DB) InsertFileMd5(ctx context.Context, hash string, hashMd5 string) error

func (*DB) InsertFileType 

func (db *DB) InsertFileType(ctx context.Context, hash string, t dao.FileType) (exist bool, err error)

func (*DB) InsertHeightWidth 

func (db *DB) InsertHeightWidth(ctx context.Context, hash string, hw dao.HeightWidth) error

func (*DB) InsertNullExif 

func (db *DB) InsertNullExif(ctx context.Context, hash string) (exist bool, err error)

func (*DB) InsertNullVideoMetadata 

func (db *DB) InsertNullVideoMetadata(ctx context.Context, hash string) (exist bool, err error)

func (*DB) InsertVideoMetadata 

func (db *DB) InsertVideoMetadata(ctx context.Context, hash string, m dao.VideoMetadata) (exist bool, err error)

func (*DB) IsSqlite 

func (db *DB) IsSqlite() bool

func (*DB) IsUniqueConstraintError 

func (db *DB) IsUniqueConstraintError(err error) bool

func (*DB) List 

func (db *DB) List(ctx context.Context, branchName string, splitPath []string) (dirItems []dao.DirItem, err error)

func (*DB) ListByHash 

func (db *DB) ListByHash(ctx context.Context, hash string) (dirItems []dao.DirItem, err error)

func (*DB) ListCloudDriverSync 

func (db *DB) ListCloudDriverSync(ctx context.Context) (drivers []dao.Driver, err error)

func (*DB) ListDCIMDriver 

func (db *DB) ListDCIMDriver(ctx context.Context) (drivers []dao.DCIMDriver, err error)

func (*DB) ListDCIMLocation 

func (db *DB) ListDCIMLocation(ctx context.Context) (list []dao.Metadata, err error)

func (*DB) ListDCIMMediaType 

func (db *DB) ListDCIMMediaType(ctx context.Context) (m map[string][]dao.Metadata, err error)

func (*DB) ListDCIMSearchSuffix 

func (db *DB) ListDCIMSearchSuffix(ctx context.Context) (list []dao.DCIMSearchSuffix, err error)

func (*DB) ListDCIMSearchType 

func (db *DB) ListDCIMSearchType(ctx context.Context) (list []dao.DCIMSearchType, err error)

func (*DB) ListDevice 

func (db *DB) ListDevice(ctx context.Context) (devices []dao.Device, err error)

func (*DB) ListDriver 

func (db *DB) ListDriver(ctx context.Context) (drivers []dao.Driver, err error)

func (*DB) ListDriverFile 

func (db *DB) ListDriverFile(ctx context.Context, driverId uint64, filePath []string) (files []dao.DriverFile, err error)

func (*DB) ListDriverFileByHash 

func (db *DB) ListDriverFileByHash(ctx context.Context, hash string) (files []dao.DriverFile, err error)

func (*DB) ListExif 

func (db *DB) ListExif(ctx context.Context) (exifMap map[string]dao.Exif, err error)

func (*DB) ListExpectExif 

func (db *DB) ListExpectExif(ctx context.Context) (hashList []string, err error)

func (*DB) ListExpectExifCb 

func (db *DB) ListExpectExifCb(ctx context.Context, cb func(hash string)) (err error)

func (*DB) ListExpectFileType 

func (db *DB) ListExpectFileType(ctx context.Context) (hashList []string, err error)

func (*DB) ListFile 

func (db *DB) ListFile(ctx context.Context) (hashList []string, err error)

func (*DB) ListFileHash 

func (db *DB) ListFileHash(ctx context.Context) (hashList []string, err error)

func (*DB) ListFileMd5 

func (db *DB) ListFileMd5(ctx context.Context, md5List []string) (m map[string]string, err error)

func (*DB) ListLivePhotoAll 

func (db *DB) ListLivePhotoAll(ctx context.Context) (hashList []string, err error)

func (*DB) ListLivePhotoNew 

func (db *DB) ListLivePhotoNew(ctx context.Context) (hashList []string, err error)

func (*DB) ListLocalFileDriver 

func (db *DB) ListLocalFileDriver(ctx context.Context, deviceId string) (drivers []dao.Driver, err error)

func (*DB) ListMetadata 

func (db *DB) ListMetadata(ctx context.Context) (list []dao.Metadata, err error)

func (*DB) ListMetadataTime 

func (db *DB) ListMetadataTime(ctx context.Context) (list []dao.Metadata, err error)

func (*DB) MaxBatchSize 

func (db *DB) MaxBatchSize() int

func (*DB) NewBranch 

func (db *DB) NewBranch(ctx context.Context, branchName string) (exist bool, err error)

func (*DB) Open 

func (db *DB) Open(ctx context.Context, branchName string, splitPath []string) (hash string, mode os.FileMode, dirItems []dao.DirItem, err error)

func (*DB) Open2 

func (db *DB) Open2(ctx context.Context, branchName string, splitPath []string) (dirItem dao.DirItem, dirItems []dao.DirItem, err error)

func (*DB) Remove 

func (db *DB) Remove() error

func (*DB) RemoveDirItem 

func (db *DB) RemoveDirItem(ctx context.Context, branchName string, splitPath []string) (commit dao.Commit, branch dao.Branch, err error)

func (*DB) ResetBranch 

func (db *DB) ResetBranch(ctx context.Context, branchName string) (err error)

func (*DB) ResetDriver 

func (db *DB) ResetDriver(ctx context.Context, driverId uint64) error

func (*DB) SearchDCIM 

func (db *DB) SearchDCIM(ctx context.Context, typeList []string, suffixList []string) (list []dao.Metadata, err error)

func (*DB) SetLivpForMovAndHeicOrJpgAll 

func (db *DB) SetLivpForMovAndHeicOrJpgAll(ctx context.Context) error

func (*DB) SetLivpForMovAndHeicOrJpgInDirPath 

func (db *DB) SetLivpForMovAndHeicOrJpgInDirPath(ctx context.Context, driverId uint64, filePath []string) (err error)

func (*DB) SetLivpForMovAndHeicOrJpgInDriver 

func (db *DB) SetLivpForMovAndHeicOrJpgInDriver(ctx context.Context, driverId uint64) (err error)

func (*DB) Size 

func (db *DB) Size() (int64, error)

func (*DB) SumFileSize 

func (db *DB) SumFileSize(ctx context.Context) (size uint64, err error)

func (*DB) UpdateDriverLocalFile 

func (db *DB) UpdateDriverLocalFile(ctx context.Context, driverId uint64, srcPath, ignores, encoder string) error

func (*DB) UpdateDriverSync 

func (db *DB) UpdateDriverSync(ctx context.Context, driverId uint64, sync bool, h int64, m int64) error

func (*DB) UpsertBranchWithTxOrDb 

func (db *DB) UpsertBranchWithTxOrDb(ctx context.Context, txOrDb dbBase.TxOrDb, branch dao.Branch) error

func (*DB) UpsertDCIMMetadataTime 

func (db *DB) UpsertDCIMMetadataTime(ctx context.Context, hash string, t int64) error

func (*DB) UpsertDirItem 

func (db *DB) UpsertDirItem(ctx context.Context, branchName string, splitPath []string, item dao.DirItem) (commit dao.Commit, branch dao.Branch, err error)

func (*DB) UpsertDirItems 

func (db *DB) UpsertDirItems(ctx context.Context, branchName string, splitPath []string, items []dao.DirItem) (commit dao.Commit, branch dao.Branch, err error)

func (*DB) UpsertDriverFile 

func (db *DB) UpsertDriverFile(ctx context.Context, f dao.DriverFile, mkdir bool) error

func (*DB) UpsertDriverFiles 

func (db *DB) UpsertDriverFiles(ctx context.Context, files []dao.DriverFile) error

func (*DB) UpsertFileType 

func (db *DB) UpsertFileType(ctx context.Context, hash string, t dao.FileType) error

func (*DB) UpsertLivePhoto 

func (db *DB) UpsertLivePhoto(ctx context.Context, movHash string, heicHash string, jpgHash string, livpHash string) error

func (*DB) WriteBranch 

func (db *DB) WriteBranch(ctx context.Context, branch dao.Branch) error

func (*DB) WriteCommit 

func (db *DB) WriteCommit(ctx context.Context, commit *dao.Commit) error

func (*DB) WriteDir 

func (db *DB) WriteDir(ctx context.Context, dirItems []dao.DirItem) (dir dao.Dir, err error)

func (*DB) WriteFile 

func (db *DB) WriteFile(ctx context.Context, file dao.File) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.