[CONJ-238] PrepareStatement prepare exception handling when using tem…

…porary tables.
mariadb-corporation · Dec 31, 2015 · 8cb011c · 8cb011c
1 parent 008c6e7
commit 8cb011c
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 1 deletion.
diff --git a/src/main/java/org/mariadb/jdbc/MariaDbConnection.java b/src/main/java/org/mariadb/jdbc/MariaDbConnection.java
@@ -372,7 +372,12 @@ public PreparedStatement prepareStatement(final String sql, final String[] colum
     public PreparedStatement internalPrepareStatement(final String sql, final int autoGeneratedKeys) throws SQLException {
         checkConnection();
         if (!options.allowMultiQueries && !options.rewriteBatchedStatements && options.useServerPrepStmts && checkIfPreparable(sql)) {
-            return new MariaDbServerPreparedStatement(this, sql, autoGeneratedKeys);
+            try {
+                return new MariaDbServerPreparedStatement(this, sql, autoGeneratedKeys);
+            } catch (SQLException e) {
+                //on some specific case, server cannot prepared data (CONJ-238)
+                return new MariaDbClientPreparedStatement(this, sql, autoGeneratedKeys);
+            }
         }
         return new MariaDbClientPreparedStatement(this, sql, autoGeneratedKeys);
     }

diff --git a/src/test/java/org/mariadb/jdbc/PreparedStatementTest.java b/src/test/java/org/mariadb/jdbc/PreparedStatementTest.java
@@ -30,6 +30,7 @@ public static void initClass() throws SQLException {
                         + "`Seems:LikeParam?` bit(1) DEFAULT NULL,"
                         + "`Webinar10-TM/ProjComp` text",
                  "ENGINE=InnoDB DEFAULT CHARSET=utf8");
+        createTable("test_insert_select","`field1` varchar(20)");
     }
 
     @Test
@@ -40,6 +41,19 @@ public void testClosingError() throws Exception {
 
     }
 
+    /**
+     * Conj-238.
+     *
+     * @throws SQLException exception
+     */
+    @org.junit.Test
+    public void insertSelect() throws Exception {
+        PreparedStatement stmt = sharedConnection.prepareStatement(
+                "insert into test_insert_select ( field1) (select  TMP.field1 from (select ? `field1` from dual) TMP)");
+        stmt.setString(1, "test");
+        stmt.executeUpdate();
+    }
+
     /**
      * Conj-90.
      *