diff --git a/Chapter07/leveldb-app/tasks.js b/Chapter07/leveldb-app/tasks.js index eaa6db4..4f04cef 100644 --- a/Chapter07/leveldb-app/tasks.js +++ b/Chapter07/leveldb-app/tasks.js @@ -1,26 +1,26 @@ -const levelup = require('levelup') -const leveldown = require('leveldown') +const levelup = require("levelup"); +const leveldown = require("leveldown"); -const db = levelup(leveldown('./data')) +const db = levelup(leveldown("./data")); -const task = process.argv[2] +const task = process.argv[2]; if (!task) { - listTasks() + listTasks(); } else { - addTask() + addTask(); } function addTask() { - const key = `Task: ${Math.random().toString(32).replace('.', '')}` - db.put(key, task, (err) => { - if (err) throw err - listTasks() - }) + const key = `Task: ${Math.random().toString(32).replace(".", "")}`; + db.put(key, task, (err) => { + if (err) throw err; + listTasks(); + }); } function listTasks() { - db.createReadStream().on('data', (data) => { - console.log(data.key.toString(), '=', data.value.toString()) - }) -} \ No newline at end of file + db.createReadStream().on("data", (data) => { + console.log(data.key.toString(), "=", data.value.toString()); + }); +} diff --git a/Chapter07/leveldb-filter/filter.js b/Chapter07/leveldb-filter/filter.js index eed5950..e0b73ea 100644 --- a/Chapter07/leveldb-filter/filter.js +++ b/Chapter07/leveldb-filter/filter.js @@ -1,25 +1,21 @@ -const levelup = require('levelup') -const leveldown = require('leveldown') -const db = levelup(leveldown('./data')) +const levelup = require("levelup"); +const leveldown = require("leveldown"); +const db = levelup(leveldown("./data")); -db.put('Task:1', '') -db.put('Task:2', '') -db.put('Task:3', '') -db.put('Task:4', '') +db.put("Task:1", ""); +db.put("Task:2", ""); +db.put("Task:3", ""); +db.put("Task:4", ""); db.createReadStream({ - gte: 'Task:1', - lte: 'Task:3' -}).on('data', function (data) { - console.log(data.key.toString()) -}) - - - - + gte: "Task:1", + lte: "Task:3", +}).on("data", function (data) { + console.log(data.key.toString()); +}); db.batch() - .put('forename', 'Beth') - .put('surname', 'Griggs') - .del('forename') - .write(() => console.log('Batch operations complete.')) \ No newline at end of file + .put("forename", "Beth") + .put("surname", "Griggs") + .del("forename") + .write(() => console.log("Batch operations complete.")); diff --git a/Chapter07/leveldb-memdown-app/tasks.js b/Chapter07/leveldb-memdown-app/tasks.js index eaa6db4..4f04cef 100644 --- a/Chapter07/leveldb-memdown-app/tasks.js +++ b/Chapter07/leveldb-memdown-app/tasks.js @@ -1,26 +1,26 @@ -const levelup = require('levelup') -const leveldown = require('leveldown') +const levelup = require("levelup"); +const leveldown = require("leveldown"); -const db = levelup(leveldown('./data')) +const db = levelup(leveldown("./data")); -const task = process.argv[2] +const task = process.argv[2]; if (!task) { - listTasks() + listTasks(); } else { - addTask() + addTask(); } function addTask() { - const key = `Task: ${Math.random().toString(32).replace('.', '')}` - db.put(key, task, (err) => { - if (err) throw err - listTasks() - }) + const key = `Task: ${Math.random().toString(32).replace(".", "")}`; + db.put(key, task, (err) => { + if (err) throw err; + listTasks(); + }); } function listTasks() { - db.createReadStream().on('data', (data) => { - console.log(data.key.toString(), '=', data.value.toString()) - }) -} \ No newline at end of file + db.createReadStream().on("data", (data) => { + console.log(data.key.toString(), "=", data.value.toString()); + }); +} diff --git a/Chapter07/leveldb-sql-app/tasks.js b/Chapter07/leveldb-sql-app/tasks.js index 2d41156..ad97703 100644 --- a/Chapter07/leveldb-sql-app/tasks.js +++ b/Chapter07/leveldb-sql-app/tasks.js @@ -1,26 +1,26 @@ -const levelup = require('levelup') -const memdown = require('memdown') +const levelup = require("levelup"); +const memdown = require("memdown"); -const db = levelup(memdown('./data')) +const db = levelup(memdown("./data")); -const task = process.argv[2] +const task = process.argv[2]; if (!task) { - listTasks() + listTasks(); } else { - addTask() + addTask(); } function addTask() { - const key = `Task: ${Math.random().toString(32).replace('.', '')}` - db.put(key, task, (err) => { - if (err) throw err - listTasks() - }) + const key = `Task: ${Math.random().toString(32).replace(".", "")}`; + db.put(key, task, (err) => { + if (err) throw err; + listTasks(); + }); } function listTasks() { - db.createReadStream().on('data', (data) => { - console.log(data.key.toString(), '=', data.value.toString()) - }) -} \ No newline at end of file + db.createReadStream().on("data", (data) => { + console.log(data.key.toString(), "=", data.value.toString()); + }); +} diff --git a/Chapter07/mongodb-app/tasks.js b/Chapter07/mongodb-app/tasks.js index 8314493..dce4126 100644 --- a/Chapter07/mongodb-app/tasks.js +++ b/Chapter07/mongodb-app/tasks.js @@ -1,42 +1,47 @@ -const { - MongoClient -} = require('mongodb') -const task = process.argv[2] +const { MongoClient } = require("mongodb"); +const task = process.argv[2]; -const URI = 'mongodb://localhost:27017/' +const URI = "mongodb://localhost:27017/"; -MongoClient.connect(URI, { - useUnifiedTopology: true -}, connected) +MongoClient.connect( + URI, + { + useUnifiedTopology: true, + }, + connected +); function connected(err, client) { - if (err) throw err - const tasks = client.db('tasklist').collection('tasks') + if (err) throw err; + const tasks = client.db("tasklist").collection("tasks"); - if (task) { - addTask(client, tasks) - } else { - listTasks(client, tasks) - } + if (task) { + addTask(client, tasks); + } else { + listTasks(client, tasks); + } } function addTask(client, tasks) { - tasks.insertOne({ - task: task - }, (err) => { - if (err) throw err - console.log("New Task: ", task); - listTasks(client, tasks) - }) + tasks.insertOne( + { + task: task, + }, + (err) => { + if (err) throw err; + console.log("New Task: ", task); + listTasks(client, tasks); + } + ); } function listTasks(client, tasks) { - tasks.find().each((err, doc) => { - if (err) throw err - if (!doc) { - client.close() - return - } - console.log(doc) - }) -} \ No newline at end of file + tasks.find().each((err, doc) => { + if (err) throw err; + if (!doc) { + client.close(); + return; + } + console.log(doc); + }); +} diff --git a/Chapter07/mongoose-app/tasks.js b/Chapter07/mongoose-app/tasks.js index 80b7579..e974930 100644 --- a/Chapter07/mongoose-app/tasks.js +++ b/Chapter07/mongoose-app/tasks.js @@ -1,23 +1,22 @@ -const mongoose = require('mongoose'); - -const URI = 'mongodb://localhost:27017/customers' +const mongoose = require("mongoose"); +const URI = "mongodb://localhost:27017/customers"; mongoose.connect(URI, { - useNewUrlParser: true, - useUnifiedTopology: true -}) + useNewUrlParser: true, + useUnifiedTopology: true, +}); -const Customer = mongoose.model('Customer', { - forename: String, - surname: String -}) +const Customer = mongoose.model("Customer", { + forename: String, + surname: String, +}); const customer_1 = new Customer({ - forename: 'Beth', - surname: 'Griggs' -}) + forename: "Beth", + surname: "Griggs", +}); customer_1.save().then((doc) => { - console.log('Added new customer', doc.forename, doc.surname) -}) \ No newline at end of file + console.log("Added new customer", doc.forename, doc.surname); +}); diff --git a/Chapter07/mysql-app/index.js b/Chapter07/mysql-app/index.js index 0b0e84a..b346fab 100644 --- a/Chapter07/mysql-app/index.js +++ b/Chapter07/mysql-app/index.js @@ -1,38 +1,40 @@ -require('dotenv').config() -const mysql = require('mysql') +require("dotenv").config(); +const mysql = require("mysql"); const db = mysql.createConnection({ - user: process.env.DB_MYSQL_USER, - password: process.env.DB_MYSQL_PASSWORD -}) + user: process.env.DB_MYSQL_USER, + password: process.env.DB_MYSQL_PASSWORD, +}); -db.query('CREATE DATABASE tasks') -db.query('USE tasks') +db.query("CREATE DATABASE tasks"); +db.query("USE tasks"); db.query( - 'CREATE TABLE tasks.tasks (' + - 'id INT NOT NULL AUTO_INCREMENT, ' + - 'task TEXT NOT NULL, PRIMARY KEY ( id )' + - ')') + "CREATE TABLE tasks.tasks (" + + "id INT NOT NULL AUTO_INCREMENT, " + + "task TEXT NOT NULL, PRIMARY KEY ( id )" + + ")" +); -const ignore = new Set([ - 'ER_DB_CREATE_EXISTS', 'ER_TABLE_EXISTS_ERROR' -]) +const ignore = new Set(["ER_DB_CREATE_EXISTS", "ER_TABLE_EXISTS_ERROR"]); -db.on('error', (err) => { - if (ignore.has(err.code)) return - throw err -}) +db.on("error", (err) => { + if (ignore.has(err.code)) return; + throw err; +}); db.query(` INSERT INTO tasks.tasks (task) VALUES ("Walk the dog"); -`) +`); -db.query(` +db.query( + ` SELECT * FROM tasks.tasks; -`, (err, results) => { - console.log(results) -}) +`, + (err, results) => { + console.log(results); + } +); -db.end() \ No newline at end of file +db.end(); diff --git a/Chapter07/mysql-app/insert.js b/Chapter07/mysql-app/insert.js index 435ad7f..68b2963 100644 --- a/Chapter07/mysql-app/insert.js +++ b/Chapter07/mysql-app/insert.js @@ -1,40 +1,45 @@ -require('dotenv').config() -const mysql = require('mysql') +require("dotenv").config(); +const mysql = require("mysql"); const db = mysql.createConnection({ - user: process.env.DB_MYSQL_USER, - password: process.env.DB_MYSQL_PASSWORD -}) + user: process.env.DB_MYSQL_USER, + password: process.env.DB_MYSQL_PASSWORD, +}); -db.query('CREATE DATABASE tasks') -db.query('USE tasks') +db.query("CREATE DATABASE tasks"); +db.query("USE tasks"); db.query( - 'CREATE TABLE tasks.tasks (' + - 'id INT NOT NULL AUTO_INCREMENT, ' + - 'task TEXT NOT NULL, PRIMARY KEY ( id )' + - ')') + "CREATE TABLE tasks.tasks (" + + "id INT NOT NULL AUTO_INCREMENT, " + + "task TEXT NOT NULL, PRIMARY KEY ( id )" + + ")" +); -const ignore = new Set([ - 'ER_DB_CREATE_EXISTS', 'ER_TABLE_EXISTS_ERROR' -]) +const ignore = new Set(["ER_DB_CREATE_EXISTS", "ER_TABLE_EXISTS_ERROR"]); -db.on('error', (err) => { - if (ignore.has(err.code)) return - throw err -}) +db.on("error", (err) => { + if (ignore.has(err.code)) return; + throw err; +}); if (process.argv[2]) { - db.query(` + db.query( + ` INSERT INTO tasks.tasks (task) VALUES (?); - `, [process.argv[2]]) + `, + [process.argv[2]] + ); } -db.query(` +db.query( + ` SELECT * FROM tasks.tasks; -`, (err, results, fields) => { - console.log(results) -}) +`, + (err, results, fields) => { + console.log(results); + } +); -db.end() \ No newline at end of file +db.end(); diff --git a/Chapter07/postgres-app/tasks.js b/Chapter07/postgres-app/tasks.js index b750f34..fb68975 100644 --- a/Chapter07/postgres-app/tasks.js +++ b/Chapter07/postgres-app/tasks.js @@ -1,32 +1,32 @@ -require('dotenv').config() -const pg = require('pg') -const db = new pg.Client() -const task = process.argv[2] +require("dotenv").config(); +const pg = require("pg"); +const db = new pg.Client(); +const task = process.argv[2]; const CREATE_TABLE_SQL = `CREATE TABLE IF NOT EXISTS tasks - (id SERIAL, task TEXT NOT NULL, PRIMARY KEY ( id ))` -const INSERT_TASK_SQL = `INSERT INTO tasks (task) VALUES ($1);` -const GET_TASKS_SQL = `SELECT * FROM tasks;` + (id SERIAL, task TEXT NOT NULL, PRIMARY KEY ( id ))`; +const INSERT_TASK_SQL = `INSERT INTO tasks (task) VALUES ($1);`; +const GET_TASKS_SQL = `SELECT * FROM tasks;`; db.connect((err) => { - if (err) throw err - db.query(CREATE_TABLE_SQL, (err) => { - if (err) throw err - if (task) { - db.query(INSERT_TASK_SQL, [task], (err) => { - if (err) throw err - listTasks() - }) - } else { - listTasks() - } - }) -}) + if (err) throw err; + db.query(CREATE_TABLE_SQL, (err) => { + if (err) throw err; + if (task) { + db.query(INSERT_TASK_SQL, [task], (err) => { + if (err) throw err; + listTasks(); + }); + } else { + listTasks(); + } + }); +}); function listTasks() { - db.query(GET_TASKS_SQL, (err, results) => { - if (err) throw err - console.log(results.rows); - db.end() - }) -} \ No newline at end of file + db.query(GET_TASKS_SQL, (err, results) => { + if (err) throw err; + console.log(results.rows); + db.end(); + }); +} diff --git a/Chapter07/postgres-object-app/tasks.js b/Chapter07/postgres-object-app/tasks.js index c09e937..4235164 100644 --- a/Chapter07/postgres-object-app/tasks.js +++ b/Chapter07/postgres-object-app/tasks.js @@ -1,32 +1,32 @@ -require('dotenv').config() -const pg = require('pg') -const db = new pg.Client() -const task = process.argv[2] +require("dotenv").config(); +const pg = require("pg"); +const db = new pg.Client(); +const task = process.argv[2]; const CREATE_TABLE_SQL = `CREATE TABLE IF NOT EXISTS task_docs - (id SERIAL, doc jsonb);` -const INSERT_TASK_SQL = `INSERT INTO task_docs (doc) VALUES ($1);` -const GET_TASKS_SQL = `SELECT * FROM task_docs;` + (id SERIAL, doc jsonb);`; +const INSERT_TASK_SQL = `INSERT INTO task_docs (doc) VALUES ($1);`; +const GET_TASKS_SQL = `SELECT * FROM task_docs;`; db.connect((err) => { - if (err) throw err - db.query(CREATE_TABLE_SQL, (err) => { - if (err) throw err - if (task) { - db.query(INSERT_TASK_SQL, [task], (err) => { - if (err) throw err - listTasks() - }) - } else { - listTasks() - } - }) -}) + if (err) throw err; + db.query(CREATE_TABLE_SQL, (err) => { + if (err) throw err; + if (task) { + db.query(INSERT_TASK_SQL, [task], (err) => { + if (err) throw err; + listTasks(); + }); + } else { + listTasks(); + } + }); +}); function listTasks() { - db.query(GET_TASKS_SQL, (err, results) => { - if (err) throw err - console.log(results.rows); - db.end() - }) -} \ No newline at end of file + db.query(GET_TASKS_SQL, (err, results) => { + if (err) throw err; + console.log(results.rows); + db.end(); + }); +} diff --git a/Chapter07/redis-app/tasks-auth.js b/Chapter07/redis-app/tasks-auth.js index f5efac8..e1cc37f 100644 --- a/Chapter07/redis-app/tasks-auth.js +++ b/Chapter07/redis-app/tasks-auth.js @@ -1,37 +1,37 @@ -const redis = require('redis') +const redis = require("redis"); const client = redis.createClient({ - port: 6380, - password: "PASSWORD" -}) -const task = process.argv[2] + port: 6380, + password: "PASSWORD", +}); +const task = process.argv[2]; -client.on('error', (err) => { - console.log("Error:", err) -}) +client.on("error", (err) => { + console.log("Error:", err); +}); if (!task) { - listTasks() + listTasks(); } else { - addTask(task) + addTask(task); } function addTask(task) { - const key = `Task: ${Math.random().toString(32).replace('.', '')}` - client.hmset(key, { - task - }) - listTasks() + const key = `Task: ${Math.random().toString(32).replace(".", "")}`; + client.hmset(key, { + task, + }); + listTasks(); } function listTasks() { - client.keys('Task:*', (err, keys) => { - if (err) throw err - keys.forEach(key => { - client.hgetall(key, (err, task) => { - if (err) throw err - console.log(task) - }) - }) - client.quit() - }) -} \ No newline at end of file + client.keys("Task:*", (err, keys) => { + if (err) throw err; + keys.forEach((key) => { + client.hgetall(key, (err, task) => { + if (err) throw err; + console.log(task); + }); + }); + client.quit(); + }); +} diff --git a/Chapter07/redis-app/tasks.js b/Chapter07/redis-app/tasks.js index 6489729..8482fbe 100644 --- a/Chapter07/redis-app/tasks.js +++ b/Chapter07/redis-app/tasks.js @@ -1,34 +1,34 @@ -const redis = require('redis') -const client = redis.createClient() -const task = process.argv[2] +const redis = require("redis"); +const client = redis.createClient(); +const task = process.argv[2]; -client.on('error', (err) => { - console.log("Error:", err) -}) +client.on("error", (err) => { + console.log("Error:", err); +}); if (!task) { - listTasks() + listTasks(); } else { - addTask(task) + addTask(task); } function addTask(task) { - const key = `Task: ${Math.random().toString(32).replace('.', '')}` - client.hmset(key, { - task - }) - listTasks() + const key = `Task: ${Math.random().toString(32).replace(".", "")}`; + client.hmset(key, { + task, + }); + listTasks(); } function listTasks() { - client.keys('Task:*', (err, keys) => { - if (err) throw err - keys.forEach(key => { - client.hgetall(key, (err, task) => { - if (err) throw err - console.log(task) - }) - }) - client.quit() - }) -} \ No newline at end of file + client.keys("Task:*", (err, keys) => { + if (err) throw err; + keys.forEach((key) => { + client.hgetall(key, (err, task) => { + if (err) throw err; + console.log(task); + }); + }); + client.quit(); + }); +}