Fix issues.

Author: vbabanin

src/integrationTest/java/com/mongodb/hibernate/jdbc/MongoPreparedStatementIntegrationTests.java

@@ -268,11 +268,9 @@ void testQueriesReturningResult() {
                     pstm.addBatch();
                     assertThatExceptionOfType(BatchUpdateException.class)
                             .isThrownBy(pstm::executeBatch)
-                            .satisfies(batchUpdateException -> {
-                                assertNull(batchUpdateException.getUpdateCounts());
-                                assertNull(batchUpdateException.getSQLState());
-                                assertEquals(0, batchUpdateException.getErrorCode());
-                            });
+                            .returns(null, BatchUpdateException::getUpdateCounts)
+                            .returns(null, BatchUpdateException::getSQLState)
+                            .returns(0, BatchUpdateException::getErrorCode);
                 } catch (SQLException e) {
                     throw new RuntimeException(e);
                 }

src/main/java/com/mongodb/hibernate/jdbc/MongoPreparedStatement.java

@@ -28,6 +28,7 @@
 import com.mongodb.hibernate.internal.type.ObjectIdJdbcType;
 import java.math.BigDecimal;
 import java.sql.Array;
+import java.sql.BatchUpdateException;
 import java.sql.Date;
 import java.sql.JDBCType;
 import java.sql.PreparedStatement;
@@ -233,6 +234,22 @@ public int[] executeBatch() throws SQLException {
         }
     }
 
+    private void checkSupportedBatchCommand(BsonDocument command) throws SQLException {
+        var commandType = getCommandType(command);
+        if (commandType == CommandType.AGGREGATE) {
+            // The method executeBatch throws a BatchUpdateException if any of the commands in the batch attempts to
+            // return a result set.
+            throw new BatchUpdateException(
+                    format(
+                            "Commands returning result set are not supported. Received command: %s",
+                            commandType.getCommandName()),
+                    null,
+                    NO_ERROR_CODE,
+                    null);
+        }
+        checkSupportedUpdateCommand(commandType);
+    }
+
     @Override
     public void setArray(int parameterIndex, Array x) throws SQLException {
         checkClosed();