Fixed a bug resulting in error "DPI-1046: parameter value cannot be a

NULL pointer" when attributes "condition", "consumername",
"correlation", "msgid", "transformation" and "exceptionq" are set on the
dequeue options, enqueue options and message properties objects.

Author: anthony-tuininga

doc/src/release_notes.rst

@@ -27,6 +27,13 @@ Thin Mode Changes
 Thick Mode Changes
 ++++++++++++++++++
 
+#)  Fixed a bug resulting in error ``DPI-1046: parameter value cannot be a NULL
+    pointer`` when the attributes :attr:`DeqOptions.condition`,
+    :attr:`DeqOptions.consumername`, :attr:`DeqOptions.correlation`,
+    :attr:`DeqOptions.msgid`, :attr:`DeqOptions.transformation`,
+    :attr:`EnqOptions.transformation`, :attr:`MessageProperties.correlation`,
+    or :attr:`MessageProperties.exceptionq` are set to ``None``.
+
 Common Changes
 ++++++++++++++
 

src/oracledb/impl/thick/queue.pyx

@@ -263,7 +263,7 @@ cdef class ThickDeqOptionsImpl(BaseDeqOptionsImpl):
         Internal method for setting the condition.
         """
         cdef StringBuffer buf = StringBuffer()
-        buf.set_value(value)
+        buf.set_value(value or "")
         if dpiDeqOptions_setCondition(self._handle, buf.ptr, buf.length) < 0:
             _raise_from_odpi()
 
@@ -272,7 +272,7 @@ cdef class ThickDeqOptionsImpl(BaseDeqOptionsImpl):
         Internal method for setting the consumer name.
         """
         cdef StringBuffer buf = StringBuffer()
-        buf.set_value(value)
+        buf.set_value(value or "")
         if dpiDeqOptions_setConsumerName(self._handle, buf.ptr,
                                          buf.length) < 0:
             _raise_from_odpi()
@@ -282,7 +282,7 @@ cdef class ThickDeqOptionsImpl(BaseDeqOptionsImpl):
         Internal method for setting the correlation.
         """
         cdef StringBuffer buf = StringBuffer()
-        buf.set_value(value)
+        buf.set_value(value or "")
         if dpiDeqOptions_setCorrelation(self._handle, buf.ptr, buf.length) < 0:
             _raise_from_odpi()
 
@@ -305,7 +305,7 @@ cdef class ThickDeqOptionsImpl(BaseDeqOptionsImpl):
         Internal method for setting the message id.
         """
         cdef StringBuffer buf = StringBuffer()
-        buf.set_value(value)
+        buf.set_value(value or "")
         if dpiDeqOptions_setMsgId(self._handle, buf.ptr, buf.length) < 0:
             _raise_from_odpi()
 
@@ -321,7 +321,7 @@ cdef class ThickDeqOptionsImpl(BaseDeqOptionsImpl):
         Internal method for setting the transformation.
         """
         cdef StringBuffer buf = StringBuffer()
-        buf.set_value(value)
+        buf.set_value(value or "")
         if dpiDeqOptions_setTransformation(self._handle, buf.ptr,
                                            buf.length) < 0:
             _raise_from_odpi()
@@ -383,7 +383,7 @@ cdef class ThickEnqOptionsImpl(BaseEnqOptionsImpl):
         Internal method for setting the transformation.
         """
         cdef StringBuffer buf = StringBuffer()
-        buf.set_value(value)
+        buf.set_value(value or "")
         if dpiEnqOptions_setTransformation(self._handle, buf.ptr,
                                            buf.length) < 0:
             _raise_from_odpi()
@@ -543,7 +543,7 @@ cdef class ThickMsgPropsImpl(BaseMsgPropsImpl):
         Internal method for setting the correlation.
         """
         cdef StringBuffer buf = StringBuffer()
-        buf.set_value(value)
+        buf.set_value(value or "")
         if dpiMsgProps_setCorrelation(self._handle, buf.ptr, buf.length) < 0:
             _raise_from_odpi()
 
@@ -559,7 +559,7 @@ cdef class ThickMsgPropsImpl(BaseMsgPropsImpl):
         Internal method for setting the exception queue.
         """
         cdef StringBuffer buf = StringBuffer()
-        buf.set_value(value)
+        buf.set_value(value or "")
         if dpiMsgProps_setExceptionQ(self._handle, buf.ptr, buf.length) < 0:
             _raise_from_odpi()
 

tests/test_7800_aq_raw.py

@@ -421,6 +421,47 @@ def test_7825(self):
         with self.assertRaisesFullCode("DPY-2062"):
             queue.enqone(props)
 
+    def test_7826(self):
+        "7826 - test providing null values on queue dequeue options"
+        queue = self.conn.queue("TEST_RAW_QUEUE")
+        str_value = "test - 7826"
+        bytes_value = str_value.encode()
+        for name in [
+            "condition",
+            "consumername",
+            "correlation",
+            "msgid",
+            "transformation",
+        ]:
+            value = bytes_value if name == "msgid" else str_value
+            with self.subTest(name=name):
+                setattr(queue.deqoptions, name, value)
+                self.assertEqual(getattr(queue.deqoptions, name), value)
+                setattr(queue.deqoptions, name, None)
+                self.assertIsNone(getattr(queue.deqoptions, name))
+
+    def test_7827(self):
+        "7827 - test providing null values on queue enqueue options"
+        queue = self.conn.queue("TEST_RAW_QUEUE")
+        value = "test - 7827"
+        for name in ["transformation"]:
+            with self.subTest(name=name):
+                setattr(queue.enqoptions, name, value)
+                self.assertEqual(getattr(queue.enqoptions, name), value)
+                setattr(queue.enqoptions, name, None)
+                self.assertIsNone(getattr(queue.enqoptions, name))
+
+    def test_7828(self):
+        "7828 - test providing null correlation on message properties"
+        props = self.conn.msgproperties()
+        value = "test - 7828"
+        for name in ["correlation", "exceptionq"]:
+            with self.subTest(name=name):
+                setattr(props, name, value)
+                self.assertEqual(getattr(props, name), value)
+                setattr(props, name, None)
+                self.assertIsNone(getattr(props, name))
+
 
 if __name__ == "__main__":
     test_env.run_test_cases()