0

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

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

下面是我得到的错误：

（节点：8084）UnhandledPromiseRejectionWarning：未处理的承诺拒绝（拒绝 id：1）：TypeError：无法读取未定义的属性“类型”

（节点：8084）[DEP0018] DeprecationWarning：不推荐使用未处理的承诺拒绝。将来，未处理的 Promise 拒绝将使用非零退出代码终止 Node.js 进程。

下面是我对存储过程的调用。我不断收到上述错误，并且未执行存储过程。我查看了以下似乎有同样问题的链接，但我仍然遇到同样的错误。

这是我第一次尝试使用此节点模块调用存储过程。因此，感谢您提供任何帮助。

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)
    }       
});
4

3 回答 3

0

抱歉，如果这听起来很圆滑，但我在您的代码中看不到您定义请求的位置 - 所以我最好的答案是它是未定义的，正如错误所说...

于 2018-11-07T04:51:37.323 回答
0

首先为sql server创建一个连接文件。 

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);

它会起作用的。

于 2018-11-07T04:59:38.423 回答
0

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

            .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)

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

于 2018-11-07T05:16:54.103 回答