Nodejs中如果一个action中有多次查询，conn.end是写在哪个回调里面？

Nodejs中如果一个action中有多次查询，conn.end是写在哪个回调里面？

比如

var mysql  = require('mysql'); 
var conn = mysql.createConnection(param);
conn.query("查询1",function(err,data){ });
conn.query("查询2",function(err,data){ });
conn.query("查询3",function(err,data){ });

6 回复

Node.js 中如果一个 action 中有多次查询，conn.end() 是写在哪个回调里面？

在 Node.js 中使用 MySQL 进行数据库操作时，如果你在一个 action 中执行多次查询，你需要确保所有查询都完成之后再关闭连接。这意味着你应该将 conn.end() 放在所有查询的回调函数之后。

下面是一个具体的例子来说明这一点：

var mysql = require('mysql');
var conn = mysql.createConnection({
    host: 'localhost',
    user: 'yourusername',
    password: 'yourpassword',
    database: 'yourdatabase'
});

// 开始执行查询
conn.connect(function(err) {
    if (err) throw err;
    
    // 第一次查询
    conn.query("SELECT * FROM table1", function(err, data1) {
        if (err) throw err;

        // 第二次查询
        conn.query("SELECT * FROM table2", function(err, data2) {
            if (err) throw err;

            // 第三次查询
            conn.query("SELECT * FROM table3", function(err, data3) {
                if (err) throw err;

                // 所有查询都已完成，现在可以关闭连接
                conn.end();
            });
        });
    });
});

解释

  • 连接数据库：首先，我们创建一个到 MySQL 数据库的连接。
  • 开始查询：在连接成功后，我们依次执行多个查询。每个查询都在一个回调函数中处理。
  • 顺序执行：由于这些查询是顺序执行的，我们需要确保每个查询的回调函数都完成后，再执行下一个查询。这样可以确保数据的一致性和完整性。
  • 关闭连接：当所有查询都完成之后，我们在最后一个查询的回调函数中调用 conn.end() 来关闭数据库连接。

这样做可以保证在所有查询都完成之后才关闭连接，从而避免因连接未关闭而导致的资源泄露问题。


用 async 管理多个查询，都执行完了再 call conn.end

var EventProxy = require('eventproxy');
var ep = new EventProxy();
ep.all('sql1', 'sql2', 'sql3', function (data1, data2, data3) {
    // 成功回调
});
// 添加error handler
ep.fail(callback);
var mysql  = require('mysql'); 
var conn = mysql.createConnection(param);
conn.query("查询1",ep.done('sql1'));
conn.query("查询2",ep.done('sql2'));
conn.query("查询3",ep.done('sql3'));

我也来一段async

var async = require('async');

var mysql  = require(‘mysql’);
var conn = mysql.createConnection(param);


var sqls = [‘查询1’,“查询2”,“查询3”]；
async.mapSeries(sqls,function(sql,callback){
conn.query(sql,callback);
},function(err,res){
//所有任务完成后，结果都在这里，res是结果
})

var async = require(‘async’);

var mysql = require(‘mysql’); var conn = mysql.createConnection(param);

var sqls = [‘查询1’,“查询2”,“查询3”]； async.mapSeries(sqls,function(sql,callback){ conn.query(sql,callback); },function(err,res){ //所有任务完成后，结果都在这里，res是结果 })

在Node.js中使用MySQL进行多次查询时，conn.end()应该在所有查询都完成之后调用。你可以通过嵌套回调或使用Promise来确保所有查询都在结束连接之前完成。

示例代码（使用回调）：

var mysql = require('mysql');
var conn = mysql.createConnection(param);

// 第一次查询
conn.query("查询1", function(err1, data1) {
    if (err1) throw err1;

    // 第二次查询
    conn.query("查询2", function(err2, data2) {
        if (err2) throw err2;

        // 第三次查询
        conn.query("查询3", function(err3, data3) {
            if (err3) throw err3;

            // 所有查询完成，关闭连接
            conn.end();
        });
    });
});

解释：

  • conn.query() 方法用于执行SQL查询。
  • 每个查询都有一个回调函数，在这里我们检查是否有错误 (if (err) throw err;)。
  • 当所有查询都完成后，调用 conn.end() 关闭数据库连接。

示例代码（使用Promise）：

如果你更喜欢使用Promise来管理异步操作，可以使用util.promisify来将回调转换为Promise，并使用async/await语法来简化代码：

const mysql = require('mysql');
const util = require('util');

var conn = mysql.createConnection(param);

const query = util.promisify(conn.query).bind(conn);

async function performQueries() {
    try {
        await query("查询1");
        await query("查询2");
        await query("查询3");
        
        // 所有查询完成，关闭连接
        conn.end();
    } catch (error) {
        console.error(error);
    }
}

performQueries();

解释：

  • 使用 util.promisify 将 conn.query 转换为返回Promise的函数。
  • 使用 async/await 确保每个查询在继续下一个查询之前完成。
  • 在所有查询完成后调用 conn.end() 来关闭数据库连接。

以上两种方法都可以确保所有的查询在关闭连接之前完成。

回到顶部