IndexedDB - 交易


事务是一组操作,要么全部成功,要么全部失败。例如,如果我们从 UPI 向商家付款并且交易失败,那么资金必须退回到发件人的帐户。事务可以维护这种完整性。

以下是打开交易的语法 -

db.transaction(store[, type]);

这里的存储是我们要进行事务的对象存储。交易类型有两种 -

  • 只读- 只能读取,默认情况下给出。

  • 读写- 我们只能读取和写入数据,但不能从对象存储中创建、删除或更改它。

交易生命周期

事务是对象存储之间的连接,用于执行任何操作。每笔交易都有一个状态,可以是 -

  • active - 首次创建交易时。或者当请求与事务关联时。当事务处于此状态时,可以针对该事务发出新请求。

  • inactive - 事务在创建后控制权返回到事件后处于此状态。当事务处于这种状态时,不能对事务发出任何请求。

  • 提交- 一旦与事务关联的所有请求完成,它就会尝试提交。在提交状态期间,不能发出新的请求。

  • Finished - 事务提交或中止后,它就处于完成状态。在完成状态期间,不能提出新的请求。

交易的生命周期

一个有范围、有模式的交易就这样形成了。事务在生成时的状态最初是活动的。

  • 要开始事务,实现必须对任务进行排队。

  • 当处理与事务连接的每个请求时,将触发成功或错误事件。发送事件时,事务状态设置为活动状态,允许针对该事务发出后续请求。事件分派完成后,事务的状态将设置为非活动状态。

  • 事务可以在完成之前随时取消,即使该事务当前未处于活动状态或尚未开始。

  • 当针对数据库发出的所有请求都成功时,实现必须尝试提交事务。

  • 当提交或中止事务时,其状态设置为完成。

交易调度

当事务可以启动时,有一些限制。

  • 当没有读或写事务时:是在交易 tx b 之前建立的。与 tx c 有重叠范围。未处于最终状态,可以开始只读事务 tx。

  • 当没有其他事务时,读/写事务 tx 可以开始 -

    • 在 tx 之前形成,
    • 与 tx 有重叠范围,或者
    • 未处于完成状态。

升级交易

模式为“ versionchange ”的事务是升级事务。

可以使用升级操作来创建、重命名和删除数据库中的对象存储和索引。

如果给定的版本高于当前版本,则在打开与数据库的连接后完成运行升级事务的步骤时,会自动生成升级事务。在Upgradeneeded事件处理程序中,此事务将处于活动状态。

进行交易

必须完成以下步骤才能提交事务 -

  • 事务状态首先设置为提交。
  • 等待列表中的所有交易请求均已处理完毕。
  • 如果发生错误,则中止事务。
  • 如果事务是升级事务,则将数据库升级事务的事务连接设置为 NULL。
  • 更改事务状态以完成。
  • 触发交易的整个事件
  • 如果事务是升级事务,则将请求的事务设置为 null 并发出与该事务关联的请求。

句法

transaction.commit()

尝试提交事务。所有待处理的请求将被允许完成,但不会接受新的请求。

如果待处理的请求失败,事务将中止。成功请求的成功事件仍将触发,但在事件处理程序中引发异常不会中止事务,调用PreventDefault()也不会阻止事务中止。

事件处理程序

各种事件处理程序属性如下

attribute EventHandler onabort; 
attribute EventHandler oncomplete; 
attribute EventHandler onerror;

交易示例

下面给出了一个简单的 JavaScript 程序来演示事务的用法 -

<!DOCTYPE html>
<html lang="en">
<head>
   <title>Document</title>
</head>
<body>
   <script>
      const request = indexedDB.open("botdatabase",1);
      request.onupgradeneeded = function(){
         const db = request.result;
         const store = db.createObjectStore("bots",{ keyPath: "id"});
      }
      request.onsuccess = function(){
         document.write("database opened successfully");
         const db = request.result;
         const transaction=db.transaction("bots","readwrite");
         const store = transaction.objectStore("bots");
         store.add({id: 1, name: "jason",branch: "IT"});
         store.add({id: 2, name: "praneeth",branch: "CSE"});
         store.add({id: 3, name: "palli",branch: "EEE"});
         store.add({id: 4, name: "abdul",branch: "IT"});
         store.put({id: 4, name: "deevana",branch: "CSE"});
         transaction.oncomplete = function(){
            document.write("transaction complete");
            db.close;
         };
      }
   </script>
</body>
</html>

输出

database opened successfully
transaction complete

这里创建了一个事务,只有创建事务后我们才能将数据添加到对象存储中,最后事务完成后我们关闭数据库。

例子

以下示例显示了事务属性 oncomplete 的用法 -

function student(db, names) {
   let transaction = db.transaction(['names'], 'readwrite');
   let store = transaction.objectStore('names');
   for (let i = 0; i < messages.length; i++) {
      store.add({text: names[i]});
   }
   transaction.oncomplete = function()
   {document.write('transaction complete')};
}

中止交易

要中止交易,请按照以下步骤操作 -

  • 对数据库的所有与事务相关的修改都将被撤消。

  • 对象存储、索引和版本中的更改同样会在升级事务期间恢复。

  • 完成交易状态。

  • 如果错误不为空,则将事务错误设置为错误。

  • 对于事务请求列表中的每个请求,将请求已处理标志设置为 true。

  • 将请求完成标志设置为 true 并定义结果。

  • 如果事务是升级事务,则将与事务连接关联的升级事务设置为空。

  • 在事务事件中创建一个中止,并将 bubbles 属性设置为 true。

  • 如果事务是升级事务,则假设该请求是事务的打开请求。