Examples of CacheKey

Examples of com.springsource.insight.plugin.files.tracker.AbstractFilesTrackerAspectSupport.CacheKey

37
38
39
40
41
42
43
44
45
46
47
    public void testFilesCacheSize() {
        final int MAX_CAPACITY = 16;
        FilesCache cache = new FilesCache(MAX_CAPACITY);

        for (int index = 0; index < 2 * MAX_CAPACITY; index++) {
            CacheKey key = CacheKey.getFileKey(Mockito.mock(Closeable.class));
            assertNull("Multiple mappings for " + key, cache.put(key, String.valueOf(index)));

            if (index < MAX_CAPACITY) {
                assertEquals("Mismatched pre-populated cache size", index + 1, cache.size());
            } else {
View Full Code Here

Examples of com.volantis.xml.pipeline.sax.cache.CacheKey

80
81
82
83
84
85
86
87
88
89
90
        // initialize the process
        process = new CacheBodyOperationProcess();
        cache = cacheProcessConfig.getCache("cacheName");
        process.setCache(cache);
        process.setCacheName("cacheName");
        cacheKey = new CacheKey();
        cacheKey.addKey("cacheKey");
        process.setCacheKey(cacheKey);
        process.setPipeline(pipeline);

        dependencies = new Dependency[1];
View Full Code Here

Examples of honeycrm.client.prefetch.CacheKey

15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
  public void testKey() {
    final long someRandomLong = r.nextLong();

    assertFalse(new Object[] { 1, 2 }.hashCode() == new Object[] { 1, 2 }.hashCode());

    final CacheKey c = new CacheKey(Dto.class, Dto.class, someRandomLong);
    final CacheKey d = new CacheKey(Dto.class, Dto.class, someRandomLong);
    final CacheKey e = new CacheKey(Dto.class, Dto.class, someRandomLong + 1);

    assertTrue(c.equals(d));
    assertFalse(c.equals(e));
    assertFalse(d.equals(e));

    final Set<CacheKey> set = new HashSet<CacheKey>();
    assertTrue(set.isEmpty());

    // add 1st item
    set.add(c);
    assertEquals(1, set.size());
    set.add(c);
    assertEquals(1, set.size());

    // add 2nd item
    set.add(e);
    set.add(d);
    set.add(d);
    set.add(e);
    set.add(new CacheKey(Dto.class, Dto.class, someRandomLong + 1));
    set.add(new CacheKey(Dto.class, Dto.class, someRandomLong));
    assertEquals(2, set.size());
  }
View Full Code Here

Examples of javax.cache.annotation.CacheKey

65
66
67
68
69
70
71
72
73
74
75
      }

      final CacheKeyInvocationContext<CachePut> cacheKeyInvocationContext = contextFactory.getCacheKeyInvocationContext(invocationContext);
      final CacheKeyGenerator cacheKeyGenerator = cacheKeyInvocationContext.unwrap(CacheKeyInvocationContextImpl.class).getCacheKeyGenerator();
      final CachePut cachePut = cacheKeyInvocationContext.getCacheAnnotation();
      final CacheKey cacheKey = cacheKeyGenerator.generateCacheKey(cacheKeyInvocationContext);
      final Cache<CacheKey, Object> cache = cacheResolver.resolveCache(cacheKeyInvocationContext);

      final Object valueToCache = cacheKeyInvocationContext.getValueParameter().getValue();

      if (!cachePut.afterInvocation() && valueToCache != null) {
View Full Code Here

Examples of oracle.toplink.essentials.internal.identitymaps.CacheKey

568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
        if (query.getObjectChangeSet() == null) {
            Object objectInMemory = getRealAttributeValueFromObject(query.getObject(), query.getSession());
   
            // delete the object in the database if it is no more a referenced object.           
            if (objectInDatabase != objectInMemory) {
                CacheKey cacheKeyForObjectInDatabase = null;
                CacheKey cacheKeyForObjectInMemory = new CacheKey(new Vector());
   
                cacheKeyForObjectInDatabase = new CacheKey(getPrimaryKeyForObject(objectInDatabase, query.getSession()));
   
                if (objectInMemory != null) {
                    cacheKeyForObjectInMemory = new CacheKey(getPrimaryKeyForObject(objectInMemory, query.getSession()));
                }
   
                if (cacheKeysAreEqual(cacheKeyForObjectInDatabase, cacheKeyForObjectInMemory)) {
                    return;
                }
View Full Code Here

Examples of org.apache.cocoon.pipeline.caching.CacheKey

56
57
58
59
60
61
62
63
64
65
66
67
68
        // collect ETag
        final String noneMatch = getIfNoneMatch();
        if (pipeline instanceof CachingPipeline) {
            CachingPipeline<PipelineComponent> cachingPipeline = (CachingPipeline<PipelineComponent>) pipeline;
            CacheKey cacheKey = cachingPipeline.getCacheKey();
            if (cacheKey != null) {
                setETag(Integer.toHexString(cacheKey.hashCode()));
            }
        }

        // set last-modified
        if (lastModified > -1 || getLastModified() <= 0) {
View Full Code Here

Examples of org.apache.ibatis.cache.CacheKey

102
103
104
105
106
107
108
109
110
111
112
    ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
    if (closed) throw new ExecutorException("Executor was closed.");
    List list;
    try {
      queryStack++;
      CacheKey key = createCacheKey(ms, parameter, rowBounds);
      list = resultHandler == null ? (List) localCache.getObject(key) : null;
      if (list != null) {
        handleLocallyCachedOutputParameters(ms, key, parameter);
      } else {
        list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key);
View Full Code Here

Examples of org.apache.ibatis.cache.CacheKey

133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
  }

  public CacheKey createCacheKey(MappedStatement ms, Object parameterObject, RowBounds rowBounds) {
    if (closed) throw new ExecutorException("Executor was closed.");
    BoundSql boundSql = ms.getBoundSql(parameterObject);
    CacheKey cacheKey = new CacheKey();
    cacheKey.update(ms.getId());
    cacheKey.update(rowBounds.getOffset());
    cacheKey.update(rowBounds.getLimit());
    cacheKey.update(boundSql.getSql());
    List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
    if (parameterMappings.size() > 0 && parameterObject != null) {
      TypeHandlerRegistry typeHandlerRegistry = ms.getConfiguration().getTypeHandlerRegistry();
      if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {
        cacheKey.update(parameterObject);
      } else {
        MetaObject metaObject = configuration.newMetaObject(parameterObject);
        for (ParameterMapping parameterMapping : parameterMappings) {
          String propertyName = parameterMapping.getProperty();
          if (metaObject.hasGetter(propertyName)) {
            cacheKey.update(metaObject.getValue(propertyName));
          } else if (boundSql.hasAdditionalParameter(propertyName)) {
            cacheKey.update(boundSql.getAdditionalParameter(propertyName));
          }
        }
      }
    }
    return cacheKey;
View Full Code Here

Examples of org.apache.ibatis.cache.CacheKey

374
375
376
377
378
379
380
381
382
383
384
    final MappedStatement nestedQuery = configuration.getMappedStatement(nestedQueryId);
    final Class nestedQueryParameterType = nestedQuery.getParameterMap().getType();
    final Object nestedQueryParameterObject = prepareParameterForNestedQuery(rs, propertyMapping, nestedQueryParameterType);
    Object value = null;
    if (nestedQueryParameterObject != null) {
      final CacheKey key = executor.createCacheKey(nestedQuery, nestedQueryParameterObject, RowBounds.DEFAULT);
      if (executor.isCached(nestedQuery, key)) {
        executor.deferLoad(nestedQuery, metaResultObject, property, key);
      } else {
        final ResultLoader resultLoader = new ResultLoader(configuration, executor, nestedQuery, nestedQueryParameterObject, propertyMapping.getJavaType());
        if (configuration.isLazyLoadingEnabled()) {
View Full Code Here

Examples of org.apache.ibatis.cache.CacheKey

58
59
60
61
62
63
64
65
66
67
68
  protected void handleRowValues(ResultSet rs, ResultMap resultMap, ResultHandler resultHandler, RowBounds rowBounds) throws SQLException {
    final DefaultResultContext resultContext = new DefaultResultContext();
    skipRows(rs, rowBounds);
    while (shouldProcessMoreRows(rs, resultContext, rowBounds)) {
      final ResultMap discriminatedResultMap = resolveDiscriminatedResultMap(rs, resultMap);
      final CacheKey rowKey = createRowKey(discriminatedResultMap, rs);
      final boolean knownValue = globalRowValueCache.containsKey(rowKey);
      Object rowValue = getRowValue(rs, discriminatedResultMap, rowKey);
      if (!knownValue) {
        resultContext.nextResultObject(rowValue);
        resultHandler.handleResult(resultContext);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.