Update AQ dequeue tests

Author: cjbj

test/aq2.js

@@ -29,6 +29,7 @@ const oracledb  = require('oracledb');
 const should    = require('should');
 const dbconfig  = require('./dbconfig.js');
 const testsUtil = require('./testsUtil.js');
+const assert    = require('assert');
 
 describe('218. aq2.js', function() {
 
@@ -179,34 +180,23 @@ describe('218. aq2.js', function() {
     }
   }); // 218.3
 
-  it.skip('218.4 getQueue() without options on DB Object data', async () => {
+  it('218.4 Negative - getQueue() without options on DB Object data', async () => {
     try {
       const addrData = {
         NAME: "Changjie",
         ADDRESS: "200 Oracle Parkway Redwood City, CA US 94065"
       };
-
-      // Enqueue
-      const queue1 = await conn.getQueue(
-        objQueueName,
-        //{ payloadType: objType }
-      );
-      const objClass = await conn.getDbObjectClass(objType);
-      const message = new objClass(addrData);
-      // const message = new queue1.payloadTypeClass(addrData);
-      await queue1.enqOne(message);
-      await conn.commit();
-
-      // Dequeue
-      const queue2 = await conn.getQueue(
-        objQueueName,
-        //{ payloadType: objType }
+      await assert.rejects(
+        async () => {
+          const queue1 = await conn.getQueue(objQueueName);
+          const objClass = await conn.getDbObjectClass(objType);
+          const message = new objClass(addrData);
+          await queue1.enqOne(message);
+        },
+        /DPI-1071/
       );
-      const msg = await queue2.deqOne();
-      await conn.commit();
-      should.exist(msg);
-      should.strictEqual(msg.payload.NAME, addrData.NAME);
-      should.strictEqual(msg.payload.ADDRESS, addrData.ADDRESS);
+      // DPI-1071: payload type in message properties must match
+      // the payload type of the queue
     } catch (err) {
       should.not.exist(err);
     }
@@ -274,34 +264,26 @@ describe('218. aq2.js', function() {
   }); // 218.6
 
   // A variation of 218.4
-  it.skip('218.7 Set payloadType as oracledb.DB_TYPE_OBJECT', async () => {
+  it('218.7 Negative - Set payloadType as oracledb.DB_TYPE_OBJECT', async () => {
     try {
       const addrData = {
         NAME: "Changjie",
         ADDRESS: "200 Oracle Parkway Redwood City, CA US 94065"
       };
-
-      // Enqueue
-      const queue1 = await conn.getQueue(
-        objQueueName,
-        { payloadType: oracledb.DB_TYPE_OBJECT }
-      );
-      const objClass = await conn.getDbObjectClass(objType);
-      const message = new objClass(addrData);
-      // const message = new queue1.payloadTypeClass(addrData);
-      await queue1.enqOne(message);
-      await conn.commit();
-
-      // Dequeue
-      const queue2 = await conn.getQueue(
-        objQueueName,
-        { payloadType: oracledb.DB_TYPE_OBJECT }
+      await assert.rejects(
+        async () => {
+          const queue1 = await conn.getQueue(
+            objQueueName,
+            { payloadType: oracledb.DB_TYPE_OBJECT }
+          );
+          const objClass = await conn.getDbObjectClass(objType);
+          const message = new objClass(addrData);
+          await queue1.enqOne(message);
+        },
+        {
+          message: 'NJS-007: invalid value for "payloadType" in parameter 2'
+        }
       );
-      const msg = await queue2.deqOne();
-      await conn.commit();
-      should.exist(msg);
-      should.strictEqual(msg.payload.NAME, addrData.NAME);
-      should.strictEqual(msg.payload.ADDRESS, addrData.ADDRESS);
     } catch (err) {
       should.not.exist(err);
     }

test/aq3.js

@@ -230,51 +230,4 @@ describe('219. aq3.js', function() {
     }
   }); // 219.7
 
-  it.skip('219.8 getQueue() with options on RAW data', async () => {
-    try {
-      // Enqueue
-      const queue1 = await conn.getQueue(
-        rawQueueName,
-        { payloadType: oracledb.DB_TYPE_RAW }
-      );
-      const messageString = 'The default value of payloadType is "oracledb.DB_TYPE_RAW"';
-      await queue1.enqOne(messageString);
-      await conn.commit();
-
-      // Dequeue
-      const queue2 = await conn.getQueue(rawQueueName);
-      const msg = await queue2.deqOne();
-      await conn.commit();
-
-      should.exist(msg);
-      should.strictEqual(msg.payload.toString(), messageString);
-
-    } catch (err) {
-      should.not.exist(err);
-    }
-  }); // 219.8
-
-  it.skip('219.9 Negative - getQueue() with invalid payloadType option', async () => {
-    try {
-      // Enqueue
-      const queue1 = await conn.getQueue(
-        rawQueueName,
-        { payloadType: oracledb.DB_TYPE_OBJECT }
-      );
-      const messageString = 'The default value of payloadType is "oracledb.DB_TYPE_RAW"';
-      await queue1.enqOne(messageString);
-      await conn.commit();
-
-      // Dequeue
-      const queue2 = await conn.getQueue(rawQueueName);
-      const msg = await queue2.deqOne();
-      await conn.commit();
-
-      should.exist(msg);
-      should.strictEqual(msg.payload.toString(), messageString);
-
-    } catch (err) {
-      should.not.exist(err);
-    }
-  }); // 219.9
-});
+});

test/list.txt

@@ -4596,5 +4596,20 @@ oracledb.OUT_FORMAT_OBJECT and resultSet =  true
     217.2 examples/aqoptions.js
     217.3 examples/aqmulti.js
 
-  218. aq2.js
-    218.1 examples/aqobject.js
+218. aq2.js
+    218.1 examples/aqobject.js
+    - 218.2 The read-only property "payloadTypeClass"
+    218.3 Negative - enqueue a raw JavaScript object directly
+    218.4 Negative - getQueue() without options on DB Object data
+    218.5 Enqueue a DB object as payload attribute
+    218.6 Enqueue a JavaScript object as payload attribute
+    218.7 Negative - Set payloadType as oracledb.DB_TYPE_OBJECT
+
+219. aq3.js
+    219.1 The read-only property "name" of AqQueue Class
+    - 219.2 The read-only property "payloadType"
+    - 219.3 The read-only property "payloadTypeName"
+    219.4 Negative - Set "maxMessages" argument to be -5
+    219.5 Negative - Set "maxMessages" argument to be 0
+    219.6 Enqueue a Buffer
+    219.7 enqMany() mixes enqueuing string and buffer