Sequelize：只更新最后几行

Question

我有一个（几千个）数据对象数组，我需要根据条件插入或更新。在我的模型类中实现了一个简单的upsert() 方法。

实施

    csv.upsert = async function (values, condition) {
    let obj = await csv.findOne({ where: condition });
    
    if (obj) {
        // update
        console.log("existing record updated")
        return await obj.update(values);
    } else {
        // insert
        console.log("new record inserted")
        return await csv.create(values);
    }
    
}

然后使用这个 upsert 方法，我循环遍历对象数组以在 db 中插入或更新它们。

用法

try {           
    await models.sequelize.authenticate();          
    await models.sequelize.sync();          
    let dataToBeInserted = getArrayOfDatatoInsert();            
    dataToBeInserted.map(async function (data) {                
        let condition = {
            'categorygroup': data.categorygroup,
            'category': data.category,
            'country': data.country,
            'city': data.city
        };
        await csvModel.upsert(data, condition);
    })
    // await restofthestuff();
} catch (error) {
    console.log("error", error);
}

为了测试，我使用了一个需要更新所有数据的数据集。

当我运行这个方法时：

我可以在（以及打开的续集日志）日志中看到，"existing record updated" 消息为存在的每条记录打印，这是所需的输出。只有最后几个 (30) 数据在数据库中得到更新。它适用于 csv.create(values)

~ 我怎样才能更新所有记录，显然不仅仅是最后 30 条数据，感谢任何帮助。 ~

编辑：显然我通过使用 csv.update(values, {where: condition}) 而不是使用 obj.update(values) 来实现这一点。

新问题：我没有进一步研究 sequelize 的更新方法，但这是一个错误还是我在这里做错了什么？

Answer 1

正如下面注释代码中的详细说明，您的日志在您返回之后，因此永远不会被执行。

另外，你没有在异步函数中使用 await，所以要么不要让它异步，要么使用 await。

csv.upsert = async function (values, condition) {
    const obj = await csv.findOne({ where: condition });
    // you can await here, no need for then as you are in an async function

    if (obj) { // update
        // you need to log before your return condition
        console.log("existing record updated")
        return obj.update(values);
        // since we return here, the rest of the code will not be executed
        // you can skip the use of else
    }
    // we are in this part of the code only if object is falsy

    // insert
    console.log("new record inserted")
    return csv.create(values);
}

您也可以使用Promise.all 来确保所有的 upsert 都已完成：

await Promise.all(dataToBeInserted.map(async function (data) {
    let condition = {
        'categorygroup': data.categorygroup,
        'category': data.category,
        'country': data.country,
        'city': data.city
    };
    await csvModel.upsert(data, condition);
}))

这也将确保如果发生错误，它会被您的 try / catch 捕获

也许这会帮助您找到导致意外行为的原因。