Mercurial > dive4elements > river
view flys-artifacts/src/main/java/de/intevation/flys/artifacts/datacage/templating/CompiledStatement.java @ 4255:670e98f5a441
Fixed leak while merging facets.
The ThemeList that is used by OutputHelper to sort the
Facets for an Output now uses a list to store the ManagedFacets.
The correct order is made up by sorting the List using
Collections.sort() function of the Java JDK. Therfore, the
ManagedFacet class implements the Comparable interface. The
return value of its compareTo(other) method depends on the
value of the 'position' field.
author | Ingo Weinzierl <weinzierl.ingo@googlemail.com> |
---|---|
date | Thu, 25 Oct 2012 14:01:46 +0200 |
parents | 5642a83420f2 |
children | c1df0dac140b |
line wrap: on
line source
package de.intevation.flys.artifacts.datacage.templating; import java.util.regex.Pattern; import java.util.regex.Matcher; import java.util.List; import java.util.Map; import java.util.TreeMap; import java.util.ArrayList; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Connection; import java.sql.ResultSet; import net.sf.ehcache.Cache; import net.sf.ehcache.Element; import de.intevation.flys.artifacts.cache.CacheFactory; import org.apache.log4j.Logger; public class CompiledStatement { private static Logger log = Logger.getLogger(CompiledStatement.class); public static final String DATACAGE_DB_CACHE = "datacage.db"; public static final Pattern VAR = Pattern.compile("\\$\\{([a-zA-Z0-9_-]+)\\}"); protected String original; protected String statement; protected Map<String, List<Integer>> positions; protected int numVars; public class Instance { protected PreparedStatement preparedStatement; public Instance() { } protected ResultData executeCached( Cache cache, Connection connection, StackFrames frames ) throws SQLException { log.debug("executeCached"); Object [] values = new Object[numVars]; StringBuilder sb = new StringBuilder(original); for (Map.Entry<String, List<Integer>> entry: positions.entrySet()) { String key = entry.getKey(); Object value = frames.get(key); sb.append(';').append(key).append(':').append(value); for (Integer index: entry.getValue()) { values[index] = value; } } // XXX: Maybe too many collisions? // String key = original + Arrays.hashCode(values); String key = sb.toString(); Element element = cache.get(key); if (element != null) { return (ResultData)element.getValue(); } if (preparedStatement == null) { preparedStatement = connection.prepareStatement(statement); } for (int i = 0; i < values.length; ++i) { preparedStatement.setObject(i+1, values[i]); } ResultData data; if (log.isDebugEnabled()) { log.debug("executing: " + statement); } ResultSet result = preparedStatement.executeQuery(); try { data = new ResultData(preparedStatement.getMetaData()) .addAll(result); } finally { result.close(); } element = new Element(key, data); cache.put(element); return data; } protected ResultData executeUncached( Connection connection, StackFrames frames ) throws SQLException { log.debug("executeUncached"); if (preparedStatement == null) { if (log.isDebugEnabled()) { log.debug("preparing statement: " + statement); } preparedStatement = connection.prepareStatement(statement); } for (Map.Entry<String, List<Integer>> entry: positions.entrySet()) { Object value = frames.get(entry.getKey()); for (Integer index: entry.getValue()) { preparedStatement.setObject(index+1, value); } } if (log.isDebugEnabled()) { log.debug("executing: " + statement); } ResultSet result = preparedStatement.executeQuery(); try { return new ResultData(preparedStatement.getMetaData()) .addAll(result); } finally { result.close(); } } public ResultData execute( Connection connection, StackFrames frames, boolean cached ) throws SQLException { if (!cached) { return executeUncached(connection, frames); } Cache cache = CacheFactory.getCache(DATACAGE_DB_CACHE); return cache != null ? executeCached(cache, connection, frames) : executeUncached(connection, frames); } public void close() { if (preparedStatement != null) { try { preparedStatement.close(); } catch (SQLException sqle) { } preparedStatement = null; } } } // class Instance public CompiledStatement() { } public CompiledStatement(String original) { this.original = original; // TreeMap to ensure order positions = new TreeMap<String, List<Integer>>(); compile(); } protected void compile() { StringBuffer sb = new StringBuffer(); Matcher m = VAR.matcher(original); int index = 0; while (m.find()) { String key = m.group(1).toUpperCase(); List<Integer> indices = positions.get(key); if (indices == null) { indices = new ArrayList<Integer>(); positions.put(key, indices); } indices.add(index); m.appendReplacement(sb, "?"); ++index; } m.appendTail(sb); numVars = index; statement = sb.toString(); } public String getStatement() { return statement; } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :