• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Result类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中net.sf.ehcache.search.Result的典型用法代码示例。如果您正苦于以下问题:Java Result类的具体用法?Java Result怎么用?Java Result使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Result类属于net.sf.ehcache.search包,在下文中一共展示了Result类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: cleanCaches

import net.sf.ehcache.search.Result; //导入依赖的package包/类
private void cleanCaches(ObjectId objectId, Instant fromVersion, Instant toVersion) {

    Results results = getUidToDocumentCache().createQuery().includeKeys()
        .includeAttribute(getUidToDocumentCache().getSearchAttribute("ObjectId"))
        .includeAttribute(getUidToDocumentCache().getSearchAttribute("VersionFromInstant"))
        .includeAttribute(getUidToDocumentCache().getSearchAttribute("VersionToInstant"))
        .addCriteria(getUidToDocumentCache().getSearchAttribute("ObjectId")
                         .eq(objectId.toString()))
        .addCriteria(getUidToDocumentCache().getSearchAttribute("VersionFromInstant")
                         .le((fromVersion != null ? fromVersion : InstantExtractor.MIN_INSTANT).toString()))
        .addCriteria(getUidToDocumentCache().getSearchAttribute("VersionToInstant")
                         .ge((toVersion != null ? toVersion : InstantExtractor.MAX_INSTANT).toString()))
        .execute();

    for (Result result : results.all()) {
      getUidToDocumentCache().remove(result.getKey());
    }
  }
 
开发者ID:DevStreet,项目名称:FinanceAnalytics,代码行数:19,代码来源:AbstractEHCachingMaster.java


示例2: searchPartitionKeys

import net.sf.ehcache.search.Result; //导入依赖的package包/类
private List searchPartitionKeys(final Query query) {
	LinkedList<Object> keys = new LinkedList<Object>();
	System.out.println("Starting search...");
	long startTime = System.currentTimeMillis();
	Results results = query.execute();
	if(log.isDebugEnabled())
		log.debug(String.format("Search time: %d ms", System.currentTimeMillis() - startTime));

	// perform the refresh
	for (Result result : results.all()) {
		keys.add(result.getKey());
	}

	results.discard();

	return keys;
}
 
开发者ID:lanimall,项目名称:ehcache-extensions,代码行数:18,代码来源:CacheFailoverDecorator.java


示例3: fetchByCriteria

import net.sf.ehcache.search.Result; //导入依赖的package包/类
public Collection<T> fetchByCriteria( Criteria criteria ) {
    net.sf.ehcache.search.Query query = this.cache.createQuery();
    query.includeValues();
    query.addCriteria( criteria );
    Results results = null;
    try {
        results = query.execute();
    } catch ( Exception e ) {
        throw new SearchException( "Query error" );
    }

    if ( results == null ) {
        return null;
    }

    Collection<T> genes = new HashSet<T>( results.size() );

    for ( Result result : results.all() ) {
        genes.add( ( T ) result.getValue() );
    }

    return genes;
}
 
开发者ID:PavlidisLab,项目名称:modinvreg,代码行数:24,代码来源:SearchableEhcache.java


示例4: getAces

import net.sf.ehcache.search.Result; //导入依赖的package包/类
private <T extends ControlEntry> List<T> getAces(String uid, CacheId cacheId) {
    Cache cache = getCache(cacheId);
    List<T> aces = new ArrayList<T>();
    // here search on uid take place
    Attribute<String> uidAttribute = cache.getSearchAttribute(UserDomainInterfaceOperationKey.USER_ID);
    // query is the fastest if you search for keys and if you need value then call Cache.get(key)
    Query queryRequestedUid = cache.createQuery().addCriteria(uidAttribute.eq(uid).or(uidAttribute.eq(WILDCARD)))
    // have specific user ids appear before wildcards
                                   .addOrderBy(uidAttribute, Direction.DESCENDING)
                                   .includeKeys()
                                   .end();
    Results results = queryRequestedUid.execute();
    for (Result result : results.all()) {
        aces.add(DomainAccessControlStoreEhCache.<T> getElementValue(cache.get(result.getKey())));
    }

    return aces;
}
 
开发者ID:bmwcarit,项目名称:joynr,代码行数:19,代码来源:DomainAccessControlStoreEhCache.java


示例5: findAlarm

import net.sf.ehcache.search.Result; //导入依赖的package包/类
@Override
public Collection<Long> findAlarm(AlarmQuery query) {

  Ehcache ehcache = getCache();
  ArrayList<Long> result = new ArrayList<Long>();

  Query cacheQuery = ehcache.createQuery();

  if (query.getFaultCode() != 0) {
      Attribute<Integer> fc = ehcache.getSearchAttribute("faultCode");
      cacheQuery.addCriteria(fc.eq(query.getFaultCode()));
  }
  if (query.getFaultFamily() != null && !"".equals(query.getFaultFamily())) {
      Attribute<String> ff = ehcache.getSearchAttribute("faultFamily");
      cacheQuery.addCriteria(ff.ilike(query.getFaultFamily()));
  }
  if (query.getFaultMember() != null && !"".equals(query.getFaultMember())) {
      Attribute<String> fm = ehcache.getSearchAttribute("faultMember");
      cacheQuery.addCriteria(fm.ilike(query.getFaultMember()));
  }
  if (query.getPriority() != 0) {
      Attribute<Integer> prio = ehcache.getSearchAttribute("priority");
      cacheQuery.addCriteria(prio.eq(query.getPriority()));
  }
  if (query.getActive() != null) {
    Attribute<Boolean> active = ehcache.getSearchAttribute("isActive");
    cacheQuery.addCriteria(active.eq(query.getActive()));
  }

  for (Result res: cacheQuery.maxResults(query.getMaxResultSize()).includeKeys().execute().all()) {
      result.add((Long) res.getKey());
  }

  return result;
}
 
开发者ID:c2mon,项目名称:c2mon,代码行数:36,代码来源:AlarmCacheImpl.java


示例6: clearDsdCacheEntry

import net.sf.ehcache.search.Result; //导入依赖的package包/类
/**
 * Given DSD entry name, clear its corresponding object values from the cache.
 *
 * @param name contains the name of object to be cleared.
 * @param contextId maps to sub-tree in DIT, e.g. ou=contextId, dc=example, dc=com.     *
 * @throws SecurityException in the event of system or rule violation.
 */
void clearDsdCacheEntry(String name, String contextId)
{
    Attribute<String> context = m_dsdCache.getSearchAttribute(CONTEXT_ID);
    Attribute<String> dsdName = m_dsdCache.getSearchAttribute(DSD_NAME);
    Query query = m_dsdCache.createQuery();
    query.includeKeys();
    query.includeValues();
    query.addCriteria(dsdName.eq(name).and(context.eq(contextId)));
    Results results = query.execute();
    for (Result result : results.all())
    {
        m_dsdCache.clear(result.getKey());
    }
}
 
开发者ID:apache,项目名称:directory-fortress-core,代码行数:22,代码来源:SDUtil.java


示例7: getDsdCache

import net.sf.ehcache.search.Result; //导入依赖的package包/类
/**
 * Given a role name, return the set of DSD's that have a matching member.
 *
 * @param name contains name of authorized Role used to search the cache.
 * @param contextId maps to sub-tree in DIT, e.g. ou=contextId, dc=example, dc=com.
 * @return un-ordered set of matching DSD's.
 * @throws SecurityException in the event of system or rule violation.
 */
private Set<SDSet> getDsdCache(String name, String contextId)
    throws SecurityException
{
    contextId = getContextId(contextId);
    Set<SDSet> finalSet = new HashSet<>();
    Attribute<String> context = m_dsdCache.getSearchAttribute(CONTEXT_ID);
    Attribute<String> member = m_dsdCache.getSearchAttribute(SchemaConstants.MEMBER_AT);
    Query query = m_dsdCache.createQuery();
    query.includeKeys();
    query.includeValues();
    query.addCriteria(member.eq(name).and(context.eq(contextId)));
    Results results = query.execute();
    boolean empty = false;
    for (Result result : results.all())
    {
        DsdCacheEntry entry = (DsdCacheEntry) result.getValue();
        if (!entry.isEmpty())
        {
            finalSet.add(entry.getSdSet());
            finalSet = putDsdCache(name, contextId);
        }
        else
        {
            empty = true;
        }
        finalSet.add(entry.getSdSet());
    }
    // If nothing was found in the cache, determine if it needs to be seeded:
    if (finalSet.size() == 0 && !empty)
    {
        finalSet = putDsdCache(name, contextId);
    }
    return finalSet;
}
 
开发者ID:apache,项目名称:directory-fortress-core,代码行数:43,代码来源:SDUtil.java


示例8: runTests

import net.sf.ehcache.search.Result; //导入依赖的package包/类
void runTests()
{
    loadCache();
    Attribute<String> member = cache.getSearchAttribute( "member" );
    Query query = cache.createQuery();
    query.includeKeys();
    query.includeValues();
    Set<String> roles = new HashSet<>();
    roles.add( "oamt17dsd1" );
    roles.add( "oamt17dsd4" );
    roles.add( "oamT13DSD6" );
    roles.add( "oamT16SDR7" );
    query.addCriteria( member.in( roles ) );
    Results results = query.execute();
    System.out.println( " Size: " + results.size() );
    System.out.println( "----Results-----\n" );
    Set<SDSet> resultSet = new HashSet<>();

    for ( Result result : results.all() )
    {
        DsdCacheEntry entry = ( DsdCacheEntry ) result.getValue();
        resultSet.add( entry.getSdSet() );
    }

    for ( SDSet sdSet : resultSet )
    {
        LOG.info( "Found SDSet: " + sdSet.getName() );
    }
}
 
开发者ID:apache,项目名称:directory-fortress-core,代码行数:30,代码来源:CacheSample.java


示例9: getDomainRoles

import net.sf.ehcache.search.Result; //导入依赖的package包/类
@Override
public List<DomainRoleEntry> getDomainRoles(String uid) {
    Cache cache = getCache(CacheId.DOMAIN_ROLES);
    List<DomainRoleEntry> domainRoles = new ArrayList<DomainRoleEntry>();
    Attribute<String> uidAttribute = cache.getSearchAttribute(UserRoleKey.USER_ID);
    // query is the fastest if you search for keys and if you need value then call Cache.get(key)
    Query queryRequestedUid = cache.createQuery().addCriteria(uidAttribute.eq(uid)).includeKeys().end();
    Results results = queryRequestedUid.execute();
    for (Result result : results.all()) {
        domainRoles.add(DomainAccessControlStoreEhCache.<DomainRoleEntry> getElementValue(cache.get(result.getKey())));
    }

    return domainRoles;
}
 
开发者ID:bmwcarit,项目名称:joynr,代码行数:15,代码来源:DomainAccessControlStoreEhCache.java


示例10: getEditableAces

import net.sf.ehcache.search.Result; //导入依赖的package包/类
private <T extends ControlEntry> List<T> getEditableAces(String uid, CacheId cacheId, Role role) {
    List<T> aces = new ArrayList<T>();
    // find out first on which domains uid has specified role
    Cache drtCache = getCache(CacheId.DOMAIN_ROLES);
    UserRoleKey dreKey = new UserRoleKey(uid, role);
    String[] uidDomains = null;
    // read domains from DRE
    if (drtCache.isKeyInCache(dreKey)) {
        DomainRoleEntry dre = DomainAccessControlStoreEhCache.<DomainRoleEntry> getElementValue(drtCache.get(dreKey));
        uidDomains = dre.getDomains();
    }
    // if uid has no domains with specified role return empty list
    if (uidDomains == null || uidDomains.length == 0) {
        return aces;
    }

    Cache cache = getCache(cacheId);
    // here should search on uid and domain take place
    Attribute<String> uidAttribute = cache.getSearchAttribute(UserDomainInterfaceOperationKey.USER_ID);
    Attribute<String> domainAttribute = cache.getSearchAttribute(UserDomainInterfaceOperationKey.DOMAIN);
    for (String domain : uidDomains) {
        Query query = cache.createQuery()
                           .addCriteria(uidAttribute.eq(uid).and(domainAttribute.eq(domain)))
                           .includeKeys()
                           .end();
        Results results = query.execute();
        for (Result result : results.all()) {
            aces.add(DomainAccessControlStoreEhCache.<T> getElementValue(cache.get(result.getKey())));
        }

    }

    return aces;
}
 
开发者ID:bmwcarit,项目名称:joynr,代码行数:35,代码来源:DomainAccessControlStoreEhCache.java



注:本文中的net.sf.ehcache.search.Result类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java Subscription类代码示例发布时间:2022-05-22
下一篇:
Java ReservoirSamplingMeta类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap