0.1.7 • Published 7 years ago
one-data-node v0.1.7
OneDataNode
Multi DB Server client for Node.js
*GitHub: OneDataNode
Quick Example
var frm = require("one-data-node");
var dbConfigMsSql = {
server: 'localhost', // You can use 'localhost\\instance' to connect to named instance,
database: "...",
user: "...",
password: "...",
pool: {
max: 10,
min: 0,
idleTimeoutMillis: 30000
}
};
var dbConnfigMySql = {
host : 'localhost',
user : 'me',
password : 'secret',
database : 'my_db'
};
var multiQManager = new frm.multiQueryManager();
var arrayQuery = [
{
dbConfig: dbConfigMsSql,
dbType: "mssql",
isTransaction: true,
key: "qKey1",
query: "select * from mytable where val = @val",
beforeExec: function (previousResults, dataBase) {
dataBase.addInputValue("val", 10, "INT" );
}
},
{
dbConfig: dbConfigMsSql,
dbType: "mssql",
isTransaction: false,
key:"qKey2",
query: "insert into mytable values(10)",
beforeExec: function (previousResults,dataBase) {
var recordset = previousResults.qKey1.result.recordset;
}
},
{
dbConfig: dbConfigMySql,
dbType: "mysql",
isTransaction: false,
key:"qKey3",
query: "select * from mytable where val = :val",
beforeExec: function (previousResults, dataBase) {
dataBase.addInputValue("val", 12 );
}
}
];
multiQManager.execMulti(arrayQuery, function (err, allResult) {
if (err) {
// ... error checks
} else {
}
});
Examples
Pass a parameter from one query to another
var frm = require("one-data-node");
var dbConfigMsSql = {
server: 'localhost', // You can use 'localhost\\instance' to connect to named instance,
database: "...",
user: "...",
password: "...",
pool: {
max: 10,
min: 0,
idleTimeoutMillis: 30000
}
};
var dbConnfigMySql = {
host : 'localhost',
user : 'me',
password : 'secret',
database : 'my_db'
};
var multiQManager = new frm.multiQueryManager();
var arrayQuery = [
{
dbConfig: dbConfigMsSql,
dbType: "mssql",
isTransaction: true,
key: "qKey1",
query: "select * from mytable",
beforeExec: function (previousResults, dataBase) {
}
},
{
dbConfig: dbConfigMsSql,
dbType: "mssql",
isTransaction: false,
key:"qKey2",
query: "insert into mytable values(@val)",
beforeExec: function (previousResults,dataBase) {
var recordset = previousResults.qKey1.result.recordset;
if(recordset.length > 0)
{
dataBase.addInputValue("val", recordset[0].val, "INT" ); //recordset[index].[columnName]
}
}
},
{
dbConfig: dbConfigMySql,
dbType: "mysql",
isTransaction: false,
key:"qKey3",
query: "select * from mytable where val = :val",
beforeExec: function (previousResults, dataBase) {
dataBase.addInputValue("val", 12 );
}
}
];
multiQManager.execMulti(arrayQuery, function (err, allResult) {
if (err) {
// ... error checks
} else {
}
});
0.1.7
7 years ago
0.1.6
7 years ago
0.1.5
7 years ago
0.1.4
7 years ago
0.1.3
7 years ago
0.1.2
7 years ago
0.1.1
7 years ago
0.1.0
7 years ago
0.0.10
7 years ago
0.0.9
7 years ago
0.0.8
7 years ago
0.0.7
7 years ago
0.0.6
7 years ago
0.0.5
7 years ago
0.0.4
7 years ago
0.0.3
7 years ago
0.0.2
7 years ago
0.0.1
7 years ago
0.0.0
7 years ago