feat(examples): modify to use isConnect()

Author: Daniele Briggi

README.md

@@ -54,7 +54,7 @@ let database = new Database('sqlitecloud://user:password@xxx.sqlite.cloud:8860/c
 
 let name = 'Breaking The Rules'
 
-let results = await database.sql`SELECT * FROM tracks WHERE name = ${name}`
+let results = await database.sql('SELECT * FROM tracks WHERE name = ?', name)
 // => returns [{ AlbumId: 1, Name: 'Breaking The Rules', Composer: 'Angus Young... }]
 ```
 
@@ -82,7 +82,7 @@ await pubSub.listen(PUBSUB_ENTITY_TYPE.TABLE, 'albums', (error, results, data) =
   }
 })
 
-await database.sql`INSERT INTO albums (Title, ArtistId) values ('Brand new song', 1)`
+await database.sql("INSERT INTO albums (Title, ArtistId) values ('Brand new song', 1)")
 
 // Stop listening changes on the table
 await pubSub.unlisten(PUBSUB_ENTITY_TYPE.TABLE, 'albums')

examples/with-javascript-browser/index.html

@@ -48,7 +48,7 @@ <h2 class="pb-4">Results:</h2>
         var database = null;
 
         sendButton.addEventListener('click', () => {
-            if (!database) {
+            if (!database || !database.isConnected()) {
                 // Get the input element by ID
                 var connectionStringinputElement = document.getElementById('connectionStringInput');
                 var connectionstring = connectionStringinputElement.value;

examples/with-javascript-expo/components/AddTaskModal.js

@@ -2,7 +2,7 @@ import React, { useState, useEffect } from "react";
 import { View, StyleSheet, Alert, Platform } from "react-native";
 import { TextInput, Button, Modal } from "react-native-paper";
 import DropdownMenu from "./DropdownMenu";
-import db from "../db/dbConnection";
+import getDbConnection from "../db/dbConnection";
 
 export default AddTaskModal = ({
   modalVisible,
@@ -30,7 +30,7 @@ export default AddTaskModal = ({
 
   const getTags = async () => {
     try {
-      const tags = await db.sql("SELECT * FROM tags");
+      const tags = await getDbConnection().sql("SELECT * FROM tags");
       setTagsList(tags);
     } catch (error) {
       console.error("Error getting tags", error);

examples/with-javascript-expo/db/dbConnection.js

@@ -1,4 +1,14 @@
 import { DATABASE_URL } from "@env";
 import { Database } from "@sqlitecloud/drivers";
 
-export default db = new Database(DATABASE_URL);
+/**
+ * @type {Database}
+ */
+let database = null;
+
+export function getDbConnection() {
+    if (!database || !database.isConnected()) {
+        database = new Database(DATABASE_URL);
+    }
+    return database;
+}

examples/with-javascript-expo/hooks/useCategories.js

@@ -1,12 +1,12 @@
 import { useState, useEffect } from "react";
-import db from "../db/dbConnection";
+import getDbConnection from "../db/dbConnection";
 
 const useCategories = () => {
   const [moreCategories, setMoreCategories] = useState(["Work", "Personal"]);
 
   const getCategories = async () => {
     try {
-      const tags = await db.sql("SELECT * FROM tags");
+      const tags = await getDbConnection().sql("SELECT * FROM tags");
       const filteredTags = tags.filter((tag) => {
         return tag["name"] !== "Work" && tag["name"] !== "Personal";
       });
@@ -21,7 +21,7 @@ const useCategories = () => {
 
   const addCategory = async (newCategory) => {
     try {
-      await db.sql(
+      await getDbConnection().sql(
         "INSERT INTO tags (name) VALUES (?) RETURNING *",
         newCategory
       );
@@ -33,15 +33,15 @@ const useCategories = () => {
 
   const initializeTables = async () => {
     try {
-      const createTasksTable = await db.sql(
+      const createTasksTable = await getDbConnection().sql(
         "CREATE TABLE IF NOT EXISTS tasks (id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL, isCompleted INT NOT NULL);"
       );
 
-      const createTagsTable = await db.sql(
+      const createTagsTable = await getDbConnection().sql(
         "CREATE TABLE IF NOT EXISTS tags (id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, UNIQUE(name));"
       );
 
-      const createTagsTasksTable = await db.sql(
+      const createTagsTasksTable = await getDbConnection().sql(
         "CREATE TABLE IF NOT EXISTS tasks_tags (id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, task_id INTEGER NOT NULL, tag_id INTEGER NOT NULL, FOREIGN KEY (task_id) REFERENCES tasks(id), FOREIGN KEY (tag_id) REFERENCES tags(id));"
       );
 
@@ -52,8 +52,8 @@ const useCategories = () => {
       ) {
         console.log("Successfully created tables");
 
-        await db.sql("INSERT OR IGNORE INTO tags (name) VALUES (?)", "Work");
-        await db.sql(
+        await getDbConnection().sql("INSERT OR IGNORE INTO tags (name) VALUES (?)", "Work");
+        await getDbConnection().sql(
           "INSERT OR IGNORE INTO tags (name) VALUES (?)",
           "Personal"
         );

examples/with-javascript-expo/hooks/useTasks.js

@@ -1,5 +1,5 @@
 import { useState, useEffect, useCallback } from "react";
-import db from "../db/dbConnection";
+import getDbConnection from "../db/dbConnection";
 
 const useTasks = (tag = null) => {
   const [taskList, setTaskList] = useState([]);
@@ -8,7 +8,7 @@ const useTasks = (tag = null) => {
     try {
       let result;
       if (tag) {
-        result = await db.sql(
+        result = await getDbConnection().sql(
           `
           SELECT tasks.*, tags.id AS tag_id, tags.name AS tag_name 
           FROM tasks 
@@ -19,11 +19,11 @@ const useTasks = (tag = null) => {
         );
         setTaskList(result);
       } else {
-        result = await db.sql`
+        result = await getDbConnection().sql(`
           SELECT tasks.*, tags.id AS tag_id, tags.name AS tag_name 
           FROM tasks 
           JOIN tasks_tags ON tasks.id = tasks_tags.task_id 
-          JOIN tags ON tags.id = tasks_tags.tag_id`;
+          JOIN tags ON tags.id = tasks_tags.tag_id`);
         setTaskList(result);
       }
     } catch (error) {
@@ -33,7 +33,7 @@ const useTasks = (tag = null) => {
 
   const updateTask = async (completedStatus, taskId) => {
     try {
-      await db.sql(
+      await getDbConnection().sql(
         "UPDATE tasks SET isCompleted=? WHERE id=? RETURNING *",
         completedStatus,
         taskId
@@ -47,21 +47,21 @@ const useTasks = (tag = null) => {
   const addTaskTag = async (newTask, tag) => {
     try {
       if (tag.id) {
-        const addNewTask = await db.sql(
+        const addNewTask = await getDbConnection().sql(
           "INSERT INTO tasks (title, isCompleted) VALUES (?, ?) RETURNING *",
           newTask.title,
           newTask.isCompleted
         );
         addNewTask[0].tag_id = tag.id;
         addNewTask[0].tag_name = tag.name;
         setTaskList([...taskList, addNewTask[0]]);
-        await db.sql(
+        await getDbConnection().sql(
           "INSERT INTO tasks_tags (task_id, tag_id) VALUES (?, ?)",
           addNewTask[0].id,
           tag.id
         );
       } else {
-        const addNewTaskNoTag = await db.sql(
+        const addNewTaskNoTag = await getDbConnection().sql(
           "INSERT INTO tasks (title, isCompleted) VALUES (?, ?) RETURNING *",
           newTask.title,
           newTask.isCompleted
@@ -75,8 +75,8 @@ const useTasks = (tag = null) => {
 
   const deleteTask = async (taskId) => {
     try {
-      await db.sql("DELETE FROM tasks_tags WHERE task_id=?", taskId);
-      const result = await db.sql("DELETE FROM tasks WHERE id=?", taskId);
+      await getDbConnection().sql("DELETE FROM tasks_tags WHERE task_id=?", taskId);
+      const result = await getDbConnection().sql("DELETE FROM tasks WHERE id=?", taskId);
       console.log(`Deleted ${result.totalChanges} task`);
       getTasks();
     } catch (error) {

examples/with-javascript-express/app.js

@@ -15,7 +15,7 @@ app.use(express.json())
 /* http://localhost:3001/ returns chinook tracks as json */
 app.get('/', async function (req, res, next) {
   var database = new sqlitecloud.Database(DATABASE_URL)
-  var tracks = await database.sql`USE DATABASE chinook.sqlite; SELECT * FROM tracks LIMIT 20;`
+  var tracks = await database.sql('USE DATABASE chinook.sqlite; SELECT * FROM tracks LIMIT 20;')
   res.send({ tracks })
 })
 

examples/with-javascript-vite/src/App.jsx

@@ -1,20 +1,29 @@
 import { useEffect, useState } from "react";
 import { Database } from "@sqlitecloud/drivers";
 
-const db = new Database(import.meta.env.VITE_DATABASE_URL);
+let db = null
+
+function getDatabase() {
+  if (!db || !db.isConnected()) {
+    db = new Database("chinook.sqlite");
+  }
+
+  return db;
+}
+
 
 function App() {
   const [data, setData] = useState([]);
 
   const getAlbums = async () => {
-    const result = await db.sql`
+    const result = await getDatabase().sql(`
       USE DATABASE chinook.sqlite; 
       SELECT albums.AlbumId as id, albums.Title as title, artists.name as artist
       FROM albums 
       INNER JOIN artists 
       WHERE artists.ArtistId = albums.ArtistId
       LIMIT 20;
-    `;
+    `);
     setData(result);
   };
 

examples/with-plain-javascript/app.js

@@ -13,7 +13,7 @@ async function selectTracks() {
   var database = new sqlitecloud.Database(DATABASE_URL)
 
   // run async query
-  var tracks = await database.sql`USE DATABASE chinook.sqlite; SELECT * FROM tracks LIMIT 20;`
+  var tracks = await database.sql('USE DATABASE chinook.sqlite; SELECT * FROM tracks LIMIT 20;')
   console.log(`selectTracks returned:`, tracks)
 
   // You can also use all the regular sqlite3 api with callbacks, see:

examples/with-typescript-nextjs/app/api/hello/route.ts

@@ -15,7 +15,7 @@ export async function GET(request: NextRequest) {
   const database = new Database(DATABASE_URL)
 
   // retrieve rows from chinook database using a plain SQL query
-  const tracks = await database.sql`USE DATABASE chinook.sqlite; SELECT * FROM tracks LIMIT 20;`
+  const tracks = await database.sql('USE DATABASE chinook.sqlite; SELECT * FROM tracks LIMIT 20;')
 
   // return as json response
   return NextResponse.json<{ data: any }>({ data: tracks })