ome.util.actions

Class PostgresSqlAction

java.lang.Object

ome.util.SqlAction.Impl

ome.util.actions.PostgresSqlAction

All Implemented Interfaces:

SqlAction

public class PostgresSqlAction
extends SqlAction.Impl

Nested Class Summary

Nested classes/interfaces inherited from interface ome.util.SqlAction

SqlAction.DeleteLog, SqlAction.IdRowMapper, SqlAction.Impl, SqlAction.LoggingSqlAction, SqlAction.StringRowMapper

Field Summary

Fields

Modifier and Type	Field and Description
static String	insertFormatSql

Fields inherited from class ome.util.SqlAction.Impl

log, MAX_IN_SIZE

Constructor Summary

Constructors

Constructor and Description
PostgresSqlAction(SimpleJdbcOperations jdbc)

Method Summary

Modifier and Type	Method and Description
protected SimpleJdbcOperations	_jdbc()
protected String	_lookup(String key)
boolean	activeSession(String sessionUUID) Returns whether the given string is the UUID of a session that is currently active.
int	closeSessions(String uuid)
long	countFormat(String name)
void	createSavepoint(String savepoint)
Set<String>	currentUserNames()
long	currValue(String segmentName)
String	dbUuid()
String	dbVersion()
void	deferConstraints()
void	delCurrentEventLog(String key)
Long	findRepoImageFromPixels(long id)
List<Long>	findRepoPixels(String uuid, String dirname, String basename)
List<Long>	getDeletedIds(String entityType)
List<String>	getPixelsNamePathRepo(long id) Retrieves the name, path and repo for the given pixels set.
List<Long>	getShapeIds(long roiId)
protected void	handlePotentialPgArrayJarError(UncategorizedSQLException e) If postgresql is installed with an older jdbc jar that is on the bootstrap classpath, then it's possible that the use of pgarrays will fail (I think).
int	insertFormat(String name)
void	insertLogs(List<Object[]> batchData)
int	insertSession(Map<String,Object> params)
Long	nextSessionId()
long	nextValue(String segmentValue, int incrementSize) The implementation of this method guarantees that even if the current transaction fails that the value found will not be used by another transaction.
long	nodeId(String internal_uuid)
Date	now()
void	prepareSession(long eventId, long userId, long groupId) Stores the current event context information in a temporary table so that triggers can make use of them.
void	releaseSavepoint(String savepoint)
int	removePassword(Long id)
Map<String,Object>	repoFile(long value)
String	rewriteHql(String query, String key, Object value) The temp_ids infrastructure was never properly put in place for the "psql" profile.
List<Map<String,Object>>	roiByImageAndNs(long imageId, String ns)
void	rollbackSavepoint(String savepoint)
long	selectCurrentEventLog(String key)
Long	sessionId(String uuid)
void	setCurrentEventLog(long id, String key)
void	setFileRepo(Collection<Long> ids, String repoId)
void	setPixelsNamePathRepo(long pixId, String name, String path, String repoId)
int	synchronizeJobs(List<Long> ids)
int	updateConfiguration(String key, String value)

Methods inherited from class ome.util.SqlAction.Impl

addMessageWithinDbPatchEnd, addMessageWithinDbPatchStart, addMimetypes, changeGroupPermissions, changeTablePermissionsForGroup, clearPermissionsBit, closeNode, closeNodeSessions, configValue, createIdsTempTable, createInsertTrigger, delConfigValue, deleteRepoDeleteLogs, fileIdsInDb, fileRepo, filterFileIdsByRepo, findRepoDeleteLogs, findRepoFile, findRepoFile, findRepoFile, findRepoFilePath, findRepoFiles, findRepoFiles, findRepoRootPath, getEventLogPartitions, getEventLogPercent, getGroupIds, getGroupPermissions, getLdapExperimenters, getPasswordHash, getShareData, getUserEmailsByGroup, getUserGroups, getUserId, getUsername, groupInfoFor, hasUnicodeUnits, isFileInRepo, isLdapExperimenter, nextPixelsDataLogForRepo, printThrowable, refreshEventLogFromUpdatedAnnotations, repoScriptCount, scriptRepo, setPermissionsBit, setStatsInfo, setUserPassword, updateOrInsertConfigValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

insertFormatSql

public static final String insertFormatSql

Constructor Detail

PostgresSqlAction

public PostgresSqlAction(SimpleJdbcOperations jdbc)

Method Detail

_jdbc

protected SimpleJdbcOperations _jdbc()

Specified by:

_jdbc in class SqlAction.Impl

_lookup

protected String _lookup(String key)

Specified by:

_lookup in class SqlAction.Impl

rewriteHql

public String rewriteHql(String query,
                         String key,
                         Object value)

The temp_ids infrastructure was never properly put in place for the "psql" profile. This method simply bypasses all query rewriting until that's functional.

Specified by:

rewriteHql in interface SqlAction

Overrides:

rewriteHql in class SqlAction.Impl

Parameters:

query - String query (non-null) which is in effect.

key - Key of the argument e.g. (:ids)

value - value which has been passed in for that parameter.

Returns:

Returns a query replacement.

See Also:

ticket 3961, ticket 9077

prepareSession

public void prepareSession(long eventId,
                           long userId,
                           long groupId)

Description copied from interface: SqlAction

Stores the current event context information in a temporary table so that triggers can make use of them.

activeSession

public boolean activeSession(String sessionUUID)

Description copied from interface: SqlAction

Returns whether the given string is the UUID of a session that is currently active.

Parameters:

sessionUUID - NOT NULL.

Returns:

true if sessionUUID is an active session, false otherwise

synchronizeJobs

public int synchronizeJobs(List<Long> ids)

findRepoPixels

public List<Long> findRepoPixels(String uuid,
                                 String dirname,
                                 String basename)

findRepoImageFromPixels

public Long findRepoImageFromPixels(long id)

nextSessionId

public Long nextSessionId()

repoFile

public Map<String,Object> repoFile(long value)

countFormat

public long countFormat(String name)

insertFormat

public int insertFormat(String name)

closeSessions

public int closeSessions(String uuid)

nodeId

public long nodeId(String internal_uuid)

insertSession

public int insertSession(Map<String,Object> params)

sessionId

public Long sessionId(String uuid)

removePassword

public int removePassword(Long id)

now

public Date now()

updateConfiguration

public int updateConfiguration(String key,
                               String value)

dbVersion

public String dbVersion()

dbUuid

public String dbUuid()

selectCurrentEventLog

public long selectCurrentEventLog(String key)

Specified by:

selectCurrentEventLog in interface SqlAction

Overrides:

selectCurrentEventLog in class SqlAction.Impl

setCurrentEventLog

public void setCurrentEventLog(long id,
                               String key)

Specified by:

setCurrentEventLog in interface SqlAction

Overrides:

setCurrentEventLog in class SqlAction.Impl

delCurrentEventLog

public void delCurrentEventLog(String key)

Specified by:

delCurrentEventLog in interface SqlAction

Overrides:

delCurrentEventLog in class SqlAction.Impl

nextValue

public long nextValue(String segmentValue,
                      int incrementSize)

Description copied from interface: SqlAction

The implementation of this method guarantees that even if the current transaction fails that the value found will not be used by another transaction. Database implementations can choose whether to do this at the procedure level or by using transaction PROPAGATION settings in Java.

See Also:

ticket 3697, ticket 3253

currValue

public long currValue(String segmentName)

insertLogs

public void insertLogs(List<Object[]> batchData)

roiByImageAndNs

public List<Map<String,Object>> roiByImageAndNs(long imageId,
                                                String ns)

getShapeIds

public List<Long> getShapeIds(long roiId)

setFileRepo

public void setFileRepo(Collection<Long> ids,
                        String repoId)

setPixelsNamePathRepo

public void setPixelsNamePathRepo(long pixId,
                                  String name,
                                  String path,
                                  String repoId)

getDeletedIds

public List<Long> getDeletedIds(String entityType)

createSavepoint

public void createSavepoint(String savepoint)

releaseSavepoint

public void releaseSavepoint(String savepoint)

rollbackSavepoint

public void rollbackSavepoint(String savepoint)

deferConstraints

public void deferConstraints()

currentUserNames

public Set<String> currentUserNames()

getPixelsNamePathRepo

public List<String> getPixelsNamePathRepo(long id)
                                   throws InternalException

Description copied from interface: SqlAction

Retrieves the name, path and repo for the given pixels set. If the id is not found, null is returned.

Throws:

InternalException

handlePotentialPgArrayJarError

protected void handlePotentialPgArrayJarError(UncategorizedSQLException e)

If postgresql is installed with an older jdbc jar that is on the bootstrap classpath, then it's possible that the use of pgarrays will fail (I think). See #7432