com.netflix.genie.web.data.services.jpa

Class JpaTagPersistenceServiceImpl

java.lang.Object

com.netflix.genie.web.data.services.jpa.JpaTagPersistenceServiceImpl

All Implemented Interfaces:

JpaTagPersistenceService, TagPersistenceService

@Transactional
public class JpaTagPersistenceServiceImpl
extends java.lang.Object
implements JpaTagPersistenceService

JPA based implementation of the TagPersistenceService interface.

Since:

3.3.0

Constructor Summary

Constructors

Constructor and Description
JpaTagPersistenceServiceImpl(JpaTagRepository tagRepository) Constructor.

Method Summary

Modifier and Type	Method and Description
void	createTagIfNotExists(@NotBlank(message="Tag cannot be blank") java.lang.String tag) Attempt to create a tag in the system if it doesn't already exist.
long	deleteUnusedTags(@NotNull java.time.Instant createdThreshold) Delete all tags from the database that aren't referenced which were created before the supplied created threshold.
java.util.Optional<TagEntity>	getTag(@NotBlank(message="Tag string to find can\'t be blank") java.lang.String tag) Get a tag entity reference for the given tag string.
java.util.Set<TagEntity>	getTags(@NotNull java.util.Set<java.lang.String> tags) Get all the tag entity references that match the input set of tag strings.

Methods inherited from class java.lang.Object

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

Constructor Detail

JpaTagPersistenceServiceImpl

public JpaTagPersistenceServiceImpl(JpaTagRepository tagRepository)

Constructor.

Parameters:

tagRepository - The repository to use to perform CRUD operations on tags

Method Detail

createTagIfNotExists

public void createTagIfNotExists(@NotBlank(message="Tag cannot be blank")
                                 @NotBlank(message="Tag cannot be blank") java.lang.String tag)

Attempt to create a tag in the system if it doesn't already exist.

Specified by:

createTagIfNotExists in interface TagPersistenceService

Parameters:

tag - the tag to create. Not blank.

deleteUnusedTags

public long deleteUnusedTags(@NotNull
                             @NotNull java.time.Instant createdThreshold)

Delete all tags from the database that aren't referenced which were created before the supplied created threshold.

Specified by:

deleteUnusedTags in interface TagPersistenceService

Parameters:

createdThreshold - The instant in time where tags created before this time that aren't referenced will be deleted. Inclusive

Returns:

The number of tags deleted

getTag

@Transactional(readOnly=true)
public java.util.Optional<TagEntity> getTag(@NotBlank(message="Tag string to find can\'t be blank")
                                                                          @NotBlank(message="Tag string to find can\'t be blank") java.lang.String tag)

Get a tag entity reference for the given tag string.

Specified by:

getTag in interface JpaTagPersistenceService

Parameters:

tag - The tag to get

Returns:

The tag entity wrapped in an Optional or Optional.empty()

getTags

@Transactional(readOnly=true)
public java.util.Set<TagEntity> getTags(@NotNull
                                                                      @NotNull java.util.Set<java.lang.String> tags)

Get all the tag entity references that match the input set of tag strings.

Specified by:

getTags in interface JpaTagPersistenceService

Parameters:

tags - the tag strings to search for

Returns:

The set of tag entities found. Note: if a tag in tags doesn't exist in database the set returned will consist of all other discovered tags. E.G. tags is ("a", "b", "c") and only "b" and "c" are in the database the returned set will contain "b" and "c". The method won't fail.