- 浏览: 6114 次
- 性别:
- 来自: 长沙
最新评论
-
mengfei86:
初试ehcache2.4中新加入的搜索api(search api,EQL) -
linuxaid:
多年以前的帖子。。。自己给自己纪念一下
唉,今天的hibernate 突然出问题了
阅读本文的时候最好是能基本掌握ehcache的配置、使用(包括分布式的配置),对于基础的配置过程、概念就不一一详细描述了
从ehcache2.4版本开始支持搜索api,可以从键(key)和值(value)中按照任意复杂的逻辑条件得到需要的查询结果(通过EQL),想想平时在缓存的value中查找自己需要的结果我用的是最笨的for循环,有了EQL,简直太棒了。单机和分布式缓存的都可以用(Terracotta貌似收费项目中不敢冒然使用),官方配置文档可以看出非常之仓促ehcache.xml都写成了ehcachel.xml,官网上的示例代码也无法下载。
jar包不需要再多添加了2.4的那个900多K的jar中已经包含了新的类,诸如:Results,Query等
很庆幸,分布式缓存是可以正常工作的,只要添加一个【<searchable />】节点就可以了:
<cache name="UserCache" maxElementsInMemory="100000" eternal="true"
overflowToDisk="false">
<cacheEventListenerFactory
class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"
properties="replicateAsynchronously=true,replicatePuts=true,replicatePutsViaCopy=true,replicateUpdates=true,replicateUpdatesViaCopy=true,replicateRemovals=true" />
<searchable />
</cache>
测试中遇到的一些问题及其解决方法:
1.Query is frozen and cannot be mutated
解决:createQuery()....end(); 去掉 end();
2.No results specified. Please specify one or more of includeKeys(), includeValues(), includeAggregator() or includeAttribute()
解决:
query = obj.createQuery();
query.includeKeys();
query.addCriteria(Query.KEY.eq(sCacheId));
query.maxResults(1000);
results = query.execute();
3.isSearchable()为false
解决:配置后重启服务器,总之我就是这么解决的,分布式缓存中也可正常使用。
基本上测试代码就可以运行了,当然我们放入cache的value往往不是简单的值,而是一个pojo(dto,vo),这个官方文档也有详细介绍,配置attribute,并且稍作编码即可。
如果想对查询内容做一些计数(Average,Count,Max,Min,Sum),可以参考
http://ehcache.org/xref/net/sf/ehcache/search/aggregator/package-frame.html
官方测试1万条的结果有:62ms,125ms,180ms,貌似目前项目中够用了,他建议查询要少于100万
用到的junit示例:
出于谨慎对于新出来的功能,不敢立刻用于目前的项目中,仅仅是测试一下,知道有EQL这么回事情,待有对技术激进一点的高手在项目中实际用过了后再跟进也不迟。
官方文档链接:
http://www.ehcache.org/documentation/search.html
从ehcache2.4版本开始支持搜索api,可以从键(key)和值(value)中按照任意复杂的逻辑条件得到需要的查询结果(通过EQL),想想平时在缓存的value中查找自己需要的结果我用的是最笨的for循环,有了EQL,简直太棒了。单机和分布式缓存的都可以用(Terracotta貌似收费项目中不敢冒然使用),官方配置文档可以看出非常之仓促ehcache.xml都写成了ehcachel.xml,官网上的示例代码也无法下载。
jar包不需要再多添加了2.4的那个900多K的jar中已经包含了新的类,诸如:Results,Query等
很庆幸,分布式缓存是可以正常工作的,只要添加一个【<searchable />】节点就可以了:
<cache name="UserCache" maxElementsInMemory="100000" eternal="true"
overflowToDisk="false">
<cacheEventListenerFactory
class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"
properties="replicateAsynchronously=true,replicatePuts=true,replicatePutsViaCopy=true,replicateUpdates=true,replicateUpdatesViaCopy=true,replicateRemovals=true" />
<searchable />
</cache>
测试中遇到的一些问题及其解决方法:
1.Query is frozen and cannot be mutated
解决:createQuery()....end(); 去掉 end();
2.No results specified. Please specify one or more of includeKeys(), includeValues(), includeAggregator() or includeAttribute()
解决:
query = obj.createQuery();
query.includeKeys();
query.addCriteria(Query.KEY.eq(sCacheId));
query.maxResults(1000);
results = query.execute();
3.isSearchable()为false
解决:配置后重启服务器,总之我就是这么解决的,分布式缓存中也可正常使用。
基本上测试代码就可以运行了,当然我们放入cache的value往往不是简单的值,而是一个pojo(dto,vo),这个官方文档也有详细介绍,配置attribute,并且稍作编码即可。
如果想对查询内容做一些计数(Average,Count,Max,Min,Sum),可以参考
http://ehcache.org/xref/net/sf/ehcache/search/aggregator/package-frame.html
官方测试1万条的结果有:62ms,125ms,180ms,貌似目前项目中够用了,他建议查询要少于100万
用到的junit示例:
package net.sf.ehcache.search; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; import java.util.ArrayList; import java.util.Arrays; import java.util.HashSet; import java.util.List; import java.util.Set; import org.junit.Test; import net.sf.ehcache.Cache; import net.sf.ehcache.CacheException; import net.sf.ehcache.CacheManager; import net.sf.ehcache.Ehcache; import net.sf.ehcache.Element; import net.sf.ehcache.config.CacheConfiguration; import net.sf.ehcache.config.Configuration; import net.sf.ehcache.config.SearchAttribute; import net.sf.ehcache.config.Searchable; import net.sf.ehcache.search.Person.Gender; import net.sf.ehcache.search.aggregator.Aggregator; import net.sf.ehcache.search.aggregator.AggregatorException; import net.sf.ehcache.search.aggregator.AggregatorInstance; import net.sf.ehcache.search.expression.Or; public class BasicSearchTest { @Test public void testInvalidConfiguration() { try { new CacheManager(getClass().getResource("/ehcache-search-invalid-key.xml")); fail(); } catch (CacheException ce) { // expected } try { new CacheManager(getClass().getResource("/ehcache-search-invalid-value.xml")); fail(); } catch (CacheException ce) { // expected } } @Test public void testNonSearchableCache() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("not-searchable"); assertFalse(cache.isSearchable()); try { cache.createQuery(); fail(); } catch (CacheException e) { // expected } } @Test public void testDefaultSearchableCache() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("default-searchable"); assertTrue(cache.isSearchable()); cache.put(new Element("key", new Object())); cache.put(new Element(new Object(), "value")); cache.put(new Element(new Object(), new Object())); cache.put(new Element(null, null)); Query query; Results results; query = cache.createQuery(); query.includeKeys(); query.addCriteria(Query.KEY.eq("key")).end(); results = query.execute(); assertEquals(1, results.size()); assertEquals("key", results.all().iterator().next().getKey()); query = cache.createQuery(); query.includeKeys(); query.addCriteria(Query.VALUE.eq("value")).end(); results = query.execute(); assertEquals(1, results.size()); Object key = results.all().iterator().next().getKey(); assertEquals("value", cache.get(key).getObjectValue()); } @Test public void testQueryBuilder() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); Query query1 = cache.createQuery(); Query query2 = cache.createQuery(); // query instances should be unique assertFalse(query1 == query2); // null checks try { query1.addCriteria(null); fail(); } catch (NullPointerException npe) { // expected } try { query1.addOrderBy(null, Direction.ASCENDING); fail(); } catch (NullPointerException npe) { // expected } try { query1.addOrderBy(new Attribute("foo"), null); fail(); } catch (NullPointerException npe) { // expected } try { query1.includeAggregator((Aggregator[]) null); fail(); } catch (NullPointerException npe) { // expected } try { query1.includeAttribute((Attribute[]) null); fail(); } catch (NullPointerException npe) { // expected } try { query1.includeAttribute(new Attribute[]{new Attribute("foo"), null}); fail(); } catch (NullPointerException npe) { // expected } // freeze query query1.end(); try { query1.addCriteria(new Attribute("foo").le(35)); fail(); } catch (SearchException se) { // expected } try { query1.addOrderBy(new Attribute("foo"), Direction.ASCENDING); fail(); } catch (SearchException se) { // expected } try { query1.includeAggregator(new Attribute("foo").max()); fail(); } catch (SearchException se) { // expected } try { query1.includeAttribute(new Attribute("foo")); fail(); } catch (SearchException se) { // expected } try { query1.includeKeys(); fail(); } catch (SearchException se) { // expected } try { query1.maxResults(3); fail(); } catch (SearchException se) { // expected } } @Test public void testRange() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); Query query = cache.createQuery(); query.includeKeys(); query.end(); Results results = query.execute(); assertEquals(4, results.all().size()); List<Integer> keys = new ArrayList<Integer>(); for (int i = 0; i < 4; i++) { List<Result> range = results.range(i, 1); assertEquals(1, range.size()); keys.add((Integer) range.get(0).getKey()); } assertEquals(4, keys.size()); for (int i = 0; i < 4; i++) { assertEquals(0, results.range(i, 0).size()); } assertEquals(0, results.range(0, 0).size()); assertEquals(1, results.range(0, 1).size()); assertEquals(2, results.range(0, 2).size()); assertEquals(3, results.range(0, 3).size()); assertEquals(4, results.range(0, 4).size()); assertEquals(4, results.range(0, 5).size()); assertEquals(4, results.range(0, Integer.MAX_VALUE).size()); try { results.range(-1, 1); fail(); } catch (IllegalArgumentException iae) { // expected } try { results.range(0, -1); fail(); } catch (IllegalArgumentException iae) { // expected } } @Test public void testBasic() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); // uses expression attribute extractors basicQueries(cacheManager.getEhcache("cache1")); // uses a "custom" attribute extractor too basicQueries(cacheManager.getEhcache("cache2")); // uses bean attributes basicQueries(cacheManager.getEhcache("bean-attributes")); } @Test public void testCustomAggregator() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); Attribute<Integer> age = cache.getSearchAttribute("age"); Query query = cache.createQuery(); query.includeAggregator(new Aggregator() { public AggregatorInstance<Integer> createInstance() { return new AggregatorInstance<Integer>() { private int doubledSum; public void accept(Object input) throws AggregatorException { if (doubledSum == 0) { doubledSum = (2 * (Integer) input); } else { doubledSum += (2 * (Integer) input); } } public Integer aggregateResult() { return doubledSum; } public Attribute<?> getAttribute() { return new Attribute("age"); } }; } }); query.end(); Results results = query.execute(); assertEquals(1, results.size()); for (Result result : results.all()) { assertEquals(246, result.getAggregatorResults().get(0)); } } @Test public void testBuiltinFunctions() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); Attribute<Integer> age = cache.getSearchAttribute("age"); { Query query = cache.createQuery(); query.includeAggregator(age.count()); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertEquals(1, results.size()); for (Result result : results.all()) { assertEquals(4, result.getAggregatorResults().get(0)); } } { Query query = cache.createQuery(); query.includeAggregator(age.max()); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertEquals(1, results.size()); for (Result result : results.all()) { assertEquals(35, result.getAggregatorResults().get(0)); } } { Query query = cache.createQuery(); query.includeAggregator(age.min()); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertEquals(1, results.size()); for (Result result : results.all()) { assertEquals(23, result.getAggregatorResults().get(0)); } } { Query query = cache.createQuery(); query.includeAggregator(age.sum()); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertEquals(1, results.size()); for (Result result : results.all()) { assertEquals(123L, result.getAggregatorResults().get(0)); } } { Query query = cache.createQuery(); query.includeAggregator(age.average()); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertEquals(1, results.size()); for (Result result : results.all()) { assertEquals(30.75F, result.getAggregatorResults().get(0)); } } { // multiple aggregators Query query = cache.createQuery(); query.includeAggregator(age.min()); query.includeAggregator(age.max()); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertEquals(1, results.size()); for (Result result : results.all()) { assertEquals(23, result.getAggregatorResults().get(0)); assertEquals(35, result.getAggregatorResults().get(1)); } } { // use criteria with an aggregator Query query = cache.createQuery(); query.includeAggregator(age.average()); query.addCriteria(age.between(0, 32)); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertEquals(1, results.size()); for (Result result : results.all()) { assertEquals(26.5F, result.getAggregatorResults().get(0)); } } { // includeKeys in addition to an aggregator Query query = cache.createQuery(); query.includeKeys(); query.includeAggregator(age.average()); query.addCriteria(age.between(0, 32)); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertTrue(results.hasKeys()); assertEquals(2, results.size()); for (Result result : results.all()) { assertEquals(26.5F, result.getAggregatorResults().get(0)); } verify(cache, query, 2, 4); } { // execute query twice Query query = cache.createQuery(); query.includeAggregator(age.count()); query.end(); Results results = query.execute(); assertTrue(results.hasAggregators()); assertFalse(results.hasKeys()); for (Result result : results.all()) { assertEquals(4, result.getAggregatorResults().get(0)); } results = query.execute(); assertTrue(results.hasAggregators()); assertFalse(results.hasKeys()); for (Result result : results.all()) { assertEquals(4, result.getAggregatorResults().get(0)); } } } @Test public void testMaxResults() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); Attribute<Integer> age = cache.getSearchAttribute("age"); Attribute<Person.Gender> gender = cache.getSearchAttribute("gender"); Query query = cache.createQuery(); query.includeKeys(); query.addCriteria(age.ne(35)); query.maxResults(1); query.end(); Results results = query.execute(); assertEquals(1, results.size()); for (Result result : results.all()) { switch ((Integer) result.getKey()) { case 2: case 4: { break; } default: { throw new AssertionError(result.getKey()); } } } query = cache.createQuery(); query.includeKeys(); query.addCriteria(age.ne(35)); query.maxResults(0); query.end(); results = query.execute(); assertEquals(0, results.size()); query = cache.createQuery(); query.includeKeys(); query.addCriteria(age.ne(35)); query.maxResults(2); query.end(); results = query.execute(); assertEquals(2, results.size()); query = cache.createQuery(); query.includeKeys(); query.addCriteria(age.ne(35)); query.maxResults(2); query.end(); results = query.execute(); assertEquals(2, results.size()); query = cache.createQuery(); query.includeKeys(); query.addCriteria(age.ne(35)); query.maxResults(-1); query.end(); results = query.execute(); assertEquals(2, results.size()); } @Test public void testAttributeQuery() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); Attribute<Integer> age = cache.getSearchAttribute("age"); Attribute<Person.Gender> gender = cache.getSearchAttribute("gender"); Query query = cache.createQuery(); // not including keys query.addCriteria(age.ne(35)); query.includeAttribute(age, gender); query.end(); Results results = query.execute(); assertFalse(results.hasKeys()); assertFalse(results.hasAggregators()); assertTrue(results.hasAttributes()); for (Result result : results.all()) { try { result.getKey(); fail(); } catch (SearchException se) { // expected } try { result.getKey(); fail(); } catch (SearchException se) { // expected } int ageAttr = result.getAttribute(age); if (ageAttr == 23) { assertEquals(Gender.FEMALE, result.getAttribute(gender)); } else if (ageAttr == 30) { assertEquals(Gender.MALE, result.getAttribute(gender)); } else { throw new AssertionError("unexpected age: " + ageAttr); } try { result.getAttribute(new Attribute("does-not-exist")); fail(); } catch (SearchException se) { // expected } } } private void basicQueries(Ehcache cache) { SearchTestUtil.populateData(cache); Query query; Attribute<Integer> age = cache.getSearchAttribute("age"); query = cache.createQuery(); query.includeKeys(); query.addCriteria(age.ne(35)); query.end(); verify(cache, query, 2, 4); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").lt(30)); query.end(); query.execute(); verify(cache, query, 2); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").le(30)); query.end(); query.execute(); verify(cache, query, 2, 4); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").in(new HashSet(Arrays.asList(23, 35)))); query.end(); query.execute(); verify(cache, query, 1, 2, 3); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").gt(30)); query.end(); query.execute(); verify(cache, query, 1, 3); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").between(23, 35, true, false)); query.end(); query.execute(); verify(cache, query, 2, 4); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").ge(30)); query.end(); query.execute(); verify(cache, query, 1, 3, 4); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").eq(35).or(cache.getSearchAttribute("gender").eq(Gender.FEMALE))); query.end(); verify(cache, query, 1, 2, 3); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").eq(35).and(cache.getSearchAttribute("gender").eq(Gender.MALE))); query.end(); verify(cache, query, 1, 3); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").eq(35).and(cache.getSearchAttribute("gender").eq(Gender.FEMALE))); query.end(); verify(cache, query); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("age").eq(35)); query.addCriteria(cache.getSearchAttribute("gender").eq(Gender.FEMALE)); query.end(); verify(cache, query); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("gender").eq(Gender.MALE).not()); query.end(); verify(cache, query, 2); query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("name").eq("Tim Eck")); query.addCriteria(cache.getSearchAttribute("gender").eq(Gender.MALE)); query.addCriteria(cache.getSearchAttribute("age").eq(35)); query.end(); verify(cache, query, 1); query = cache.createQuery(); query.includeKeys(); Attribute name = cache.getSearchAttribute("name"); query.addCriteria(name.eq("Tim Eck").or(name.eq("Ari Zilka")).or(name.eq("Nabib El-Rahman"))); query.end(); verify(cache, query, 1, 3, 4); try { cache.getSearchAttribute("DOES_NOT_EXIST_PLEASE_DO_NOT_CREATE_ME"); fail(); } catch (CacheException ce) { // expected } } @Test public void testOrdering() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); Attribute<Integer> age = cache.getSearchAttribute("age"); Attribute<String> name = cache.getSearchAttribute("name"); Query query; query = cache.createQuery(); query.includeKeys(); // no critera -- select all elements query.addOrderBy(age, Direction.DESCENDING); query.addOrderBy(name, Direction.ASCENDING); query.end(); verifyOrdered(cache, query, 3, 1, 4, 2); query = cache.createQuery(); query.includeKeys(); // no critera -- select all elements query.addOrderBy(age, Direction.DESCENDING); query.addOrderBy(name, Direction.ASCENDING); query.maxResults(2); query.end(); verifyOrdered(cache, query, 3, 1); } @Test public void testILike() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); Attribute<String> name = cache.getSearchAttribute("name"); Query query; query = cache.createQuery(); query.includeKeys(); query.addCriteria(new Or(name.ilike("tim*"), name.ilike("ari*"))); query.end(); verify(cache, query, 3, 1); cache.removeAll(); cache.put(new Element(1, new Person("Test // Bob * ?", 35, Gender.MALE))); cache.put(new Element(2, new Person("(..Test", 35, Gender.MALE))); cache.put(new Element(3, new Person("lowercase", 35, Gender.MALE))); cache.put(new Element(4, new Person("UPPERCASE", 35, Gender.MALE))); cache.put(new Element(5, new Person("MiXeD", 35, Gender.MALE))); cache.put(new Element(6, new Person("Hello there\nI am on a newline\nMe too\n", 999, Gender.MALE))); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("Test //// Bob //* //?")); query.end(); verify(cache, query, 1); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("*Test*")); query.end(); verify(cache, query, 1, 2); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("Test*//?")); query.end(); verify(cache, query, 1); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("(..*")); query.end(); verify(cache, query, 2); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("Lowercase")); query.end(); verify(cache, query, 3); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("LOWER*")); query.end(); verify(cache, query, 3); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("uppercase")); query.end(); verify(cache, query, 4); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("mixed")); query.end(); verify(cache, query, 5); query = cache.createQuery(); query.includeKeys(); query.addCriteria(name.ilike("*am on a*")); query.end(); verify(cache, query, 6); } @Test public void testTypeChecking() { CacheManager cm = new CacheManager(new Configuration().defaultCache(new CacheConfiguration())); CacheConfiguration config = new CacheConfiguration("test", 0); config.setOverflowToDisk(false); config.diskPersistent(false); config.setEternal(true); Searchable searchable = new Searchable().searchAttribute(new SearchAttribute().name("attr").expression("value.getAttr()")); config.addSearchable(searchable); cm.addCache(new Cache(config)); class Value { private final Object attr; Value(Object attr) { this.attr = attr; } Object getAttr() { return attr; } } Ehcache cache = cm.getEhcache("test"); cache.put(new Element(1, new Value("foo"))); Query query = cache.createQuery(); query.includeKeys(); query.addCriteria(cache.getSearchAttribute("attr").le(4)); query.end(); try { query.execute(); fail(); } catch (SearchException se) { // expected since the criteria wants INT, but actual attribute value is STRING } // with proper type search will execute cache.put(new Element(1, new Value(4))); assertEquals(1, query.execute().all().iterator().next().getKey()); } @Test public void testEmptyQueries() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); { Query query = cache.createQuery(); query.end(); try { query.execute(); fail(); } catch (SearchException e) { System.err.println("Expected " + e); } } { Attribute<Integer> age = cache.getSearchAttribute("age"); Query query = cache.createQuery(); query.addCriteria(age.ne(35)); query.end(); try { query.execute(); fail(); } catch (SearchException e) { System.err.println("Expected " + e); } } } @Test public void testIncludeValues() { CacheManager cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml")); Ehcache cache = cacheManager.getEhcache("cache1"); SearchTestUtil.populateData(cache); { Query query = cache.createQuery(); query.includeValues(); query.end(); Results results = query.execute(); assertTrue(results.hasValues()); assertEquals(4, results.size()); int ageSum = 0; for (Result result : results.all()) { Person p = (Person) result.getValue(); ageSum += p.getAge(); try { result.getKey(); fail(); } catch (SearchException se) { // expected since keys not included } } assertEquals(123, ageSum); } { Query query = cache.createQuery(); query.includeKeys(); query.end(); Results results = query.execute(); assertFalse(results.hasValues()); assertEquals(4, results.size()); for (Result result : results.all()) { try { result.getValue(); fail(); } catch (SearchException se) { // expected since keys not included } } } } private void verify(Ehcache cache, Query query, Integer... expectedKeys) { Results results = query.execute(); assertEquals(expectedKeys.length, results.size()); assertTrue(results.hasKeys()); assertFalse(results.hasAttributes()); Set<Integer> keys = new HashSet<Integer>(Arrays.asList(expectedKeys)); for (Result result : results.all()) { int key = (Integer) result.getKey(); if (!keys.remove(key)) { throw new AssertionError("unexpected key: " + key); } } } private void verifyOrdered(Ehcache cache, Query query, Integer... expectedKeys) { Results results = query.execute(); assertEquals(results.size(), expectedKeys.length); int pos = 0; for (Result result : results.all()) { Object expectedKey = expectedKeys[pos++]; assertEquals(expectedKey, result.getKey()); } } }
出于谨慎对于新出来的功能,不敢立刻用于目前的项目中,仅仅是测试一下,知道有EQL这么回事情,待有对技术激进一点的高手在项目中实际用过了后再跟进也不迟。
官方文档链接:
http://www.ehcache.org/documentation/search.html
相关推荐
包含翻译后的API文档:ehcache-3.3.1-javadoc-API文档-中文(简体)版.zip; Maven坐标:org.ehcache:ehcache:3.3.1; 标签:ehcache、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index....
包含翻译后的API文档:ehcache-2.10.0-javadoc-API文档-中文(简体)版.zip 对应Maven信息:groupId:net.sf.ehcache,artifactId:ehcache,version:2.10.0 使用方法:解压翻译后的API文档,用浏览器打开“index....
赠送原API文档:ehcache-2.10.0-javadoc.jar 赠送源代码:ehcache-2.10.0-sources.jar 包含翻译后的API文档:ehcache-2.10.0-javadoc-API文档-中文(简体)-英语-对照版.zip 对应Maven信息:groupId:net.sf.ehcache...
**Ehcache常用API整理** Ehcache是一个广泛使用的Java缓存库,它提供高效的内存管理和数据缓存功能,能够显著提升应用性能。在本文中,我们将深入探讨Ehcache的一些核心API及其用法。 首先,我们需要引入Ehcache的...
包含翻译后的API文档:ehcache-3.9.9-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:org.ehcache:ehcache:3.9.9; 标签:ehcache、jar包、java、中英对照文档; 使用方法:解压翻译后的API文档,用...
包含翻译后的API文档:ehcache-core-2.6.11-javadoc-API文档-中文(简体)版.zip; Maven坐标:net.sf.ehcache:ehcache-core:2.6.11; 标签:sf、ehcache、core、中文文档、jar包、java; 使用方法:解压翻译后的API...
### EHCache API的基本用法 #### 一、EHCache简介 EHCache 是一款开源的 Java 缓存框架,用于在应用程序中实现缓存功能。它提供了高性能、内存和磁盘缓存支持,使得开发者能够轻松地管理和控制数据的缓存策略。...
Ehcache是一款高性能、广泛使用的Java缓存框架,它的API为开发者提供了丰富的功能,以便在应用程序中实现高效的数据缓存。Ehcache API允许我们创建、管理、存取和更新缓存,从而优化数据访问速度,减少对数据库的...
包含翻译后的API文档:ehcache-3.3.1-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:org.ehcache:ehcache:3.3.1; 标签:ehcache、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用...
包含翻译后的API文档:shiro-ehcache-1.2.3-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:org.apache.shiro:shiro-ehcache:1.2.3; 标签:apache、shiro、ehcache、中英对照文档、jar包、java; 使用...
包含翻译后的API文档:shiro-ehcache-1.4.0-javadoc-API文档-中文(简体)版.zip; Maven坐标:org.apache.shiro:shiro-ehcache:1.4.0; 标签:apache、shiro、ehcache、中文文档、jar包、java; 使用方法:解压翻译后...
包含翻译后的API文档:ehcache-core-2.6.11-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:net.sf.ehcache:ehcache-core:2.6.11; 标签:sf、ehcache、core、中英对照文档、jar包、java; 使用方法:...
包含翻译后的API文档:shiro-ehcache-1.3.2-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:org.apache.shiro:shiro-ehcache:1.3.2; 标签:apache、shiro、ehcache、中英对照文档、jar包、java; 使用...
包含翻译后的API文档:ehcache-3.9.9-javadoc-API文档-中文(简体)版.zip; Maven坐标:org.ehcache:ehcache:3.9.9; 标签:ehcache、jar包、java、中文文档; 使用方法:解压翻译后的API文档,用浏览器打开“index....
包含翻译后的API文档:ehcache-web-2.0.4-javadoc-API文档-中文(简体)版.zip; Maven坐标:net.sf.ehcache:ehcache-web:2.0.4; 标签:sf、ehcache、web、中文文档、jar包、java; 使用方法:解压翻译后的API文档,...
包含翻译后的API文档:shiro-ehcache-1.2.3-javadoc-API文档-中文(简体)版.zip; Maven坐标:org.apache.shiro:shiro-ehcache:1.2.3; 标签:apache、shiro、ehcache、中文文档、jar包、java; 使用方法:解压翻译后...
包含翻译后的API文档:shiro-ehcache-1.3.2-javadoc-API文档-中文(简体)版.zip; Maven坐标:org.apache.shiro:shiro-ehcache:1.3.2; 标签:apache、shiro、ehcache、中文文档、jar包、java; 使用方法:解压翻译后...
包含翻译后的API文档:shiro-ehcache-1.4.0-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:org.apache.shiro:shiro-ehcache:1.4.0; 标签:apache、shiro、ehcache、中英对照文档、jar包、java; 使用...
包含翻译后的API文档:ehcache-web-2.0.4-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:net.sf.ehcache:ehcache-web:2.0.4; 标签:sf、ehcache、web、中英对照文档、jar包、java; 使用方法:解压翻译...
Java缓存框架 EhCache EhCache 是一个纯Java的进程内缓存框架,具有快速、精干等特点,是Hibernate中默认的CacheProvider。 从之前发布其他chm文件下载用户的反映看,有不少朋友反映下载后打开无法显示,这一般不是...