SELECT query synchronous with nodejs and sqlite3

Question

I am new to nodejs and facing an issue with sqlite select query

Below is my code.

function parse(topic, msg, name) {

    item = get_obj(tbl_name, handle, JSON.stringify(arg))

    // get item from database
    return [handle, arg, item, action];
}


function get_obj(tbl_name, handle, obj_str) {

    let dbname = "test.sql";
    let query, ret;
    let my_obj = {};
    let db = new sql.Database(dbname);
    let str = "'" + obj_str + "'";
    query = "SELECT handle from " + tbl_name + " where object=" + str;
    db.serialize(function(ret) {
    let ret1 = db.each(query, function(err, row, ret) {
        if (err) {
            console.log("No records found");
        } else {
            if (row.handle == handle) {
                ret = JSON.parse(obj_str);
            }
        }
    });
    });
    }

I want my parse should wait till i am done with get_obj(). In current scenario my parse returns immediately. Any help is appreciated.

deChristo · Accepted Answer · 2016-12-12 13:13:31Z

1

Add an anonymous function to your db.each function:

let ret1 = db.each(query, function(err, row, ret) {
        if (err) {
            console.log("No records found");
        } else {
            if (row.handle == handle) {
                ret = JSON.parse(obj_str);
            }
        }, function (err, rows) {             <---- this one
                parse(topic, msg, name)
            });
    });

Keep in mind that node.js functions are executed asynchronously. Due to this you need to have a callback that will be executed once the db.each() finishes and thus guaranteeing the callback function will only execute after the DB query has completed.

edited Dec 12, 2016 at 13:13

answered Dec 12, 2016 at 13:01

deChristo

1,8882 gold badges21 silver badges30 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

pkoulianos · Accepted Answer · 2020-01-10 20:10:33Z

If you want to await a function to finish at node.js you have to use Promises , try the code below :

async function parse(topic, msg, name) {

    item = await get_obj(tbl_name, handle, JSON.stringify(arg))

    // get item from database
    return [handle, arg, item, action];
}


function get_obj(tbl_name, handle, obj_str) {
    return new Promise(resolve => {
        let dbname = "test.sql";
        let query;
        let db = new sql.Database(dbname);
        query = "SELECT handle from " + tbl_name + " where object=?";
        db.each(query, [obj_str], function (err, row) {
            if (err) {
                console.log("No records found");
            } else {
                if (row.handle == handle) {
                    resolve(obj_str);
                }

            }
        });
    });
}

Collectives™ on Stack Overflow

SELECT query synchronous with nodejs and sqlite3

2 Answers 2

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related