update(indexedDB) |
カーソルを使用してすべての行を更新 |
| getAll() | 数百件〜数千件程度 ※getAll()は全件を一括でメモリに読み込むため、 データ量が多いと ブラウザのメモリを圧迫する可能性があります。 |
| カーソル | 数万件以上 特に画像やバイナリデータを含む場合は、カーソル推奨。 |
async function sampleTest(dbName, storeName)
{
const db = await databaseOpen(dbName);
//update
await runTx(db, storeName, "readwrite", (store) =>
{
const cursorReq = store.openCursor();
cursorReq.onsuccess = (event) =>
{
const cursor = event.target.result;
if (cursor) {
const record = cursor.value;
record.f3 = "change" + (record.f1 + 1);
cursor.update(record);
cursor.continue();
}
};
});
//select all
const rows = await runTx(db, storeName, "readonly", (store) =>
{
return new Promise((resolve, reject) =>
{
const req = store.getAll();
req.onsuccess = () => resolve(req.result);
req.onerror = () => reject(req.error);
});
});
rows.forEach(r => console.log(`f1:${r.f1}, f2:${r.f2}, f3:${r.f3}`));
db.close();
}
function waitForTx(tx)
{
return new Promise((resolve, reject) =>
{
tx.oncomplete = () => resolve();
tx.onabort = () => reject(tx.error ?? new Error("Transaction aborted"));
tx.onerror = () => reject(tx.error);
});
}
async function runTx(db, storeName, mode, work)
{
const tx = db.transaction([storeName], mode);
const store = tx.objectStore(storeName);
const result = await work(store);
await waitForTx(tx);
return result;
}
function databaseOpen(dbName)
{
return new Promise((resolve, reject) =>
{
const req = indexedDB.open(dbName);
req.onsuccess = (event) =>
{
resolve(event.target.result);
};
req.onerror = () => reject(req.error);
});
}
sampleTest("aaa", "t1");
| ホームページおよプリ等に掲載されている情報等については、いかなる保障もいたしません。 ホームページおよびアプリ等を通じて入手したいかなる情報も複製、販売、出版または使用させたり、 または公開したりすることはできません。 当方は、ホームペーよびアプリ利用したいかなる理由によっての障害等が発生しても、 その結果ホームページおよびアプリ等を利用された本人または他の第三者が被った損害について 一切の責任を負わないものとします。 |