File	Doc	Category	Size	Date	Package
TestRemoteCachingWrapperFilter.java	API Doc	Apache Lucene 2.2.0	5726	Sat Jun 16 22:20:28 BST 2007	org.apache.lucene.search

TestRemoteCachingWrapperFilter

• java.lang.Object
  • junit.framework.Assert
    • junit.framework.TestCase

Fields Summary

Constructors Summary
public TestRemoteCachingWrapperFilter(String name) super(name);

Methods Summary
private static org.apache.lucene.search.Searchable	getRemote() try { return lookupRemote(); } catch (Throwable e) { startServer(); return lookupRemote(); }
private static org.apache.lucene.search.Searchable	lookupRemote() return (Searchable)Naming.lookup("//localhost/Searchable");
private static void	search(org.apache.lucene.search.Query query, org.apache.lucene.search.Filter filter, int hitNumber, java.lang.String typeValue) Searchable[] searchables = { getRemote() }; Searcher searcher = new MultiSearcher(searchables); Hits result = searcher.search(query,filter); assertEquals(1, result.length()); Document document = result.doc(hitNumber); assertTrue("document is null and it shouldn't be", document != null); assertEquals(typeValue, document.get("type")); assertTrue("document.getFields() Size: " + document.getFields().size() + " is not: " + 3, document.getFields().size() == 3);
private static void	startServer() // construct an index RAMDirectory indexStore = new RAMDirectory(); IndexWriter writer = new IndexWriter(indexStore,new SimpleAnalyzer(),true); Document doc = new Document(); doc.add(new Field("test", "test text", Field.Store.YES, Field.Index.TOKENIZED)); doc.add(new Field("type", "A", Field.Store.YES, Field.Index.TOKENIZED)); doc.add(new Field("other", "other test text", Field.Store.YES, Field.Index.TOKENIZED)); writer.addDocument(doc); //Need a second document to search for doc = new Document(); doc.add(new Field("test", "test text", Field.Store.YES, Field.Index.TOKENIZED)); doc.add(new Field("type", "B", Field.Store.YES, Field.Index.TOKENIZED)); doc.add(new Field("other", "other test text", Field.Store.YES, Field.Index.TOKENIZED)); writer.addDocument(doc); writer.optimize(); writer.close(); // publish it LocateRegistry.createRegistry(1099); Searchable local = new IndexSearcher(indexStore); RemoteSearchable impl = new RemoteSearchable(local); Naming.rebind("//localhost/Searchable", impl);
public void	testTermRemoteFilter() CachingWrapperFilterHelper cwfh = new CachingWrapperFilterHelper(new QueryFilter(new TermQuery(new Term("type", "a")))); // This is what we are fixing - if one uses a CachingWrapperFilter(Helper) it will never // cache the filter on the remote site cwfh.setShouldHaveCache(false); search(new TermQuery(new Term("test", "test")), cwfh, 0, "A"); cwfh.setShouldHaveCache(false); search(new TermQuery(new Term("test", "test")), cwfh, 0, "A"); // This is how we fix caching - we wrap a Filter in the RemoteCachingWrapperFilter(Handler - for testing) // to cache the Filter on the searcher (remote) side RemoteCachingWrapperFilterHelper rcwfh = new RemoteCachingWrapperFilterHelper(cwfh, false); search(new TermQuery(new Term("test", "test")), rcwfh, 0, "A"); // 2nd time we do the search, we should be using the cached Filter rcwfh.shouldHaveCache(true); search(new TermQuery(new Term("test", "test")), rcwfh, 0, "A"); // assert that we get the same cached Filter, even if we create a new instance of RemoteCachingWrapperFilter(Helper) // this should pass because the Filter parameters are the same, and the cache uses Filter's hashCode() as cache keys, // and Filters' hashCode() builds on Filter parameters, not the Filter instance itself rcwfh = new RemoteCachingWrapperFilterHelper(new QueryFilter(new TermQuery(new Term("type", "a"))), false); rcwfh.shouldHaveCache(false); search(new TermQuery(new Term("test", "test")), rcwfh, 0, "A"); rcwfh = new RemoteCachingWrapperFilterHelper(new QueryFilter(new TermQuery(new Term("type", "a"))), false); rcwfh.shouldHaveCache(true); search(new TermQuery(new Term("test", "test")), rcwfh, 0, "A"); // assert that we get a non-cached version of the Filter because this is a new Query (type:b) rcwfh = new RemoteCachingWrapperFilterHelper(new QueryFilter(new TermQuery(new Term("type", "b"))), false); rcwfh.shouldHaveCache(false); search(new TermQuery(new Term("type", "b")), rcwfh, 0, "B");