org.nuxeo.ecm.directory.sql

Class SQLSession

java.lang.Object

org.nuxeo.ecm.directory.BaseSession

org.nuxeo.ecm.directory.sql.SQLSession

All Implemented Interfaces:

AutoCloseable, EntrySource, Session

public class SQLSession
extends BaseSession

This class represents a session against an SQLDirectory.

Field Summary

Fields

Modifier and Type	Field and Description
protected JDBCLogger	logger
protected SQLStaticFilter[]	staticFilters

Fields inherited from class org.nuxeo.ecm.directory.BaseSession

autoincrementId, directory, directoryName, MULTI_TENANT_ID_FORMAT, passwordHashAlgorithm, permissions, POWER_USERS_GROUP, readAllColumns, READONLY_ENTRY_FLAG, referenceClass, schemaName, substringMatchType

Constructor Summary

Constructors

Constructor and Description
SQLSession(SQLDirectory directory, SQLDirectoryDescriptor config)

Method Summary

Modifier and Type	Method and Description
protected void	addFilterValues(PreparedStatement ps, int startIdx)
protected void	addFilterValuesForLog(List<Serializable> values)
protected String	addFilterWhereClause(String whereClause)
boolean	authenticate(String username, String password) Checks that the credentials provided by the UserManager match those registered in the directory.
protected boolean	canDeleteMultiTenantEntry(String entryId)
protected void	checkConcurrentUpdate(Throwable e) Checks the SQL error we got and determine if a concurrent update happened.
void	close() Closes the session and all open result sets obtained from this session.
protected DocumentModel	createEntryWithoutReferences(Map<String,Object> fieldMap) To be implemented for specific creation.
void	deleteEntry(String id) Deletes a directory entry by id.
void	deleteEntry(String id, Map<String,String> map) Deletes a directory entry by id and secondary ids.
void	deleteEntryWithoutReferences(String id) To be implemented for specific deletion.
protected DocumentModel	fieldMapToDocumentModel(Map<String,Object> fieldMap)
protected Serializable	fieldValueForWrite(Object value, Column column)
protected void	fillPreparedStatementFields(Map<String,Object> filterMap, List<Column> orderedColumns, PreparedStatement ps)
protected String	getCurrentTenantId() Returns the tenant id of the logged user if any, null otherwise.
SQLDirectory	getDirectory() To be implemented with a more specific return type.
DocumentModel	getEntryFromSource(String id, boolean fetchReferences)
protected String	getPassword(String id) Internal method to read the hashed password for authentication.
protected List<Column>	getReadColumns()
protected String	getReadColumnsSQL()
boolean	hasEntry(String id) Returns true if session has an entry with given id.
boolean	isAuthenticating() Tells whether the directory implementation can be used as an authenticating backend for the UserManager (based on login / password check).
boolean	isLive() Enable connection status checking on SQL directory connections
protected boolean	isMultiTenant() Returns true if this directory supports multi tenancy, false otherwise.
DocumentModelList	query(Map<String,Serializable> filter, Set<String> fulltext, Map<String,String> orderBy, boolean fetchReferences) Executes a query with the possibility to fetch references
DocumentModelList	query(Map<String,Serializable> filter, Set<String> fulltext, Map<String,String> orderBy, boolean fetchReferences, int limit, int offset) Executes a query with the possibility to fetch a subset of the results.
String	toString()
protected List<String>	updateEntryWithoutReferences(DocumentModel docModel) To be implemented for specific update.

Methods inherited from class org.nuxeo.ecm.directory.BaseSession

checkDeleteConstraints, checkPermission, computeMultiTenantDirectoryId, createEntry, createEntry, createEntryModel, createEntryModel, deleteEntry, getEntries, getEntry, getEntry, getIdField, getPasswordField, getProjection, getProjection, hasPermission, hasPermission, isReadOnly, isReadOnlyEntry, query, query, query, setReadAllColumns, setReadOnlyEntry, setReadWriteEntry, updateEntry

Methods inherited from class java.lang.Object

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

Field Detail

staticFilters

protected SQLStaticFilter[] staticFilters

logger

protected JDBCLogger logger

Constructor Detail

SQLSession

public SQLSession(SQLDirectory directory,
                  SQLDirectoryDescriptor config)
           throws DirectoryException

Throws:

DirectoryException

Method Detail

getDirectory

public SQLDirectory getDirectory()

Description copied from class: BaseSession

To be implemented with a more specific return type.

Specified by:

getDirectory in class BaseSession

getEntryFromSource

public DocumentModel getEntryFromSource(String id,
                                        boolean fetchReferences)
                                 throws DirectoryException

Specified by:

getEntryFromSource in interface EntrySource

Overrides:

getEntryFromSource in class BaseSession

Throws:

DirectoryException

getReadColumns

protected List<Column> getReadColumns()

getReadColumnsSQL

protected String getReadColumnsSQL()

fieldMapToDocumentModel

protected DocumentModel fieldMapToDocumentModel(Map<String,Object> fieldMap)

checkConcurrentUpdate

protected void checkConcurrentUpdate(Throwable e)
                              throws ConcurrentUpdateException

Checks the SQL error we got and determine if a concurrent update happened. Throws if that's the case.

Parameters:

e - the exception

Throws:

ConcurrentUpdateException

Since:

7.10-HF04, 8.2

addFilterWhereClause

protected String addFilterWhereClause(String whereClause)
                               throws DirectoryException

Throws:

DirectoryException

addFilterValues

protected void addFilterValues(PreparedStatement ps,
                               int startIdx)
                        throws DirectoryException

Throws:

DirectoryException

addFilterValuesForLog

protected void addFilterValuesForLog(List<Serializable> values)

getPassword

protected String getPassword(String id)

Internal method to read the hashed password for authentication.

Since:

9.1

deleteEntry

public void deleteEntry(String id)

Description copied from interface: Session

Deletes a directory entry by id.

Specified by:

deleteEntry in interface Session

Overrides:

deleteEntry in class BaseSession

Parameters:

id - the id of the entry to delete

canDeleteMultiTenantEntry

protected boolean canDeleteMultiTenantEntry(String entryId)
                                     throws DirectoryException

Throws:

DirectoryException

deleteEntry

public void deleteEntry(String id,
                        Map<String,String> map)
                 throws DirectoryException

Description copied from interface: Session

Deletes a directory entry by id and secondary ids.

This is used for hierarchical vocabularies, where the actual unique key is the couple (parent, id).

Specified by:

deleteEntry in interface Session

Overrides:

deleteEntry in class BaseSession

Parameters:

id - the id of the entry to delete.

map - a map of secondary key values.

Throws:

DirectoryException - if a communication error occurs.

query

public DocumentModelList query(Map<String,Serializable> filter,
                               Set<String> fulltext,
                               Map<String,String> orderBy,
                               boolean fetchReferences)

Description copied from interface: Session

Executes a query with the possibility to fetch references

Specified by:

query in interface Session

Overrides:

query in class BaseSession

See Also:

Session.query(Map, Set, Map)

query

public DocumentModelList query(Map<String,Serializable> filter,
                               Set<String> fulltext,
                               Map<String,String> orderBy,
                               boolean fetchReferences,
                               int limit,
                               int offset)
                        throws DirectoryException

Description copied from interface: Session

Executes a query with the possibility to fetch a subset of the results. org.nuxeo.ecm.directory.BaseSession provides a default implementation fetching all results to return the subset. Not recommended.

Specified by:

query in interface Session

Overrides:

query in class BaseSession

limit - maximum number of results ignored if less than 1

offset - number of rows skipped before starting, will be 0 if less than 0.

Throws:

DirectoryException

See Also:

Session.query(Map, Set, Map, boolean)

createEntryWithoutReferences

protected DocumentModel createEntryWithoutReferences(Map<String,Object> fieldMap)

Description copied from class: BaseSession

To be implemented for specific creation.

Specified by:

createEntryWithoutReferences in class BaseSession

updateEntryWithoutReferences

protected List<String> updateEntryWithoutReferences(DocumentModel docModel)
                                             throws DirectoryException

Description copied from class: BaseSession

To be implemented for specific update.

Specified by:

updateEntryWithoutReferences in class BaseSession

Throws:

DirectoryException

deleteEntryWithoutReferences

public void deleteEntryWithoutReferences(String id)
                                  throws DirectoryException

Description copied from class: BaseSession

To be implemented for specific deletion.

Specified by:

deleteEntryWithoutReferences in class BaseSession

Throws:

DirectoryException

fillPreparedStatementFields

protected void fillPreparedStatementFields(Map<String,Object> filterMap,
                                           List<Column> orderedColumns,
                                           PreparedStatement ps)
                                    throws DirectoryException

Throws:

DirectoryException

fieldValueForWrite

protected Serializable fieldValueForWrite(Object value,
                                          Column column)

close

public void close()
           throws DirectoryException

Description copied from interface: Session

Closes the session and all open result sets obtained from this session.

Releases this Connection object's resources immediately instead of waiting for them to be automatically released.

TODO: should this operation auto-commit pending changes?

Throws:

DirectoryException - if a communication error occurs

isLive

public boolean isLive()
               throws DirectoryException

Enable connection status checking on SQL directory connections

Throws:

DirectoryException

Since:

5.7.2

authenticate

public boolean authenticate(String username,
                            String password)

Description copied from interface: Session

Checks that the credentials provided by the UserManager match those registered in the directory. If username is not in the directory, this should return false instead of throrwing an exception.

Returns:

true is the credentials match those stored in the directory

isAuthenticating

public boolean isAuthenticating()

Description copied from interface: Session

Tells whether the directory implementation can be used as an authenticating backend for the UserManager (based on login / password check).

Specified by:

isAuthenticating in interface Session

Overrides:

isAuthenticating in class BaseSession

Returns:

true is the directory is authentication aware

hasEntry

public boolean hasEntry(String id)

Description copied from interface: Session

Returns true if session has an entry with given id.

isMultiTenant

protected boolean isMultiTenant()

Returns true if this directory supports multi tenancy, false otherwise.

getCurrentTenantId

protected String getCurrentTenantId()

Returns the tenant id of the logged user if any, null otherwise.

toString

public String toString()

Overrides:

toString in class Object