Added support for using Queue.deqmany() with JSON payloads using Oracle

Database 21c.

Author: anthony-tuininga

doc/src/release_notes.rst

@@ -17,6 +17,9 @@ oracledb 3.2.0 (TBD)
 Thin Mode Changes
 +++++++++++++++++
 
+#)  Added support for using :meth:`Queue.deqmany()` with JSON payloads using
+    Oracle Database 21c.
+
 Thick Mode Changes
 ++++++++++++++++++
 

src/oracledb/aq.py

@@ -146,7 +146,15 @@ def deqmany(self, max_num_messages: int) -> list:
         Dequeues up to the specified number of messages from the queue and
         returns a list of these messages.
         """
-        message_impls = self._impl.deq_many(max_num_messages)
+        if self._impl._supports_deq_many(self._connection._impl):
+            message_impls = self._impl.deq_many(max_num_messages)
+        else:
+            message_impls = []
+            while len(message_impls) < max_num_messages:
+                message_impl = self._impl.deq_one()
+                if message_impl is None:
+                    break
+                message_impls.append(message_impl)
         return [MessageProperties._from_impl(impl) for impl in message_impls]
 
     def deqMany(self, max_num_messages: int) -> List["MessageProperties"]:

src/oracledb/impl/base/queue.pyx

@@ -1,5 +1,5 @@
 #------------------------------------------------------------------------------
-# Copyright (c) 2020, 2024, Oracle and/or its affiliates.
+# Copyright (c) 2020, 2025, Oracle and/or its affiliates.
 #
 # This software is dual-licensed to you under the Universal Permissive License
 # (UPL) 1.0 as shown at https://oss.oracle.com/licenses/upl and Apache License
@@ -31,6 +31,13 @@
 
 cdef class BaseQueueImpl:
 
+    def _supports_deq_many(self, BaseConnImpl conn_impl):
+        """
+        Returns a boolean indicating if array dequeue is supported or not. JSON
+        payloads are not supported by array dequeue until Oracle Database 23ai.
+        """
+        return not self.is_json or conn_impl.server_version[0] >= 23
+
     def deq_many(self, uint32_t max_num_messages):
         errors._raise_not_supported("dequeuing multiple messages")