我使用MySQL
和strongloop
,我有一个存储过程来交换数据
swap_XYZ('<old_abc>', '<new_new>')
我不能找到文档中的任何实例调用存储过程。如何调用此存储过程?提前致谢。
module.exports = function (ABCModel) {
var ds = app.dataSources.dsMySQL;
ABCModel.swap = function (old_abc, new_abc, cb) {
var sql = "CALL `swap_XYZ`('" + old_abc + "','" + new_abc + "');";
ds.connector.query(sql, function (err, data) {
if (err) {
console.log("Error:", err);
}
cb(null, data);
console.log("data:", data);
});
}
ABCModel.remoteMethod(
'swap',
{
accepts: [
{arg: 'old_abc', type: 'string'},
{arg: 'new_abc', type: 'string'}
],
returns: {arg: 'result', type: 'object'},
http: {path: '/swap', verb: 'post'}
}
);
};
请参阅此链接。 dataSource.connector.execute(SQL,则params,CB);或dataSource.connector.query(SQL,则params,CB);
https://docs.strongloop.com/display/public/LB/Database+connectors https://docs.strongloop.com/display/public/LB/Executing+native+SQL
module.exports = function(DemoModel) {
var server = require('../../server/server');
var ds = server.dataSources.MySQL;
DemoModel.list = function(optionalparam, cb) {
var sql = 'select * from DemoModel';
ds.connector.execute(sql, function(err, data)
{
if(err) return err;
console.log(err);
console.log("data",data);
cb(null, data);
});
}
DemoModel.remoteMethod(
'list',
{
accepts: {arg: 'param', type: 'string'},
returns: {arg: 'result', type: 'object'},
http: {path: '/list', verb: 'get'}
}
);
};
我终于调用的存储过程顺利..
首先,我们需要定义app
像里亚兹为kather var app = require('../../server/server');
但两者app.dataSources.MySQL
和app.dataSources.dsMySQL
不是为我工作。我的环回的版本是[email protected]
和我正确的属性名称是app.dataSources.mysql;
然后确保你的数据库的用户帐户具有用于调用存储过程的权限:
在功能/过程授予权限:当使用函数和过程,GRANT语句可以用来授予用户执行在MySQL的函数和过程的能力。授予执行权限:执行权限给执行函数或过程的能力。
句法:
GRANT EXECUTE ON [PROCEDURE | FUNCTION]对象TO用户;
https://www.geeksforgeeks.org/mysql-grant-revoke-privileges/:从报价
如何使用Node.js调用PL / SQL存储过程
假设过程名称是getCountryName,并把它的一个输入值和一个输出变量。
var executeProcedure = function () {
var procedureName = "CALL GETCOUNTRYNAME(:inputVal,:outVal)";
var oracledb = require('oracledb');
oracledb.maxRows = 1;
// oracledb.fetchAsString = [oracledb.CLOB];
oracledb.getConnection(
{
user: 'user',
password: 'password',
connectString: "connectString"
},
function (err, connection) {
if (err) {
console.error(err);
return;
}
connection.execute(
procedureName,
{
outVal: {
type: oracledb.STRING,
dir: oracledb.BIND_OUT
},
inputVal: {
type: oracledb.STRING,
dir: oracledb.BIND_IN,
val: 'IN'
}
},
function (err, result) {
if (err) {
console.error(err);
return;
}
console(result)
});
});
};
更多细节
https://github.com/oracle/node-oracledb/blob/master/doc/api.md#queryinglobs https://dzone.com/articles/plsql-record-types-and-the-nodejs-driver
https://github.com/oracle/node-oracledb/blob/master/examples/example.js