我在 MySQL 中创建了一个存储过程，它需要一些输入并返回一些输出。 在我正在运行的 MySQL 中调用存储过程

CALL createCoupon(1236,321, @message);
SELECT @message AS message

并在消息对象中获取输出。

现在出现了我需要在 sequelize 中调用此 SP 的情况。我正在从事 sailsjs 项目并使用 sequelize 模块进行查询。

我在 config/db_config 中创建了数据库连接，我的连接字符串是:

var sequelize = new Sequelize(db.name, db.user, db.pass, {
    host: db.host,
    dialect: "mysql", // or 'sqlite', 'postgres', 'mariadb'
    port:    3306, // or 5432 (for postgres)
    maxConcurrentQueries: 100,
    pool: {
    maxConnections: 50,
    maxIdleTime: 2000
    },
    queue: true
})

我在 Controller 中这样调用它:

var Sequelize = require('sequelize');
var sequelize = require('../../config/db_config').dbase;

function setCoupon(couponCode, userId, setCouponResponse) {
    var createCouponSQL = "some raw query";


    sequelize.query(createCouponSQL, null, {
        raw: true
    }).success(function(createCoupon) {
            sails.log.info(createCoupon);
            setCouponResponse(null, createCoupon);
    }).error(function(err) {
        sails.log.error(err);
            setCouponResponse(err, null);
    });
}


module.exports = {
    'createCoupon': function(req, callback) {
        setCoupon(req.param('coupon_code'), req.session.userSession, function(err, setCouponResponse){

        })

    }
}

现在我需要在 sequelize 中调用 SP 所以我只是尝试:

 var createCouponSQL = "CALL createCoupon(1236,321, @message);";
          createCouponSQL += "SELECT @message AS message";

    sequelize.query(createCouponSQL, null, {
        raw: true
    }).success(function(createCoupon) {
            sails.log.info(createCoupon);
            setCouponResponse(null, createCoupon);
    }).error(function(err) {
        sails.log.error(err);
            setCouponResponse(err, null);
    });

但是sequlize触发了错误:

Executing (default): CALL createCoupon(1236,321, @message);SELECT @message AS m
essage
error: Error: ER_PARSE_ERROR: You have an error in your SQL syntax; check the m
anual that corresponds to your MySQL server version for the right syntax to use
 near 'SELECT @message AS message' at line 1
    at Query.Sequence._packetToError (C:\Users\asd\Desktop\CardCash P2\Website\
node_modules\mysql\lib\protocol\sequences\Sequence.js:30:14)

我已经进行了一些研发，但无法找到任何适合调用存储过程的方法，该存储过程在@message 中将响应发回给我，我需要执行另一个选择语句来获取结果。

请指导我如何使用连接数据库的方式正确执行此操作。

谢谢。

最佳答案

虽然很晚了，但是我们正在做一个项目中类似的事情。 整个旅程看起来像，

我们已经在单独的 SQL 文件中创建了所有 SP，并且有一个部署步骤，将所有 SP 插入数据库，从特定位置获取它们。

所有 SP 基本上都是通过在 SP 末尾运行 SELECT 语句来返回的。并且在 SP 之外没有单独的选择。

基本结构如下

DELIMITER $$
DROP PROCEDURE IF EXISTS sp_copy_cleansheet;
$$
CREATE PROCEDURE `take_over_the_world` (#Some Input Args)

BEGIN
  DECLARE method_to_be_used  VARCHAR(1000);
  # Define how to take over the world, 
  # SET method_to_be_used = "Approach A";
  ...
  ...
  SELECT method_to_be_used as Result;
END

现在我们调用 SP 使用 sequelize 原始查询，

const query = 'CALL take_over_the_world(:someArg)';
return Model.sequelize.query(query, 
 { 
   replacements : { someArg},
   type : Model.sequelize.QueryTypes.SELECT 
})
.then((response) => {

//Access response here. Its of the form [{Result: /*How to take over*/}]
});

到目前为止一切似乎都在完美地工作:)

关于mysql - 在 Sequelize 中调用输入/输出类型的存储过程，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30643415/