nodejs中的多个sql查询答案

【问题标题】：Multiple sql queries in nodejsnodejs中的多个sql查询
【发布时间】：2015-10-23 08:11:14
【问题描述】：

我是 nodejs 的新手。我正在使用 nodeJs 开发一个演示应用程序。我在运行多个查询时遇到问题。我的代码如下：

exports.dashboard = function(req, res){

 req.getConnection(function(err,connection){

 var id = req.session.userId;
  var queryData =  "SELECT node_questions.question_name,node_questions.description FROM node_questions LEFT JOIN node_user ON node_questions.user_id=node_user.id";
        var query = connection.query(queryData,'SELECT * FROM node_user Where id = ?',[id],function(err,rows)
        {
                console.log(rows);
               res.render('dashboard',{page_title:"Dashboard",session:req.session.userId,email:req.session.email,data:rows});
         });
    });  
};

数据库连接是：

 app.use(
        connection(mysql,{
            host: 'localhost',
            user: 'root',
            password : 'password',
            port : 3306, //port mysql
            database:'nodeDemo',
            multipleStatements:true

        },'pool') //or single

    );

【问题讨论】：

请您提供有关该错误的更多信息吗？
这是错误：“TypeError: undefined is not a function”
这个错误会给你一个堆栈跟踪吗？
你能告诉我如何在nodeJs中运行多个mysql查询吗？
未定义不是函数错误并不意味着问题与运行多个查询有关，但如果没有堆栈跟踪，则很难提供帮助。您可以将错误堆栈跟踪发布到您的问题吗？

标签： javascript node.js ejs

【解决方案1】：

你把东西混在一起了。例如，您希望您的rows 是什么？它应该是第一个或第二个查询的结果集吗？处理此问题的一个好方法是使用 async 模块（确保首先通过 npm 在 package.json 中安装它）。

var async = require('async');
var mysql      = require('mysql');

client = mysql.createConnection({
    user: 'root',
    password : 'password',
    port : 3306, //port mysql
    database:'nodeDemo',
    multipleStatements:true
});

var id = req.session.userId;

async.parallel([
    function(callback) {
        var queryData = '' +
            ' SELECT node_questions.question_name,node_questions.description' +
            ' FROM node_questions' +
            ' LEFT JOIN node_user' +
            ' ON node_questions.user_id=node_user.id';
        client.query(queryData, function (err, rows1) {
            if (err) {
                return callback(err);
            }
            return callback(null, rows1);
        });
    },
    function(callback) {
        client.query('SELECT * FROM node_user Where id = ?', id, function (err, rows2) {
            if (err) {
                return callback(err);
            }
            return callback(null, rows2);
        });
    }
], function(error, callbackResults) {
    if (error) {
        //handle error
        console.log(error);
    } else {
        console.log(callbackResults[0]); // rows1
        console.log(callbackResults[1]); // rows2
        // use this data to send back to client etc.
    }
});

【讨论】：

嗨 Kaya Toast：我收到错误“ReferenceError：未定义客户端”
基本上，我的回答只是说明如何处理两个单独的查询并获得响应。不管怎样，我现在已经定义了client。
很高兴能提供帮助。在某些时候，探索更多关于为什么app.use、为什么pool、async.series等的细节。祝你的项目好运:-)

【解决方案2】：

为什么不使用 Promise？

let Promise = require('bluebird'),
    begin = []

begin.push(promise1(a,b))
begin.push(promise2(c.d))

return Promise.all(begin)
    .spread(function (resultFromQuery1, resultFromQuery2) {
        // do something with the result here
    })

【讨论】：