This is a node module, that provides:
- linking generic-pool, and felixge-mysql
- sending sequences of queries
- usage of external queries module, that would accept { type, arguments } objects and return ready queries
- execution of single queries, mentioned objects, arrays of them, and arrays of arrays of a.........rrays of them :P
It is currently dependent on:
- generic-pool (https://github.com/coopernurse/node-pool)
- mysql (https://github.com/felixge/node-mysql)
It is planned to become independent of above.
Hope you like it.
// Usage:
/* Options:
Necessary:
- user
- password
Optional
- database - better use it or you will have to use USE sth; as first query of each connection
- queriesModule - module returning function that would return queries given (type, arguments); I strongly suggest to make use of it
- host - default to localhost
- port - default to 3306
- poolSize - default to 10
- cluster - default to false; if true then poolSize will be devided by numCPUs with minimal minSize || 10 value
- numCPUs - default to require('os').cpus().length, but only if cluster is truthy
- minSize - default to ten
- initQueries - false/true, default true; if false, no initQueries will be executed on start
- log
- includeFields - if true every result will be array of[{ rows1, fields1 }, { rows2, fields2 }, ...] objects; otherwise it will be only [ rows1, rows2, rows3, ...]
*/
var qrMan = require("queriesManager")(options)
, database;
qrMan(function(err, db){
if(err){
console.log("You are guilty of:\n" + err);
}else{
database = db;
}
});
// e.g.
database([
[ { type: "getCakes", arguments: [ withCherries, withCockolate ] }
, { type: "getCookies", arguments: [ withMarmolade, small, fresh ] }
]
, "SELECT * FROM users;"
], function(err, resp){
if(err){
console.log("You naughty one, you! Here's your error:\n" + err);
}else{
console.log("Server responded with sth like this:\n" + JSON.stringify(resp));
}
});
/*
database( queries, callback )
queries ::= "string being a ready to send query;"
queries ::= {
type: "query_function_name_from_queries_module"
, arguments: [whatever_works_with_it]
}
arguments ::= whatever your queries module work with
if you want to return another function inside, then you will of course have to route the arguments, but it's possible to for a function to return e.g. { type: "addUser", arguments: [arguments_from_outer_function] }, and all recursive processing will be done
queries ::= [ array of those above, or even arrays of arrays of arrays of ... of arrays ... of those above ]
callback ::= function(err, resp){ ... }
*/
Distributed under MIT licence; see LICENCE for more