NvmStorage

nvm-storage

Обертка над IndexDb Api, предоставляющая более стандартный интерфейс Установка

npm install nvm-storage --save

Интеграция

import { IDBWrapperService } from 'nvm-storage';

@Injectable({
	providedIn: 'root'
})
export class StorageService {
	private static readonly DB_NAME: string = 'sample-db';
	public isActive: boolean = false;

	constructor(private _db: IDBWrapperService) {}
}

addMigration(migration: (db: IDBDatabase, ev: IDBRequest) => void): void

Регистрирует миграции базы, для поддержания актуальной версии. Регистрация должна производиться до установления соединения.

this._db.addMigration((db: IDBDatabase, ev: IDBRequest) => {
	db.createObjectStore('Entity', { autoIncrement: true });
});
this._db.addMigration((db: IDBDatabase, ev: IDBRequest) => {
	db.createObjectStore('Log', { autoIncrement: true });
});

open(name): Subject

Принимает в качестве параметра имя базы; Открывает соединение с базой и высталяет флаг isActive в true если все прошло успешно. Если версия базы ниже количества зарегистрированных миграций - обновляет базу. Возвращает Subject<boolean> который эмитит значение true/false по завершении соединения.

this._db.open(DB_NAME).subscribe((result: booleean) => {
	this.isActive = true;
	console.log(result ? 'success' : 'fail');
});

insert(obj: IdItem): Observable

Реализует добавление элемента в базу. Все сущности в базе должны реализовывать интерфейс IdItem. Данные добавляются в существующую таблицу по имени класса. В примере это будет таблица 'Entity'

export class Entity implements IdItem {
	constructor(public id: number, public name: string);
}
const item = new Entity(1, 'Иванов Иван Иванович');
this._db.insert(item).subscribe((result: IdItem) => {
	console.log(`объект добавлен успешно с id: ${result.id}`);
});

update(obj: IdItem, key: number): Observable

Реализует обновление элемента в базе

item.name = 'Петров Петр Петрович';
this._db.update(item, 1).subscribe((result: IdItem) => {
	console.log(`объект с id: ${result.id} обновлен: ${result.name}`);
});

select(table: string, query?: IDBKeyRange): Observable<Array>

Выборка из базы

this._db
	.select<Entity>('Entity', IDBKeyRange.bound(1, 20))
	.subscribe((items: Entity[]) => {
		console.log(
			`Найдено элементов в базе с id от 1 до 20: ${items.length} штук`
		);
	});

delete(table: string, key: string): Observable

Реализует удаление из базы.

this._db.delete('Entity', '1').subscribe((result: boolean) => {
	console.log(
		`объект с id: ${result.id} удален ${!result ? 'не ' : ''}успешно`
	);
});