SimpleIDB
// ==UserScript==
// @name indexedDB 操作封装
// @namespace https://scriptcat.org/
// @version 1.0.0
// @description 针对indexedDB的链式调用封装，支持批量操作。
// @author 仙灵天使
// @match http://*/*
// @icon data:image/gif;base64,R0lGODlhAQABAAAAACH5BAEKAAEALAAAAAABAAEAAAICTAEAOw==
// @grant none
// ==/UserScript==
class SimpleIDB {
constructor(dbName = 'defaultDB', defaultTable = 'defaultTable') {
this.dbName = dbName;
this.storeName = defaultTable; // 初始化时使用默认表名
this.operationsQueue = []; // 存储操作队列
this.dbConnection = null;
this.key = null;
this.value = null;
// 打开数据库连接并设置连接对象
const request = indexedDB.open(this.dbName);
request.onupgradeneeded = (event) => {
const db = event.target.result;
if (!db.objectStoreNames.contains(this.storeName)) {
db.createObjectStore(this.storeName, { keyPath: 'id' });
}
};
request.onsuccess = (event) => {
this.dbConnection = event.target.result;
};
request.onerror = (event) => {
console.error('Database error:', event.target.error);
};
}
// 设置表名
useTable(storeName) {
if (!storeName || !storeName.trim()) {
throw new Error('Store name cannot be empty or whitespace.');
}
this.storeName = storeName;
return this;
}
// 存储JS对象
set(key, object) {
this.key = key;
this.value = object;
this.operationsQueue.push((conn, table, key, value) => {
return new Promise((resolve, reject) => {
const transaction = conn.transaction([table], 'readwrite');
const store = transaction.objectStore(table);
const request = store.put({ id: key, ...value });
request.onsuccess = () => resolve();
request.onerror = (event) => reject(event.target.error);
});
});
return this;
}
// 读取JS对象
get(key) {
this.key = key;
this.operationsQueue.push((conn, table, key, value) => {
return new Promise((resolve, reject) => {
const transaction = conn.transaction([table], 'readonly');
const store = transaction.objectStore(table);
const request = store.get(key);
request.onsuccess = () => resolve(request.result);
request.onerror = (event) => reject(event.target.error);
});
});
return this;
}
// 移除某key数据
remove(key) {
this.key = key
this.operationsQueue.push((conn, table, key, value) => {
return new Promise((resolve, reject) => {
const transaction = conn.transaction([table], 'readwrite');
const store = transaction.objectStore(table);
const request = store.delete(key);
request.onsuccess = () => resolve();
request.onerror = (event) => reject(event.target.error);
});
});
return this;
}
clear() {
this.operationsQueue.push((conn, table, key, value) => {
return new Promise((resolve, reject) => {
const transaction = conn.transaction([table], 'readwrite');
const store = transaction.objectStore(table);
const request = store.clear();
request.onsuccess = () => resolve();
request.onerror = (event) => reject(event.target.error);
});
});
}
// 执行所有队列中的操作
execute() {
const operationsToExecute = [...this.operationsQueue]; // 复制当前队列并清空原队列
this.operationsQueue = [];
// ...债开特性可以自动忽略undefined
return [...operationsToExecute.reduce((promiseChain, operation) => {
return promiseChain.then((r) => [...r,operation(this.dbConnection, this.storeName, this.key, this.value)]);
}, Promise.resolve())];
}
}