Skip to content

Instantly share code, notes, and snippets.

@arulprabakaran
Forked from aggarwalankush/Sql.ts
Created September 27, 2017 06:46
Show Gist options
  • Save arulprabakaran/77f84d8391c4ad8daaa8931acdc3f3c5 to your computer and use it in GitHub Desktop.
Save arulprabakaran/77f84d8391c4ad8daaa8931acdc3f3c5 to your computer and use it in GitHub Desktop.
Ionic 2 storage
providers: [
Sql
]
import {Sql} from "../Sql";
export class ExampleComponent {
constructor(public sql: Sql) {
sql.query('create table danceMoves(name VARCHAR(32))').then(() => {}).catch(() => {});
}
}
import {Injectable} from "@angular/core";
import {Platform} from "ionic-angular";
const DB_NAME: string = '__mydbname';
const win: any = window;
@Injectable()
export class Sql {
private _dbPromise: Promise<any>;
constructor(public platform: Platform) {
this._dbPromise = new Promise((resolve, reject) => {
try {
let _db: any;
this.platform.ready().then(() => {
if (this.platform.is('cordova') && win.sqlitePlugin) {
_db = win.sqlitePlugin.openDatabase({
name: DB_NAME,
location: 'default'
});
} else {
console.warn('Storage: SQLite plugin not installed, falling back to WebSQL. Make sure to install cordova-sqlite-storage in production!');
_db = win.openDatabase(DB_NAME, '1.0', 'database', 5 * 1024 * 1024);
}
resolve(_db);
});
} catch (err) {
reject({err: err});
}
});
this._tryInit();
}
// Initialize the DB with our required tables
_tryInit() {
this.query('CREATE TABLE IF NOT EXISTS kv (key text primary key, value text)').catch(err => {
console.error('Storage: Unable to create initial storage tables', err.tx, err.err);
});
}
/**
* Perform an arbitrary SQL operation on the database. Use this method
* to have full control over the underlying database through SQL operations
* like SELECT, INSERT, and UPDATE.
*
* @param {string} query the query to run
* @param {array} params the additional params to use for query placeholders
* @return {Promise} that resolves or rejects with an object of the form { tx: Transaction, res: Result (or err)}
*/
query(query: string, params: any[] = []): Promise<any> {
return new Promise((resolve, reject) => {
try {
this._dbPromise.then(db => {
db.transaction((tx: any) => {
tx.executeSql(query, params,
(tx: any, res: any) => resolve({tx: tx, res: res}),
(tx: any, err: any) => reject({tx: tx, err: err}));
},
(err: any) => reject({err: err}));
});
} catch (err) {
reject({err: err});
}
});
}
/**
* Get the value in the database identified by the given key.
* @param {string} key the key
* @return {Promise} that resolves or rejects with an object of the form { tx: Transaction, res: Result (or err)}
*/
get(key: string): Promise<any> {
return this.query('select key, value from kv where key = ? limit 1', [key]).then(data => {
if (data.res.rows.length > 0) {
return data.res.rows.item(0).value;
}
});
}
/**
* Set the value in the database for the given key. Existing values will be overwritten.
* @param {string} key the key
* @param {string} value The value (as a string)
* @return {Promise} that resolves or rejects with an object of the form { tx: Transaction, res: Result (or err)}
*/
set(key: string, value: string): Promise<any> {
return this.query('insert or replace into kv(key, value) values (?, ?)', [key, value]);
}
getJson(key: string): Promise<any> {
return this.get(key).then(value => {
try {
return JSON.parse(value);
} catch (e) {
throw e; // rethrowing exception so it can be handled with .catch()
}
});
}
setJson(key: string, value: any): Promise<any> {
try {
return this.set(key, JSON.stringify(value));
} catch (e) {
return Promise.reject(e);
}
}
/**
* Remove the value in the database for the given key.
* @param {string} key the key
* @return {Promise} that resolves or rejects with an object of the form { tx: Transaction, res: Result (or err)}
*/
remove(key: string): Promise<any> {
return this.query('delete from kv where key = ?', [key]);
}
/**
* Clear all keys/values of your database.
* @return {Promise} that resolves or rejects with an object of the form { tx: Transaction, res: Result (or err)}
*/
clear(): Promise<any> {
return this.query('delete from kv');
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment