optimize query cache

Author: lvyahui8

spring-boot-data-aggregator-autoconfigure/src/main/java/io/github/lvyahui8/spring/annotation/DataProvider.java

@@ -32,4 +32,9 @@
      */
     long timeout() default -1;
 
+    /**
+     * The call to this data providing method should be idempotent,
+     * which determines whether its execution result will be cached.
+     */
+    boolean idempotent() default true;
 }

spring-boot-data-aggregator-autoconfigure/src/main/java/io/github/lvyahui8/spring/autoconfigure/BeanAggregateAutoConfiguration.java

@@ -107,6 +107,7 @@ private void dealProvideMethod(DataProviderRepository repository, Method method)
         Assert.isTrue(! StringUtils.isEmpty(dataId),"data id must be not null!");
         provider.setId(dataId);
         provider.setMethod(method);
+        provider.setIdempotent(beanProvider.idempotent());
         provider.setTimeout(beanProvider.timeout() > 0 ? beanProvider.timeout() : properties.getDefaultTimeout());
         Parameter[] parameters = provider.getMethod().getParameters();
         List<MethodArg> methodArgs = new ArrayList<>(method.getParameterCount());

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/model/DataProvideDefinition.java

@@ -17,4 +17,5 @@ public class DataProvideDefinition {
     private List<DataConsumeDefinition>     depends;
     private List<InvokeParameterDefinition> params;
     private List<MethodArg>                 methodArgs;
+    private boolean                         idempotent;
 }

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/service/impl/DataBeanAggregateQueryServiceImpl.java

@@ -95,14 +95,16 @@ public <T> T get(String id, Map<String, Object> invokeParams, Class<T> resultTyp
         /* 如果调用方法是幂等的, 那么当方法签名和方法参数完全一致时, 可以直接使用缓存结果 */
         InvokeSignature invokeSignature = new InvokeSignature(provider.getMethod(),args);
         Object resultModel;
-        if(queryCache.containsKey(invokeSignature)) {
+        if(provider.isIdempotent() && queryCache.containsKey(invokeSignature)) {
             resultModel = queryCache.get(invokeSignature);
         }
         else {
             resultModel = provider.getMethod()
                     .invoke(applicationContext.getBean(provider.getMethod().getDeclaringClass()), args);
-            /* Map 中可能不能放空value */
-            queryCache.put(invokeSignature,resultModel != null ? resultModel : AggregatorConstant.EMPTY_MODEL);
+            if(provider.isIdempotent()) {
+                /* Map 中可能不能放空value */
+                queryCache.put(invokeSignature,resultModel != null ? resultModel : AggregatorConstant.EMPTY_MODEL);
+            }
         }
 
         return resultType.cast(resultModel != AggregatorConstant.EMPTY_MODEL ? resultModel : null);