From dcb7bd61916f8c9f716bad21d0e43cd062fa9738 Mon Sep 17 00:00:00 2001
From: Christopher Jones <christopher.jones@oracle.com>
Date: Wed, 14 Aug 2019 22:06:08 +1000
Subject: [PATCH] Add two more AQ enqMany() tests

---
 test/aq2.js   | 115 ++++++++++++++++++++++++++++++++++++++++++++++++++
 test/list.txt |   3 ++
 2 files changed, 118 insertions(+)

diff --git a/test/aq2.js b/test/aq2.js
index 672e4232..263fa532 100644
--- a/test/aq2.js
+++ b/test/aq2.js
@@ -288,4 +288,119 @@ describe('218. aq2.js', function() {
       should.not.exist(err);
     }
   }); // 218.7
+
+  const addrArray = [
+    {
+      NAME: "John",
+      ADDRESS: "100 Oracle Parkway Redwood City, CA US 94065"
+    },
+    {
+      NAME: "Jenny",
+      ADDRESS: "200 Oracle Parkway Redwood City, CA US 94065"
+    },
+    {
+      NAME: "Laura",
+      ADDRESS: "300 Oracle Parkway Redwood City, CA US 94065"
+    },
+    {
+      NAME: "Lawrance",
+      ADDRESS: "400 Oracle Parkway Redwood City, CA US 94065"
+    }
+  ];
+
+  it('218.8 enqMany() with DB object array', async () => {
+
+    try {
+      // Enqueue
+      const queue1 = await conn.getQueue(
+        objQueueName,
+        { payloadType: objType }
+      );
+      let msgArray = [];
+      for (let i = 0; i < addrArray.length; i++) {
+        msgArray[i] = new queue1.payloadTypeClass(addrArray[i]);
+      }
+      await queue1.enqMany(msgArray);
+
+      // Dequeue
+      const queue2 = await conn.getQueue(
+        objQueueName,
+        { payloadType: objType }
+      );
+      const messages = await queue2.deqMany(5);  // get at most 5 messages
+      if (messages) {
+        should.strictEqual(addrArray.length, messages.length);
+        should.strictEqual(addrArray[0].NAME, messages[0].payload.NAME);
+        should.strictEqual(addrArray[0].ADDRESS, messages[0].payload.ADDRESS);
+        should.strictEqual(addrArray[3].NAME, messages[3].payload.NAME);
+        should.strictEqual(addrArray[3].ADDRESS, messages[3].payload.ADDRESS);
+      }
+    } catch (err) {
+      should.not.exist(err);
+    }
+  }); // 218.8
+
+  it('218.9 enqMany() with DB object array as payload', async () => {
+    try {
+      // Enqueue
+      const queue1 = await conn.getQueue(
+        objQueueName,
+        { payloadType: objType }
+      );
+      let msgArray = [];
+      for (let i = 0; i < addrArray.length; i++) {
+        let msg = new queue1.payloadTypeClass(addrArray[i]);
+        msgArray[i] = { payload: msg };
+      }
+      await queue1.enqMany(msgArray);
+
+      // Dequeue
+      const queue2 = await conn.getQueue(
+        objQueueName,
+        { payloadType: objType }
+      );
+      const messages = await queue2.deqMany(5);  // get at most 5 messages
+      if (messages) {
+        should.strictEqual(addrArray.length, messages.length);
+        should.strictEqual(addrArray[0].NAME, messages[0].payload.NAME);
+        should.strictEqual(addrArray[0].ADDRESS, messages[0].payload.ADDRESS);
+        should.strictEqual(addrArray[3].NAME, messages[3].payload.NAME);
+        should.strictEqual(addrArray[3].ADDRESS, messages[3].payload.ADDRESS);
+      }
+    } catch (err) {
+      should.not.exist(err);
+    }
+  }); //218.9
+
+  it('218.10 enqMany() with JavaScript objects as payload', async () => {
+    try {
+      // Enqueue
+      const queue1 = await conn.getQueue(
+        objQueueName,
+        { payloadType: objType }
+      );
+      let msgArray = [];
+      for (let i = 0; i < addrArray.length; i++) {
+        let msg = addrArray[i];
+        msgArray[i] = { payload: msg };
+      }
+      await queue1.enqMany(msgArray);
+
+      // Dequeue
+      const queue2 = await conn.getQueue(
+        objQueueName,
+        { payloadType: objType }
+      );
+      const messages = await queue2.deqMany(5);  // get at most 5 messages
+      if (messages) {
+        should.strictEqual(addrArray.length, messages.length);
+        should.strictEqual(addrArray[0].NAME, messages[0].payload.NAME);
+        should.strictEqual(addrArray[0].ADDRESS, messages[0].payload.ADDRESS);
+        should.strictEqual(addrArray[3].NAME, messages[3].payload.NAME);
+        should.strictEqual(addrArray[3].ADDRESS, messages[3].payload.ADDRESS);
+      }
+    } catch (err) {
+      should.not.exist(err);
+    }
+  }); // 218.10
 });
\ No newline at end of file
diff --git a/test/list.txt b/test/list.txt
index b38c9e8c..9dac2a2a 100755
--- a/test/list.txt
+++ b/test/list.txt
@@ -4590,6 +4590,9 @@ oracledb.OUT_FORMAT_OBJECT and resultSet =  true
     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
+    218.8 enqMany() with DB object array
+    218.9 enqMany() with DB object array as payload
+    218.10 enqMany() with JavaScript objects as payload
 
 219. aq3.js
     219.1 The read-only property "name" of AqQueue Class