node-mssql 不会执行存储过程给出 unhandlePromiseRejectionWarning

Question

以下是我的 server.js 文件的输出。
我正在打印传递给存储过程的查询字符串参数。

ID : 10################_
Email : test@mail.com
Name : testname
FamilyName : testtesttest

下面是我得到的错误：

(node:8084) UnhandledPromiseRejectionWarning: Unhandled promise rejection (rejection id: 1): TypeError: Cannot read property 'type' of undefined

(node:8084) [DEP0018] DeprecationWarning: Unhandled promise rejections are deprecated. In the future, promise rejections that are not handled will terminate the Node.js process with a non-zero exit code.

下面是我对存储过程的调用。我一直收到上述错误，存储过程没有被执行。我查看了以下似乎有相同问题的，但我仍然遇到相同的错误。

这是我第一次尝试使用此节点模块调用存储过程。因此，我们将不胜感激。

app.get('/addRegistration', function(req,res){
    try 
    {
        const pool5 = new sql2.ConnectionPool(config, err => 
            {
                // Stored Procedure
                pool5.request()
                .input('FBID', sql2.varchar, 250, req.query.id)
                .input('FBEmail', sql2.varchar, 250, req.query.email)
                .input('FBName', sql2.varchar, 250, req.query.memberName)
                .input('FamilyName', sql2.varchar, 250, req.query.familyName)
                .execute('sp_registerUser', (err, result) => 
                {
                    console.log("Success"); 
                }).catch(function(err) {
                    console.log(err);
                });
            })
         pool5.on('error', err => {
            console.log("Error");
         })
    } catch (err) {
    // ... error checks
        console.log("addRegistration: " + err)
    }       
});

Answer 1

抱歉，如果这听起来有点油嘴滑舌，但我在您的代码中看不到您定义请求的位置 - 所以我的最佳答案是它未定义，如错误所述...

Answer 2

首先为sql服务器创建一个连接文件。

import mysql from 'mysql';
import config from 'config-yml';
import logger from '../logger';

/**
 * @description Creating pool to have simultanious connection to SQL.
 */
const pool = mysql.createPool({
  connectionLimit: config.db.max_limit,
  host: config.db.host,
  user: config.db.user,
  port: config.db.port,
  password: config.db.password,
  database: config.db.name,
  debug: process.env.DB_DEBUG || false, // Set to true if you want to debug the database.
});

/**
 * @description Creates the database connection.
 */
pool.getConnection((err, connection) => {
  if (err) {
    if (err.code === 'PROTOCOL_CONNECTION_LOST') {
      logger.error('Database connection was closed.');
    }
    if (err.code === 'ER_CON_COUNT_ERROR') {
      logger.error('Database has too many connections.');
    }
    if (err.code === 'ECONNREFUSED') {
      logger.error('Database connection was refused.');
    }
  }
  if (connection) connection.release();
});

module.exports = pool;

然后创建一个导出函数来执行下面的查询代码。

import pool from '../index';

const execQuery =  async (query, fn) => {
  pool.query(query, async (err, result, fields) => { // eslint-disable-line
    try {
      console.log(result[0][0]);
      fn(result[0][0]);
      return result;
    } catch (err) {
      return err;
    }
  });
};

export default execQuery;

在 Workbench 中编写程序并调用 sql 程序函数

call SO_CALLED_PROCEDURE(PASS_ARGUMENT);

它会起作用。

Answer 3

我发现了问题。这是我的原始代码。

            .input('FBID', sql2.varchar, 250, req.query.id)
            .input('FBEmail', sql2.varchar, 250, req.query.email)
            .input('FBName', sql2.varchar, 250, req.query.memberName)
            .input('FamilyName', sql2.varchar, 250, req.query.familyName)

需要改为：

            .input('FBID', sql2.VarChar(250), req.query.id)
            .input('FBEmail', sql2.VarChar(250), req.query.email)
            .input('FBName', sql2.VarChar(250), req.query.memberName)
            .input('FamilyName', sql2.VarChar(250), req.query.familyName)

最终我将大小作为值参数的一部分。一切都错了。一旦我做对了，存储过程就会按预期执行。

node-mssql 不会执行存储过程给出 unhandlePromiseRejectionWarning

node-mssql won't execute stored procedure giving unhandlePromiseRejectionWarning

javascript

node.js

express

node-mssql