indexeddb 原生 api 事件驱动、嵌套深，promise 封装后支持 async/await，提升可读性；需封装 open（含版本控制与 objectstore 创建）、增删改查等操作，并统一处理事务、错误及批量/游标场景。
IndexedDB 原生 API 是基于事件的（如 onsuccess、onerror），写起来冗长且嵌套深。用 Promise 封装后，就能配合 async/await 写出清晰、可读性强的异步逻辑。
封装 open 方法：创建并升级数据库
数据库打开过程涉及版本控制和 objectStore 创建，容易出错。封装时需统一处理错误，并返回 Promise 包裹的 IDBDatabase 实例。
关键点：
- 监听
upgradeneeded事件时才创建或修改 objectStore（仅在版本号升高时触发） - 成功时 resolve 数据库实例；失败时 reject 错误
- 避免重复打开——可加简单缓存，但注意多标签场景下版本变更需重新打开
示例封装：
function openDB(name, version, upgradeCb) {
return new Promise((resolve, reject) => {
const request = indexedDB.open(name, version);
request.onerror = () => reject(request.error);
request.onsuccess = () => resolve(request.result);
request.onupgradeneeded = (event) => {
const db = event.target.result;
if (typeof upgradeCb === 'function') {
upgradeCb(db, event.oldVersion, event.newVersion, event.transaction);
}
};
});
}
封装通用操作：add、put、get、delete、clear
每个操作都对应一个事务（transaction），而事务本身不支持 Promise，需手动包装其 oncomplete 和 onerror。
推荐统一模式：传入数据库实例、store 名称、操作类型及参数，内部自动创建只读/读写事务。
常见封装要点：
-
get和count可用只读事务（readonly） -
add/put/delete/clear必须用读写事务（readwrite） - 所有操作都应在事务完成前监听
request.onerror和request.onsuccess，否则可能丢失错误
示例 get 封装：
function get(db, storeName, key) {
return new Promise((resolve, reject) => {
const transaction = db.transaction(storeName, 'readonly');
const store = transaction.objectStore(storeName);
const request = store.get(key);
request.onsuccess = () => resolve(request.result);
request.onerror = () => reject(request.error);
});
}
批量操作与游标遍历：用 Promise.all 或 async 迭代
批量写入（如插入 100 条记录）不要逐个 await，应合并到单个事务中提升性能；遍历大量数据则需用游标（cursor），不能直接 Promise 化，需转成异步迭代器或递归 Promise。
实用策略：
- 批量写入：在一个
readwrite事务里循环调用put，最后统一监听事务oncomplete - 游标遍历：封装为返回
Promise<array></array>的函数，内部递归或用for await...of（需配合自定义异步迭代器） - 注意游标默认只遍历一次，多次使用需重新打开
简单游标封装（返回全部数据）：
async function getAll(db, storeName) {
return new Promise((resolve, reject) => {
const transaction = db.transaction(storeName, 'readonly');
const store = transaction.objectStore(storeName);
const results = [];
const request = store.openCursor();
request.onsuccess = (event) => {
const cursor = event.target.result;
if (cursor) {
results.push(cursor.value);
cursor.continue();
} else {
resolve(results);
}
};
request.onerror = () => reject(request.error);
});
}
错误处理与事务边界：避免“silent fail”
IndexedDB 的错误常被忽略——比如事务超时、存储空间不足、键冲突等。Promise 封装必须显式暴露这些错误，且明确事务生命周期。
必须注意：
- 事务对象本身没有 Promise 接口，
transaction.onerror捕获的是整个事务级错误（如并发冲突） - 单个请求失败不会自动终止事务，除非手动调用
transaction.abort() - 建议在每个操作封装中同时监听 request 和 transaction 的 error，并优先 reject request 错误（更具体）
增强版写入封装（带事务级兜底）：
function put(db, storeName, value, key) {
return new Promise((resolve, reject) => {
const transaction = db.transaction(storeName, 'readwrite');
const store = transaction.objectStore(storeName);
const request = store.put(value, key);
request.onsuccess = () => resolve(request.result);
request.onerror = () => reject(request.error);
transaction.onerror = (event) => {
// 防止 request.onerror 未触发时遗漏错误
reject(event.target.error);
};
});
}
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
