Enable CQN tests

Author: Christopher Jones

test/runCQN.js

@@ -21,7 +21,7 @@
  * DESCRIPTION
  *   Test Continuous Query Notification (CQN).
  *
- *   To keep it simple, this test only run on Linux. Because the database
+ *   To keep it simple, this test will not run on my macOS. Because the database
  *   must be able to connect to the node-oracledb machine for notifications
  *   to be received. Typically this means that the machine running node-oracledb
  *   needs a fixed IP address.
@@ -41,10 +41,9 @@ describe('185. runCQN.js', function() {
 
   let isRunnable = true;
   let conn, connAsDBA;
-  const TABLE = 'nodb_tab_cqn_1';
 
   before(async function() {
-    if ( (!dbconfig.test.DBA_PRIVILEGE) || (process.platform !== 'linux') ) {
+    if ( (!dbconfig.test.DBA_PRIVILEGE) || (process.platform == 'darwin') ) {
       isRunnable = false;
     }
 
@@ -71,13 +70,6 @@ describe('185. runCQN.js', function() {
           events: true
         });
 
-        sql =
-          `CREATE TABLE ${TABLE} (
-            k NUMBER
-          )`;
-        let plsql = testsUtil.sqlCreateTable(TABLE, sql);
-        await conn.execute(plsql);
-
       } catch (err) {
         should.not.exist(err);
       }
@@ -90,10 +82,8 @@ describe('185. runCQN.js', function() {
       return;
     } else {
       try {
-        let sql = `DROP TABLE ${TABLE} PURGE`;
-        await conn.execute(sql);
 
-        sql = `REVOKE CHANGE NOTIFICATION FROM ${dbconfig.user}`;
+        let sql = `REVOKE CHANGE NOTIFICATION FROM ${dbconfig.user}`;
         await connAsDBA.execute(sql);
 
         await conn.close();
@@ -107,6 +97,13 @@ describe('185. runCQN.js', function() {
   it('185.1 examples/cqn1.js', async () => {
 
     try {
+      const TABLE = 'nodb_tab_cqn_1';
+      let sql =
+          `CREATE TABLE ${TABLE} (
+            k NUMBER
+          )`;
+      let plsql = testsUtil.sqlCreateTable(TABLE, sql);
+      await conn.execute(plsql);
 
       const myCallback = async function(message) {
         // console.log(message);
@@ -128,19 +125,34 @@ describe('185. runCQN.js', function() {
 
       await conn.subscribe('mysub', options);
 
-      let sql = `INSERT INTO ${TABLE} VALUES (101)`;
+      sql = `INSERT INTO ${TABLE} VALUES (101)`;
       await conn.execute(sql);
+
+      plsql = `BEGIN DBMS_SESSION.SLEEP(2); END;`;
+      await conn.execute(plsql);
       await conn.commit();
 
       await conn.unsubscribe('mysub');
+
+      sql = `DROP TABLE ${TABLE} PURGE`;
+      await conn.execute(sql);
     } catch (err) {
       should.not.exist(err);
     }
 
   }); // 185.1
 
-  it.skip('185.2 SQL Delete operation', async () => {
+  it('185.2 SQL Delete operation', async () => {
     try {
+
+      const TABLE = 'nodb_tab_cqn_2';
+      let sql =
+          `CREATE TABLE ${TABLE} (
+            k NUMBER
+          )`;
+      let plsql = testsUtil.sqlCreateTable(TABLE, sql);
+      await conn.execute(plsql);
+
       const myCallback = async function(message) {
         console.log(message);
         should.strictEqual(message.type, oracledb.SUBSCR_EVENT_TYPE_QUERY_CHANGE);
@@ -159,26 +171,42 @@ describe('185. runCQN.js', function() {
       };
       await conn.subscribe('sub2', options);
 
-      let sql = `DELETE FROM ${TABLE} WHERE k > :bv`;
+      sql = `DELETE FROM ${TABLE} WHERE k > :bv`;
       await conn.execute(sql, { bv : 100 });
+
+      plsql = `BEGIN DBMS_SESSION.SLEEP(2); END;`;
+      await conn.execute(plsql);
       await conn.commit();
 
       await conn.unsubscribe('sub2');
+
+      sql = `DROP TABLE ${TABLE} PURGE`;
+      await conn.execute(sql);
     } catch (err) {
       should.not.exist(err);
     }
   }); // 185.2
 
-  it.skip('185.3 Specify the notification only for INSERT operation', async() => {
+  it('185.3 Specify the notification only for INSERT operation', async() => {
     try {
+
+      const TABLE = 'nodb_tab_cqn_3';
+      let sql =
+          `CREATE TABLE ${TABLE} (
+            k NUMBER
+          )`;
+      let plsql = testsUtil.sqlCreateTable(TABLE, sql);
+      await conn.execute(plsql);
+
       const myCallback = async function(message) {
         // console.log(message);
         should.strictEqual(message.type, oracledb.SUBSCR_EVENT_TYPE_QUERY_CHANGE);
         should.strictEqual(message.registered, true);
         const table = message.queries[0].tables[0];
         const tableName = dbconfig.user.toUpperCase() + '.' + TABLE.toUpperCase();
         should.strictEqual(table.name, tableName);
-        should.strictEqual(table.operation, oracledb.CQN_OPCODE_INSERT);
+        let expect = oracledb.CQN_OPCODE_INSERT | oracledb.CQN_OPCODE_ALL_ROWS;
+        should.strictEqual(table.operation, expect);
       };
 
       const options = {
@@ -191,21 +219,36 @@ describe('185. runCQN.js', function() {
 
       await conn.subscribe('sub3', options);
 
-      let sql = `DELETE FROM ${TABLE} WHERE k > :bv`;
+      sql = `DELETE FROM ${TABLE} WHERE k > :bv`;
       await conn.execute(sql, { bv : 100 });
 
       sql = `INSERT INTO ${TABLE} VALUES (103)`;
       await conn.execute(sql);
+
+      plsql = `BEGIN DBMS_SESSION.SLEEP(2); END;`;
+      await conn.execute(plsql);
       await conn.commit();
 
       await conn.unsubscribe('sub3');
+
+      sql = `DROP TABLE ${TABLE} PURGE`;
+      await conn.execute(sql);
     } catch (err) {
       should.not.exist(err);
     }
   }); // 185.3
 
   it.skip('185.4 Negative - provide invalid SQL in CQN option', async() => {
     try {
+
+      const TABLE = 'nodb_tab_cqn_4';
+      let sql =
+          `CREATE TABLE ${TABLE} (
+            k NUMBER
+          )`;
+      let plsql = testsUtil.sqlCreateTable(TABLE, sql);
+      await conn.execute(plsql);
+
       const myCallback = async function(message) {
         console.log(message);
       };
@@ -220,11 +263,17 @@ describe('185. runCQN.js', function() {
 
       await conn.subscribe('sub4', options);
 
-      let sql = `INSERT INTO ${TABLE} VALUES (103)`;
+      sql = `INSERT INTO ${TABLE} VALUES (103)`;
       await conn.execute(sql);
+
+      plsql = `BEGIN DBMS_SESSION.SLEEP(2); END;`;
+      await conn.execute(plsql);
       await conn.commit();
 
       await conn.unsubscribe('sub4');
+
+      sql = `DROP TABLE ${TABLE} PURGE`;
+      await conn.execute(sql);
     } catch (err) {
       should.not.exist(err);
     }
@@ -233,6 +282,14 @@ describe('185. runCQN.js', function() {
   it('185.5 examples/cqn2.js', async () => {
     try {
 
+      const TABLE = 'nodb_tab_cqn_5';
+      let sql =
+          `CREATE TABLE ${TABLE} (
+            k NUMBER
+          )`;
+      let plsql = testsUtil.sqlCreateTable(TABLE, sql);
+      await conn.execute(plsql);
+
       const myCallback = async function(message) {
         // console.log(message);
         should.strictEqual(message.type, oracledb.SUBSCR_EVENT_TYPE_OBJ_CHANGE);
@@ -253,15 +310,20 @@ describe('185. runCQN.js', function() {
 
       await conn.subscribe('sub5', options);
 
-      let sql = `INSERT INTO ${TABLE} VALUES (:1)`;
+      sql = `INSERT INTO ${TABLE} VALUES (:1)`;
       let bindArr = [ [1], [2], [3], [4], [5], [6], [7] ];
       for (let i = 0; i < bindArr.length; i++) {
         await conn.execute(sql, bindArr[i], { autoCommit: true });
-        await testsUtil.sleep();
       }
+
+      plsql = `BEGIN DBMS_SESSION.SLEEP(2); END;`;
+      await conn.execute(plsql);
       await conn.commit();
 
       await conn.unsubscribe('sub5');
+
+      sql = `DROP TABLE ${TABLE} PURGE`;
+      await conn.execute(sql);
     } catch (err) {
       should.not.exist(err);
     }