| Method from org.hibernate.search.event.FullTextIndexEventListener Detail: |
public void cleanup() {
searchFactoryImplementor.close();
}
|
public SearchFactoryImplementor getSearchFactoryImplementor() {
return searchFactoryImplementor;
}
|
public void initialize(Configuration cfg) {
searchFactoryImplementor = ContextHolder.getOrBuildSearchFactory( cfg );
String indexingStrategy = searchFactoryImplementor.getIndexingStrategy();
if ( "event".equals( indexingStrategy ) ) {
used = searchFactoryImplementor.getDocumentBuilders().size() != 0;
}
else if ( "manual".equals( indexingStrategy ) ) {
used = false;
}
}
Initialize method called by Hibernate Core when the SessionFactory starts |
public void onPostDelete(PostDeleteEvent event) {
if ( used ) {
final Class< ? > entityType = event.getEntity().getClass();
if ( searchFactoryImplementor.getDocumentBuilders().containsKey( entityType )
|| searchFactoryImplementor.getContainedInOnlyBuilder( entityType ) != null ) {
processWork( event.getEntity(), event.getId(), WorkType.DELETE, event );
}
}
}
|
public void onPostInsert(PostInsertEvent event) {
if ( used ) {
final Object entity = event.getEntity();
if ( searchFactoryImplementor.getDocumentBuilder( entity.getClass() ) != null
|| searchFactoryImplementor.getContainedInOnlyBuilder( entity.getClass() ) != null ) {
Serializable id = event.getId();
processWork( entity, id, WorkType.ADD, event );
}
}
}
|
public void onPostRecreateCollection(PostCollectionRecreateEvent event) {
processCollectionEvent( event );
}
|
public void onPostRemoveCollection(PostCollectionRemoveEvent event) {
processCollectionEvent( event );
}
|
public void onPostUpdate(PostUpdateEvent event) {
if ( used ) {
final Object entity = event.getEntity();
if ( searchFactoryImplementor.getDocumentBuilder( entity.getClass() ) != null
|| searchFactoryImplementor.getContainedInOnlyBuilder( entity.getClass() ) != null ) {
Serializable id = event.getId();
processWork( entity, id, WorkType.UPDATE, event );
}
}
}
|
public void onPostUpdateCollection(PostCollectionUpdateEvent event) {
processCollectionEvent( event );
}
|
protected void processCollectionEvent(AbstractCollectionEvent event) {
Object entity = event.getAffectedOwnerOrNull();
if ( entity == null ) {
//Hibernate cannot determine every single time the owner especially in case detached objects are involved
// or property-ref is used
//Should log really but we don't know if we're interested in this collection for indexing
return;
}
if ( used ) {
if ( searchFactoryImplementor.getDocumentBuilder( entity.getClass() ) != null
|| searchFactoryImplementor.getContainedInOnlyBuilder( entity.getClass() ) != null ) {
Serializable id = getId( entity, event );
if ( id == null ) {
log.warn(
"Unable to reindex entity on collection change, id cannot be extracted: {}",
event.getAffectedOwnerEntityName()
);
return;
}
processWork( entity, id, WorkType.COLLECTION, event );
}
}
}
|
protected void processWork(Object entity,
Serializable id,
WorkType workType,
AbstractEvent event) {
Work work = new Work( entity, id, workType );
final EventSourceTransactionContext transactionContext = new EventSourceTransactionContext( event.getSession() );
searchFactoryImplementor.getWorker().performWork( work, transactionContext );
}
|