Oracle query string example

oracle-query-string.js

var oracle = require('strong-oracle')();

// Or use the other Oracle driver
// var oracle = require('oracle');

var OracleQueryStream = require('oracle-query-stream');
var JSONStream = require('JSONStream');

var db = require('./db');

function pipeQueryToResponse(res, query, queryargs) {
  var queryargs = queryargs || [];
  oracle.connect(db, function(err, connection) {
    if (err) {
      res.status(500).send("" + err);
      console.error(err);
      return;
    }

    var reader = connection.reader(query, queryargs);

    connection.setPrefetchRowCount(100);

    var stream = new OracleQueryStream(reader);

    stream.pipe(JSONStream.stringify('[',
      ',\n\n',
      ']')).pipe(res);

    stream.on('end', function() {
      console.log('closing connection');
      connection.close();
    })
  });
}

var app = require('express')();

app.get('/', function(req, res) {
  res.setHeader("Content-Type", "application/json");

  var query =
    "SELECT * FROM (SELECT * FROM USERS ORDER BY NAME ) WHERE ROWNUM <= 2000";
  pipeQueryToResponse(res, query);
});


app.listen(3000);