NodeJS MSSQLドライバ呼び出し関数へのデータの受け渡し

Question

NodeJSでSQL Serverを使用していて、データを取得していることを確認しましたが、データを呼び出し元関数に戻そうとしています。ここで

は、データベースを照会機能への私の呼び出しです：

const dbq = require('./dbquery.js'); 
app.get('/:id', (req, res) => { 
    reqlog(`/${req.params.id}`); 
    var set = dbq.getPersonById(req.params.id); 
    console.log(set); 
}); 

、ここではdbquery.js内部関数です。

qry.getPersonById = (id) => { 

    mssql.connect(sqlConfig).then(() => { 
    new mssql.Request().query(`select * from FNVPeople where IndivID=${id}`).then((record)=>{ 
     console.log(record); 
     return record; 
    }).catch((err)=>{ 
     console.log(err); 
    }); 
    }); 
} 

関数への私の呼び出しは次のようになりますか？そのため非同期な性質の

var dataset = await(dbq.getPersonById(req.params.id));

Answer 1

あなたがに対処するためのクライアントへの約束（二つの追加returnsに注意してください）返す必要があります：、その後約束

とクライアントのお得な情報を

qry.getPersonById = (id) => { 

    return mssql.connect(sqlConfig).then(() => { 
    return new mssql.Request().query(`...`) 
     .then((record)=>{ 
      console.log(record); 
      return record; 
     }) 
     .catch((err)=>{ 
      console.log(err); 
     }); 
    }); 

} 

を

app.get('/:id', (req, res) => { 
    reqlog(`/${req.params.id}`); 
    dbq.getPersonById(req.params.id).then(set => 
    console.log(set); 
); 
}); 

約束を書いてasync/awaitに書き換えると、 nは前

qry.getPersonById = async (id) => { 

    try { 
    await mssql.connect(sqlConfig) 
    var record = await new mssql.Request().query(`...`); 
    console.log(record); 
    return record; 
    } 
    catch (err) { 
    console.log(err); 
    } 
} 

と

app.get('/:id', async (req, res) => { 
    reqlog(`/${req.params.id}`); 
    var set = await dbq.getPersonById(req.params.id); 
    console.log(set); 
}); 

Answer 2

。

次のために試してみてください。

const dbq = require('./dbquery.js'); 
app.get('/:id', (req, res) => { 
    reqlog(`/${req.params.id}`); 
    dbq.getPersonById(req.params.id, function(err, res){ 
     console.log(res); 
    });  
}); 


qry.getPersonById = (id, callback) => { 

    mssql.connect(sqlConfig).then(() => { 
     new mssql.Request().query(`select * from FNVPeople where IndivID=${id}`).then((record)=>{ 
      console.log(record); 
      callback(null, record); 
     }).catch((err)=>{ 
      console.log(err); 
     }); 
     }); 
    }