pg-promise任務和映射具有多個相同級別的嵌套查詢

Question

我正在使用節點和pg-promise創建一個基本的rest 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的承諾庫，那麼你可以將這段代碼：這一個

.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。