/*
* Hibernate Search, full-text search for your domain model
*
* License: GNU Lesser General Public License (LGPL), version 2.1 or later
* See the lgpl.txt file in the root directory or <http://www.gnu.org/licenses/lgpl-2.1.html>.
*/
package org.hibernate.search.test.query.initandlookup;
import java.util.List;
import org.apache.lucene.search.MatchAllDocsQuery;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;
import org.hibernate.cfg.Environment;
import org.hibernate.search.FullTextQuery;
import org.hibernate.search.FullTextSession;
import org.hibernate.search.Search;
import org.hibernate.search.query.DatabaseRetrievalMethod;
import org.hibernate.search.query.ObjectLookupMethod;
import org.hibernate.search.test.SearchTestBase;
import org.hibernate.search.testsupport.backend.GatedLuceneBackend;
import org.hibernate.stat.Statistics;
import org.hibernate.testing.cache.CachingRegionFactory;
import org.junit.Test;
import static org.fest.assertions.Assertions.assertThat;
/**
* Test second level cache and persistence context lookup methods
*
* @author Sanne Grinovero <sanne@hibernate.org> (C) 2011 Red Hat Inc.
*/
public class StrictSecondLCAndPCLookupTest extends SearchTestBase {
@Test
public void testStaleCacheWithAsyncIndexer() {
Session session = openSession();
final Statistics statistics = session.getSessionFactory().getStatistics();
statistics.clear();
statistics.setStatisticsEnabled( true );
setData( session, statistics );
GatedLuceneBackend.open.set( false ); // disable processing of index updates
Transaction tx = session.beginTransaction();
List list = session.createCriteria( StrictKernel.class ).list();
assertThat( list ).hasSize( 2 );
session.delete( list.get( 0 ) );
tx.commit();
session.clear();
GatedLuceneBackend.open.set( true );
FullTextSession fullTextSession = Search.getFullTextSession( session );
FullTextQuery allKernelsQuery = fullTextSession.createFullTextQuery( new MatchAllDocsQuery() )
.initializeObjectsWith( ObjectLookupMethod.SECOND_LEVEL_CACHE, DatabaseRetrievalMethod.QUERY );
//Identify the mismatch between index/database:
assertThat( allKernelsQuery.getResultSize() ).isEqualTo( 2 );
assertThat( allKernelsQuery.list() ).hasSize( 1 );
}
private void setData(Session session, Statistics statistics) {
Transaction transaction = session.beginTransaction();
StrictKernel k = new StrictKernel();
k.setCodeName( "coconut" );
k.setProduct( "Polgeiser" );
session.persist( k );
StrictKernel k2 = new StrictKernel();
k2.setCodeName( "ballpark" );
k2.setProduct( "Polgeiser" );
session.persist( k2 );
transaction.commit();
session.clear();
transaction = session.beginTransaction();
session.get( StrictKernel.class, k.getId() );
session.get( StrictKernel.class, k2.getId() );
transaction.commit();
assertThat( statistics.getSecondLevelCachePutCount() )
.isEqualTo( 2 );
}
@Override
protected void configure(Configuration cfg) {
super.configure( cfg );
cfg.setProperty( Environment.USE_SECOND_LEVEL_CACHE, "true" );
cfg.setProperty( "hibernate.search.default.worker.backend", GatedLuceneBackend.class.getName() );
cfg.setProperty( Environment.CACHE_REGION_FACTORY, CachingRegionFactory.class.getCanonicalName() );
}
@Override
protected Class<?>[] getAnnotatedClasses() {
return new Class<?>[] { StrictKernel.class };
}
}