9:18 a.m.
the searchable cache indexes are not updated if there were data manipulation in
transaction or batch
-----------------------------------------------------------------------------------------------------
Key: JBCACHE-1495
URL: https://jira.jboss.org/jira/browse/JBCACHE-1495
Project: JBoss Cache
Issue Type: Bug
Security Level: Public (Everyone can see)
Components: SearchableCache
Environment: searchable cache version 1.0.0 GA
Reporter: Yan Falken
Assignee: Manik Surtani
Priority: Blocker
// runnable unit test:
package problems;
import org.hibernate.search.annotations.Field;
import org.hibernate.search.annotations.ProvidedId;
import org.hibernate.search.annotations.Indexed;
import org.hibernate.search.annotations.Store;
import org.jboss.cache.*;
import org.jboss.cache.loader.jdbm.JdbmCacheLoaderConfig;
import org.jboss.cache.config.Configuration;
import org.jboss.cache.config.CacheLoaderConfig;
import org.jboss.cache.search.SearchableCacheFactory;
import org.jboss.cache.search.SearchableCache;
import org.testng.annotations.Test;
import org.testng.annotations.BeforeMethod;
import org.apache.lucene.search.Query;
import org.apache.lucene.search.BooleanQuery;
import org.apache.lucene.search.TermQuery;
import org.apache.lucene.search.BooleanClause;
import org.apache.lucene.index.Term;
import static org.testng.AssertJUnit.*;
import java.util.Properties;
import java.io.Serializable;
@Test(groups = {"unit"}, sequential = true)
public class IndexingInTransaction {
private static final Fqn fname = Fqn.fromString("blah");
private Cache coreCache;
private SearchableCache searchableCache;
Node node;
public IndexingInTransaction() {
init();
}
@BeforeMethod
public void init() {
CacheFactory factory = new DefaultCacheFactory();
Configuration c = new Configuration();
c.setInvocationBatchingEnabled(true);
CacheLoaderConfig clc = new CacheLoaderConfig();
JdbmCacheLoaderConfig jclc = new JdbmCacheLoaderConfig();
jclc.setAsync(false);
jclc.setFetchPersistentState(false);
jclc.setIgnoreModifications(false);
jclc.setPurgeOnStartup(true);
jclc.setLocation("/tmp/c1");
clc.addIndividualCacheLoaderConfig(jclc);
c.setCacheLoaderConfig(clc);
coreCache = factory.createCache(c, false);
SearchableCacheFactory f = new SearchableCacheFactory();
Properties p = new Properties();
p.put("hibernate.search.default.indexBase", "/tmp/c1idx");
searchableCache = f.createSearchableCache(coreCache, p, Entity.class);
searchableCache.create();
searchableCache.start();
node = searchableCache.getRoot().addChild(fname);
}
@Test
public void testPutEntitiesWithoutTransaction() {
for (int i = 1; i <= 10; i++) {
Entity e = getEntity(i);
System.out.println("caching: " + e);
Node c = node.addChild(Fqn.fromString(e.getName()));
c.put(""+ e.getId(), e);
}
assertFalse(searchableCache.createQuery(
Entity.searchByName("Name5")).list().isEmpty());
}
@Test
public void testPutEntitiesWithTransaction() throws Exception {
((CacheSPI)(coreCache)).getTransactionManager().begin();
for (int i = 11; i <= 20; i++) {
Entity e = getEntity(i);
System.out.println("caching: " + e);
Node c = node.addChild(Fqn.fromString(e.getName()));
c.put(""+ e.getId(), e);
}
((CacheSPI)(coreCache)).getTransactionManager().commit();
assertFalse(searchableCache.createQuery(
Entity.searchByName("Name15")).list().isEmpty());
}
Entity getEntity(long id) {
return new Entity(id, "Name" + id, "Surname" + id, true);
}
// public static void main(String[] args) {
// IndexingInTransaction stb = new IndexingInTransaction();
// stb.init();
// }
}
@ProvidedId
@Indexed
class Entity implements Serializable {
public static final String IDX_NAME = "name";
public static final String IDX_SURNAME = "surname";
private long id;
@Field(store = Store.YES)
private String name;
@Field (store = Store.YES)
private String surname;
private boolean dead;
Entity(long id, String name, String surname, boolean dead) {
this.id = id;
this.name = name;
this.surname = surname;
this.dead = dead;
}
public long getId() {
return id;
}
public String getName() {
return name;
}
public String getSurname() {
return surname;
}
public boolean isDead() {
return dead;
}
public static Query searchByName(String name) {
BooleanQuery query = new BooleanQuery();
query.add(new TermQuery(
new Term(Entity.IDX_NAME,
name.toLowerCase())),
BooleanClause.Occur.MUST);
return query;
}
@Override
public String toString() {
return "Entity{" +
"id=" + id +
", name='" + name + '\'' +
", surname='" + surname + '\'' +
", dead=" + dead +
'}';
}
}
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
https://jira.jboss.org/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira