當(dāng)我使用promise數(shù)組（Promise.all）時(shí)，Mongoose事務(wù)不會(huì)回滾

Question 1

我在這里遇到了一個(gè)奇怪的情況，我試圖在一個(gè)數(shù)組中插入一些寫(xiě)查詢（所有這些查詢都屬于同一個(gè)事務(wù)），并使用Promise.all(arr)對(duì)整個(gè)事務(wù)執(zhí)行/回滾。問(wèn)題是，如果我的代碼拋出錯(cuò)誤，并且我在調(diào)用Promise.all()之前中止了事務(wù)，那么promise數(shù)組中的操作to-be-done將被提交！。但是，如果我的代碼在調(diào)用Promise.all()后拋出錯(cuò)誤，文檔將按預(yù)期恢復(fù)到原始狀態(tài)。如何避免在調(diào)用Promise.all()之前拋出異常而導(dǎo)致事務(wù)中止的情況下提交對(duì)文檔的更改。

這是代碼剪

module.exports.updateVariantStock = async (req, res, next) => {
  const session = await mongoose.startSession();
  try {

    session.startTransaction();

    const opts = { session };

    const { newStock } = req.body;

    const { variant } = req.mydata;

    const promises = [];

    variant.stock = Number(variant.stock) + Number(newStock);

    const variantPromise = variant.save(opts);
    promises.push(variantPromise);

    const stockLogElement = new VariantStockLogElement({
     // Data to insert
    });

    const newStockLogContainerPromise = stockLogElement.save(opts);

    promises.push(newStockLogContainerPromise);

    throw new Error("A test error"); // If error is thrown here, changes are commited
    await Promise.all(promises);
    throw new Error("A test error"); // If error is thrown here, changes are rolled-back

    await session.commitTransaction();
  
    return res.status(200).json({ success: "Stock is updated." });
  } catch (err) {
      await session.abortTransaction();
    next(err);
  } finally {
    session.endSession();
  }
};

請(qǐng)注意，如果在拋出此錯(cuò)誤之前運(yùn)行任何數(shù)據(jù)庫(kù)查詢（與事務(wù)無(wú)關(guān)），則更改為rolled-back。但我犯了這個(gè)錯(cuò)誤

UnhandledPromiseRejectionWarning: MongoError: Transaction with { txnNumber: 1 } has been aborted.

我真的不明白這里發(fā)生了什么。

Question 2

當(dāng)將Promise.all與MongoDB中的事務(wù)一起使用時(shí)，注意承諾的結(jié)算順序是很重要的。在您的代碼中，當(dāng)您在調(diào)用Promise.all（promise）之前拋出錯(cuò)誤時(shí)，數(shù)組中的promise可能已經(jīng)開(kāi)始執(zhí)行，而MongoDB可能會(huì)將這些更改視為事務(wù)之外的單獨(dú)操作。但是，如果在調(diào)用Promise.all（promise）后拋出錯(cuò)誤，則這些操作將綁定到同一事務(wù)中。為了確保在調(diào)用Promise.all之前不會(huì)執(zhí)行數(shù)組中的promise，您可以將換行new Error（“A test Error”）移動(dòng)到Promise.all（promise）之后。你可以考慮這樣做，

// Execute promises within the transaction
const promiseResult = await Promise.all(promises);

// Check if any promise rejected
const hasRejectedPromise = promiseResult.some(p => p instanceof Error || p instanceof mongoose.Error);

if (hasRejectedPromise) {
      throw new Error("A test error"); // If error is thrown here, changes are rolled-back
}

await session.commitTransaction();

但是，如果出于某種原因，您的目標(biāo)是在單個(gè)promise拋出錯(cuò)誤時(shí)立即中止事務(wù)，則可以通過(guò)刪除Promise.all并使用try...catch塊單獨(dú)處理每個(gè)promise來(lái)實(shí)現(xiàn)這一點(diǎn)。如果任何promise拋出錯(cuò)誤，您可以立即中止事務(wù)并處理錯(cuò)誤。考慮一下這樣的事情，

    variant.stock = Number(variant.stock) + Number(newStock);
    const variantPromise = variant.save(opts);

    try {
      await variantPromise; // Handle the promise individually
    } catch (error) {
      // If an error occurs, immediately abort the transaction
      await session.abortTransaction();
      throw error;
    }

    const stockLogElement = new VariantStockLogElement({
      // Data to insert
    });

    const newStockLogContainerPromise = stockLogElement.save(opts);

    try {
      await newStockLogContainerPromise; // Handle the promise individually
    } catch (error) {
      // If an error occurs, immediately abort the transaction
      await session.abortTransaction();
      throw error;
    }

    await session.commitTransaction();
    // .... Continue with the rest of your code ...

Answer 1

當(dāng)將Promise.all與MongoDB中的事務(wù)一起使用時(shí)，注意承諾的結(jié)算順序是很重要的。在您的代碼中，當(dāng)您在調(diào)用Promise.all（promise）之前拋出錯(cuò)誤時(shí)，數(shù)組中的promise可能已經(jīng)開(kāi)始執(zhí)行，而MongoDB可能會(huì)將這些更改視為事務(wù)之外的單獨(dú)操作。但是，如果在調(diào)用Promise.all（promise）后拋出錯(cuò)誤，則這些操作將綁定到同一事務(wù)中。為了確保在調(diào)用Promise.all之前不會(huì)執(zhí)行數(shù)組中的promise，您可以將換行new Error（“A test Error”）移動(dòng)到Promise.all（promise）之后。你可以考慮這樣做，

// Execute promises within the transaction
const promiseResult = await Promise.all(promises);

// Check if any promise rejected
const hasRejectedPromise = promiseResult.some(p => p instanceof Error || p instanceof mongoose.Error);

if (hasRejectedPromise) {
      throw new Error("A test error"); // If error is thrown here, changes are rolled-back
}

await session.commitTransaction();

但是，如果出于某種原因，您的目標(biāo)是在單個(gè)promise拋出錯(cuò)誤時(shí)立即中止事務(wù)，則可以通過(guò)刪除Promise.all并使用try...catch塊單獨(dú)處理每個(gè)promise來(lái)實(shí)現(xiàn)這一點(diǎn)。如果任何promise拋出錯(cuò)誤，您可以立即中止事務(wù)并處理錯(cuò)誤。考慮一下這樣的事情，

    variant.stock = Number(variant.stock) + Number(newStock);
    const variantPromise = variant.save(opts);

    try {
      await variantPromise; // Handle the promise individually
    } catch (error) {
      // If an error occurs, immediately abort the transaction
      await session.abortTransaction();
      throw error;
    }

    const stockLogElement = new VariantStockLogElement({
      // Data to insert
    });

    const newStockLogContainerPromise = stockLogElement.save(opts);

    try {
      await newStockLogContainerPromise; // Handle the promise individually
    } catch (error) {
      // If an error occurs, immediately abort the transaction
      await session.abortTransaction();
      throw error;
    }

    await session.commitTransaction();
    // .... Continue with the rest of your code ...

當(dāng)我使用promise數(shù)組（Promise.all）時(shí)，Mongoose事務(wù)不會(huì)回滾

熱門(mén)問(wèn)答

django獲取上一個(gè)url

如何打印出特定工作日以前輸入的列表？

在c中訂閱powershell progress#不工作

Javascript：在URL更改時(shí)更新內(nèi)部html

如何在pandas中的一個(gè)繪圖中繪制不同的時(shí)間序列？

使用cssText函數(shù)用JavaScript添加CSS屬性

maskrcnn 制作masks

Golang for-select炸毀CPU

如何在Hadoop集群上部署和運(yùn)行Mahout作業(yè)

試圖讓一個(gè)站點(diǎn)訪問(wèn)localhost :(端口）而不是localhost

sql重復(fù)數(shù)據(jù)個(gè)數(shù)

檢查電腦運(yùn)行的代碼