Added test cases for AQ enqueue/dequeue options and message properties

anthony-tuininga · anthony-tuininga · commit c1005ddcacb9 · 2017-07-13T13:57:29.000-06:00
(oracle/odpi#16).
diff --git a/odpi b/odpi
@@ -1 +1 @@
-Subproject commit f7643e23892956976a5f92817b80cd5919ceeb7c
+Subproject commit af4c7336aeaf61bd22e6c0750982d77fa7f3e2d1
diff --git a/test/AQ.py b/test/AQ.py
@@ -0,0 +1,44 @@
+#------------------------------------------------------------------------------
+# Copyright 2017, Oracle and/or its affiliates. All rights reserved.
+#------------------------------------------------------------------------------
+
+"""Module for testing AQ objects."""
+
+import cx_Oracle
+
+class TestAQ(BaseTestCase):
+
+    def __verifyAttribute(self, obj, attrName, value):
+        setattr(obj, attrName, value)
+        self.assertEqual(getattr(obj, attrName), value)
+
+    def testDeqOptions(self):
+        "test getting/setting dequeue options attributes"
+        options = self.connection.deqoptions()
+        self.__verifyAttribute(options, "condition", "TEST_CONDITION")
+        self.__verifyAttribute(options, "consumername", "TEST_CONSUMERNAME")
+        self.__verifyAttribute(options, "correlation", "TEST_CORRELATION")
+        self.__verifyAttribute(options, "mode", cx_Oracle.DEQ_LOCKED)
+        self.__verifyAttribute(options, "navigation",
+                cx_Oracle.DEQ_NEXT_TRANSACTION)
+        self.__verifyAttribute(options, "transformation",
+                "TEST_TRANSFORMATION")
+        self.__verifyAttribute(options, "visibility", cx_Oracle.ENQ_IMMEDIATE)
+        self.__verifyAttribute(options, "wait", 1287)
+
+    def testEnqOptions(self):
+        "test getting/setting enqueue options attributes"
+        options = self.connection.enqoptions()
+        self.__verifyAttribute(options, "visibility", cx_Oracle.ENQ_IMMEDIATE)
+
+    def testMsgProps(self):
+        "test getting/setting message properties attributes"
+        props = self.connection.msgproperties()
+        self.__verifyAttribute(props, "correlation", "TEST_CORRELATION")
+        self.__verifyAttribute(props, "delay", 60)
+        self.__verifyAttribute(props, "exceptionq", "TEST_EXCEPTIONQ")
+        self.__verifyAttribute(props, "expiration", 30)
+        self.assertEqual(props.attempts, 0)
+        self.__verifyAttribute(props, "priority", 1)
+        self.assertEqual(props.state, cx_Oracle.MSG_READY)
+
diff --git a/test/test.py b/test/test.py
@@ -44,7 +44,8 @@
             "ObjectVar",
             "SessionPool",
             "StringVar",
-            "TimestampVar"
+            "TimestampVar",
+            "AQ"
     ]
     if sys.version_info[0] < 3:
         moduleNames.extend([
