sqlite

Author: bradwestfall

chinook.db

@@ -1,4 +1,4 @@
-// import './app.ts'
+// import './app'
 import * as http from 'http'
 
 const hostname = '127.0.0.1'

database.db

@@ -1,27 +1,16 @@
-// Okay you caught us, it was all fake. But we can't really expect you
-// to setup local databases on your machine specifically for a workshop.
-// If you did use a third party database driver for an SQL-based
-// database, it would probably work a little like this:
-// db.query('SELECT ...').then(results => {})
+import path from 'path'
+import sqlite3 from 'sqlite3'
 
-const data = [
-  { id: 1, name: 'Michael Jackson' },
-  { id: 2, name: 'Ryan Florence' },
-  { id: 3, name: 'Brad Westfall' },
-  { id: 4, name: 'Chance Stickland' },
-]
+const db = new sqlite3.Database(path.resolve(__dirname, 'database.db'))
 
-export const db = {
-  query: (sql: string) => {
-    if (!sql.startsWith('SELECT')) return Promise.reject('Invalid SQL, must start with SELECT')
-
-    const results = data.filter((row) => {
-      const formatted = sql.toLowerCase().replace(/(`|')/g, '')
-      if (formatted === 'select * from user') return true
-      const matches = formatted.match(/id = (\d+)/)
-      return matches ? row.id === parseInt(matches[1], 10) : false
+export function query(sql: string) {
+  return new Promise((resolve, reject) => {
+    db.all(sql, (err, rows) => {
+      if (err) {
+        reject(err.message)
+      } else {
+        resolve(rows || [])
+      }
     })
-
-    return Promise.resolve(results)
-  },
+  })
 }

lessons/06-server/lecture/index.ts

@@ -1,5 +1,6 @@
 import express from 'express'
-import { db } from './db'
+import { query } from './db'
+
 const app = express()
 const port = 3000
 
@@ -8,7 +9,7 @@ app.get('/', (req, res) => {
 })
 
 app.get('/users', (req, res, next) => {
-  db.query('SELECT * FROM user')
+  query('SELECT * FROM user')
     .then((results) => {
       res.json(results)
     })
@@ -21,8 +22,8 @@ app.get('/users/:id', (req, res, next) => {
     next()
     return
   }
-  db.query(`SELECT * FROM user WHERE user.id = '${id}'`)
-    .then((results) => {
+  query(`SELECT * FROM user WHERE user.id = '${id}'`)
+    .then((results: any) => {
       if (results.length === 0) {
         next()
         return

lessons/06-server/practice/database.db

@@ -1,5 +1,6 @@
 import express from 'express'
-import { db } from './db'
+import { query } from './db'
+// import './index.final'
 
 const app = express()
 const port = 3000

lessons/06-server/practice/db.ts

@@ -0,0 +1,4 @@
+{
+  "watch": ["lessons"],
+  "ext": "ts,tsx,json,csv"
+}