Spaces:
Running
Running
File size: 3,994 Bytes
947c08e |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 |
import { Platform } from "react-native";
import * as SQLite from 'expo-sqlite';
const DATABASE_NAME = 'StorageDB'
class Storage_Web {
private static dbPromise: Promise<IDBDatabase>;
private static getDB(): Promise<IDBDatabase> {
if (!this.dbPromise) {
this.dbPromise = new Promise((resolve, reject) => {
const request = indexedDB.open(DATABASE_NAME, 1);
request.onupgradeneeded = (event) => {
const db = (event.target as IDBOpenDBRequest).result;
db.createObjectStore('dataStore');
};
request.onsuccess = () => {
resolve(request.result);
};
request.onerror = () => {
reject(request.error);
};
});
}
return this.dbPromise;
}
static async store(key: string, value: any): Promise<void> {
const db = await this.getDB();
return new Promise((resolve, reject) => {
const transaction = db.transaction('dataStore', 'readwrite');
const store = transaction.objectStore('dataStore');
const request = store.put(value, key);
request.onsuccess = () => {
resolve();
};
request.onerror = () => {
reject(request.error);
};
});
}
static async get(key: string): Promise<any> {
const db = await this.getDB();
return new Promise((resolve, reject) => {
const transaction = db.transaction('dataStore', 'readonly');
const store = transaction.objectStore('dataStore');
const request = store.get(key);
request.onsuccess = () => {
resolve(request.result);
};
request.onerror = () => {
reject(request.error);
};
});
}
static async remove(key: string): Promise<void> {
const db = await this.getDB();
return new Promise((resolve, reject) => {
const transaction = db.transaction('dataStore', 'readwrite');
const store = transaction.objectStore('dataStore');
const request = store.delete(key);
request.onsuccess = () => {
resolve();
};
request.onerror = () => {
reject(request.error);
};
});
}
}
class Storage_Native{
private DATABASE:any
constructor() {
this.DATABASE = new Promise(async (resolve, reject) => {
resolve(await SQLite.openDatabaseAsync(DATABASE_NAME))
})
}
public async store(key: string, value: any) {
try{
const db = await this.DATABASE;
await db.runAsync('CREATE TABLE IF NOT EXISTS storage (key TEXT PRIMARY KEY NOT NULL, value TEXT);')
await db.runAsync(
'INSERT OR REPLACE INTO storage (key, value) VALUES (?, ?);', key, JSON.stringify(value)
);
}catch(error){console.log(error)}
}
public async get(key: string) {
try {
const db = await this.DATABASE;
await db.runAsync('CREATE TABLE IF NOT EXISTS storage (key TEXT PRIMARY KEY NOT NULL, value TEXT);')
const DATA:any = await db.getFirstAsync(
'SELECT value FROM storage WHERE key = ?;', key
)
if (DATA) return JSON.parse(DATA.value)
else return DATA
}catch(error){console.log(error)}
}
public async remove(key: string) {
try{
const db = await this.DATABASE;
await db.runAsync('CREATE TABLE IF NOT EXISTS storage (key TEXT PRIMARY KEY NOT NULL, value TEXT);')
await db.runAsync(
'DELETE FROM storage WHERE key = ?;', key
);
}catch(error){console.log(error)}
}
}
var Storage:any
if (Platform.OS === "web") {
Storage = Storage_Web;
}else{
Storage = new Storage_Native();
}
export default Storage
|