|
|
@ -28,9 +28,7 @@ const createCollection = (Vue, db) => { |
|
|
|
const create = (db, collection, data) => { |
|
|
|
return new Promise((resolve, reject) => { |
|
|
|
const request = db.transaction([collection], 'readwrite').objectStore(collection).add(data); |
|
|
|
request.onsuccess = () => { |
|
|
|
resolve(); |
|
|
|
}; |
|
|
|
request.onsuccess = () => resolve(); |
|
|
|
|
|
|
|
request.onerror = event => { |
|
|
|
const { name, message } = event.target.error; |
|
|
@ -53,12 +51,8 @@ const create = (db, collection, data) => { |
|
|
|
const findOne = (db, collection, key) => { |
|
|
|
return new Promise((resolve, reject) => { |
|
|
|
const request = db.transaction([collection]).objectStore(collection).get(key); |
|
|
|
request.onerror = event => { |
|
|
|
reject(event.target.error.message); |
|
|
|
}; |
|
|
|
request.onsuccess = event => { |
|
|
|
resolve(event.target.result); |
|
|
|
}; |
|
|
|
request.onerror = event => reject(event.target.error.message); |
|
|
|
request.onsuccess = event => resolve(event.target.result); |
|
|
|
}); |
|
|
|
}; |
|
|
|
|
|
|
@ -73,9 +67,7 @@ const find = (db, collection) => { |
|
|
|
const request = db.transaction(collection).objectStore(collection).openCursor(); |
|
|
|
let result = []; |
|
|
|
|
|
|
|
request.onerror = event => { |
|
|
|
reject(event.target.error.message); |
|
|
|
}; |
|
|
|
request.onerror = event => reject(event.target.error.message); |
|
|
|
request.onsuccess = event => { |
|
|
|
const cursor = event.target.result; |
|
|
|
if (cursor) { |
|
|
@ -98,12 +90,8 @@ const find = (db, collection) => { |
|
|
|
const update = (db, collection, newData) => { |
|
|
|
return new Promise((resolve, reject) => { |
|
|
|
const request = db.transaction([collection], 'readwrite').objectStore(collection).put(newData); |
|
|
|
request.onerror = event => { |
|
|
|
reject(event.target.error.message); |
|
|
|
}; |
|
|
|
request.onsuccess = () => { |
|
|
|
resolve(newData); |
|
|
|
}; |
|
|
|
request.onerror = event => reject(event.target.error.message); |
|
|
|
request.onsuccess = () => resolve(newData); |
|
|
|
}); |
|
|
|
}; |
|
|
|
|
|
|
@ -117,12 +105,8 @@ const update = (db, collection, newData) => { |
|
|
|
const remove = (db, collection, key) => { |
|
|
|
return new Promise((resolve, reject) => { |
|
|
|
const request = db.transaction([collection], 'readwrite').objectStore(collection).delete(key); |
|
|
|
request.onerror = event => { |
|
|
|
reject(event.target.error.message); |
|
|
|
}; |
|
|
|
request.onsuccess = () => { |
|
|
|
resolve(); |
|
|
|
}; |
|
|
|
request.onerror = event => reject(event.target.error.message); |
|
|
|
request.onsuccess = () => resolve(); |
|
|
|
}); |
|
|
|
}; |
|
|
|
|
|
|
@ -137,15 +121,11 @@ const remove = (db, collection, key) => { |
|
|
|
const createIndexAndFind = (db, collection, field, key) => { |
|
|
|
return new Promise((resolve, reject) => { |
|
|
|
const store = db.transaction([collection], 'readonly').objectStore(collection); |
|
|
|
console.log('store: ', store); |
|
|
|
store.createIndex(field, field); |
|
|
|
const index = store.index(field); |
|
|
|
const request = index.get(key); |
|
|
|
request.onerror = event => reject(event.target.error.message); |
|
|
|
request.onsuccess = event => { |
|
|
|
console.log('event: ', event); |
|
|
|
resolve(event.target.result); |
|
|
|
}; |
|
|
|
request.onsuccess = event => resolve(event.target.result); |
|
|
|
}); |
|
|
|
}; |
|
|
|
|
|
|
|