ome.services.blitz.repo

Interface RepositoryDao

All Known Implementing Classes:

RepositoryDaoImpl

public interface RepositoryDao

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canUpdate(omero.model.IObject obj, Ice.Current current) Delegates to IAdmin#canUpdate
void	createOrFixUserDir(String uuid, List<CheckedPath> path, org.hibernate.Session s, ServiceFactory sf, SqlAction sql) Checks that the given CheckedPath objects exist (via findRepoFile(String, CheckedPath, String, Ice.Current)) and are in the "user" group.
List<Integer>	deleteRepoDeleteLogs(List<SqlAction.DeleteLog> templates, Ice.Current current) Call SqlAction.deleteRepoDeleteLogs(DeleteLog) with the current context for a number of templates.
int	deleteRepoDeleteLogs(SqlAction.DeleteLog template, Ice.Current current) Call SqlAction.deleteRepoDeleteLogs(DeleteLog) with the current context.
List<Long>	filterFilesByRepository(String repo, List<Long> ids, Ice.Current current) Find the original file IDs among those given that are in the given repository.
List<List<SqlAction.DeleteLog>>	findRepoDeleteLogs(List<SqlAction.DeleteLog> templates, Ice.Current current) As #findRepoDeleteLogs(DeleteLog, Current) but for a collection of templates.
List<SqlAction.DeleteLog>	findRepoDeleteLogs(SqlAction.DeleteLog template, Ice.Current current) Call SqlAction.findRepoDeleteLogs(DeleteLog) with the current context.
OriginalFile	findRepoFile(ServiceFactory sf, SqlAction sql, String uuid, CheckedPath checked, String mimetype) As findRepoFile(String, CheckedPath, String, Current) but can be called from within a transaction.
omero.model.OriginalFile	findRepoFile(String uuid, CheckedPath checked, String mimetype, Ice.Current current) Delegate to SqlAction.findRepoFile(String, String, String, String) for looking up the id of the file, and then load it normally via IQuery.
ChecksumAlgorithm	getChecksumAlgorithm(String name, Ice.Current current) Retrieve the checksum algorithm of the given name.
omero.sys.EventContext	getEventContext(Ice.Current current) Look up information for the current session as specified in the ctx field of the current.
FsFile	getFile(long id, Ice.Current current, String repoUuid) Get an FsFile object based on its ID.
omero.model.OriginalFile	getOriginalFile(long fileId, Ice.Current current) Gets the original file instance for a given file ID.
List<omero.model.OriginalFile>	getOriginalFiles(String repoUuid, CheckedPath checked, Ice.Current current) Return a non-null, possibly empty list of OriginalFile elements which are accessible to the given user at the given path.
OriginalFile	getOriginalFileWithHasher(long id, Ice.Current current) Retrieve the original file of the given ID.
RawFileStore	getRawFileStore(long fileId, CheckedPath checked, String mode, Ice.Current current) Create a RawFileBean (i.e. an implementation of RawFileStore which can be passed to RepoRawFileStore for performing internal functions.
String	getUserInstitution(long userId, Ice.Current current) Get the current user's institution.
String	getUserInstitution(long userId, ServiceFactory sf) Get the current user's institution.
List<omero.model.Fileset>	loadFilesets(List<Long> ids, Ice.Current current) Load filesets by id.
void	makeDirs(PublicRepositoryI repo, List<CheckedPath> dirs, boolean parents, Ice.Current c) Create a number of directories in a single transaction, using the PublicRepositoryI instance as a callback for implementation specific logic.
omero.model.OriginalFile	register(String repoUuid, CheckedPath checked, String mimetype, Ice.Current current) Register an OriginalFile object
OriginalFile	register(String repoUuid, CheckedPath checked, String mimetype, ServiceFactory sf, SqlAction sql) Like {@link #register(String, CheckedPath, String, Ice.Current) but does not create a new transaction.
omero.model.Fileset	saveFileset(String repoUuid, omero.model.Fileset fs, omero.model.ChecksumAlgorithm checksumAlgorithm, List<CheckedPath> paths, Ice.Current current) Fill the various fields of the Fileset and then save the entire instance into the database.
<T extends omero.model.Job> T	saveJob(T job, Ice.Current current) Create a job from an instance provided by either the client or the server.
void	saveObject(IObject object, Ice.Current current) Save the given model object.
omero.RMap	treeList(String repoUuid, CheckedPath checked, Ice.Current __current)
void	updateJob(omero.model.Job job, String message, String status, Ice.Current current) Set both the message and the status of the given job.

Method Detail

getRawFileStore

RawFileStore getRawFileStore(long fileId,
                           CheckedPath checked,
                           String mode,
                           Ice.Current current)
                             throws omero.SecurityViolation

Create a RawFileBean (i.e. an implementation of RawFileStore which can be passed to RepoRawFileStore for performing internal functions. The primary difference to an instance created via the ServiceFactory is that the RawFileBean#setFileIdWithBuffer(FileBuffer) method is called pointing to a non-romio file path, e.g. /OMERO/Files/x.

Parameters:

fileId - ID of an OriginalFile

checked - Not null. Normalized path from the repository.

mode - FileChannel mode, "r", "rw", etc.

Returns:

An instance with RawFileBean#setFileIdWithBuffer(FileBuffer) called.

Throws:

omero.SecurityViolation

findRepoFile

omero.model.OriginalFile findRepoFile(String uuid,
                                    CheckedPath checked,
                                    String mimetype,
                                    Ice.Current current)
                                      throws omero.ServerError

Delegate to SqlAction.findRepoFile(String, String, String, String) for looking up the id of the file, and then load it normally via IQuery. This will enforce any read security checks.

Parameters:

uuid -

dirname -

basename -

mimetype -

Returns:

Throws:

omero.ServerError

findRepoFile

OriginalFile findRepoFile(ServiceFactory sf,
                        SqlAction sql,
                        String uuid,
                        CheckedPath checked,
                        String mimetype)

As findRepoFile(String, CheckedPath, String, Current) but can be called from within a transaction.

treeList

omero.RMap treeList(String repoUuid,
                  CheckedPath checked,
                  Ice.Current __current)
                    throws omero.ServerError

Throws:

omero.ServerError

createOrFixUserDir

void createOrFixUserDir(String uuid,
                      List<CheckedPath> path,
                      org.hibernate.Session s,
                      ServiceFactory sf,
                      SqlAction sql)
                        throws omero.ServerError

Checks that the given CheckedPath objects exist (via findRepoFile(String, CheckedPath, String, Ice.Current)) and are in the "user" group. If they don't exist, they are created; and if they aren't in the "user" group, they are moved.

Throws:

omero.ServerError

canUpdate

boolean canUpdate(omero.model.IObject obj,
                Ice.Current current)

Delegates to IAdmin#canUpdate

Parameters:

fileId -

current -

Returns:

Throws:

an - SecurityViolation if the currentUser is not allowed to access the given file.

filterFilesByRepository

List<Long> filterFilesByRepository(String repo,
                                 List<Long> ids,
                                 Ice.Current current)

Find the original file IDs among those given that are in the given repository.

Parameters:

repo - a repository UUID

ids - IDs of original files

Ice - method invocation context

Returns:

those IDs among those given whose original files are in the given repository

getOriginalFile

omero.model.OriginalFile getOriginalFile(long fileId,
                                       Ice.Current current)
                                         throws omero.SecurityViolation

Gets the original file instance for a given file ID.

Parameters:

fileId - a file ID

current - applicable ICE context

Returns:

the original file corresponding to the given file ID

Throws:

omero.SecurityViolation - if the query threw a security violation

getOriginalFiles

List<omero.model.OriginalFile> getOriginalFiles(String repoUuid,
                                              CheckedPath checked,
                                              Ice.Current current)
                                                throws omero.SecurityViolation

Return a non-null, possibly empty list of OriginalFile elements which are accessible to the given user at the given path. If the directory which they are associated with is not also readable by the current user, then a SecurityViolation will be thrown.

Parameters:

uuid - for the repository in question.

checked - normalized path which can be found as the value of OriginalFile.getPath() in the database.

current -

Throws:

omero.SecurityViolation

saveFileset

omero.model.Fileset saveFileset(String repoUuid,
                              omero.model.Fileset fs,
                              omero.model.ChecksumAlgorithm checksumAlgorithm,
                              List<CheckedPath> paths,
                              Ice.Current current)
                                throws omero.ServerError

Fill the various fields of the Fileset and then save the entire instance into the database.

Parameters:

repoUuid - for the repository in question.

fs - a user provided Fileset that must minimally have the FilesetEntry objects present with their clientPath set. The rest of the fields will be filled here.

paths - a List of the same size as the number of entries in fs one per FilesetEntry.

currentUser -

Throws:

omero.ServerError

loadFilesets

List<omero.model.Fileset> loadFilesets(List<Long> ids,
                                     Ice.Current current)
                                       throws omero.ServerError

Load filesets by id.

Parameters:

ids -

current -

Returns:

Throws:

omero.ServerError

register

omero.model.OriginalFile register(String repoUuid,
                                CheckedPath checked,
                                String mimetype,
                                Ice.Current current)
                                  throws omero.ServerError

Register an OriginalFile object

Parameters:

repoUuid - uuid of the repository that the given file argument should be registered with. Cannot be null.

checked - Normalized path provided by the repository. Not null.

mimetype - Mimetype for use with the OriginalFile. May be null in which case a default will be chosen.

current - Not null.

Returns:

The OriginalFile with id set (unloaded)

Throws:

omero.ServerError

register

OriginalFile register(String repoUuid,
                    CheckedPath checked,
                    String mimetype,
                    ServiceFactory sf,
                    SqlAction sql)
                      throws omero.ServerError

Like #register(String, CheckedPath, String, Ice.Current) but does not create a new transaction. Instead, the {@link ServiceFactory} and {@link SqlAction} must be passed in. The returned OriginalFile instance is still connected to Hibernate.

Parameters:

repoUuid -

checked -

mimetype -

sf -

sql -

Returns:

Throws:

omero.ServerError

getFile

FsFile getFile(long id,
             Ice.Current current,
             String repoUuid)

Get an FsFile object based on its ID. Returns null if the file does not exist or does not belong to this repository.

Parameters:

id - database ID of the sought original file

current - current applicable ICE context

repoUuid - the UUID of the repository containing the original file

Returns:

the requested FsFile object

saveJob

<T extends omero.model.Job> T saveJob(T job,
                                    Ice.Current current)
                                  throws omero.ServerError

Create a job from an instance provided by either the client or the server. Only those fields which are modifiable by the user will be copied.

Parameters:

job - Not null.

current - Not null.

Returns:

Throws:

omero.ServerError

updateJob

void updateJob(omero.model.Job job,
             String message,
             String status,
             Ice.Current current)
               throws omero.ServerError

Set both the message and the status of the given job.

Parameters:

job - Not null.

message - If null, no modification will be made for the message

status - If null, no modification will be made for the status.

Throws:

omero.ServerError

getEventContext

omero.sys.EventContext getEventContext(Ice.Current current)

Look up information for the current session as specified in the ctx field of the current.

getUserInstitution

String getUserInstitution(long userId,
                        Ice.Current current)

Get the current user's institution.

Parameters:

userId - the ID of the user whose institution is to be fetched

current - the current ICE method invocation context

Returns:

the institution, may be null

getUserInstitution

String getUserInstitution(long userId,
                        ServiceFactory sf)

Get the current user's institution.

Parameters:

userId - the ID of the user whose institution is to be fetched

sf - the service factory to use for the query

Returns:

the institution, may be null

findRepoDeleteLogs

List<SqlAction.DeleteLog> findRepoDeleteLogs(SqlAction.DeleteLog template,
                                           Ice.Current current)

Call SqlAction.findRepoDeleteLogs(DeleteLog) with the current context.

Parameters:

template - not null.

current - not null.

Returns:

all the rows found which match the non-null fields on templates

findRepoDeleteLogs

List<List<SqlAction.DeleteLog>> findRepoDeleteLogs(List<SqlAction.DeleteLog> templates,
                                                 Ice.Current current)

As #findRepoDeleteLogs(DeleteLog, Current) but for a collection of templates.

Parameters:

templates - not null.

current - not null.

Returns:

all the rows found which match the non-null fields on templates

deleteRepoDeleteLogs

int deleteRepoDeleteLogs(SqlAction.DeleteLog template,
                       Ice.Current current)

Call SqlAction.deleteRepoDeleteLogs(DeleteLog) with the current context.

Parameters:

template - not null.

current - not null.

Returns:

the number of rows deleted

deleteRepoDeleteLogs

List<Integer> deleteRepoDeleteLogs(List<SqlAction.DeleteLog> templates,
                                 Ice.Current current)

Call SqlAction.deleteRepoDeleteLogs(DeleteLog) with the current context for a number of templates.

Parameters:

templates - not null.

current - not null.

Returns:

A list containing the number of rows deleted

makeDirs

void makeDirs(PublicRepositoryI repo,
            List<CheckedPath> dirs,
            boolean parents,
            Ice.Current c)
              throws omero.ServerError

Create a number of directories in a single transaction, using the PublicRepositoryI instance as a callback for implementation specific logic. Applies the real user's event context when within a PublicRepositoryI.sudo(Current, String).

Throws:

omero.ServerError

getChecksumAlgorithm

ChecksumAlgorithm getChecksumAlgorithm(String name,
                                     Ice.Current current)

Retrieve the checksum algorithm of the given name.

Parameters:

name - a checksum algorithm name, must exist

Ice - method invocation context

Returns:

the corresponding checksum algorithm model object

getOriginalFileWithHasher

OriginalFile getOriginalFileWithHasher(long id,
                                     Ice.Current current)

Retrieve the original file of the given ID.

Parameters:

id - the ID of an original file, must exist

Ice - method invocation context

Returns:

the corresponding original file model object

saveObject

void saveObject(IObject object,
              Ice.Current current)

Save the given model object.

Parameters:

object - a model object

Ice - method invocation context