Nested query in node js using mysql

Question

I am trying following code at node js using mysql but getting error "Cannot enqueue Query after invoking quit.

var mysql = require('mysql');

var connection = mysql.createConnection({
host     : 'localhost',
user     : 'USER',
password : 'PASS',
database : 'DB',
});

connection.connect();

var queryString = 'SELECT * FROM tbl_product';

connection.query(queryString, function(err, rows, fields) {
    if (err) throw err;
    for (var i in rows) {
        console.log('Product Name: ', rows[i].product_name);
        var emp_query = 'SELECT * FROM tbl_employer';
        connection.query(queryString, function(emp_err, emp_rows, emp_fields) {
            if (emp_err) throw emp_err;
            for (var e in emp_rows) {
                console.log('Employer Name: ', emp_rows[e].company_name);
            }
        }); 
    }
});  
connection.end();

Rodrigo Medeiros · Accepted Answer · 2015-03-30 11:53:14Z

I see two problems in your code:

You're calling connection.end() synchronously, but your queries run in a asynchronous flow. You have to call connection.end() only when you've finished the second query.
You're using a regular for loop to run assynchronous calls (you outter loop).

To accomplish what you're trying to do, you have to consider those assynchronous scenarios. You could use promises or a module like async, that provides you a lot of methods to deal with assyncronous flows, like async.each():

connection.query(queryString, function(err, rows, fields) {
    if (err) throw err;

    async.each(rows, function (row, callback) {
        console.log('Product Name: ', row.product_name);
        var emp_query = 'SELECT * FROM tbl_employer';
        connection.query(queryString, function(emp_err, emp_rows, emp_fields) {
            if (emp_err) callback(emp_err);
            for (var e in emp_rows) {
                console.log('Employer Name: ', emp_rows[e].company_name);
            }
            callback();
        }); 
    });
    }, function (err) {
        connection.end();
    }
});

Now it will guarantee that connection.end() will just be called when all your queries have finished.

som · Accepted Answer · 2015-03-30 11:33:05Z

5

Remove connection end function

==> connection.end();

answered Mar 30, 2015 at 11:33

som

4,6542 gold badges23 silver badges36 bronze badges

Comments

Arkar Aung · Accepted Answer · 2015-03-30 11:41:05Z

1

The problem is connection.end() triggered before your query is not finished yet. Try to put connection.end() to end of outer loop.

connection.query(queryString, function(err, rows, fields) {
    if (err) throw err;
    for (var i in rows) {
        console.log('Product Name: ', rows[i].product_name);
        var emp_query = 'SELECT * FROM tbl_employer';
        connection.query(queryString, function(emp_err, emp_rows, emp_fields) {
            if (emp_err) throw emp_err;
            for (var e in emp_rows) {
                console.log('Employer Name: ', emp_rows[e].company_name);
            }
        }); 
    }
    connection.end();
});

Hope it will be useful for you.

answered Mar 30, 2015 at 11:41

Arkar Aung

3,5841 gold badge19 silver badges26 bronze badges

2 Comments

Edo Over a year ago

queries are asynchronous so even putting the connection.end() after the for loop doesn't solve the problem

Adrian Smith Over a year ago

By experiment I can confirm Edo is correct.

Collectives™ on Stack Overflow

Nested query in node js using mysql

3 Answers 3

Comments

Comments

2 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

Comments

Comments

2 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related