Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var oracledb = require('oracledb');
- var dbConfig = require('./dbconfig.js');
- var rowcount = 0;
- oracledb.getConnection(
- {
- user : dbConfig.user,
- password : dbConfig.password,
- connectString : dbConfig.connectString
- },
- function(err, connection) {
- if (err) {
- console.error(err.message);
- return;
- }
- var stream = connection.queryStream(
- 'SELECT first_name, last_name FROM employees ORDER BY employee_id',
- [], // no binds
- { fetchArraySize: 150 } // internal buffer size for performance tuning
- );
- stream.on('error', function (error) {
- // console.log("stream 'error' event");
- console.error(error);
- return;
- });
- stream.on('metadata', function (metadata) {
- // console.log("stream 'metadata' event");
- console.log(metadata);
- });
- stream.on('data', function (data) {
- // console.log("stream 'data' event");
- console.log(data);
- rowcount++;
- });
- stream.on('end', function () {
- // console.log("stream 'end' event");
- console.log('Rows selected: ' + rowcount);
- connection.close(
- function(err) {
- if (err) {
- console.error(err.message);
- }
- });
- });
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement