db

package

v0.0.4 Latest Latest Go to latest Published: Apr 10, 2023 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func GetAllFiles(db DBQuery) ([]iface.File, error)

func GetAllTokens(db DBQuery) ([]iface.Token, error)

func GetExpiredFiles(db DBQuery, limit int) ([]iface.File, error)

func GetFileById(db DBQuery, id string) (*iface.File, error)

func GetFilesByHash(db DBQuery, hash string) ([]iface.File, error)

files are stored many to one. 1 file on disk can represent many files in the db

func GetFilesByToken(db DBQuery, token string) ([]iface.File, error)

func GetTokenById(db DBQuery, id string) (*iface.Token, error)

func InsertFile(db DBQuery, token, name, hash, mime string, size int64, expire time.Duration) (*iface.File, error)

func InsertToken(db DBQuery, isAdmin bool) (*iface.Token, error)

func RemoveFile(db DBQuery, id string) (*iface.File, error)

func RemoveToken(db DBQuery, id string) (*iface.Token, error)

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

func OpenLiteDB(dbPath string) (*DBHandler, error)

func (db *DBHandler) Close() error

func (db *DBHandler) Query(query string, args ...any) (*sql.Rows, error)

func (db *DBHandler) Setup() error

func (db *DBHandler) Transaction(transaction func(*sql.Tx) error) (err error)

calls transaction, if transaction returns a non-nil error the transaction is rolled back. otherwise the transaction is committed

type DBQuery interface {
	Query(query string, args ...any) (*sql.Rows, error)
}