com.atlassian.jira.crowd.embedded.ofbiz

Class OfBizUserDao

java.lang.Object

com.atlassian.jira.crowd.embedded.ofbiz.OfBizUserDao

All Implemented Interfaces:

com.atlassian.crowd.embedded.spi.UserDao

public class OfBizUserDao
extends Object
implements com.atlassian.crowd.embedded.spi.UserDao

Implementation of the user DAO that works with OfBiz

Constructor Summary

Constructors

Constructor and Description
OfBizUserDao(OfBizDelegator ofBizDelegator, com.atlassian.crowd.embedded.spi.DirectoryDao directoryDao, InternalMembershipDao membershipDao, UserKeyStore userKeyStore, UserDeleteVeto userDeleteVeto, com.atlassian.cache.CacheManager cacheManager, com.atlassian.beehive.ClusterLockService clusterLockService, ApplicationProperties applicationProperties)

Method Summary

Modifier and Type	Method and Description
com.atlassian.crowd.model.user.User	add(com.atlassian.crowd.model.user.User user, com.atlassian.crowd.embedded.api.PasswordCredential credential)
com.atlassian.crowd.util.BatchResult<com.atlassian.crowd.model.user.User>	addAll(Set<com.atlassian.crowd.model.user.UserTemplateWithCredentialAndAttributes> users)
com.atlassian.jira.crowd.embedded.ofbiz.OfBizUser	findByExternalId(long directoryId, String externalId)
com.atlassian.crowd.model.user.TimestampedUser	findByName(long directoryId, String userName)
com.atlassian.crowd.model.user.UserWithAttributes	findByNameWithAttributes(long directoryId, String userName)
Collection<String>	findNamesOfUsersInGroups(Collection<String> groupNames) Returns the lower-cased names of all users in the specified groups.
void	flushCache() Invoked by OfBizCacheFlushingManager to ensure caches are being flushed in the right order on XMLRestoreFinishedEvent
Collection<String>	getAllAttributeKeys()
Set<String>	getAllExternalIds(long directoryId)
com.atlassian.crowd.embedded.api.PasswordCredential	getCredential(long directoryId, String userName)
List<com.atlassian.crowd.embedded.api.PasswordCredential>	getCredentialHistory(long directoryId, String userName)
long	getUniqueUserCount(Set<Long> directoryIds)
long	getUserCount(long directoryId)
boolean	isCacheInitialized() We check if the cache is initialized or not.
void	processUsers(java.util.function.Consumer<? super com.atlassian.crowd.model.user.User> userProcessor) Performs an operation on every user in the system.
void	remove(com.atlassian.crowd.model.user.User user)
com.atlassian.crowd.util.BatchResult<String>	removeAllUsers(long directoryId, Set<String> userNames)
void	removeAttribute(com.atlassian.crowd.model.user.User user, String attributeName)
com.atlassian.crowd.model.user.User	rename(com.atlassian.crowd.model.user.User oldUser, String newName)
<T> List<T>	search(long directoryId, com.atlassian.crowd.search.query.entity.EntityQuery<T> query)
void	setAttributeForAllInDirectory(long directoryId, String attrName, String attrValue)
void	storeAttributes(com.atlassian.crowd.model.user.User user, Map<String,Set<String>> attributes)
com.atlassian.crowd.model.user.User	update(com.atlassian.crowd.model.user.User user)
void	updateCredential(com.atlassian.crowd.model.user.User user, com.atlassian.crowd.embedded.api.PasswordCredential credential, int credentialHistory)
protected void	updateGroupMembership(long directoryId, String oldName, String newName)
boolean	useFullCache()

Methods inherited from class java.lang.Object

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

Constructor Detail

OfBizUserDao

public OfBizUserDao(OfBizDelegator ofBizDelegator,
                    com.atlassian.crowd.embedded.spi.DirectoryDao directoryDao,
                    InternalMembershipDao membershipDao,
                    UserKeyStore userKeyStore,
                    UserDeleteVeto userDeleteVeto,
                    com.atlassian.cache.CacheManager cacheManager,
                    com.atlassian.beehive.ClusterLockService clusterLockService,
                    ApplicationProperties applicationProperties)

Method Detail

useFullCache

public boolean useFullCache()

findByName

@Nonnull
public com.atlassian.crowd.model.user.TimestampedUser findByName(long directoryId,
                                                                          String userName)
                                                                   throws UserNotFoundException

Specified by:

findByName in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

findByExternalId

@Nonnull
public com.atlassian.jira.crowd.embedded.ofbiz.OfBizUser findByExternalId(long directoryId,
                                                                                   String externalId)
                                                                            throws UserNotFoundException

Specified by:

findByExternalId in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

findByNameWithAttributes

@Nonnull
public com.atlassian.crowd.model.user.UserWithAttributes findByNameWithAttributes(long directoryId,
                                                                                           String userName)
                                                                                    throws UserNotFoundException

Specified by:

findByNameWithAttributes in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

getCredential

@Nullable
public com.atlassian.crowd.embedded.api.PasswordCredential getCredential(long directoryId,
                                                                                   String userName)
                                                                            throws UserNotFoundException

Specified by:

getCredential in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

getCredentialHistory

public List<com.atlassian.crowd.embedded.api.PasswordCredential> getCredentialHistory(long directoryId,
                                                                                      String userName)
                                                                               throws UserNotFoundException

Specified by:

getCredentialHistory in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

add

public com.atlassian.crowd.model.user.User add(com.atlassian.crowd.model.user.User user,
                                               com.atlassian.crowd.embedded.api.PasswordCredential credential)
                                        throws com.atlassian.crowd.exception.UserAlreadyExistsException

Specified by:

add in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

com.atlassian.crowd.exception.UserAlreadyExistsException

addAll

@Nonnull
public com.atlassian.crowd.util.BatchResult<com.atlassian.crowd.model.user.User> addAll(Set<com.atlassian.crowd.model.user.UserTemplateWithCredentialAndAttributes> users)

Specified by:

addAll in interface com.atlassian.crowd.embedded.spi.UserDao

storeAttributes

public void storeAttributes(com.atlassian.crowd.model.user.User user,
                            Map<String,Set<String>> attributes)
                     throws UserNotFoundException

Specified by:

storeAttributes in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

setAttributeForAllInDirectory

public void setAttributeForAllInDirectory(long directoryId,
                                          String attrName,
                                          String attrValue)

Specified by:

setAttributeForAllInDirectory in interface com.atlassian.crowd.embedded.spi.UserDao

update

public com.atlassian.crowd.model.user.User update(com.atlassian.crowd.model.user.User user)
                                           throws UserNotFoundException

Specified by:

update in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

updateCredential

public void updateCredential(com.atlassian.crowd.model.user.User user,
                             com.atlassian.crowd.embedded.api.PasswordCredential credential,
                             int credentialHistory)
                      throws UserNotFoundException

Specified by:

updateCredential in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

rename

public com.atlassian.crowd.model.user.User rename(com.atlassian.crowd.model.user.User oldUser,
                                                  String newName)
                                           throws UserNotFoundException

Specified by:

rename in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

isCacheInitialized

public boolean isCacheInitialized()

We check if the cache is initialized or not. This is an important cache to see if jira is available or not for the users to login.

Returns:

true if the cache is initialized, false if not.

updateGroupMembership

protected void updateGroupMembership(long directoryId,
                                     String oldName,
                                     String newName)

removeAllUsers

public com.atlassian.crowd.util.BatchResult<String> removeAllUsers(long directoryId,
                                                                   Set<String> userNames)

Specified by:

removeAllUsers in interface com.atlassian.crowd.embedded.spi.UserDao

getAllExternalIds

public Set<String> getAllExternalIds(long directoryId)
                              throws com.atlassian.crowd.exception.DirectoryNotFoundException

Specified by:

getAllExternalIds in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

com.atlassian.crowd.exception.DirectoryNotFoundException

getUserCount

public long getUserCount(long directoryId)
                  throws com.atlassian.crowd.exception.DirectoryNotFoundException

Specified by:

getUserCount in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

com.atlassian.crowd.exception.DirectoryNotFoundException

getUniqueUserCount

public long getUniqueUserCount(Set<Long> directoryIds)
                        throws com.atlassian.crowd.exception.DirectoryNotFoundException

Throws:

com.atlassian.crowd.exception.DirectoryNotFoundException

removeAttribute

public void removeAttribute(com.atlassian.crowd.model.user.User user,
                            String attributeName)
                     throws UserNotFoundException

Specified by:

removeAttribute in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

remove

public void remove(com.atlassian.crowd.model.user.User user)
            throws UserNotFoundException

Specified by:

remove in interface com.atlassian.crowd.embedded.spi.UserDao

Throws:

UserNotFoundException

search

public <T> List<T> search(long directoryId,
                          com.atlassian.crowd.search.query.entity.EntityQuery<T> query)

Specified by:

search in interface com.atlassian.crowd.embedded.spi.UserDao

findNamesOfUsersInGroups

public Collection<String> findNamesOfUsersInGroups(Collection<String> groupNames)

Returns the lower-cased names of all users in the specified groups. Only searches directly in these groups, if a recursive group search is required the caller will need to pre-expand the groups.

Parameters:

groupNames - the names of the groups to search.

Returns:

set of all user names in these groups, in lower case.

getAllAttributeKeys

public Collection<String> getAllAttributeKeys()

processUsers

public void processUsers(java.util.function.Consumer<? super com.atlassian.crowd.model.user.User> userProcessor)

Performs an operation on every user in the system.

This can be a time-consuming operation on JIRA instances that contain many users. It is recommended to use one of the search methods where possible.

This method performs a live iteration over a database result set. Care must be taken if additional database operations are performed within the userProcessor consumer.

Parameters:

userProcessor - the operation to perform on each user.

Since:

v7.0

flushCache

public void flushCache()

Invoked by OfBizCacheFlushingManager to ensure caches are being flushed in the right order on XMLRestoreFinishedEvent