Tag: data

I'm new to nodejs and I'm trying to understand why I can not get the expected result from my API.

I have an application that sends an API node an array containing data to be saved in bd.
When I receive this data, I have to verify that each one is saved in my database. db.buscaPorId() . If each record is not saved, a function db.salva() record each of these new records in the bank.
At the end of this process, I would like to return all data (new and old) to my application.

The problem is getting all the records after foreach because it does not return the last saved data. Only those who were previously saved …

What I have tried is in the code below.

What would be the best way to solve this problem? I study the promises but I still do not understand how to put it into practice in my code.
Note: the code is probably full of flaws, so if someone can give me a hint to improve it, that would be cool 🙂

Road function

sincroniza(app) {
    return function (req, res) {
        const dadosApp = req.body;

        const conexao = app.persistencia.ConexaoDb();
        const db = new app.persistencia.PontoDao(conexao);

        if(dadosApp !== ""){
            console.log('recebendo dados');
            dadosApp.forEach(dado =>{
                db.buscaPorId(dado.uuid,(erro,resultado)=>{
                    if(resultado == '' || resultado == undefined || resultado.length == 0){
                        dado.sync = 1;
                        db.salva(dado,(erro,res)=>{
                            if(erro){
                                res.send('falha ao salvar os dados')
                            }
                        })
                    }
                })
            })
        }

        //não retorna os últimos dados salvos
        db.lista((erro,result)=>{                
            res.json(result);
        })

}

bd functions

function PontoDao(conn){
    this._conn = conn;

}

PontoDao.prototype.salva = function(ponto,callback){
    this._conn.query('INSERT INTO ponto SET ?', ponto, callback);
}

PontoDao.prototype.atualiza = function(ponto,callback) {
    this._conn.query('UPDATE ponto SET sync = ? where id = ?', (ponto.sync, ponto.id), callback);
}

PontoDao.prototype.lista = function(callback) {
    this._conn.query('SELECT * from ponto',callback);
}

PontoDao.prototype.buscaPorId = function (id,callback) {
    this._conn.query("select * from ponto where uuid = ?",(id),callback);
}

module.exports = function(){
    return PontoDao;
};