複数の同じレベルのネストされたクエリを持つpg-promiseタスクとマップ

Question

私はnodeとpg-promiseを使って基本的な残りのAPIを作成していますが、特定のユーザのすべてのデータをクエリする際に問題があります。以下は、返されるデータの外観です。住所、電話番号、およびスキルはすべて別々のテーブルに保存されています。私はアドレスや電話番号を取得することに問題はなく、私は得ることができないそのスキルを持っています。これらの他のフィールドをすべて取得するためのメインクエリの後に複数のクエリを設定する方法が不明な場合は、添付のコードを参考にしてください。質問にお答えします。

---

{ 
"user_id": 1, 
"first_name": "Eugene", 
"last_name": "Hanson", 
"display_name": "Eugene Hanson", 
"email": "ehanson0@typepad.com", 
"hash": "88a6aa27235d2e39dd9cb854cc246487147050f265578a3e1aee35be5db218ef", 
"privilege_id": 14, 
"seniority": 1, 
"birthday": "19-11-1940 00:00:00.0", 
"shift_count_total": 587, 
"shift_count_year": 62, 
"address_id": 1, 
"street": "92 Schmedeman Lane", 
"city": "Fort Smith", 
"state": "AR", 
"zip": 72905, 
"phone_numbers": [ 
    { 
    "phone_number": "62-(705)636-2916", 
    "name": "PRIMARY" 
    } 
], 
"skills": [ 
    "Head Audio", 
    "Head Video", 
    "Head Electrician", 
    "Carpenter", 
    "rigger" 
    ] 
} 

---

function getAllUsers() { 
 
    // console.time("answer time") 
 
    var deferred = Q.defer(); 
 
    db.task(t => { 
 
     return t.map('SELECT * \ 
 
         FROM users \ 
 
         JOIN addresses \ 
 
         ON users.address_id = addresses.address_id',[], user => { 
 
      var user_id = user.user_id; 
 
      // console.log(user_id) 
 
      console.time("answer time") 
 
      return t.manyOrNone('SELECT phone_numbers.phone_number, phone_types.name \ 
 
            FROM users \ 
 
            JOIN users_phone_numbers \ 
 
            ON users.user_id = users_phone_numbers.user_id \ 
 
            JOIN phone_numbers \ 
 
            ON users_phone_numbers.phone_id = phone_numbers.phone_id \ 
 
            JOIN phone_types \ 
 
            ON phone_numbers.phone_type_id = phone_types.phone_type_id \ 
 
            WHERE users.user_id = $1', user.user_id) 
 
            .then(phone_numbers=> { 
 
             // logger.log('info', phone_numbers) 
 
             user.phone_numbers = phone_numbers; 
 
             return user; 
 
            }) 
 
     }).then(t.batch); 
 
    }) 
 
    .then(data => { 
 
     // console.log(data) 
 
     console.timeEnd("answer time"); 
 
     var response = {code: "200", 
 
         message: "", 
 
         payload: data}; 
 
     deferred.resolve(response); 
 
    }) 
 
    .catch(error => { 
 
    var response = {code: error.code, 
 
        message: error.message, 
 
        payload: ""}; 
 
    logger.log('error', error) 
 
    deferred.reject(response) 
 
});

Answer 1

私はpg-promiseの著者です。

---

あなたの関数の

簡易版は、次のようになります

function getAllUsers() { 
    return db.task(t => { 
     return t.map('SELECT * FROM users', [], user => { 
      return t.batch([ 
       t.any('SELECT * FROM phones'), // plus formatting params 
       t.any('SELECT * FROM skills'), // plus formatting params 
      ]) 
       .then(data => { 
        user.phones = data[0]; 
        user.skills = data[1]; 
        return user; 
       }); 
     }).then(t.batch); 
    }); 
} 

getAllUsers() 
    .then(data => { 
     // data tree 
    }) 
    .catch(error => { 
     // error 
    }); 

そして、あなたが約束ライブラリとしてbluebirdを使用している場合、あなたはこのコードを置き換えることができます。この1と

.then(data => { 
    user.phones = data[0]; 
    user.skills = data[1]; 
    return user; 
}); 

を：

.spread((phones, skills) => { 
    user.phones = phones; 
    user.skills = skills; 
    return user; 
}); 

var deferred = Q.defer();のようなものは使用しないでください。必要ありません。図書館はすでに約束しています。

高性能の代替品については、get JOIN table as array of results with PostgreSQL/NodeJSを参照してください。