+++ /dev/null
-package org.apache.lucene.search;
-
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-import org.apache.lucene.analysis.SimpleAnalyzer;
-import org.apache.lucene.document.Document;
-import org.apache.lucene.document.Field;
-import org.apache.lucene.index.IndexWriter;
-import org.apache.lucene.index.Term;
-import org.apache.lucene.store.Directory;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-/**
- * Tests that the index is cached on the searcher side of things.
- */
-public class TestRemoteCachingWrapperFilter extends RemoteTestCase {
- private static Directory indexStore;
- private static Searchable local;
-
- @BeforeClass
- public static void beforeClass() throws Exception {
- // construct an index
- indexStore = newDirectory();
- IndexWriter writer = new IndexWriter(indexStore, newIndexWriterConfig(
- TEST_VERSION_CURRENT, new SimpleAnalyzer(
- TEST_VERSION_CURRENT)));
- Document doc = new Document();
- doc.add(newField("test", "test text", Field.Store.YES, Field.Index.ANALYZED));
- doc.add(newField("type", "A", Field.Store.YES, Field.Index.ANALYZED));
- doc.add(newField("other", "other test text", Field.Store.YES, Field.Index.ANALYZED));
- writer.addDocument(doc);
- //Need a second document to search for
- doc = new Document();
- doc.add(newField("test", "test text", Field.Store.YES, Field.Index.ANALYZED));
- doc.add(newField("type", "B", Field.Store.YES, Field.Index.ANALYZED));
- doc.add(newField("other", "other test text", Field.Store.YES, Field.Index.ANALYZED));
- writer.addDocument(doc);
- writer.optimize();
- writer.close();
- local = new IndexSearcher(indexStore, true);
- startServer(local);
- }
-
- @AfterClass
- public static void afterClass() throws Exception {
- local.close();
- indexStore.close();
- indexStore = null;
- }
-
- private static void search(Query query, Filter filter, int hitNumber, String typeValue) throws Exception {
- Searchable[] searchables = { lookupRemote() };
- Searcher searcher = new MultiSearcher(searchables);
- ScoreDoc[] result = searcher.search(query,filter, 1000).scoreDocs;
- assertEquals(1, result.length);
- Document document = searcher.doc(result[hitNumber].doc);
- 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);
- }
-
- @Test
- public void testTermRemoteFilter() throws Exception {
- CachingWrapperFilterHelper cwfh = new CachingWrapperFilterHelper(new QueryWrapperFilter(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 QueryWrapperFilter(new TermQuery(new Term("type", "a"))), false);
- rcwfh.shouldHaveCache(false);
- search(new TermQuery(new Term("test", "test")), rcwfh, 0, "A");
-
- rcwfh = new RemoteCachingWrapperFilterHelper(new QueryWrapperFilter(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 QueryWrapperFilter(new TermQuery(new Term("type", "b"))), false);
- rcwfh.shouldHaveCache(false);
- search(new TermQuery(new Term("type", "b")), rcwfh, 0, "B");
- }
-}
fnp / pylucene.git / blobdiff