Visit Tutorials https://jepiqueau.github.io/
@capacitor-community/sqlite@latest
CAPACITOR 3
In Ionic/Vue Applications, the @capacitor-community/sqlite@latest
can be accessed through a Singleton Vue Hook initialized in the main.ts
file
Vue SQLite Hook Definition
Vue SQLite Hook Declaration for platforms other than Web
Vue SQLite Hook Declaration for platforms including Web
Vue SQLite Hook Use in Components
A Vue hook specific to @capacitor-community/sqlite
plugin has been developed to access the plugin API
To install it in your Ionic/Vue App
npm i --save-dev @capacitor-community/sqlite@latest
npm i --save-dev vue-sqlite-hook@latest
To use the vue-sqlite-hook
as a singleton hook, the declaration must be done in the main.ts
file of your application
...
import { useSQLite } from 'vue-sqlite-hook';
import { useState } from '@/composables/state';
...
//Existing Connections
const [existConn, setExistConn] = useState(false);
// Listeners onProgressImport and Export
const [jsonListeners, setJsonListeners] = useState(false);
const [isModal, setIsModal] = useState(false);
const [message, setMessage] = useState("");
...
const app = createApp(App)
.use(IonicVue)
.use(router);
...
// Singleton SQLite Hook
// !!!!! if you do not want to use the progress events !!!!!
// since vue-sqlite-hook 2.1.1
// app.appContext.config.globalProperties.$sqlite = useSQLite()
// before
// app.appContext.config.globalProperties.$sqlite = useSQLite({})
// !!!!! !!!!!
const onProgressImport = async (progress: string) => {
if(jsonListeners.jsonListeners.value) {
if(!isModalOpen.isModal.value) isModalOpen.setIsModal(true);
contentMessage.setMessage(
contentMessage.message.value.concat(`${progress}\n`));
}
}
const onProgressExport = async (progress: string) => {
if(jsonListeners.jsonListeners.value) {
if(!isModalOpen.isModal.value) isModalOpen.setIsModal(true);
contentMessage.setMessage(
contentMessage.message.value.concat(`${progress}\n`));
}
}
// SQLite Hook definition
app.appContext.config.globalProperties.$sqlite = useSQLite({
onProgressImport,
onProgressExport
});
// Listeners onProgressImport and Export
app.config.globalProperties.$isModalOpen = {isModal: isModal, setIsModal: setIsModal};
app.config.globalProperties.$isJsonListeners = {jsonListeners: jsonListeners, setJsonListeners: setJsonListeners};
app.config.globalProperties.$messageContent = {message: message, setMessage: setMessage};
// Existing Connections
app.config.globalProperties.$existingConn = {existConn: existConn, setExistConn: setExistConn};
...
router.isReady().then(() => {
app.mount('#app');
});
Now the Singleton SQLite Hook $sqlite
and Existing Connections Store $existingConn
can be use in app's components
As for the Web platform, the jeep-sqlite
Stencil component is used and requires the DOM:
the declaration of the SQLite Hook has to be moved to the App.vue
So the main.ts
file
...
import { defineCustomElements as jeepSqlite, applyPolyfills } from "jeep-sqlite/loader";
import { Capacitor } from '@capacitor/core';
import { CapacitorSQLite, SQLiteConnection, SQLiteDBConnection } from '@capacitor-community/sqlite';
import { useState } from '@/composables/state';
import { schemaToImport179 } from '@/utils/utils-import-from-json';
applyPolyfills().then(() => {
jeepSqlite(window);
});
window.addEventListener('DOMContentLoaded', async () => {
const platform = Capacitor.getPlatform();
const sqlite: SQLiteConnection = new SQLiteConnection(CapacitorSQLite)
const app = createApp(App)
.use(IonicVue)
.use(router);
/* SQLite Global Variables*/
// Only if you want to use the onProgressImport/Export events
const [jsonListeners, setJsonListeners] = useState(false);
const [isModal, setIsModal] = useState(false);
const [message, setMessage] = useState("");
app.config.globalProperties.$isModalOpen = {isModal: isModal, setIsModal: setIsModal};
app.config.globalProperties.$isJsonListeners = {jsonListeners: jsonListeners, setJsonListeners: setJsonListeners};
app.config.globalProperties.$messageContent = {message: message, setMessage: setMessage};
// Existing Connections Store
const [existConn, setExistConn] = useState(false);
app.config.globalProperties.$existingConn = {existConn: existConn, setExistConn: setExistConn};
try {
if(platform === "web") {
// Create the 'jeep-sqlite' Stencil component
const jeepSqlite = document.createElement('jeep-sqlite');
document.body.appendChild(jeepSqlite);
await customElements.whenDefined('jeep-sqlite');
// Initialize the Web store
await sqlite.initWebStore();
}
// here you can initialize some database schema if required
// example: database creation with standard SQLite statements
const ret = await sqlite.checkConnectionsConsistency();
const isConn = (await sqlite.isConnection("db_tab3")).result;
let db: SQLiteDBConnection
if (ret.result && isConn) {
db = await sqlite.retrieveConnection("db_tab3");
} else {
db = await sqlite.createConnection("db_tab3", false, "no-encryption", 1);
}
await db.open();
const query = `
CREATE TABLE IF NOT EXISTS test (
id INTEGER PRIMARY KEY NOT NULL,
name TEXT NOT NULL
);
`
const res = await db.execute(query);
if(res.changes && res.changes.changes && res.changes.changes < 0) {
throw new Error(`Error: execute failed`);
}
await sqlite.closeConnection("db_tab3");
// example: database creation from importFromJson
const result = await sqlite.isJsonValid(JSON.stringify(schemaToImport179));
if(!result.result) {
throw new Error(`isJsonValid: "schemaToImport179" is not valid`);
}
// full import
const resJson = await sqlite.importFromJson(JSON.stringify(schemaToImport179));
if(resJson.changes && resJson.changes.changes && resJson.changes.changes < 0) {
throw new Error(`importFromJson: "full" failed`);
}
router.isReady().then(() => {
app.mount('#app');
});
} catch (err) {
console.log(`Error: ${err}`);
throw new Error(`Error: ${err}`)
}
});
and the App.vue
file
<template>
<ion-app>
<ion-router-outlet />
</ion-app>
</template>
<script lang="ts">
import { IonApp, IonRouterOutlet } from '@ionic/vue';
import { defineComponent, getCurrentInstance} from 'vue';
import { useSQLite} from 'vue-sqlite-hook';
export default defineComponent({
name: 'App',
components: {
IonApp,
IonRouterOutlet,
},
setup() {
const app = getCurrentInstance();
const isModalOpen = app?.appContext.config.globalProperties.$isModalOpen;
const contentMessage = app?.appContext.config.globalProperties.$messageContent;
const jsonListeners = app?.appContext.config.globalProperties.$isJsonListeners;
const onProgressImport = async (progress: string) => {
if(jsonListeners.jsonListeners.value) {
if(!isModalOpen.isModal.value) isModalOpen.setIsModal(true);
contentMessage.setMessage(
contentMessage.message.value.concat(`${progress}\n`));
}
}
const onProgressExport = async (progress: string) => {
if(jsonListeners.jsonListeners.value) {
if(!isModalOpen.isModal.value) isModalOpen.setIsModal(true);
contentMessage.setMessage(
contentMessage.message.value.concat(`${progress}\n`));
}
}
if( app != null) {
// !!!!! if you do not want to use the progress events !!!!!
// since vue-sqlite-hook 2.1.1
// app.appContext.config.globalProperties.$sqlite = useSQLite()
// before
// app.appContext.config.globalProperties.$sqlite = useSQLite({})
// !!!!! !!!!!
app.appContext.config.globalProperties.$sqlite = useSQLite({
onProgressImport,
onProgressExport
});
}
return;
}
});
</script>
Now the Singleton SQLite Hook $sqlite
and Existing Connections Store $existingConn
can be use in app's components
- in a
component
file
<template>
<div id="no-encryption-container">
<div v-if="showSpinner">
<br>
<LoadingSpinner />
<div>
<span class="spinner">Running tests ...</span>
</div>
</div>
<div v-else id="log">
<pre>
<p>{{log}}</p>
</pre>
<div v-if="errMess.length > 0">
<p>{{errMess}}</p>}
</div>
</div>
</div>
</template>
<script lang="ts">
import { defineComponent, onMounted, getCurrentInstance } from 'vue';
import { createTablesNoEncryption, importTwoUsers,
dropTablesTablesNoEncryption } from '@/utils/utils-db-no-encryption';
import { useState } from '@/composables/state';
import LoadingSpinner from '@/components/LoadingSpinner.vue'
import { SQLiteDBConnection, SQLiteHook } from 'vue-sqlite-hook/dist';
import { deleteDatabase } from '@/utils/utils-delete-db';
import { Dialog } from '@capacitor/dialog';
export default defineComponent({
name: 'NoEncryptionTest',
components: {
LoadingSpinner
},
setup() {
console.log('$$$ Start NoEncryptionTest setup $$$')
const [showSpinner, setShowSpinner] = useState(true);
const [log, setLog] = useState("");
const app = getCurrentInstance()
const sqlite: SQLiteHook = app?.appContext.config.globalProperties.$sqlite;
let errMess = "";
const showAlert = async (message: string) => {
await Dialog.alert({
title: 'Error Dialog',
message: message,
});
};
const noEncryptionTest = async (): Promise<boolean> => {
try {
console.log(' Starting testDatabaseNoEncryption')
setLog(log.value
.concat("* Starting testDatabaseNoEncryption *\n"));
// test the plugin with echo
let res: any = await sqlite.echo("Hello from echo");
if(res.value !== "Hello from echo"){
errMess = `Echo not returning "Hello from echo"`;
return false;
}
console.log(`after echo ${JSON.stringify(res)}`);
setLog(log.value.concat("> Echo successful\n"));
// create a connection for NoEncryption
const db: SQLiteDBConnection = await sqlite.createConnection("NoEncryption");
setLog(log.value.concat("> createConnection " +
" 'NoEncryption' successful\n"));
console.log("after createConnection")
// check if the databases exist
// and delete it for multiple successive tests
await deleteDatabase(db);
// open NoEncryption database
await db.open();
setLog(log.value.concat("> open 'NoEncryption' successful\n"));
// Drop tables if exists
res = await db.execute(dropTablesTablesNoEncryption);
if(res.changes.changes !== 0 &&
res.changes.changes !== 1){
errMess = `Execute dropTablesTablesNoEncryption changes < 0`;
return false;
}
setLog(log.value.concat(" Execute1 successful\n"));
// Create tables
res = await db.execute(createTablesNoEncryption);
if (res.changes.changes < 0) {
errMess = `Execute createTablesNoEncryption changes < 0`;
return false;
}
setLog(log.value.concat(" Execute2 successful\n"));
// Insert two users with execute method
res = await db.execute(importTwoUsers);
if (res.changes.changes !== 2) {
errMess = `Execute importTwoUsers changes != 2`;
return false;
}
setLog(log.value.concat(" Execute3 successful\n"));
// Select all Users
res = await db.query("SELECT * FROM users");
if(res.values.length !== 2 ||
res.values[0].name !== "Whiteley" ||
res.values[1].name !== "Jones") {
errMess = `Query not returning 2 values`;
return false;
}
setLog(log.value.concat(" Select1 successful\n"));
// add one user with statement and values
let sqlcmd = "INSERT INTO users (name,email,age) VALUES (?,?,?)";
let values: Array<any> = ["Simpson","[email protected]",69];
res = await db.run(sqlcmd,values);
if(res.changes.changes !== 1 ||
res.changes.lastId !== 3) {
errMess = `Run lastId != 3`;
return false;
}
setLog(log.value.concat(" Run1 successful\n"));
// add one user with statement
sqlcmd = `INSERT INTO users (name,email,age) VALUES `+
`("Brown","[email protected]",15)`;
res = await db.run(sqlcmd);
if(res.changes.changes !== 1 ||
res.changes.lastId !== 4) {
errMess = `Run lastId != 4`;
return false;
}
setLog(log.value.concat(" Run2 successful\n"));
// Select all Users
res = await db.query("SELECT * FROM users");
if(res.values.length !== 4) {
errMess = `Query not returning 4 values`;
return false;
}
setLog(log.value.concat(" Select2 successful\n"));
// Select Users with age > 35
sqlcmd = "SELECT name,email,age FROM users WHERE age > ?";
values = ["35"];
res = await db.query(sqlcmd,values);
if(res.values.length !== 2) {
errMess = `Query > 35 not returning 2 values`;
return false;
}
setLog(log.value
.concat(" Select with filter on age successful\n"));
// Close Connection NoEncryption
await sqlite.closeConnection("NoEncryption");
setLog(log.value
.concat("* Ending testDatabaseNoEncryption *\n"));
return true;
} catch (err) {
errMess = `${err.message}`;
return false;
}
};
onMounted(async () => {
// Running the test
console.log('$$$ Start NoEncryptionTest on Mounted $$$')
const retNoEncryption: boolean = await noEncryptionTest();
console.log(`retNoEncryption ${retNoEncryption}`);
setShowSpinner(false);
if(!retNoEncryption) {
setLog(log.value
.concat("* testDatabaseNoEncryption failed *\n"));
setLog(log.value
.concat("\n* The set of tests failed *\n"));
await showAlert(errMess);
} else {
setLog(log.value
.concat("\n* The set of tests was successful *\n"));
}
console.log('$$$ End NoEncryptionTest on Mounted $$$')
});
console.log('$$$ End NoEncryptionTest setup $$$')
return { log, showSpinner, errMess };
},
});
</script>
Where
@/utils/utils-db-no-encryption
import { capSQLiteSet } from '@capacitor-community/sqlite';
export const createTablesNoEncryption = `
CREATE TABLE IF NOT EXISTS users (
id INTEGER PRIMARY KEY NOT NULL,
email TEXT UNIQUE NOT NULL,
name TEXT,
company TEXT,
size REAL,
age INTEGER,
last_modified INTEGER DEFAULT (strftime('%s', 'now'))
);
CREATE TABLE IF NOT EXISTS messages (
id INTEGER PRIMARY KEY NOT NULL,
userid INTEGER,
title TEXT NOT NULL,
body TEXT NOT NULL,
last_modified INTEGER DEFAULT (strftime('%s', 'now')),
FOREIGN KEY (userid) REFERENCES users(id) ON DELETE SET DEFAULT
);
CREATE INDEX IF NOT EXISTS users_index_name ON users (name);
CREATE INDEX IF NOT EXISTS users_index_last_modified ON users (last_modified);
CREATE INDEX IF NOT EXISTS messages_index_last_modified ON messages (last_modified);
CREATE TRIGGER IF NOT EXISTS users_trigger_last_modified
AFTER UPDATE ON users
FOR EACH ROW WHEN NEW.last_modified <= OLD.last_modified
BEGIN
UPDATE users SET last_modified= (strftime('%s', 'now')) WHERE id=OLD.id;
END;
CREATE TRIGGER IF NOT EXISTS messages_trigger_last_modified AFTER UPDATE ON messages
FOR EACH ROW WHEN NEW.last_modified <= OLD.last_modified
BEGIN
UPDATE messages SET last_modified= (strftime('%s', 'now')) WHERE id=OLD.id;
END;
PRAGMA user_version = 1;
`;
export const importTwoUsers = `
DELETE FROM users;
INSERT INTO users (name,email,age) VALUES ("Whiteley","Whiteley.com",30);
INSERT INTO users (name,email,age) VALUES ("Jones","Jones.com",44);
`;
export const importThreeMessages = `
DELETE FROM messages;
INSERT INTO messages (userid,title,body) VALUES (1,"test post 1","content test post 1");
INSERT INTO messages (userid,title,body) VALUES (2,"test post 2","content test post 2");
INSERT INTO messages (userid,title,body) VALUES (1,"test post 3","content test post 3");
`;
export const dropTablesTablesNoEncryption = `
PRAGMA foreign_keys = OFF;
DROP TABLE IF EXISTS users;
DROP TABLE IF EXISTS messages;
PRAGMA foreign_keys = ON;
`;
export const setUsers: Array<capSQLiteSet> = [
{
statement: 'INSERT INTO users (name,email,age) VALUES (?,?,?);',
values: ['Jackson', '[email protected]', 18],
},
{
statement: 'INSERT INTO users (name,email,age) VALUES (?,?,?);',
values: ['Kennedy', '[email protected]', 25],
},
{
statement: 'INSERT INTO users (name,email,age) VALUES (?,?,?);',
values: ['Bush', '[email protected]', 42],
},
];
@/utils/utils-db-encrypted-set
import { capSQLiteSet } from '@capacitor-community/sqlite';
export const createSchemaContacts = `
CREATE TABLE IF NOT EXISTS contacts (
id INTEGER PRIMARY KEY NOT NULL,
email TEXT UNIQUE NOT NULL,
name TEXT,
FirstName TEXT,
company TEXT,
size REAL,
age INTEGER,
MobileNumber TEXT
);
CREATE INDEX IF NOT EXISTS contacts_index_name ON contacts (name);
CREATE INDEX IF NOT EXISTS contacts_index_email ON contacts (email);
PRAGMA user_version = 1;
`;
export const setContacts: Array<capSQLiteSet> = [
{
statement:
'INSERT INTO contacts (name,FirstName,email,age,MobileNumber) VALUES (?,?,?,?,?);',
values: ['Simpson', 'Tom', '[email protected]', 69, '4405060708'],
},
{
statement:
'INSERT INTO contacts (name,FirstName,email,age,MobileNumber) VALUES (?,?,?,?,?);',
values: ['Jones', 'David', '[email protected]', 42, '4404030201'],
},
{
statement:
'INSERT INTO contacts (name,FirstName,email,age,MobileNumber) VALUES (?,?,?,?,?);',
values: ['Whiteley', 'Dave', '[email protected]', 45, '4405162732'],
},
{
statement:
'INSERT INTO contacts (name,FirstName,email,age,MobileNumber) VALUES (?,?,?,?,?);',
values: ['Brown', 'John', '[email protected]', 35, '4405243853'],
},
{
statement: 'UPDATE contacts SET age = ? , MobileNumber = ? WHERE id = ?;',
values: [51, '4404030202', 2],
},
];
export const createSchemaMessages = `
CREATE TABLE IF NOT EXISTS messages (
id INTEGER PRIMARY KEY NOT NULL,
contactid INTEGER,
title TEXT NOT NULL,
body TEXT NOT NULL,
last_modified INTEGER DEFAULT (strftime('%s', 'now')),
FOREIGN KEY (contactid) REFERENCES contacts(id) ON DELETE SET DEFAULT
);
CREATE INDEX IF NOT EXISTS messages_index_name ON messages (title);
CREATE INDEX IF NOT EXISTS messages_index_last_modified ON messages (last_modified);
`;
export const setMessages: Array<capSQLiteSet> = [
{
statement: 'INSERT INTO messages (contactid,title,body) VALUES (?,?,?);',
values: [1, 'message 1', 'body message1'],
},
{
statement: 'INSERT INTO messages (contactid,title,body) VALUES (?,?,?);',
values: [2, 'message 2', 'body message2'],
},
{
statement: 'INSERT INTO messages (contactid,title,body) VALUES (?,?,?);',
values: [1, 'message 3', 'body message3'],
},
];
@/utils/utils-delete-db
import { SQLiteDBConnection } from '@capacitor-community/sqlite';
export async function deleteDatabase(db: SQLiteDBConnection): Promise<void> {
try {
const ret: any = await db.isExists();
if(ret.result) {
const dbName = db.getConnectionDBName();
console.log("$$$ database " + dbName + " before delete");
await db.delete();
console.log("$$$ database " + dbName + " after delete " + ret.result);
return Promise.resolve();
} else {
return Promise.resolve();
}
} catch (err) {
return Promise.reject(err);
}
}
composables/state.ts
import { readonly, ref } from 'vue';
// eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types
export function useState(initialState: any): any {
const state = ref(initialState);
const setState = (newState: any) => {
state.value = newState;
};
return [readonly(state), setState];
}