nodeJs中实现连表查询-阿里云开发者社区

nodeJs中实现连表查询

2024-05-24 24

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 在Node.js中，这段代码演示了如何使用Promise处理异步数据库查询以实现连表查询。首先，通过Promise从`orders`表中获取指定用户ID的订单，然后对每个订单，再次使用Promise查询对应的`food`信息。查询结果合并后，将foodList添加到对应订单对象。最后，使用Promise.all处理并发查询并发送响应。文章还介绍了Promise的基础知识，包括创建Promise、处理状态变化以及Promise.all和Promise.race方法。

nodeJs中实现连表查询

router.post('/getOrder', async function(req, res, next) {
   
   
    let userId = req.body.phone;

    let sql = 'select * from orders where userId=?';
    let orders = await new Promise((resolve, reject) => {
   
   
        connection.query(sql, [userId], function(error, result) {
   
   
            if (error) {
   
   
                reject(error);
            } else {
   
   
                resolve(result);
            }
        });
    });

    for (let i = 0; i < orders.length; i++) {
   
   
        let foodId = orders[i].foodId;
        let foodSql = 'select * from food where id=?';
        let food = await new Promise((resolve, reject) => {
   
   
            connection.query(foodSql, [foodId], function(error, result) {
   
   
                if (error) {
   
   
                    reject(error);
                } else {
   
   
                    resolve(result);
                }
            });
        });
        orders[i].foodList = food; // 将foodList数组添加到对应的order对象中
    }

    console.log('Orders with Food List:', orders);

    res.send({
   
   
        code: 200,
        data: {
   
   
            data: orders
        }
    });
});

在这里插入图片描述

异步操作

Promise是用于处理异步操作的对象，它代表了一个异步操作的最终完成或失败，以及其结果值。Promise有三种状态：pending（进行中）、fulfilled（已成功）和rejected（已失败）。以下是Promise的基本用法：

创建一个Promise对象：

let myPromise = new Promise((resolve, reject) => {
   
   
    // 异步操作，比如数据库查询、文件读取等
    if (/* 操作成功 */) {
   
   
        resolve('操作成功，返回结果');
    } else {
   
   
        reject('操作失败，返回错误信息');
    }
});

处理Promise对象的状态：

myPromise.then((result) => {
   
   
    // 当Promise状态为fulfilled时调用，result为操作成功的结果
    console.log(result);
}).catch((error) => {
   
   
    // 当Promise状态为rejected时调用，error为操作失败的错误信息
    console.log(error);
});

Promise.all()：用于将多个Promise实例包装成一个新的Promise实例，当所有Promise实例的状态都变为fulfilled时，新的Promise实例的状态才会变为fulfilled；只要有一个Promise实例的状态变为rejected，新的Promise实例的状态就会变为rejected。

let promise1 = Promise.resolve(1);
let promise2 = Promise.resolve(2);

Promise.all([promise1, promise2])
    .then((results) => {
   
   
        console.log(results); // [1, 2]
    })
    .catch((error) => {
   
   
        console.log(error);
    });

Promise.race()：用于将多个Promise实例包装成一个新的Promise实例，只要其中一个Promise实例的状态发生变化，新的Promise实例的状态就会跟着变化。

let promise1 = new Promise((resolve) => setTimeout(resolve, 500, 'one'));
let promise2 = new Promise((resolve) => setTimeout(resolve, 100, 'two'));

Promise.race([promise1, promise2])
    .then((value) => {
   
   
        console.log(value); // 'two'
    });