mysql - 如何多次循环 MYSQL 查询并从 Node.js 中的每个循环查询返回数据?

标签 mysql node.js asynchronous q

我有一个数据库,其中有一个名为 Inventory 的表,该表有五列:主键、sku、商品名称、描述和价格。我还有一组名为 skus 的 SKU。我的目标是运行 for 循环并针对每个 SKU 多次查询 Inventory 表,以收集有关每个 SKU 的每一列的所有信息,然后输出。

我对 Node 的异步特性相当陌生,并且我在首先从表中获取所有数据,然后在收集和组织数据后将其输出时遇到了麻烦。

这是我的代码:

var skus = [2, 1, 3, 4];

function inventoryLoop() {

    for(var i=0; i<skus.length; i++)
    {

        var deferred = Q.defer();

        connection.query("select * from Inventory where SKU = '"+skus[i]+"'", function(err, rows, fields) {

        deferred.resolve(rows);       

        }); //connection.query

    } //for-loop

    return deferred.promise;

} //inventoryLoop()


Q.all(inventoryLoop()).then(function(results) {

    console.log("results");        
    console.log(JSON.stringify(results));

}); //Q.all

这是我的输出:

[
    {"inventoryObjectID":2,"SKU":"2","itemName":"Lego 2","description":"Lego 2 Description","price":2}
]

这是我正在寻找的输出:

Results
[
    {"inventoryObjectID":2,"SKU":"2","itemName":"Lego 2","description":"Lego 2 Description","price":2}
    {"inventoryObjectID":1,"SKU":"1","itemName":"Lego 1","description":"Lego 1 Description","price":1}
    {"inventoryObjectID":3,"SKU":"3","itemName":"Lego 3","description":"Lego 3 Description","price":3}
    {"inventoryObjectID":4,"SKU":"4","itemName":"Lego 4","description":"Lego 4 Description","price":4}
]

最佳答案

如果您迭代列表以单独获取每个项目的信息,您最终会对数据库执行多次查询。相反,您可以创建一个更复杂的查询,该查询将为您提供所需的所有信息,从而减少执行的查询数量。

就您而言,因为您有一个 sku 列表,您可以运行一个查询,在其中获取与该 sku 匹配的所有行。您可以使用以下查询来做到这一点:

从库存中选择 * WHERE SKU='1' OR SKU='2' OR SKU='3' OR SKU='4'

您可以创建一个更好的查询,产生相同的输出,如下所示:

从库存中选择 * WHERE SKU IN ('1','2','3','4')

因此,您可以按如下方式编写查询并避免循环遍历列表:

connection.query("从库存中选择 * WHERE SKU IN ("+skus+")", 函数(错误,行,字段){...});

关于mysql - 如何多次循环 MYSQL 查询并从 Node.js 中的每个循环查询返回数据?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30689734/

相关文章:

Javascript:如何获取对象的原型(prototype)链构造函数名称列表?

asynchronous - 将数据对象与 Polymer 元素中的属性绑定(bind)

c# - 如何处理一些异步的 TcpClient 响应?

mysql 计算重复项

mysql - 将站点移动到另一个主机后 Magento 出错

mysql - 使用文件排序优化自连接

c# - 如何创建自定义 SynchronizationContext 以便所有延续都可以由我自己的单线程事件循环处理?

mysql - 查询在/tmp 目录上占用更多空间,执行时占用更多负载和时间

node.js - 无服务器出站流量保护

node.js - 如何使用 vue-cli(webpack) 创建多页面应用程序(每个页面都有不同的路由器,以及不同的 dist/index.html)