Fix for Bug#103303 (32766143), JAVA.LANG.CLASSCASTEXCEPTION WHEN

INSERTING BLOB WITH SERVER PREPARED STATEMENT.

Author: soklakov

CHANGES

@@ -3,6 +3,8 @@
 
 Version 8.0.26
 
+  - Fix for Bug#103303 (32766143), JAVA.LANG.CLASSCASTEXCEPTION WHEN INSERTING BLOB WITH SERVER PREPARED STATEMENT.
+
   - WL#14205, Support query attributes.
 
   - WL#14411, Support for authentication_kerberos_client authentication plugin.

src/main/core-impl/java/com/mysql/cj/ClientPreparedQueryBindings.java

@@ -182,7 +182,7 @@ public void setBlob(int parameterIndex, Blob x) {
             setNull(parameterIndex);
         } else {
             try {
-                setBinaryStream(parameterIndex, x.getBinaryStream());
+                setBinaryStream(parameterIndex, x.getBinaryStream(), x.length());
             } catch (Throwable t) {
                 throw ExceptionFactory.createException(t.getMessage(), t, this.session.getExceptionInterceptor());
             }

src/main/user-impl/java/com/mysql/cj/jdbc/ServerPreparedStatement.java

@@ -720,10 +720,21 @@ protected int setOneBatchedParameterSet(java.sql.PreparedStatement batchedStatem
                 if (paramArg[j].isStream()) {
                     Object value = paramArg[j].value;
 
-                    if (value instanceof InputStream) {
+                    if (value instanceof byte[]) {
+                        batchedStatement.setBytes(batchedParamIndex++, (byte[]) value);
+                    } else if (value instanceof InputStream) {
                         batchedStatement.setBinaryStream(batchedParamIndex++, (InputStream) value, paramArg[j].getStreamLength());
-                    } else {
+                    } else if (value instanceof java.sql.Blob) {
+                        try {
+                            batchedStatement.setBinaryStream(batchedParamIndex++, ((java.sql.Blob) value).getBinaryStream(), paramArg[j].getStreamLength());
+                        } catch (Throwable t) {
+                            throw ExceptionFactory.createException(t.getMessage(), this.session.getExceptionInterceptor());
+                        }
+                    } else if (value instanceof Reader) {
                         batchedStatement.setCharacterStream(batchedParamIndex++, (Reader) value, paramArg[j].getStreamLength());
+                    } else {
+                        throw ExceptionFactory.createException(WrongArgumentException.class,
+                                Messages.getString("ServerPreparedStatement.18") + value.getClass().getName() + "'", this.session.getExceptionInterceptor());
                     }
                 } else {
                     switch (paramArg[j].bufferType) {

src/test/java/testsuite/regression/StatementRegressionTest.java

@@ -106,6 +106,7 @@
 import java.util.function.ToIntFunction;
 
 import javax.sql.XAConnection;
+import javax.sql.rowset.serial.SerialBlob;
 
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
@@ -11538,4 +11539,49 @@ public void testBug20391550() throws Exception {
             }
         }
     }
+
+    /**
+     * Test fix for Bug#103303 (32766143), JAVA.LANG.CLASSCASTEXCEPTION WHEN INSERTING BLOB WITH SERVER PREPARED STATEMENT.
+     * 
+     * @throws Exception
+     */
+    @Test
+    public void testBug103303() throws Exception {
+        createTable("testBug103303", "(id INT AUTO_INCREMENT PRIMARY KEY, blob1 MEDIUMBLOB)");
+
+        Connection con = null;
+        Properties props = new Properties();
+
+        for (boolean rewriteBS : new boolean[] { true, false }) {
+            for (boolean useSSPS : new boolean[] { true, false }) {
+                props.setProperty(PropertyKey.rewriteBatchedStatements.getKeyName(), "" + rewriteBS);
+                props.setProperty(PropertyKey.useServerPrepStmts.getKeyName(), "" + useSSPS);
+
+                try {
+                    this.stmt.executeUpdate("truncate table testBug103303");
+
+                    con = getConnectionWithProps(props);
+
+                    PreparedStatement statement = con.prepareStatement("INSERT INTO testBug103303(blob1) VALUES(?)", PreparedStatement.RETURN_GENERATED_KEYS);
+                    statement.setBlob(1, new SerialBlob("test1".getBytes()));
+                    statement.addBatch();
+                    statement.setBlob(1, new SerialBlob("test2".getBytes()));
+                    statement.addBatch();
+                    statement.executeBatch();
+
+                    this.rs = this.stmt.executeQuery("select blob1 from testBug103303 order by id");
+                    assertTrue(this.rs.next());
+                    assertEquals("test1", this.rs.getString(1));
+                    assertTrue(this.rs.next());
+                    assertEquals("test2", this.rs.getString(1));
+                    assertFalse(this.rs.next());
+
+                } finally {
+                    if (con != null) {
+                        con.close();
+                    }
+                }
+            }
+        }
+    }
 }