Add tests for soda bulk insert

Author: Christopher Jones

test/list.txt

@@ -4309,6 +4309,13 @@ oracledb.OUT_FORMAT_OBJECT and resultSet =  true
     177.4 insertOneAndGet() with a document
     177.5 createDocument() followd by getContent() i.e. without being inserted
 
+178. soda10.js
+    178.1 insertMany() with newSodaDocumentArray
+    178.2 insertMany() with newSodaDocumentContentArray
+    178.3 insertManyAndGet() with newDocumentArray
+    178.4 insertManyAndGet() with newDocumentContentArray
+    - 174.5 Negative - insertMany() with empty array
+
 179. soda11.js
    179.1 create collection with metadata
    179.2 Negative - create collection with an invalid metadata

test/opts/mocha.opts

@@ -203,6 +203,7 @@ test/soda6.js
 test/soda7.js
 test/soda8.js
 test/soda9.js
+test/soda10.js
 test/soda11.js
 test/externalProxyAuth.js
 

test/soda10.js

@@ -35,45 +35,49 @@ const testsUtil = require('./testsUtil.js');
 
 describe('178. soda10.js', () => {
 
+  let runnable;
   let conn, soda;
 
   before(async function() {
-    try {
-      const runnable = await testsUtil.checkPrerequisites();
-      if (!runnable) {
-        this.skip();
-        return;
-      } else {
-        await sodaUtil.cleanup();
-        conn = await oracledb.getConnection(dbconfig);
-        soda = conn.getSodaDatabase();
-      }
 
-    } catch (err) {
-      should.not.exist(err);
+    const runnable = await testsUtil.checkPrerequisites();
+
+    if (!runnable) {
+      this.skip();
+      return;
+    } else {
+      conn = await oracledb.getConnection(dbconfig);
+      soda = conn.getSodaDatabase();
     }
+
+    await sodaUtil.cleanup();
+
   }); // before()
 
-  after(async() => {
+  after(async function() {
+    if (!runnable) {
+      this.skip();
+      return;
+    }
     try {
-
       await conn.close();
     } catch (err) {
       should.not.exist(err);
     }
   }); // after()
 
-  it('178.1 basic case of sodaCollection.insertMany()', async () => {
+  const inContents = [
+    { id: 1, name: "Paul",  office: "Singapore" },
+    { id: 2, name: "Emma",  office: "London" },
+    { id: 3, name: "Kate",  office: "Edinburgh" },
+    { id: 4, name: "Changjie",  office: "Shenzhen" }
+  ];
+
+  it('178.1 insertMany() with newSodaDocumentArray', async () => {
     try {
       const COLL = "soda_test_178_1";
       const collection = await soda.createCollection(COLL);
 
-      let inContents = [
-        { id: 1, name: "Paul",  office: "Singapore" },
-        { id: 2, name: "Emma",  office: "London" },
-        { id: 3, name: "Kate",  office: "Edinburgh" },
-        { id: 4, name: "Changjie",  office: "Shenzhen" }
-      ];
       let inDocuments = [];
       for (let i = 0; i < inContents.length; i++) {
         inDocuments[i] = soda.createDocument(inContents[i]); // n.b. synchronous method
@@ -99,17 +103,36 @@ describe('178. soda10.js', () => {
     }
   }); // 178.1
 
-  it.skip('178.2 basic case of sodaCollection.insertManyAndGet()', async () => {
+  it('178.2 insertMany() with newSodaDocumentContentArray', async () => {
     try {
       const COLL = "soda_test_178_2";
       const collection = await soda.createCollection(COLL);
 
-      let inContents = [
-        { id: 1, name: "Paul",  office: "Singapore" },
-        { id: 2, name: "Emma",  office: "London" },
-        { id: 3, name: "Kate",  office: "Edinburgh" },
-        { id: 4, name: "Changjie",  office: "Shenzhen" }
-      ];
+      await collection.insertMany(inContents);
+
+      // Fetch back
+      let outDocuments = await collection.find().getDocuments();
+      let outContents = [];
+      for (let i = 0; i < outDocuments.length; i++) {
+        outContents[i] = outDocuments[i].getContent(); // n.b. synchronous method
+      }
+
+      should.deepEqual(outContents, inContents);
+
+      await conn.commit();
+
+      let res = await collection.drop();
+      should.strictEqual(res.dropped, true);
+    } catch (err) {
+      should.not.exist(err);
+    }
+  }); // 178.2
+
+  it('178.3 insertManyAndGet() with newDocumentArray', async () => {
+    try {
+      const COLL = "soda_test_178_3";
+      const collection = await soda.createCollection(COLL);
+
       let inDocuments = [];
       for (let i = 0; i < inContents.length; i++) {
         inDocuments[i] = soda.createDocument(inContents[i]); // n.b. synchronous method
@@ -118,9 +141,68 @@ describe('178. soda10.js', () => {
       let middleDocuments = await collection.insertManyAndGet(inDocuments);
       let middleContents = [];
       for (let i = 0; i < middleDocuments.length; i++) {
-        middleContents[i] = middleDocuments[i].getContent(); // n.b. synchronous method
+        middleContents[i] = middleDocuments[i].getContent();
+        should.exist(middleDocuments[i].key);
       }
-      console.log(middleContents);
+      should.deepEqual(middleContents, [null, null, null, null]);
+
+      // Fetch back
+      let outDocuments = await collection.find().getDocuments();
+      let outContents = [];
+      for (let i = 0; i < outDocuments.length; i++) {
+        outContents[i] = outDocuments[i].getContent(); // n.b. synchronous method
+      }
+
+      should.deepEqual(outContents, inContents);
+
+      await conn.commit();
+
+      let res = await collection.drop();
+      should.strictEqual(res.dropped, true);
+    } catch (err) {
+      should.not.exist(err);
+    }
+  }); // 178.3
+
+  it('178.4 insertManyAndGet() with newDocumentContentArray', async () => {
+    try {
+      const COLL = "soda_test_178_4";
+      const collection = await soda.createCollection(COLL);
+
+      let middleDocuments = await collection.insertManyAndGet(inContents);
+      let middleContents = [];
+      for (let i = 0; i < middleDocuments.length; i++) {
+        middleContents[i] = middleDocuments[i].getContent();
+        should.exist(middleDocuments[i].key);
+      }
+      should.deepEqual(middleContents, [null, null, null, null]);
+
+      // Fetch back
+      let outDocuments = await collection.find().getDocuments();
+      let outContents = [];
+      for (let i = 0; i < outDocuments.length; i++) {
+        outContents[i] = outDocuments[i].getContent(); // n.b. synchronous method
+      }
+
+      should.deepEqual(outContents, inContents);
+
+      await conn.commit();
+
+      let res = await collection.drop();
+      should.strictEqual(res.dropped, true);
+    } catch (err) {
+      should.not.exist(err);
+    }
+  }); // 178.4
+
+  it.skip('174.5 Negative - insertMany() with empty array', async () => {
+    try {
+      const COLL = "soda_test_178_5";
+      const collection = await soda.createCollection(COLL);
+
+      // ORA-40673: arrayLength argument cannot be NULL.
+      let inDocuments = [];
+      await collection.insertMany(inDocuments);
 
       // Fetch back
       let outDocuments = await collection.find().getDocuments();
@@ -130,6 +212,7 @@ describe('178. soda10.js', () => {
       }
 
       console.log(outContents);
+      // should.deepEqual(outContents, inContents);
 
       await conn.commit();
 
@@ -138,5 +221,6 @@ describe('178. soda10.js', () => {
     } catch (err) {
       should.not.exist(err);
     }
-  }); // 178.2
+  }); // 174.5
+
 });