org.ametys.cms.content.indexing.solr

Class SolrIndexer

java.lang.Object

org.ametys.runtime.plugin.component.AbstractLogEnabled

org.ametys.cms.content.indexing.solr.SolrIndexer

All Implemented Interfaces:

LogEnabled, Initializable, Component, Contextualizable, Serviceable

public class SolrIndexer
extends AbstractLogEnabled
implements Component, Serviceable, Initializable, Contextualizable

Solr indexer.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	SolrIndexer.IndexationResult

Field Summary

Fields

Modifier and Type	Field and Description
private static ThreadLocal<SimpleDateFormat>	__DATE_FORMAT
private static int	__SOLR_STRING_NB_BYTES_LIMIT
protected String	_ametysInternalUrl The Ametys internal URL used by Solr to query Ametys
private static String	_CONFIGSET_NAME_PREFIX
protected Context	_context The avalon context
private static List<String>	_READ_ONLY_FIELDS
private static List<String>	_READ_ONLY_FIELDTYPES
protected ReadAccessHelper	_readAccessHelper The helper for read access
protected AmetysObjectResolver	_resolver The ametys object resolver.
protected SchemaDefinitionProviderExtensionPoint	_schemaDefProviderEP The schema definition provider extension point.
protected SchemaHelper	_schemaHelper The schema helper.
protected SolrClientProvider	_solrClientProvider The Solr client provider
protected SolrContentIndexer	_solrContentIndexer Solr Ametys contents indexer
protected String	_solrCorePrefix The solr core prefix.
protected SolrResourceIndexer	_solrResourceIndexer Solr resource indexer.
protected SolrWorkflowIndexer	_solrWorkflowIndexer Solr workflow indexer.
protected WorkspaceSelector	_workspaceSelector The workspace selector.
static String	ROLE The component role.

Constructor Summary

Constructors

Constructor and Description
SolrIndexer()

Method Summary

Modifier and Type	Method and Description
private <T> void	_addField(SolrInputDocument document, String fieldName, Set<T> values, Function<T,String> stringifier)
private void	_createConfigset(String name)
private SolrClient	_defaultSolrClient()
private void	_doIndexContent(Content content, String workspaceName, boolean indexAttachments, SolrClient solrClient)
protected SolrClient	_getAutoCommitSolrClient(String workspaceName) Gets the 'autocommit' Solr client
protected SolrClient	_getNoAutoCommitSolrClient(String workspaceName) Gets the 'no autocommit' Solr client
private void	_indexContentAttachment(Resource resource, SolrInputDocument document, Content content)
protected void	_indexResourceDocument(Resource resource, SolrInputDocument document, SolrClient solrClient) Index a populated solr input document of type Resource.
private void	_unindexAllResources(String workspaceName, SolrClient solrClient)
protected void	addCustomUpdates(List<org.apache.solr.client.solrj.request.schema.SchemaRequest.Update> updates, SchemaFields schemaFields) Compute the list of custom SchemaRequest.Update directives.
protected void	addStaticSchemaUpdates(List<org.apache.solr.client.solrj.request.schema.SchemaRequest.Update> updates, org.apache.solr.client.solrj.response.schema.SchemaRepresentation staticSchema, SchemaFields schemaFields) Compute the list of SchemaRequest.Update directives from the static schema.
protected void	clearSchema(SolrClient solrClient, String collection) Delete all the fields of the existing schema in the given collection.
void	commit() Process a Solr commit operation in all workspaces.
void	commit(String workspaceName, SolrClient solrClient) Process a Solr commit operation in given workspace.
void	contextualize(Context context)
void	createCore(String name) Create a Solr core.
static SimpleDateFormat	dateFormat() Returns the formatter for indexing dates.
protected boolean	definitionExists(SchemaDefinition definition, SchemaFields schemaFields) Test if the given schema definition exists in the given SchemaFields reference.
void	deleteCore(String name) Delete a Solr core.
protected void	deleteRepeaterDocs(String contentId, String workspaceName, SolrClient solrClient) Delete repeater documents of a specified content.
protected void	doIndexContent(Content content, String workspaceName, SolrClient solrClient) Add or update a content into Solr index
protected SolrIndexer.IndexationResult	doIndexContents(Iterable<Content> contents, String workspaceName, boolean indexAttachments, SolrClient solrClient) Send some contents for indexation in the solr server.
protected void	doIndexContentWorkflow(Content content, String workspaceName, SolrClient solrClient) Index the whole workflow of a content.
protected void	doIndexExplorerItem(AmetysObject node, String documentType, TraversableAmetysObject resourceRoot, SolrClient solrClient) Add or update a resource into Solr index
protected void	doIndexResource(Resource resource, String documentType, TraversableAmetysObject resourceRoot, SolrClient solrClient) Add or update a resource into Solr index
protected SolrIndexer.IndexationResult	doIndexResources(Iterable<? extends AmetysObject> resources, String documentType, TraversableAmetysObject resourceRoot, String workspaceName, SolrClient solrClient) Send some resources for indexation in the solr server.
protected void	doUnindexContentAttachments(String contentId, String workspaceName, SolrClient solrClient) Delete content attachments documents of a given content from the Solr server.
protected void	doUnindexDocument(String id, String workspaceName, SolrClient solrClient) Delete a document from the Solr server.
Set<String>	getCoreNames() Get the names of the Solr cores.
protected Set<String>	getRealCoreNames() Get the names of the Solr cores.
protected org.apache.solr.client.solrj.request.schema.SchemaRequest.Update	getSchemaUpdate(SchemaDefinition definition) Get the schema SchemaRequest.Update directive from the given schema definition.
void	indexAclInitValues(AmetysObject ametysObject, SolrInputDocument document) Indexes read-ACl initial values for object
Map<String,Object>	indexAllContents(String workspaceName, boolean indexAttachments, SolrClient solrClient) Index all the contents in a given workspace.
Map<String,Object>	indexAllResources(String workspaceName, SolrClient solrClient) Index all the resources in a given workspace.
void	indexContent(String contentId, boolean indexAttachments) Add or update a content into Solr index on all workspaces and commit
void	indexContent(String contentId, String workspaceName, boolean indexAttachments) Add or update a content into Solr index
void	indexContent(String contentId, String workspaceName, boolean indexAttachments, SolrClient solrClient) Add or update a content into Solr index
void	indexContentAttachment(Resource resource, Content content) Index a content attachment
void	indexContentAttachment(Resource resource, Content content, SolrClient solrClient) Index a content attachment
void	indexContentAttachments(ResourceCollection collection, Content content) Index content attachments as new entries in the idnex
void	indexContentAttachments(ResourceCollection collection, Content content, SolrClient solrClient) Index content attachments as new entries in the idnex
SolrIndexer.IndexationResult	indexContents(Iterable<Content> contents) Send a collection of contents for indexation in the solr server on all workspaces and commit
SolrIndexer.IndexationResult	indexContents(Iterable<Content> contents, String workspaceName, boolean indexAttachments, SolrClient solrClient) Send a collection of contents for indexation in the solr server.
void	indexResource(Resource resource, String documentType, String workspaceName) Add or update a resource into Solr index
SolrIndexer.IndexationResult	indexResources(Iterable<? extends AmetysObject> resources, String documentType, TraversableAmetysObject resourceRoot, String workspaceName, SolrClient solrClient) Send a collection of contents for indexation in the solr server.
SolrIndexer.IndexationResult	indexResources(Iterable<AmetysObject> resources, String documentType, String workspaceName) Send a collection of contents for indexation in the solr server.
void	indexSubcontents(String collectionId, boolean indexAttachments) Add or update the child contents of a AmetysObjectCollection into Solr index, for all workspaces and commit
void	indexSubcontents(String collectionId, String workspaceName, boolean indexAttachments) Index the child contents of a AmetysObjectCollection
void	initialize()
void	optimize(String workspaceName, SolrClient solrClient) Launch a solr index optimization.
void	reloadAclCache() Reloads the ACL Solr cache for all users
void	reloadAclCache(String workspaceName) Reloads the ACL Solr cache for all users
void	reloadAclCache(String workspaceName, boolean checkIfNecessary) Reloads the ACL Solr cache for all users
protected void	reloadCores() Reload the solr cores.
protected void	reorderUpdates(List<org.apache.solr.client.solrj.request.schema.SchemaRequest.Update> updates) Reorder the list of SchemaRequest.Update directives.
void	sendSchema() Send the schema.
void	service(ServiceManager serviceManager)
static String	truncateUtf8StringValue(String value, Logger logger, String documentId, String fieldName) Truncates (if needed) the given string in order to be indexed without immense term error by Solr.
protected void	unindexAllContents(String workspaceName, boolean unindexAttachments, SolrClient solrClient) Unindex all content documents.
void	unindexAllDocuments(String workspaceName, SolrClient solrClient) Delete all documents from the solr index.
void	unindexContent(String contentId, boolean unindexAttachments) Remove a content from Solr index for all workspaces and commit
void	unindexContent(String contentId, String workspaceName, boolean unindexAttachments) Remove a content from Solr index
void	unindexContent(String contentId, String workspaceName, boolean unindexAttachments, SolrClient solrClient) Remove a content from Solr index
void	unindexContents(Collection<String> contentIds) Remove a content from Solr index for all workspaces and commit
void	unindexContents(Collection<String> contentIds, String workspaceName) Remove a content from Solr index
void	unindexResource(String resourceId) Remove a resource from Solr index for all workspaces and commit
void	unindexResource(String resourceId, String workspaceName) Remove a resource from the Solr index.
void	unindexResourcesByPath(String rootId, String path) Delete all resource documents at a given path for all workspaces and commit
void	unindexResourcesByPath(String rootId, String path, String workspaceName) Delete all resource documents at a given path.
void	updateAmetysUrlCoreProperty() Updates the ametys.url property of the Solr cores.
void	updateSystemProperty(Content content, String propertyId, String workspaceName) Update the value of a specific system property in a content document.
void	updateSystemProperty(Content content, String propertyId, String workspaceName, SolrClient solrClient) Update the value of a specific system property in a content document.

Methods inherited from class org.ametys.runtime.plugin.component.AbstractLogEnabled

getLogger, setLogger

Methods inherited from class java.lang.Object

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

Field Detail

ROLE

public static final String ROLE

The component role.

__DATE_FORMAT

private static final ThreadLocal<SimpleDateFormat> __DATE_FORMAT

_CONFIGSET_NAME_PREFIX

private static final String _CONFIGSET_NAME_PREFIX

See Also:

Constant Field Values

_READ_ONLY_FIELDS

private static final List<String> _READ_ONLY_FIELDS

_READ_ONLY_FIELDTYPES

private static final List<String> _READ_ONLY_FIELDTYPES

__SOLR_STRING_NB_BYTES_LIMIT

private static final int __SOLR_STRING_NB_BYTES_LIMIT

See Also:

Constant Field Values

_resolver

protected AmetysObjectResolver _resolver

The ametys object resolver.

_schemaDefProviderEP

protected SchemaDefinitionProviderExtensionPoint _schemaDefProviderEP

The schema definition provider extension point.

_schemaHelper

protected SchemaHelper _schemaHelper

The schema helper.

_solrContentIndexer

protected SolrContentIndexer _solrContentIndexer

Solr Ametys contents indexer

_solrWorkflowIndexer

protected SolrWorkflowIndexer _solrWorkflowIndexer

Solr workflow indexer.

_solrResourceIndexer

protected SolrResourceIndexer _solrResourceIndexer

Solr resource indexer.

_solrClientProvider

protected SolrClientProvider _solrClientProvider

The Solr client provider

_solrCorePrefix

protected String _solrCorePrefix

The solr core prefix.

_ametysInternalUrl

protected String _ametysInternalUrl

The Ametys internal URL used by Solr to query Ametys

_workspaceSelector

protected WorkspaceSelector _workspaceSelector

The workspace selector.

_readAccessHelper

protected ReadAccessHelper _readAccessHelper

The helper for read access

_context

protected Context _context

The avalon context

Constructor Detail

SolrIndexer

public SolrIndexer()

Method Detail

dateFormat

public static SimpleDateFormat dateFormat()

Returns the formatter for indexing dates. This is used for adding a dates as formatted strings (and not with date object directly) to prevent indexing of the wrong value because of time zone

Returns:

The date format for indexing dates

truncateUtf8StringValue

public static String truncateUtf8StringValue(String value,
                                             Logger logger,
                                             String documentId,
                                             String fieldName)

Truncates (if needed) the given string in order to be indexed without immense term error by Solr. Only the 32766 first bytes of the String will be kept.

Parameters:

value - The string value to index

logger - The logger for logging in WARN level in case the given string is too long and will be truncated. Can be null if you do not want to log.

documentId - The id of the document being indexed. Can be null if you do not want to log.

fieldName - The name of the field being indexed. Can be null if you do not want to log.

Returns:

The given string value, or its truncation if it is too long (greater than 32766 bytes)

service

public void service(ServiceManager serviceManager)
             throws ServiceException

Specified by:

service in interface Serviceable

Throws:

ServiceException

initialize

public void initialize()
                throws Exception

Specified by:

initialize in interface Initializable

Throws:

Exception

contextualize

public void contextualize(Context context)
                   throws ContextException

Specified by:

contextualize in interface Contextualizable

Throws:

ContextException

_getAutoCommitSolrClient

protected SolrClient _getAutoCommitSolrClient(String workspaceName)

Gets the 'autocommit' Solr client

Parameters:

workspaceName - The name of the workspace

Returns:

the Solr client

_getNoAutoCommitSolrClient

protected SolrClient _getNoAutoCommitSolrClient(String workspaceName)

Gets the 'no autocommit' Solr client

Parameters:

workspaceName - The name of the workspace

Returns:

the Solr client

_defaultSolrClient

private SolrClient _defaultSolrClient()

getCoreNames

public Set<String> getCoreNames()
                         throws IOException,
                                SolrServerException

Get the names of the Solr cores.

Returns:

The names of the Solr cores.

Throws:

IOException - If an I/O error occurs.

SolrServerException - If a Solr error occurs.

getRealCoreNames

protected Set<String> getRealCoreNames()
                                throws IOException,
                                       SolrServerException

Get the names of the Solr cores.

Returns:

The names of the Solr cores.

Throws:

IOException - If an I/O error occurs.

SolrServerException - If a Solr error occurs.

createCore

public void createCore(String name)
                throws IOException,
                       SolrServerException

Create a Solr core.

Parameters:

name - The name of the core to create.

Throws:

IOException - If an I/O error occurs.

SolrServerException - If a Solr error occurs.

updateAmetysUrlCoreProperty

public void updateAmetysUrlCoreProperty()

Updates the ametys.url property of the Solr cores.

_createConfigset

private void _createConfigset(String name)
                       throws IOException,
                              SolrServerException

Throws:

IOException

SolrServerException

deleteCore

public void deleteCore(String name)
                throws IOException,
                       SolrServerException

Delete a Solr core.

Parameters:

name - The name of the core to delete.

Throws:

IOException - If an I/O error occurs.

SolrServerException - If a Solr error occurs.

sendSchema

public void sendSchema()
                throws IOException,
                       SolrServerException

Send the schema.

Throws:

IOException - If a communication error occurs.

SolrServerException - If a solr error occurs.

addStaticSchemaUpdates

protected void addStaticSchemaUpdates(List<org.apache.solr.client.solrj.request.schema.SchemaRequest.Update> updates,
                                      org.apache.solr.client.solrj.response.schema.SchemaRepresentation staticSchema,
                                      SchemaFields schemaFields)

Compute the list of SchemaRequest.Update directives from the static schema.

Parameters:

updates - The list of SchemaRequest.Update directives to fill.

staticSchema - The static schema representation.

schemaFields - The current schema fields, used to track the existing fields (to be filled).

addCustomUpdates

protected void addCustomUpdates(List<org.apache.solr.client.solrj.request.schema.SchemaRequest.Update> updates,
                                SchemaFields schemaFields)

Compute the list of custom SchemaRequest.Update directives.

Parameters:

updates - The list of SchemaRequest.Update directives to fill.

schemaFields - The current schema fields, used to track the existing fields (to be filled).

reorderUpdates

protected void reorderUpdates(List<org.apache.solr.client.solrj.request.schema.SchemaRequest.Update> updates)

Reorder the list of SchemaRequest.Update directives.

Parameters:

updates - The list of SchemaRequest.Update directives to reorder.

definitionExists

protected boolean definitionExists(SchemaDefinition definition,
                                   SchemaFields schemaFields)

Test if the given schema definition exists in the given SchemaFields reference.

Parameters:

definition - The schema definition to test.

schemaFields - The current schema fields.

Returns:

true if the SchemaFields contain the schema definition.

clearSchema

protected void clearSchema(SolrClient solrClient,
                           String collection)
                    throws IOException,
                           SolrServerException

Delete all the fields of the existing schema in the given collection.

Parameters:

solrClient - The Solr client

collection - The collection.

Throws:

IOException - If a communication error occurs.

SolrServerException - If a solr error occurs.

getSchemaUpdate

protected org.apache.solr.client.solrj.request.schema.SchemaRequest.Update getSchemaUpdate(SchemaDefinition definition)

Get the schema SchemaRequest.Update directive from the given schema definition.

Parameters:

definition - The schema definition to add.

Returns:

The add SchemaRequest.Update directive.

reloadCores

protected void reloadCores()
                    throws IOException,
                           SolrServerException

Reload the solr cores.

Throws:

IOException - If a communication error occurs.

SolrServerException - If a solr error occurs.

reloadAclCache

public void reloadAclCache()
                    throws IOException,
                           SolrServerException,
                           RepositoryException

Reloads the ACL Solr cache for all users

Throws:

IOException - If an I/O error occurs.

SolrServerException - If a Solr error occurs.

RepositoryException - If a repository exception occurs when retrieving workspaces.

reloadAclCache

public void reloadAclCache(String workspaceName)
                    throws IOException,
                           SolrServerException

Reloads the ACL Solr cache for all users

Parameters:

workspaceName - The workspace name

Throws:

IOException - If an I/O error occurs.

SolrServerException - If a Solr error occurs.

reloadAclCache

public void reloadAclCache(String workspaceName,
                           boolean checkIfNecessary)
                    throws IOException,
                           SolrServerException

Reloads the ACL Solr cache for all users

Parameters:

workspaceName - The workspace name

checkIfNecessary - true to check if the reload is necessary for each segment (i.e. reload only the segments not already in cache)

Throws:

IOException - If an I/O error occurs.

SolrServerException - If a Solr error occurs.

indexAllContents

public Map<String,Object> indexAllContents(String workspaceName,
                                           boolean indexAttachments,
                                           SolrClient solrClient)
                                    throws Exception

Index all the contents in a given workspace.

Parameters:

workspaceName - the workspace where to index

indexAttachments - to index content attachments

solrClient - The solr client to use

Returns:

The indexation result as a Map.

Throws:

Exception - if an error occurs while indexing.

unindexAllContents

protected void unindexAllContents(String workspaceName,
                                  boolean unindexAttachments,
                                  SolrClient solrClient)
                           throws Exception

Unindex all content documents.

Parameters:

workspaceName - The workspace name

unindexAttachments - also unindex content attachments

solrClient - The solr client to use

Throws:

Exception - if an error occurs while unindexing.

indexSubcontents

public void indexSubcontents(String collectionId,
                             boolean indexAttachments)
                      throws Exception

Add or update the child contents of a AmetysObjectCollection into Solr index, for all workspaces and commit

Parameters:

collectionId - The id of collection

indexAttachments - to index content attachments

Throws:

Exception - if an error occurs while indexing.

indexSubcontents

public void indexSubcontents(String collectionId,
                             String workspaceName,
                             boolean indexAttachments)
                      throws Exception

Index the child contents of a AmetysObjectCollection

Parameters:

collectionId - The id of collection

workspaceName - the workspace where to index

indexAttachments - to index content attachments

Throws:

Exception - if an error occurs while unindexing.

indexContent

public void indexContent(String contentId,
                         boolean indexAttachments)
                  throws Exception

Add or update a content into Solr index on all workspaces and commit

Parameters:

contentId - The id of the content to index

indexAttachments - to index content attachments

Throws:

Exception - if an error occurs while indexing.

indexContent

public void indexContent(String contentId,
                         String workspaceName,
                         boolean indexAttachments)
                  throws Exception

Add or update a content into Solr index

Parameters:

contentId - The id of the content to index

workspaceName - the workspace where to index

indexAttachments - to index content attachments

Throws:

Exception - if an error occurs while indexing.

indexContent

public void indexContent(String contentId,
                         String workspaceName,
                         boolean indexAttachments,
                         SolrClient solrClient)
                  throws Exception

Add or update a content into Solr index

Parameters:

contentId - The id of the content to index

workspaceName - the workspace where to index

indexAttachments - to index content attachments

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

_doIndexContent

private void _doIndexContent(Content content,
                             String workspaceName,
                             boolean indexAttachments,
                             SolrClient solrClient)
                      throws IndexingException

Throws:

IndexingException

indexContents

public SolrIndexer.IndexationResult indexContents(Iterable<Content> contents)
                                           throws Exception

Send a collection of contents for indexation in the solr server on all workspaces and commit

Parameters:

contents - the collection of contents to index.

Returns:

the indexation result.

Throws:

Exception - if an error occurs while indexing.

indexContents

public SolrIndexer.IndexationResult indexContents(Iterable<Content> contents,
                                                  String workspaceName,
                                                  boolean indexAttachments,
                                                  SolrClient solrClient)
                                           throws Exception

Send a collection of contents for indexation in the solr server.

Parameters:

contents - the collection of contents to index.

workspaceName - the workspace where to index

indexAttachments - to index content attachments

solrClient - The solr client to use

Returns:

the indexation result.

Throws:

Exception - if an error occurs while indexing.

doIndexContents

protected SolrIndexer.IndexationResult doIndexContents(Iterable<Content> contents,
                                                       String workspaceName,
                                                       boolean indexAttachments,
                                                       SolrClient solrClient)
                                                throws Exception

Send some contents for indexation in the solr server.

Parameters:

contents - the contents to index.

workspaceName - The workspace name

indexAttachments - to index content attachments

solrClient - The solr client to use

Returns:

the indexation result.

Throws:

Exception - if an error occurs committing the results.

updateSystemProperty

public void updateSystemProperty(Content content,
                                 String propertyId,
                                 String workspaceName)
                          throws Exception

Update the value of a specific system property in a content document.

Parameters:

content - The content to update.

propertyId - The system property ID.

workspaceName - The workspace name

Throws:

Exception - if an error occurs while indexing.

updateSystemProperty

public void updateSystemProperty(Content content,
                                 String propertyId,
                                 String workspaceName,
                                 SolrClient solrClient)
                          throws Exception

Update the value of a specific system property in a content document.

Parameters:

content - The content to update.

propertyId - The system property ID.

workspaceName - The workspace name

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

unindexContent

public void unindexContent(String contentId,
                           boolean unindexAttachments)
                    throws Exception

Remove a content from Solr index for all workspaces and commit

Parameters:

contentId - The id of content to unindex

unindexAttachments - also unindex content attachments

Throws:

Exception - if an error occurs while indexing.

unindexContent

public void unindexContent(String contentId,
                           String workspaceName,
                           boolean unindexAttachments)
                    throws Exception

Remove a content from Solr index

Parameters:

contentId - The id of content to unindex

workspaceName - The workspace where to work in

unindexAttachments - also unindex content attachments

Throws:

Exception - if an error occurs while indexing.

unindexContent

public void unindexContent(String contentId,
                           String workspaceName,
                           boolean unindexAttachments,
                           SolrClient solrClient)
                    throws Exception

Remove a content from Solr index

Parameters:

contentId - The id of content to unindex

workspaceName - The workspace where to work in

unindexAttachments - also unindex content attachments

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

unindexContents

public void unindexContents(Collection<String> contentIds)
                     throws Exception

Remove a content from Solr index for all workspaces and commit

Parameters:

contentIds - The id of content to unindex

Throws:

Exception - if an error occurs while indexing.

unindexContents

public void unindexContents(Collection<String> contentIds,
                            String workspaceName)
                     throws Exception

Remove a content from Solr index

Parameters:

contentIds - The id of content to unindex

workspaceName - The workspace where to work in

Throws:

Exception - if an error occurs while indexing.

doIndexContent

protected void doIndexContent(Content content,
                              String workspaceName,
                              SolrClient solrClient)
                       throws Exception

Add or update a content into Solr index

Parameters:

content - The content to index

workspaceName - The workspace where to index

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

indexAclInitValues

public void indexAclInitValues(AmetysObject ametysObject,
                               SolrInputDocument document)

Indexes read-ACl initial values for object

Parameters:

ametysObject - The object

document - The Solr document

_addField

private <T> void _addField(SolrInputDocument document,
                           String fieldName,
                           Set<T> values,
                           Function<T,String> stringifier)

doIndexContentWorkflow

protected void doIndexContentWorkflow(Content content,
                                      String workspaceName,
                                      SolrClient solrClient)
                               throws Exception

Index the whole workflow of a content.

Parameters:

content - The content.

workspaceName - The workspace name

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

indexContentAttachments

public void indexContentAttachments(ResourceCollection collection,
                                    Content content)
                             throws Exception

Index content attachments as new entries in the idnex

Parameters:

collection - the collection of attachments

content - the content whose attachments will be indexed

Throws:

Exception - if something goes wrong when indexing the attachments of the content

indexContentAttachments

public void indexContentAttachments(ResourceCollection collection,
                                    Content content,
                                    SolrClient solrClient)
                             throws Exception

Index content attachments as new entries in the idnex

Parameters:

collection - the collection of attachments

content - the content whose attachments will be indexed

solrClient - The solr client to use

Throws:

Exception - if something goes wrong when indexing the attachments of the content

indexContentAttachment

public void indexContentAttachment(Resource resource,
                                   Content content)
                            throws Exception

Index a content attachment

Parameters:

resource - the content attachment as a Resource

content - the content whose attachment is going to be indexed

Throws:

Exception - if something goes wrong when processing the indexation of the content attachment

indexContentAttachment

public void indexContentAttachment(Resource resource,
                                   Content content,
                                   SolrClient solrClient)
                            throws Exception

Index a content attachment

Parameters:

resource - the content attachment as a Resource

content - the content whose attachment is going to be indexed

solrClient - The solr client to use

Throws:

Exception - if something goes wrong when processing the indexation of the content attachment

_indexContentAttachment

private void _indexContentAttachment(Resource resource,
                                     SolrInputDocument document,
                                     Content content)
                              throws Exception

Throws:

Exception

_indexResourceDocument

protected void _indexResourceDocument(Resource resource,
                                      SolrInputDocument document,
                                      SolrClient solrClient)
                               throws SolrServerException,
                                      IOException

Index a populated solr input document of type Resource.

Parameters:

resource - the resource from which the input document is created

document - the input document

solrClient - The solr client to use

Throws:

SolrServerException - if there is an error on the server

IOException - if there is a communication error with the server

deleteRepeaterDocs

protected void deleteRepeaterDocs(String contentId,
                                  String workspaceName,
                                  SolrClient solrClient)
                           throws Exception

Delete repeater documents of a specified content.

Parameters:

workspaceName - The workspace name

contentId - the content ID.

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

indexAllResources

public Map<String,Object> indexAllResources(String workspaceName,
                                            SolrClient solrClient)
                                     throws Exception

Index all the resources in a given workspace.

Parameters:

workspaceName - The workspace where to index

solrClient - The solr client to use

Returns:

The indexation result as a Map.

Throws:

Exception - if an error occurs while indexing.

indexResources

public SolrIndexer.IndexationResult indexResources(Iterable<AmetysObject> resources,
                                                   String documentType,
                                                   String workspaceName)
                                            throws Exception

Send a collection of contents for indexation in the solr server.

Parameters:

resources - the collection of contents to index.

documentType - The document type of the resource

workspaceName - The workspace where to index

Returns:

the indexation result.

Throws:

Exception - if an error occurs while indexing.

indexResources

public SolrIndexer.IndexationResult indexResources(Iterable<? extends AmetysObject> resources,
                                                   String documentType,
                                                   TraversableAmetysObject resourceRoot,
                                                   String workspaceName,
                                                   SolrClient solrClient)
                                            throws Exception

Send a collection of contents for indexation in the solr server.

Parameters:

resources - the collection of contents to index.

documentType - The document type of the resource

resourceRoot - The resource root, can be null. In that case, it will be computed for each resource.

workspaceName - The workspace where to index

solrClient - The solr client to use

Returns:

the indexation result.

Throws:

Exception - if an error occurs while indexing.

doIndexResources

protected SolrIndexer.IndexationResult doIndexResources(Iterable<? extends AmetysObject> resources,
                                                        String documentType,
                                                        TraversableAmetysObject resourceRoot,
                                                        String workspaceName,
                                                        SolrClient solrClient)
                                                 throws Exception

Send some resources for indexation in the solr server.

Parameters:

resources - the resources to index.

documentType - The document type of the resource

resourceRoot - The resource root, can be null. In that case, it will be computed for each resource.

workspaceName - The workspace where to index

solrClient - The solr client to use

Returns:

the indexation result.

Throws:

Exception - if an error occurs committing the results.

indexResource

public void indexResource(Resource resource,
                          String documentType,
                          String workspaceName)
                   throws Exception

Add or update a resource into Solr index

Parameters:

resource - The resource to index

documentType - The document type of the resource

workspaceName - The workspace where to index

Throws:

Exception - if an error occurs while indexing.

_unindexAllResources

private void _unindexAllResources(String workspaceName,
                                  SolrClient solrClient)
                           throws Exception

Throws:

Exception

unindexResourcesByPath

public void unindexResourcesByPath(String rootId,
                                   String path)
                            throws Exception

Delete all resource documents at a given path for all workspaces and commit

Parameters:

rootId - The resource root ID, must not be null.

path - The resource path relative to the given root, must start with a slash.

Throws:

Exception - If an error occurs while unindexing.

unindexResourcesByPath

public void unindexResourcesByPath(String rootId,
                                   String path,
                                   String workspaceName)
                            throws Exception

Delete all resource documents at a given path.

Parameters:

rootId - The resource root ID, must not be null.

path - The resource path relative to the given root, must start with a slash.

workspaceName - The workspace where to work in

Throws:

Exception - If an error occurs while unindexing.

unindexResource

public void unindexResource(String resourceId)
                     throws Exception

Remove a resource from Solr index for all workspaces and commit

Parameters:

resourceId - The id of resource to unindex

Throws:

Exception - if an error occurs while indexing.

unindexResource

public void unindexResource(String resourceId,
                            String workspaceName)
                     throws Exception

Remove a resource from the Solr index.

Parameters:

resourceId - The id of resource to unindex

workspaceName - The workspace where to work in

Throws:

Exception - if an error occurs while unindexing.

doIndexExplorerItem

protected void doIndexExplorerItem(AmetysObject node,
                                   String documentType,
                                   TraversableAmetysObject resourceRoot,
                                   SolrClient solrClient)
                            throws Exception

Add or update a resource into Solr index

Parameters:

node - The resource to index

documentType - The document type of the resource

resourceRoot - The resource root, can be null. In that case, it will be computed for each resource.

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

doIndexResource

protected void doIndexResource(Resource resource,
                               String documentType,
                               TraversableAmetysObject resourceRoot,
                               SolrClient solrClient)
                        throws Exception

Add or update a resource into Solr index

Parameters:

resource - The resource to index

documentType - The document type of the resource

resourceRoot - The resource root, can be null. In that case, it will be computed for each resource.

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

commit

public void commit()
            throws SolrServerException,
                   IOException

Process a Solr commit operation in all workspaces.
Use this only after a long operation with updates sent via NoAutoCommitUpdateClient

Throws:

SolrServerException - if there is an error on the server

IOException - if there is a communication error with the server

commit

public void commit(String workspaceName,
                   SolrClient solrClient)
            throws SolrServerException,
                   IOException

Process a Solr commit operation in given workspace.

Parameters:

workspaceName - The workspace's name

solrClient - The solr client to use

Throws:

SolrServerException - if there is an error on the server

IOException - if there is a communication error with the server

optimize

public void optimize(String workspaceName,
                     SolrClient solrClient)
              throws SolrServerException,
                     IOException

Launch a solr index optimization.

Parameters:

workspaceName - The workspace's name

solrClient - The solr client to use

Throws:

SolrServerException - if there is an error on the server

IOException - if there is a communication error with the server

unindexAllDocuments

public void unindexAllDocuments(String workspaceName,
                                SolrClient solrClient)
                         throws Exception

Delete all documents from the solr index.

Parameters:

workspaceName - The workspace name

solrClient - The solr client to use

Throws:

Exception - if an error occurs while unindexing.

doUnindexDocument

protected void doUnindexDocument(String id,
                                 String workspaceName,
                                 SolrClient solrClient)
                          throws Exception

Delete a document from the Solr server.

Parameters:

id - The id of the document to delete from Solr

workspaceName - The workspace name

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.

doUnindexContentAttachments

protected void doUnindexContentAttachments(String contentId,
                                           String workspaceName,
                                           SolrClient solrClient)
                                    throws Exception

Delete content attachments documents of a given content from the Solr server.

Parameters:

contentId - The id of the content

workspaceName - The workspace name

solrClient - The solr client to use

Throws:

Exception - if an error occurs while indexing.