概述批量写入应分批处理以降低事务压力。本文给出分批策略与进度回调示例。分批写入与进度function openDB(name) { return new Promise((resolve, reject) => { const r = indexedDB.open(name, 1); r.onupgradeneeded = () => { const db = r.result; if (!db.objectStoreNames.contains('items')) db.createObjectStore('items', { keyPath: 'id' }); }; r.onsuccess = () => resolve(r.result); r.onerror = () => reject(r.error); }); }
async function bulkPutBatched(records, batch = 500, onProgress) {
const db = await openDB('batchdb');
let done = 0;
for (let i = 0; i < records.length; i += batch) {
const slice = records.slice(i, i + batch);
const tx = db.transaction('items', 'readwrite');
const store = tx.objectStore('items');
for (const r of slice) store.put(r);
await new Promise((resolve, reject) => { tx.oncomplete = resolve; tx.onerror = () => reject(tx.error); tx.onabort = () => reject(tx.error); });
done += slice.length; onProgress && onProgress(done, records.length);
}
db.close();
}

发表评论 取消回复