Changes the recording proxy cache to a more fancy one using hsqldb.

git-svn-id: https://olap4j.svn.sourceforge.net/svnroot/olap4j/trunk@422 c6a108a4-781c-0410-a6c6-c2d559e19af0

test.properties

@@ -58,15 +58,16 @@ org.olap4j.test.connectUrl=jdbc:mondrian:Datasource=jdbc/SampleData;Catalog=./fo
 # known responses. So far, it is only a proof of concept. We do not recommend
 # to rely on this for testing.
 
-# This example uses a cached Mondrian 3.3-SNAPSHOT server requests/responses data file
-# to run the TCK.
+# This example uses a cached Mondrian 3.3-SNAPSHOT server requests/responses
+# hsqldb database to run the TCK.
 # To make this example work, one must first unzip the data file manually.
-#org.olap4j.test.helperClassName=org.olap4j.RemoteXmlaTester
-#org.olap4j.RemoteXmlaTester.JdbcUrl=jdbc:xmla:Server=http://example.com;Cache=org.olap4j.driver.xmla.cache.XmlaTextFileCache;Cache.Play=true;Cache.Input=./xmla-cache/mondrian-xmla-3.3-SNAPSHOT.dat
 
-# This other example conencts to an olap server and records the requests to a file.
 #org.olap4j.test.helperClassName=org.olap4j.RemoteXmlaTester
-#org.olap4j.RemoteXmlaTester.JdbcUrl=jdbc:xmla:Server=http://localhost:81/mondrian/xmla;Cache=org.olap4j.driver.xmla.cache.XmlaTextFileCache;Cache.Record=true;Cache.Output=./output-xmla.dat
+#org.olap4j.RemoteXmlaTester.JdbcUrl=jdbc:xmla:Server=http://localhost:81/mondrian/xmla;Cache=org.olap4j.driver.xmla.cache.XmlaDatabaseCache;Cache.Play=true
 
+# This other example connects to an olap server and records the requests to
+# an hsqldb database that it creates.
+#org.olap4j.test.helperClassName=org.olap4j.RemoteXmlaTester
+#org.olap4j.RemoteXmlaTester.JdbcUrl=jdbc:xmla:Server=http://localhost:81/mondrian/xmla;Cache=org.olap4j.driver.xmla.cache.XmlaDatabaseCache;Cache.Init=true;Cache.Record=true
 
 # End test.properties

testsrc/org/olap4j/driver/xmla/cache/XmlaDatabaseCache.java

@@ -0,0 +1,200 @@
+package org.olap4j.driver.xmla.cache;
+
+import java.net.URL;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.Map;
+
+import org.olap4j.impl.Base64;
+
+/**
+ * This mock server cache is only used to save and load
+ * runs of the XMLA driver as a database table.
+ * @see Properties
+ * @author LBoudreau
+ */
+public class XmlaDatabaseCache implements XmlaOlap4jCache {
+
+ private static Connection connection = null;
+ private final static String CACHE_IDENT = "Panda steak!";
+ private Map<String, String> props;
+
+ public static enum Properties {
+
+ /**
+ * Jdbc driver class to use. Defaults to
+ * <code>org.hsqldb.jdbcDriver</code>
+ */
+
+ JDBC_DRIVER("org.hsqldb.jdbcDriver"),
+ /**
+ * Jdbc url to use. Defaults to
+ * <code>jdbc:hsqldb:file:xmla-cache/xmla-cache-hsqldb</code>
+ */
+ JDBC_URL("jdbc:hsqldb:file:xmla-cache/xmla-cache-hsqldb"),
+
+ /**
+ * Jdbc username to use. Defaults to
+ * <code>sa</code>
+ */
+ JDBC_USER("sa"),
+
+ /**
+ * Jdbc password to use. Defaults to
+ * an empty string
+ */
+ JDBC_PASS(""),
+
+ /**
+ * Query to execute to insert elements. Defaults to
+ * <code>insert into "cache" ("request", "response") values(?,?);</code>
+ */
+ QUERY_INSERT(
+ "insert into \"cache\"(\"request\", \"response\") values(?,?);"),
+
+ /**
+ * Query to execute to select elements. Defaults to
+ * <code>select "request", "response" from "cache"
+ * where "request" = ?;</code>
+ */
+ QUERY_SELECT(
+ "select \"request\", \"response\" from \"cache\" where"
+ + "\"request\" = ?;"),
+
+ /**
+ * Query to initialize the cache. Can be a batch of SQL. Defaults to
+ * <code>create table "cache" ("request"
+ * varchar, "response" varchar);</code>
+ */
+ QUERY_INIT_CACHE(
+ "drop table \"cache\" if exists; create table \"cache\" (\"request\" varchar, \"response\" varchar);"),
+
+ /**
+ * Should the cache insert requests/responses.
+ * defaults to false.
+ */
+ RECORD("false"),
+
+ /**
+ * Should the cache return cached responses.
+ * defaults to false.
+ */
+ PLAY("false"),
+
+ /**
+ * Should the cache execute Properties.QUERY_INIT_CACHE.
+ * defaults to false.
+ */
+ INIT("false");
+
+ private final String defaultValue;
+
+ private Properties(String defaultValue) {
+ this.defaultValue = defaultValue;
+ }
+ String getValueOrDefault(Map<String, String> props) {
+ if (props.containsKey(this.name())) {
+ return props.get(name());
+ } else {
+ return this.defaultValue;
+ }
+ }
+ }
+
+ public void flushCache() {
+ // no op
+ }
+
+ public byte[] get(String id, URL url, byte[] request)
+ throws XmlaOlap4jInvalidStateException
+ {
+ if (!Boolean.valueOf(Properties.PLAY.getValueOrDefault(props))) {
+ return null;
+ }
+ try {
+ final PreparedStatement stm =
+ connection.prepareStatement(
+ Properties.QUERY_SELECT.getValueOrDefault(props));
+ try {
+ stm.setString(
+ 1,
+ XmlaOlap4jShaEncoder.encodeSha1(new String(request)));
+ stm.execute();
+ ResultSet rs = stm.getResultSet();
+ if (rs.next()) {
+ return Base64.decode(rs.getString(2));
+ } else {
+ return null;
+ }
+ } finally {
+ stm.close();
+ }
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ public void put(String id, URL url, byte[] request, byte[] response)
+ throws XmlaOlap4jInvalidStateException
+ {
+ if (!Boolean.valueOf(Properties.RECORD.getValueOrDefault(props))) {
+ return;
+ }
+ try {
+ final PreparedStatement stm =
+ connection.prepareStatement(
+ Properties.QUERY_INSERT.getValueOrDefault(props));
+ try {
+ stm.setString(
+ 1,
+ XmlaOlap4jShaEncoder.encodeSha1(new String(request)));
+ stm.setString(2, Base64.encodeBytes(response));
+ stm.execute();
+ } finally {
+ stm.close();
+ }
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ public String setParameters(
+ Map<String, String> config,
+ Map<String, String> props)
+ {
+ this.props = props;
+ if (connection == null) {
+ try {
+ Class.forName(Properties.JDBC_DRIVER.getValueOrDefault(props));
+ connection =
+ DriverManager.getConnection(
+ Properties.JDBC_URL.getValueOrDefault(props),
+ Properties.JDBC_USER.getValueOrDefault(props),
+ Properties.JDBC_PASS.getValueOrDefault(props));
+ if (Boolean.valueOf(
+ Properties.INIT.getValueOrDefault(props)))
+ {
+ final Statement stm = connection.createStatement();
+ try {
+ stm.addBatch(
+ Properties.QUERY_INIT_CACHE
+ .getValueOrDefault(props));
+ stm.executeBatch();
+ } catch (SQLException e) {
+ // no op
+ } finally {
+ stm.close();
+ }
+ flushCache();
+ }
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+ return CACHE_IDENT;
+ }
+}