--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/geo-backend/src/main/java/de/intevation/gnv/geobackend/base/query/CachingQueryExecutorFactory.java	Fri Dec 18 16:13:52 2009 +0000
@@ -0,0 +1,50 @@
+package de.intevation.gnv.geobackend.base.query;
+
+import java.util.Collection;
+
+import net.sf.ehcache.Cache;
+import net.sf.ehcache.Element;
+import net.sf.ehcache.CacheManager;
+
+
+import de.intevation.gnv.geobackend.base.Result;
+
+/**
+ * @author Sascha L. Teichmann <sascha.teichmann@intevation.de>
+ *
+ */
+public class CachingQueryExecutorFactory
+extends      QueryExecutorFactory
+{
+    public static final String QUERY_EXECUTOR_FACTORY = "caching.query.executor.config";
+    public static final String CACHE_NAME             = "sql.cache";
+
+    protected CacheManager manager;
+
+    public CachingQueryExecutorFactory() {
+        String configFile = System.getProperty(QUERY_EXECUTOR_FACTORY);
+        manager = configFile != null
+            ? new CacheManager(configFile)
+            : new CacheManager();
+        manager.addCache(CACHE_NAME);
+    }
+
+    public QueryExecutor getQueryExecutor() {
+        return new DefaultQueryExceutor() {
+
+            public Collection<Result> cachedResults(String query) {
+                Cache   cache   = manager.getCache(CACHE_NAME);
+                Element element = cache.get(query);
+                return element != null
+                    ? (Collection<Result>)element.getObjectValue()
+                    : null;
+            }
+
+            public void cacheResult(String query, Collection<Result> results) {
+                Cache cache = manager.getCache(CACHE_NAME);
+                cache.put(new Element(query, results));
+            }
+        };
+    }
+}
+// vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8: