承诺-mysql 返回承诺

Question

我即将解决这个问题：我打算将 PHP 应用程序转换为 Angular 6，但是我会在 JavaSript ES6 中开发这个问题, 在最终和最终代码之前进行简化。情况如下：

我的用户表是：

    +-------------------------+-----------------------+------+-----+---------+----------------+
    | Field                   | Type                  | Null | Key | Default | Extra          |
    +-------------------------+-----------------------+------+-----+---------+----------------+
    | id                      | mediumint(8) unsigned | NO   | PRI | NULL    | auto_increment |
    | ip_address              | varchar(45)           | NO   |     | NULL    |                |
    | username                | varchar(100)          | NO   |     | NULL    |                |
    | password                | varchar(80)           | NO   |     | NULL    |                |
    | salt                    | varchar(40)           | YES  |     | NULL    |                |
    | email                   | varchar(254)          | NO   | UNI | NULL    |                |
    | activation_code         | varchar(40)           | YES  |     | NULL    |                |
    | forgotten_password_code | varchar(40)           | YES  |     | NULL    |                |
    | forgotten_password_time | int(11) unsigned      | YES  |     | NULL    |                |
    | remember_code           | varchar(40)           | YES  |     | NULL    |                |
    | created_on              | int(11) unsigned      | NO   |     | NULL    |                |
    | last_login              | int(11) unsigned      | YES  |     | NULL    |                |
    | active                  | tinyint(1) unsigned   | YES  |     | NULL    |                |
    | first_name              | varchar(50)           | YES  |     | NULL    |                |
    | last_name               | varchar(50)           | YES  |     | NULL    |                |
    | company                 | varchar(100)          | YES  |     | NULL    |                |
    | phone                   | varchar(20)           | YES  |     | NULL    |                |
    +-------------------------+-----------------------+------+-----+---------+----------------+

我的组表是：

    +-------------+-----------------------+------+-----+---------+----------------+
    | Field       | Type                  | Null | Key | Default | Extra          |
    +-------------+-----------------------+------+-----+---------+----------------+
    | id          | mediumint(8) unsigned | NO   | PRI | NULL    | auto_increment |
    | name        | varchar(20)           | NO   |     | NULL    |                |
    | description | varchar(100)          | NO   |     | NULL    |                |
    +-------------+-----------------------+------+-----+---------+----------------+

我还有这样的关系：

    +----------+-----------------------+------+-----+---------+----------------+
    | Field    | Type                  | Null | Key | Default | Extra          |
    +----------+-----------------------+------+-----+---------+----------------+
    | id       | mediumint(8) unsigned | NO   | PRI | NULL    | auto_increment |
    | user_id  | mediumint(8) unsigned | NO   | MUL | NULL    |                |
    | group_id | mediumint(8) unsigned | NO   | MUL | NULL    |                |
    +----------+-----------------------+------+-----+---------+----------------+

好吧，在这种情况下，我想获取到期用户（在本例中为用户 2）所属的所有组。

我的 JavaScript 代码是：

var mysql = require('promise-mysql');

var connection;
var arr = [];

mysql.createConnection({
    host: 'host',
    user: 'user',
    password: 'password',
    database: 'database'
}).then(
    function (conn) {
        connection = conn;
        return conn.query('select * from users_groups where user_id=2');
    }
).then(
    function(value) {
        console.log('Initial value : ' + JSON.stringify(value) );


        for (let user_group of value) {
            console.log('Each value : ' + JSON.stringify(user_group.group_id));
            arr.push( connection.query(`select * from groups where id = ${user_group.group_id}`));
        }     
        return arr;
    }, function (reason) {
        console.log('Rechazo: ' + reason);    
    }
).then (
    function (echo) {
        console.log('Echo: ' + JSON.stringify(echo));
        connection.end();
    }
);

我确实得到了：

Initial value : [{"id":10,"user_id":2,"group_id":1},{"id":11,"user_id":2,"group_id":2}]
Each value : 1
Each value : 2
Echo: [{"isFulfilled":false,"isRejected":false},{"isFulfilled":false,"isRejected":false}]

谁能帮帮我？ 提前致谢！

Answer 1

为了让 Promise 链正常工作，您必须在 then 调用中返回 Promise 以执行任何异步操作。在您的第二个then 调用中，您将一系列异步数据库调用推送到一个数组中。由于您返回的是一个数组而不是一个 Promise，因此您的下一个 then 调用不会不等待所有查询完成。将此数组传递给 Promise.all 并将其返回，您将获得所需的结果。

var mysql = require('promise-mysql');

var connection;
var arr = [];

mysql.createConnection({
    host: 'host',
    user: 'user',
    password: 'password',
    database: 'database'
}).then(
    function (conn) {
        connection = conn;
        return conn.query('select * from users_groups where user_id=2');
    }
).then(
    function(value) {
        console.log('Initial value : ' + JSON.stringify(value) );


        for (let user_group of value) {
            console.log('Each value : ' + JSON.stringify(user_group.group_id));
            arr.push( connection.query(`select * from groups where id = ${user_group.group_id}`));
        }     
        return Promise.all(arr);
    }, function (reason) {
        console.log('Rechazo: ' + reason);    
    }
).then (
    function (echo) {
        console.log('Echo: ' + JSON.stringify(echo));
        connection.end();
    }
);