Merge pull request #39 from StephG38/master

Providing way to disable prepared statement cache

README.md

@@ -35,6 +35,7 @@ Current supported options are;
 * `connectTimeout=X` - have an X second connection timeout.
 * `createDB=true` - create the given database if it does not exist when connecting.
 * `enableBlobStreaming=true` - experimental support for PBMS blob streaming.
+* `noPrepStmtCache=true` - Disable prepared statement cache.
 
 
 Building and testing

src/main/java/org/drizzle/jdbc/DrizzlePreparedStatement.java

@@ -92,7 +92,7 @@ public DrizzlePreparedStatement(final Protocol protocol,
         if(log.isLoggable(Level.FINEST)) {
             log.finest("Creating prepared statement for " + query);
         }
-        dQuery = queryFactory.createParameterizedQuery(query);
+        dQuery = queryFactory.createParameterizedQuery(query, protocol.noPrepStmtCache());
         this.parameterizedBatchHandler = parameterizedBatchHandler;
     }
 

src/main/java/org/drizzle/jdbc/internal/common/Protocol.java

@@ -230,4 +230,6 @@ public interface Protocol {
      * @see #setCatalog
      */
     public String getCatalog() throws QueryException;
+
+    public boolean noPrepStmtCache();
 }

src/main/java/org/drizzle/jdbc/internal/common/query/DrizzleQueryFactory.java

@@ -39,9 +39,13 @@ public DrizzleQuery createQuery(byte[] query)
     {
         return new DrizzleQuery(query);
     }
-    public ParameterizedQuery createParameterizedQuery(final String query) {
+    public ParameterizedQuery createParameterizedQuery(final String query, boolean noCache) {
+
+        if(noCache)
+            return new DrizzleParameterizedQuery(new DrizzleParameterizedQuery(query));
+
+        // Cache prepared statements
         ParameterizedQuery pq = DrizzleQueryFactory.PREPARED_CACHE.get(query);
-
 
         if(pq == null) {
             pq = new DrizzleParameterizedQuery(query);

src/main/java/org/drizzle/jdbc/internal/common/query/QueryFactory.java

@@ -31,7 +31,7 @@ public interface QueryFactory {
     Query createQuery(String query);
     Query createQuery(byte[] query);
 
-    ParameterizedQuery createParameterizedQuery(String query);
+    ParameterizedQuery createParameterizedQuery(String query, boolean noCache);
 
     ParameterizedQuery createParameterizedQuery(ParameterizedQuery dQuery);
 }

src/main/java/org/drizzle/jdbc/internal/mysql/MySQLProtocol.java

@@ -641,6 +641,10 @@ public boolean createDB() {
                 && info.getProperty("createDB", "").equalsIgnoreCase("true");
     }
 
+    public boolean noPrepStmtCache() {
+        return info != null
+                && info.getProperty("noPrepStmtCache", "").equalsIgnoreCase("true");
+    }
 
     /**
      * Send the given file to the server starting with packet number packIndex