architect-oracle-pool
v2.0.0
Published
architect oracle database connection pool
Downloads
1
Readme
architect-oracle-pool
Expose a Oracle connection pool as architect plugin. Automaticaly returns connection to the pool after query.
Installation
npm install --save architect-oracle-pool
Config Format
module.exports = [{
packagePath: "architect-oracle-pool",
url: {
user: 'scott',
password: 'tiger',
connectString: 'backend.local/X3PV7',
poolMax: 10
}
}];
url
: Defines the oracle url to use for connection
Usage
Boot Architect :
var path = require('path');
var architect = require("architect");
var configPath = path.join(__dirname, "config.js");
var config = architect.loadConfig(configPath);
architect.createApp(config, function (err, app) {
if (err) {
throw err;
}
console.log("app ready");
});
Configure Architect with config.js
:
module.exports = [{
packagePath: "architect-oracle-pool",
url: {
user: 'scott',
password: 'tiger',
connectString: 'backend.local/PV7',
poolMax: 10
}
}, './routes'];
Consume oradb plugin in your ./routes/package.json
:
{
"name": "routes",
"version": "0.0.1",
"main": "index.js",
"private": true,
"plugin": {
"consumes": ["oradb"]
}
}
Eventually use Oracle connection in your routes ./routes/index.js
:
module.exports = function setup(options, imports, register) {
var rest = imports.rest;
var db = imports.oradb;
// register routes
rest.get('/hello/:name', function (req, res, next) {
db.query('SELECT * FROM Users WHERE id=$1', [req.params.name], function(err, res){
res.write("{'message':'hello," + res.rows[0].name + "'}");
res.end();
});
});
register();
};
Multiple pool configuration
This module supports multiple pools.
Here is how to define 2 different pools :
module.exports = [{
packagePath: "architect-oracle-pool",
first : {
url: {
user: 'scott',
password: 'tiger',
connectString: 'backend1.local/PV7',
poolMax: 10
}
},
second : {
url: {
user: 'scott',
password: 'tiger',
connectString: 'backend2.local/PV7',
poolMax: 10
}
}
}];
This will create 2 properties (first
and second
) in the db
object.
module.exports = function setup(options, imports, register) {
var db = imports.oradb;
db.first.connection(function (err, client) {
client.query(/*...*/);
});
register();
};
Configuration
url
either a connection url or an object :host
: serveur hostname or ipport
: serveur portuser
: username to login,password
: password to login,database
: database name,application_name
: a name to identify client,validationQuery
: a query to run to validate a connection
See Oracle createPool
API
The pool object (oradb
) has the following methods :
connection
Retreive a connection from the pool. The method takes a callback as parameter. Once the connection is avaliable the callback is called with an :
err
object if an error occured or null;client
the Oracle connection object;done
, the close method.
query
The query
method let you directly query the database without worrying about the database connection. Behind the scene the method retreive a connection from the pool and close it afterward.
- string text: the query text;
- optional array parameters: the query parameters;
- optional function callback : the function called when data is ready.
Once the data is ready the callback is fired with an :
err
object if an error occured or null;rows
the result set.
module.exports = function setup(options, imports, register) {
var db = imports.oradb;
db.query('SELECT * from USERS', function (err, res) {
res.rows.forEach(console.log);
});
//...
};
queryStream
The queryStream
method let you directly query the database without worrying about the database connection. This method passes a stream to the callback instead of a resultset.
- string text: the query text;
- optional array parameters: the query parameters;
- optional function callback : the function called when stream is ready.
- returns: ReadableStream
Once the stream is ready the callback is fired with an :
err
object if an error occured or null;stream
the result stream.
var JSONSteam = require('JSONStream');
module.exports = function setup(options, imports, register) {
var db = imports.oradb;
db.queryStream('SELECT * from USERS')
.pipe(JSONSteam.stringify())
.pipe(process.stdout);
//...
};