363 lines
12 KiB
JavaScript
363 lines
12 KiB
JavaScript
/* Copyright (c) 2015, 2023, Oracle and/or its affiliates. */
|
|
|
|
/******************************************************************************
|
|
*
|
|
* This software is dual-licensed to you under the Universal Permissive License
|
|
* (UPL) 1.0 as shown at https://oss.oracle.com/licenses/upl and Apache License
|
|
* 2.0 as shown at https://www.apache.org/licenses/LICENSE-2.0. You may choose
|
|
* either license.
|
|
*
|
|
* If you elect to accept the software under the Apache License, Version 2.0,
|
|
* the following applies:
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* https://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
|
|
* 40. dataTypeClob.js
|
|
*
|
|
* DESCRIPTION
|
|
* Testing Oracle data type support - CLOB.
|
|
* This test corresponds to example files:
|
|
* clobinsert1.js, clobstream1.js and clobstream2.js
|
|
* Firstly, reads text from clobexample.txt and INSERTs it into a CLOB column.
|
|
* Secondly, SELECTs a CLOB and pipes it to a file, clobstreamout.txt
|
|
* Thirdly, SELECTs the CLOB and compares it with the content in clobexample.txt.
|
|
* Fourthly, query the CLOB with Object outFormat.
|
|
*
|
|
*****************************************************************************/
|
|
'use strict';
|
|
|
|
const oracledb = require('oracledb');
|
|
const fs = require('fs');
|
|
const assert = require('assert');
|
|
const dbConfig = require('./dbconfig.js');
|
|
const assist = require('./dataTypeAssist.js');
|
|
const testsUtil = require('./testsUtil.js');
|
|
const random = require('./random.js');
|
|
|
|
const inFileName = 'test/clobexample.txt'; // the file with text to be inserted into the database
|
|
const outFileName = 'test/clobstreamout.txt'; // output file with the stream out data
|
|
|
|
describe('40. dataTypeClob.js', function() {
|
|
|
|
let connection = null;
|
|
const tableName = "nodb_myclobs";
|
|
|
|
before('get one connection', async function() {
|
|
connection = await oracledb.getConnection(dbConfig);
|
|
});
|
|
|
|
after('release connection', async function() {
|
|
await connection.close();
|
|
});
|
|
|
|
describe('40.1 testing CLOB data type', function() {
|
|
before('create table', async function() {
|
|
await connection.execute(assist.sqlCreateTable(tableName));
|
|
});
|
|
|
|
after(async function() {
|
|
await connection.execute("DROP table " + tableName + " PURGE");
|
|
});
|
|
|
|
it('40.1.1 stores CLOB value correctly', async function() {
|
|
let result = await connection.execute(
|
|
'INSERT INTO nodb_myclobs (num, content) ' +
|
|
'VALUES (:n, EMPTY_CLOB()) RETURNING content INTO :lobbv',
|
|
{ n: 1, lobbv: {type: oracledb.CLOB, dir: oracledb.BIND_OUT} },
|
|
{ autoCommit: false }); // a transaction needs to span the INSERT and pipe()
|
|
|
|
assert.strictEqual(result.rowsAffected, 1);
|
|
assert.strictEqual(result.outBinds.lobbv.length, 1);
|
|
|
|
const inStream = await fs.createReadStream(inFileName);
|
|
let lob = result.outBinds.lobbv[0];
|
|
|
|
await new Promise((resolve, reject) => {
|
|
inStream.on('error', reject);
|
|
lob.on('error', reject);
|
|
lob.on('finish', resolve);
|
|
inStream.pipe(lob);
|
|
});
|
|
await connection.commit();
|
|
|
|
result = await connection.execute(
|
|
"SELECT content FROM nodb_myclobs WHERE num = :n",
|
|
{ n: 1 });
|
|
|
|
lob = result.rows[0][0];
|
|
lob.setEncoding('utf8');
|
|
await new Promise((resolve, reject) => {
|
|
lob.on("error", reject);
|
|
const outStream = fs.createWriteStream(outFileName);
|
|
outStream.on('error', reject);
|
|
outStream.on('finish', resolve);
|
|
lob.pipe(outStream);
|
|
});
|
|
const originalData = fs.readFileSync(inFileName, { encoding: 'utf8' });
|
|
const generatedData = fs.readFileSync(outFileName, { encoding: 'utf8' });
|
|
assert.strictEqual(originalData, generatedData);
|
|
|
|
result = await connection.execute(
|
|
"SELECT content FROM nodb_myclobs WHERE num = :n",
|
|
{ n: 1 });
|
|
|
|
lob = result.rows[0][0];
|
|
let clob = await lob.getData();
|
|
const data = fs.readFileSync(inFileName, { encoding: 'utf8' });
|
|
assert.strictEqual(data, clob);
|
|
|
|
result = await connection.execute(
|
|
"SELECT content FROM nodb_myclobs WHERE num = :n",
|
|
{ n: 1 },
|
|
{ outFormat: oracledb.OUT_FORMAT_OBJECT });
|
|
|
|
const row = result.rows[0];
|
|
lob = row['CONTENT'];
|
|
clob = await lob.getData();
|
|
assert.strictEqual(data, clob);
|
|
fs.unlinkSync(outFileName);
|
|
|
|
}); // 40.1.1
|
|
|
|
|
|
it('40.1.2 CLOB getData()', async function() {
|
|
|
|
let result = await connection.execute(
|
|
`INSERT INTO nodb_myclobs (num, content) ` +
|
|
`VALUES (:n, EMPTY_CLOB()) RETURNING content INTO :lobbv`,
|
|
{ n: 2, lobbv: {type: oracledb.CLOB, dir: oracledb.BIND_OUT} },
|
|
{ autoCommit: false }); // a transaction needs to span the INSERT and pipe()
|
|
|
|
assert.strictEqual(result.rowsAffected, 1);
|
|
assert.strictEqual(result.outBinds.lobbv.length, 1);
|
|
|
|
const inStream = await fs.createReadStream(inFileName);
|
|
let lob = result.outBinds.lobbv[0];
|
|
|
|
await new Promise((resolve, reject) => {
|
|
inStream.on('error', reject);
|
|
lob.on('error', reject);
|
|
lob.on('finish', resolve);
|
|
inStream.pipe(lob);
|
|
});
|
|
await connection.commit();
|
|
|
|
result = await connection.execute(
|
|
"SELECT content FROM nodb_myclobs WHERE num = :n",
|
|
{ n: 2 });
|
|
|
|
lob = result.rows[0][0];
|
|
|
|
const data = fs.readFileSync(inFileName, { encoding: 'utf8' });
|
|
const clob = await lob.getData();
|
|
assert.strictEqual(data, clob);
|
|
|
|
}); // 40.1.2
|
|
|
|
it('40.1.3 CLOB getData(offset, len)', async function() {
|
|
const lenStr = 32768;
|
|
const specialStr = "40.1.3";
|
|
const largeStr = random.getRandomString(lenStr, specialStr);
|
|
const multiByteStr = 'aüÅæÖÆåøübcd';
|
|
|
|
const binds = [
|
|
[3, largeStr],
|
|
[4, multiByteStr]
|
|
];
|
|
let result = await connection.executeMany(
|
|
`INSERT INTO nodb_myclobs (num, content) ` +
|
|
`VALUES (:1, :2)`,
|
|
binds,
|
|
[
|
|
{ type: oracledb.NUMBER },
|
|
{ type: oracledb.CLOB }
|
|
]);
|
|
assert.strictEqual(result.rowsAffected, 2);
|
|
|
|
result = await connection.execute(
|
|
"SELECT content FROM nodb_myclobs WHERE num = :n",
|
|
{ n: 3 });
|
|
|
|
let lob = result.rows[0][0];
|
|
let clob = await lob.getData();
|
|
assert.strictEqual(largeStr, clob);
|
|
|
|
let offset = 5;
|
|
let len = 10;
|
|
// starting from position 4 (largeStr[4]) to 10 characters.
|
|
clob = await lob.getData(offset, len);
|
|
assert.strictEqual(largeStr.slice(offset - 1, offset + len - 1), clob);
|
|
|
|
// len not specified gives entire data starting from offset
|
|
offset = 5;
|
|
clob = await lob.getData(offset);
|
|
assert.strictEqual(largeStr.slice(offset - 1), clob);
|
|
|
|
// len specified as 0 gives error.
|
|
offset = 5;
|
|
len = 0;
|
|
await assert.rejects(
|
|
async () => await lob.getData(offset, len),
|
|
/NJS-005:/
|
|
);
|
|
|
|
// large number of characters starting from offset 5.
|
|
offset = 5;
|
|
len = 9999;
|
|
clob = await lob.getData(offset, len);
|
|
assert.strictEqual(largeStr.slice(offset - 1, offset + len - 1), clob);
|
|
|
|
// len exceeding lob length is simply ignored and
|
|
// characters till end starting from offset is returned.
|
|
offset = 5;
|
|
len = 99999;
|
|
clob = await lob.getData(offset, len);
|
|
assert.strictEqual(largeStr.slice(offset - 1), clob);
|
|
|
|
// Invalid ofset, we get null.
|
|
offset = 99999;
|
|
len = 10;
|
|
clob = await lob.getData(offset, len);
|
|
assert.equal(clob, null);
|
|
|
|
result = await connection.execute(
|
|
"SELECT content FROM nodb_myclobs WHERE num = :n",
|
|
{ n: 4 });
|
|
|
|
lob = result.rows[0][0];
|
|
|
|
clob = await lob.getData();
|
|
assert.strictEqual(multiByteStr, clob);
|
|
|
|
offset = 2;
|
|
len = 10;
|
|
// starting from position 1 (multiByteStr[1]) to 10 characters. "üÅæÖÆåøübc"
|
|
clob = await lob.getData(offset, len);
|
|
assert.strictEqual(multiByteStr.slice(offset - 1, offset + len - 1), clob);
|
|
|
|
}); // 40.1.3
|
|
|
|
}); // 40.1
|
|
|
|
describe('40.2 stores null value correctly', function() {
|
|
it('40.2.1 testing Null, Empty string and Undefined', async function() {
|
|
await assist.verifyNullValues(connection, tableName);
|
|
});
|
|
});
|
|
|
|
describe('40.3 Read CLOB data on meta data change', function() {
|
|
let connection = null;
|
|
const tableNameCLOB = 'nodb_myclobs_re_create';
|
|
const sqlCreateQuery = `
|
|
CREATE TABLE ${tableNameCLOB} (
|
|
num NUMBER,
|
|
value varchar2(255),
|
|
content CLOB
|
|
)`;
|
|
const sqlDrop = testsUtil.sqlDropTable(tableNameCLOB);
|
|
const sqlCreate = testsUtil.sqlCreateTable(tableNameCLOB, sqlCreateQuery);
|
|
const insertSql = `INSERT INTO ${tableNameCLOB} (num, value, content) ` +
|
|
`VALUES (:n, :val, 'CLOB')`;
|
|
const selectSqlCharBind = `SELECT * FROM ${tableNameCLOB} WHERE value = :val`;
|
|
const binds = [
|
|
{ n: 1, val: 'GEN_COL' },
|
|
{ n: 2, val: 'GEN_COL_NEW' }
|
|
];
|
|
|
|
async function setupConnAndTable() {
|
|
connection = await oracledb.getConnection(dbConfig);
|
|
await connection.execute(sqlCreate);
|
|
await connection.executeMany(insertSql, binds);
|
|
}
|
|
|
|
async function doFirstSelect() {
|
|
await connection.execute(selectSqlCharBind, {val: 'GEN_COL'}, { keepInStmtCache: true });
|
|
await connection.execute(sqlDrop);
|
|
await connection.execute(sqlCreate);
|
|
await connection.executeMany(insertSql, binds);
|
|
}
|
|
|
|
afterEach(async function() {
|
|
if (connection) {
|
|
await connection.execute(sqlDrop);
|
|
await connection.close();
|
|
connection = null;
|
|
}
|
|
});
|
|
|
|
after(async function() {
|
|
oracledb.fetchAsString = [];
|
|
if (connection) {
|
|
await connection.execute(sqlDrop);
|
|
await connection.close();
|
|
}
|
|
});
|
|
|
|
it('40.3.1 Recreate table after CLOB column as CLOB is read and statement is in statement cache',
|
|
async function() {
|
|
oracledb.fetchAsString = [];
|
|
await setupConnAndTable();
|
|
await doFirstSelect();
|
|
await connection.execute(selectSqlCharBind, {val: 'GEN_COL'});
|
|
});
|
|
|
|
it('40.3.2 Recreate table after CLOB column as String is read and statement is in statement cache',
|
|
async function() {
|
|
oracledb.fetchAsString = [oracledb.CLOB];
|
|
await setupConnAndTable();
|
|
await doFirstSelect();
|
|
await connection.execute(selectSqlCharBind, {val: 'GEN_COL'});
|
|
});
|
|
|
|
it('40.3.3 select with large bindvalue than previous select bindvalue after Recreate table ',
|
|
async function() {
|
|
oracledb.fetchAsString = [oracledb.CLOB];
|
|
await setupConnAndTable();
|
|
await doFirstSelect();
|
|
// provide bind value 'GEN_COL_NEW' larger than earlier bind value 'GEN_COL'.
|
|
await connection.execute(selectSqlCharBind, {val: 'GEN_COL_NEW'});
|
|
});
|
|
|
|
it('40.3.4 select using fetchAsCLOB with large bindvalue than previous select bindvalue after Recreate table ',
|
|
async function() {
|
|
oracledb.fetchAsString = [];
|
|
await setupConnAndTable();
|
|
await doFirstSelect();
|
|
// provide bind value 'GEN_COL_NEW' larger than earlier bind value 'GEN_COL'.
|
|
await connection.execute(selectSqlCharBind, {val: 'GEN_COL_NEW'});
|
|
});
|
|
|
|
it('40.3.5 select using fetchAsCLOB with large bindvalue than previous select bindvalue after Recreate table twice',
|
|
async function() {
|
|
oracledb.fetchAsString = [oracledb.CLOB];
|
|
await setupConnAndTable();
|
|
await doFirstSelect();
|
|
// provide bind value 'GEN_COL_NEW' larger than earlier bind value 'GEN_COL'.
|
|
await connection.execute(selectSqlCharBind, {val: 'GEN_COL_NEW'});
|
|
|
|
// cleanup the connection
|
|
await connection.execute(sqlDrop);
|
|
await connection.close();
|
|
connection = null;
|
|
|
|
await setupConnAndTable();
|
|
await doFirstSelect();
|
|
// provide bind value 'GEN_COL_NEW' larger than earlier bind value 'GEN_COL'.
|
|
await connection.execute(selectSqlCharBind, {val: 'GEN_COL_NEW'});
|
|
});
|
|
|
|
});
|
|
|
|
});
|