Update tests

Author: cjbj

test/binding_buffer_string.js

@@ -0,0 +1,94 @@
+/* Copyright (c) 2022, Oracle and/or its affiliates. */
+
+/******************************************************************************
+ *
+ * You may not use the identified files except in compliance with the Apache
+ * License, Version 2.0 (the "License.")
+ *
+ * You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0.
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, withOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * NAME
+ *   263.binding_buffer_string.js
+ *
+ * DESCRIPTION
+ *   Test case for bug 33943738
+ *
+ *****************************************************************************/
+'use strict';
+
+var oracledb = require('oracledb');
+var assert   = require('assert');
+const sql      = require('./sqlClone.js');
+var dbConfig = require('./dbconfig.js');
+
+describe('263. binding_buffer_string.js', function() {
+  var connection = null;
+
+  var proc_blob_in_tab = "BEGIN \n" +
+                         "    DECLARE \n" +
+                         "        e_table_missing EXCEPTION; \n" +
+                         "        PRAGMA EXCEPTION_INIT(e_table_missing, -00942); \n" +
+                         "    BEGIN \n" +
+                         "        EXECUTE IMMEDIATE('DROP TABLE blob_tab PURGE'); \n" +
+                         "    EXCEPTION \n" +
+                         "        WHEN e_table_missing \n" +
+                         "        THEN NULL; \n" +
+                         "    END; \n" +
+                         "    EXECUTE IMMEDIATE (' \n" +
+                         "        CREATE TABLE blob_tab ( \n" +
+                         "            id      NUMBER, \n" +
+                         "            blob_1  BLOB \n" +
+                         "        ) \n" +
+                         "    '); \n" +
+                         "END; ";
+  var drop_table = "DROP TABLE blob_tab PURGE";
+  before('get connection and create table', async function() {
+    try {
+      connection = await oracledb.getConnection(dbConfig);
+      assert(connection);
+      await sql.executeSql(connection, proc_blob_in_tab, {}, {});
+    } catch (err) {
+      assert.ifError(err);
+    }
+  });
+
+  after('release connection', async function() {
+    try {
+      await sql.executeSql(connection, drop_table, {}, {});
+      await connection.release();
+    } catch (err) {
+      assert.ifError(err);
+    }
+
+  });
+
+  describe('263.1 BLOB, PLSQL, BIND_IN', function() {
+
+    it('263.1.1 works with buffer', async function() {
+      const data = [
+        {a: 1, b: Buffer.from("Dummy data 1".repeat(5000), "utf-8")},
+        {a: 2, b: Buffer.from("Dummy data 2".repeat(7500), "utf-8")}
+      ];
+      const bindDefs = {
+        a: { type: oracledb.NUMBER },
+        b: { type: oracledb.DB_TYPE_BLOB }
+      };
+      const options = {
+        bindDefs: bindDefs,
+        autoCommit: true
+      };
+
+      const result = await connection.executeMany("insert into blob_tab (id, blob_1) values(:a, :b)", data, options);
+      console.log(result.rowsAffected);
+      await connection.close();
+    });
+  });
+});

test/connHealthy.js

@@ -48,6 +48,28 @@ describe('261. connHealthy.js', function() {
       assert.strictEqual(isHealthy, false);
     });
 
+    it('261.1.3 connection health on closed connection from a pool', async function() {
+      const pool = await oracledb.createPool(
+        {
+          user              : dbconfig.user,
+          password          : dbconfig.password,
+          connectString     : dbconfig.connectString,
+          poolMin           : 1,
+          poolMax           : 5,
+          poolIncrement     : 1,
+          poolTimeout       : 28,
+          stmtCacheSize     : 23
+        });
+      assert.strictEqual(pool.connectionsInUse, 0);
+      const conn = await pool.getConnection();
+      var isHealthy = conn.isHealthy();
+      assert.strictEqual(isHealthy, true);
+      await conn.close();
+      isHealthy = conn.isHealthy();
+      assert.strictEqual(isHealthy, false);
+    });
+
+
   });
 
 });