Promise 本身不直接处理离线存储,但可优雅封装 IndexedDB 异步操作,通过包装 IDBRequest 事件、抽象 openDB 和读写工具函数,实现链式调用与 async/await 支持,并增强批量操作容错性及离线优先策略集成。

Promise 本身不直接处理离线存储,但它能优雅封装 IndexedDB 的异步操作,把回调地狱转为可链式调用、可 await 的契约接口。核心思路是:用 Promise 包裹 IDBRequest 的 success/error 事件,再结合 IDBDatabase、IDBObjectStore 等原生 API 构建语义清晰的工具函数。
封装 openDB:统一数据库连接与版本升级
IndexedDB 初始化需监听 onupgradeneeded 和 onsuccess,容易分散逻辑。用 Promise 封装后,可确保只打开一次连接,并自动处理 schema 创建:
function openDB(name, version, upgradeCb) {
return new Promise((resolve, reject) => {
const req = indexedDB.open(name, version);
req.onerror = () => reject(req.error);
req.onsuccess = () => resolve(req.result);
req.onupgradeneeded = (e) => {
const db = e.target.result;
if (typeof upgradeCb === 'function') {
upgradeCb(db, e.oldVersion, e.newVersion, e.transaction);
}
};
});
}
// 使用示例(创建 users 表)
openDB('myApp', 1, (db, old, newV, tx) => {
if (!db.objectStoreNames.contains('users')) {
db.createObjectStore('users', { keyPath: 'id' });
}
}).then(db => console.log('DB ready'));
封装通用读写操作:put/get/delete/all
每个 IDBObjectStore 操作都依赖 transaction → objectStore → request 三层嵌套。Promise 封装后,可抽象出高复用函数,隐藏底层细节:
Java项目代码review工具。分析Git变更+完整调用链路上下文,推断业务需求,进行多维度评分和分类汇总,生成完整PRD文档。包含细粒度Java代码审查清单(Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
function withStore(db, storeName, mode = 'readonly', fn) {
return new Promise((resolve, reject) => {
const tx = db.transaction(storeName, mode);
const store = tx.objectStore(storeName);
const req = fn(store);
req.onerror = () => reject(req.error);
req.onsuccess = () => resolve(req.result);
});
}
// 封装常用方法
const idb = {
put: (db, store, value) => withStore(db, store, 'readwrite', s => s.put(value)),
get: (db, store, key) => withStore(db, store, 'readonly', s => s.get(key)),
delete: (db, store, key) => withStore(db, store, 'readwrite', s => s.delete(key)),
getAll: (db, store) => withStore(db, store, 'readonly', s => s.getAll())
};
// 使用示例(async/await 风格)
async function saveUser(user) {
const db = await openDB('myApp', 1);
await idb.put(db, 'users', user);
return user;
}
处理批量操作与错误边界
IndexedDB 批量写入(如 addAll)不原生支持,需手动循环;同时事务失败会中断整个流程。Promise 封装时应支持原子性控制和部分失败兜底:
立即学习“Java免费学习笔记(深入)”;
- 用 transaction.oncomplete 替代单个 request.success,确保整批提交成功
- 对批量操作返回 Promise.allSettled() 结果,区分 fulfilled/rejected 条目
- 在 withStore 中捕获 transaction.onerror,避免静默失败
async function batchPut(db, store, values) {
return new Promise((resolve, reject) => {
const tx = db.transaction(store, 'readwrite');
const storeRef = tx.objectStore(store);
const results = [];
values.forEach((val, i) => {
const req = storeRef.put(val);
req.onsuccess = () => results[i] = { status: 'fulfilled', value: req.result };
req.onerror = () => results[i] = { status: 'rejected', reason: req.error };
});
tx.oncomplete = () => resolve(results);
tx.onerror = () => reject(tx.error);
});
}
配合 Cache API 或 Service Worker 做离线优先策略
Promise 封装的 IDB 操作可自然融入离线优先流程:先查缓存(IDB),命中则 resolve;未命中则 fetch 网络,存 IDB 后再返回。搭配 async/await 可写出清晰的 fallback 逻辑:
async function fetchWithCache(url) {
const db = await openDB('cacheDB', 1);
// 先查 IDB 缓存
const cached = await idb.get(db, 'responses', url);
if (cached) return cached;
// 网络请求 + 写入缓存(并行不阻塞返回)
const res = await fetch(url);
const data = await res.json();
idb.put(db, 'responses', { url, data, ts: Date.now() }).catch(console.warn);
return data;
}

















