NodeJs - 複数のSELECTクエリの後に同じページをレンダリングする

Question

私のindex.jsファイルに以下のコードがあります。私はプロファイルテーブルのデータを印刷することができます。そして私は同じ（index.njk）ページでもレジュームテーブルのデータを印刷する必要があります。しかし、私はできませんでした。私もsimilar questionが見つかりましたが、私は新しいですし、私のプロジェクトに従ってそれらのコードを変更することができませんでした。あなたは助けてもらえますか？

var express = require('express'), 
path = require('path'), 
bodyParser = require('body-parser'), 
router = express.Router(), 
app = express(); 
var pg =require('pg'); 

// DB Connect string 
var connect = { 
user: 'arslan', 
database: 'resumedb', 
password: '1984', 
host: 'localhost', 
port: 5432, 
max: 10, 
idleTimeoutMillis: 30000, 
}; 

router.get('/', function(req, res){ 
pg.connect(connect, function(err, client, done, skills){ 
    if(err){ 
    return console.error('errrr', err) 
    } 
    //Get Profile Informations 
client.query('select id,fname,lname,title,description,profileimage from profile', function(err, result){ 

    if(err){ 
     return console.error('error running query', err); 
    } 
    if(result.rows.length > 0) { 
      res.render('index.njk', { 
       profileName: result.rows[0].fname, 
       profileLName: result.rows[0].lname , profileTitle: result.rows[0].title 
       , profileDesc: result.rows[0].description 
       , profileImage: result.rows[0].profileimage 
      }); 

     console.log(result.rows[0].profileimage); 
    }else { 
     console.log('No rows found in DB'); 
    } 
    done() 
}); 
}); 
}); 

Answer 1

すべての非同期用の最適な解決策は、約束を使用することです。 あなたのコードは接続プールにconfigを使用しますが、後でプールを使用しませんが、しばしばプールを使用することをお勧めします。あなたはdb.query('select 1 + 1').then(rows => { /* your code */}).catch(err => { next(err) })を使用することができ、単一のクエリを作成したい場合は あなたのルートで、その後

// ... 
const db = require('./db') 

router.get('/', function(req, res, next) { 

    let profileQuery = db.queryOne('select id,fname,lname,title,description,profileimage from profile') 
    let resumeQuery = db.query('???') 
    Promise.all([profileQuery, resumeQuery]).then(([profile, resume]) => { 
    if (!profile) { 
     return res.status(404).send('Profile not found') // error page 
    res.render('index.njk', { 
      profileName: profile.fname, 
      profileLName: profile.lname, 
      profileTitle: profile.title, 
      profileDesc: profile.description, 
      profileImage: profile.profileimage 
     }) 
    }).catch(err => { 
    next(err) 
    }) 

}) 

をデシベル

const pg = require('pg') 

const connect = { // Normaly you would use an config file to store this information 
    user: 'arslan', 
    database: 'resumedb', 
    password: '1984', 
    host: 'localhost', 
    port: 5432, 
    max: 10, 
    idleTimeoutMillis: 30000 
} 

let pool = new pg.Pool(config) 

exports.query = (query, values) => { 
    return new Promise((resolve, reject) => { 
    pool.connect(function(err, client, done) { 
     if (err) 
     return reject(err) 
     client.query(query, values, (err, result) => { 
     done() 
     if (err) 
      return reject(err) 
     resolve(result) 
     }) 
    }) 
    }) 
} 

exports.queryOne = (query, values) => { 
    return new Promise((resolve, reject) => { 
    this.query(query, values).then(rows => { 
     if (rows.length === 1) { 
     resolve(rows[0]) 
     } else if (rows.length === 0) { 
     resolve() 
     } else { 
     reject(new Error('More than one row in queryOne')) 
     } 
    }).catch(err => { 
     reject(err) 
    }) 
    }) 
} 

pool.on('error', function (err, client) { 
    console.error('idle client error', err.message, err.stack) 
}) 

を照会する新しいモジュールdb.jsを作成します。 多くの場合、1つの行だけが必要なので、queryOneを使用できます。 undefinedが返されます。行、必要な行、または複数行のエラー

next()引数にエラーがあると、エラーハンドラが呼び出されます。あなたが何かを理解しないならば、それは最初に複雑になる可能性があるため、そこには、エラーを記録し、あなたがその

ために独自に作成する必要がある500を返すことができます:)