ecki/Node.js-14-Cookbook
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Chapter 7: prettier

Browse Source
This commit is contained in:
Beth Griggs
2020-05-20 12:05:00 +01:00
parent a0cf6a254c
commit 85007a6879
12 changed files with 269 additions and 262 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Chapter07/leveldb-app/tasks.js
+15 -15
View File
@@ -1,26 +1,26 @@
const levelup = require('levelup') const levelup = require("levelup");
const leveldown = require('leveldown') 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) { if (!task) {
listTasks() listTasks();
} else { } else {
addTask() addTask();
} }
function addTask() { function addTask() {
const key = `Task: ${Math.random().toString(32).replace('.', '')}` const key = `Task: ${Math.random().toString(32).replace(".", "")}`;
db.put(key, task, (err) => { db.put(key, task, (err) => {
if (err) throw err if (err) throw err;
listTasks() listTasks();
}) });
} }
function listTasks() { function listTasks() {
db.createReadStream().on('data', (data) => { db.createReadStream().on("data", (data) => {
console.log(data.key.toString(), '=', data.value.toString()) console.log(data.key.toString(), "=", data.value.toString());
}) });
} }
Chapter07/leveldb-filter/filter.js
+16 -20
View File
@@ -1,25 +1,21 @@
const levelup = require('levelup') const levelup = require("levelup");
const leveldown = require('leveldown') const leveldown = require("leveldown");
const db = levelup(leveldown('./data')) const db = levelup(leveldown("./data"));
db.put('Task:1', '') db.put("Task:1", "");
db.put('Task:2', '') db.put("Task:2", "");
db.put('Task:3', '') db.put("Task:3", "");
db.put('Task:4', '') db.put("Task:4", "");
db.createReadStream({ db.createReadStream({
gte: 'Task:1', gte: "Task:1",
lte: 'Task:3' lte: "Task:3",
}).on('data', function (data) { }).on("data", function (data) {
console.log(data.key.toString()) console.log(data.key.toString());
}) });
db.batch() db.batch()
.put('forename', 'Beth') .put("forename", "Beth")
.put('surname', 'Griggs') .put("surname", "Griggs")
.del('forename') .del("forename")
.write(() => console.log('Batch operations complete.')) .write(() => console.log("Batch operations complete."));
Chapter07/leveldb-memdown-app/tasks.js
+15 -15
View File
@@ -1,26 +1,26 @@
const levelup = require('levelup') const levelup = require("levelup");
const leveldown = require('leveldown') 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) { if (!task) {
listTasks() listTasks();
} else { } else {
addTask() addTask();
} }
function addTask() { function addTask() {
const key = `Task: ${Math.random().toString(32).replace('.', '')}` const key = `Task: ${Math.random().toString(32).replace(".", "")}`;
db.put(key, task, (err) => { db.put(key, task, (err) => {
if (err) throw err if (err) throw err;
listTasks() listTasks();
}) });
} }
function listTasks() { function listTasks() {
db.createReadStream().on('data', (data) => { db.createReadStream().on("data", (data) => {
console.log(data.key.toString(), '=', data.value.toString()) console.log(data.key.toString(), "=", data.value.toString());
}) });
} }
Chapter07/leveldb-sql-app/tasks.js
+15 -15
View File
@@ -1,26 +1,26 @@
const levelup = require('levelup') const levelup = require("levelup");
const memdown = require('memdown') 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) { if (!task) {
listTasks() listTasks();
} else { } else {
addTask() addTask();
} }
function addTask() { function addTask() {
const key = `Task: ${Math.random().toString(32).replace('.', '')}` const key = `Task: ${Math.random().toString(32).replace(".", "")}`;
db.put(key, task, (err) => { db.put(key, task, (err) => {
if (err) throw err if (err) throw err;
listTasks() listTasks();
}) });
} }
function listTasks() { function listTasks() {
db.createReadStream().on('data', (data) => { db.createReadStream().on("data", (data) => {
console.log(data.key.toString(), '=', data.value.toString()) console.log(data.key.toString(), "=", data.value.toString());
}) });
} }
Chapter07/mongodb-app/tasks.js
+36 -31
View File
@@ -1,42 +1,47 @@
const { const { MongoClient } = require("mongodb");
MongoClient const task = process.argv[2];
} = require('mongodb')
const task = process.argv[2]
const URI = 'mongodb://localhost:27017/' const URI = "mongodb://localhost:27017/";
MongoClient.connect(URI, { MongoClient.connect(
useUnifiedTopology: true URI,
}, connected) {
useUnifiedTopology: true,
},
connected
);
function connected(err, client) { function connected(err, client) {
if (err) throw err if (err) throw err;
const tasks = client.db('tasklist').collection('tasks') const tasks = client.db("tasklist").collection("tasks");
if (task) { if (task) {
addTask(client, tasks) addTask(client, tasks);
} else { } else {
listTasks(client, tasks) listTasks(client, tasks);
} }
} }
function addTask(client, tasks) { function addTask(client, tasks) {
tasks.insertOne({ tasks.insertOne(
task: task {
}, (err) => { task: task,
if (err) throw err },
console.log("New Task: ", task); (err) => {
listTasks(client, tasks) if (err) throw err;
}) console.log("New Task: ", task);
listTasks(client, tasks);
}
);
} }
function listTasks(client, tasks) { function listTasks(client, tasks) {
tasks.find().each((err, doc) => { tasks.find().each((err, doc) => {
if (err) throw err if (err) throw err;
if (!doc) { if (!doc) {
client.close() client.close();
return return;
} }
console.log(doc) console.log(doc);
}) });
} }
Chapter07/mongoose-app/tasks.js
+14 -15
View File
@@ -1,23 +1,22 @@
const mongoose = require('mongoose'); const mongoose = require("mongoose");
const URI = 'mongodb://localhost:27017/customers'
const URI = "mongodb://localhost:27017/customers";
mongoose.connect(URI, { mongoose.connect(URI, {
useNewUrlParser: true, useNewUrlParser: true,
useUnifiedTopology: true useUnifiedTopology: true,
}) });
const Customer = mongoose.model('Customer', { const Customer = mongoose.model("Customer", {
forename: String, forename: String,
surname: String surname: String,
}) });
const customer_1 = new Customer({ const customer_1 = new Customer({
forename: 'Beth', forename: "Beth",
surname: 'Griggs' surname: "Griggs",
}) });
customer_1.save().then((doc) => { customer_1.save().then((doc) => {
console.log('Added new customer', doc.forename, doc.surname) console.log("Added new customer", doc.forename, doc.surname);
}) });
Chapter07/mysql-app/index.js
+26 -24
View File
@@ -1,38 +1,40 @@
require('dotenv').config() require("dotenv").config();
const mysql = require('mysql') const mysql = require("mysql");
const db = mysql.createConnection({ const db = mysql.createConnection({
user: process.env.DB_MYSQL_USER, user: process.env.DB_MYSQL_USER,
password: process.env.DB_MYSQL_PASSWORD password: process.env.DB_MYSQL_PASSWORD,
}) });
db.query('CREATE DATABASE tasks') db.query("CREATE DATABASE tasks");
db.query('USE tasks') db.query("USE tasks");
db.query( db.query(
'CREATE TABLE tasks.tasks (' + "CREATE TABLE tasks.tasks (" +
'id INT NOT NULL AUTO_INCREMENT, ' + "id INT NOT NULL AUTO_INCREMENT, " +
'task TEXT NOT NULL, PRIMARY KEY ( id )' + "task TEXT NOT NULL, PRIMARY KEY ( id )" +
')') ")"
);
const ignore = new Set([ const ignore = new Set(["ER_DB_CREATE_EXISTS", "ER_TABLE_EXISTS_ERROR"]);
'ER_DB_CREATE_EXISTS', 'ER_TABLE_EXISTS_ERROR'
])
db.on('error', (err) => { db.on("error", (err) => {
if (ignore.has(err.code)) return if (ignore.has(err.code)) return;
throw err throw err;
}) });
db.query(` db.query(`
INSERT INTO tasks.tasks (task) INSERT INTO tasks.tasks (task)
VALUES ("Walk the dog"); VALUES ("Walk the dog");
`) `);
db.query(` db.query(
`
SELECT * FROM tasks.tasks; SELECT * FROM tasks.tasks;
`, (err, results) => { `,
console.log(results) (err, results) => {
}) console.log(results);
}
);
db.end() db.end();
Chapter07/mysql-app/insert.js
+30 -25
View File
@@ -1,40 +1,45 @@
require('dotenv').config() require("dotenv").config();
const mysql = require('mysql') const mysql = require("mysql");
const db = mysql.createConnection({ const db = mysql.createConnection({
user: process.env.DB_MYSQL_USER, user: process.env.DB_MYSQL_USER,
password: process.env.DB_MYSQL_PASSWORD password: process.env.DB_MYSQL_PASSWORD,
}) });
db.query('CREATE DATABASE tasks') db.query("CREATE DATABASE tasks");
db.query('USE tasks') db.query("USE tasks");
db.query( db.query(
'CREATE TABLE tasks.tasks (' + "CREATE TABLE tasks.tasks (" +
'id INT NOT NULL AUTO_INCREMENT, ' + "id INT NOT NULL AUTO_INCREMENT, " +
'task TEXT NOT NULL, PRIMARY KEY ( id )' + "task TEXT NOT NULL, PRIMARY KEY ( id )" +
')') ")"
);
const ignore = new Set([ const ignore = new Set(["ER_DB_CREATE_EXISTS", "ER_TABLE_EXISTS_ERROR"]);
'ER_DB_CREATE_EXISTS', 'ER_TABLE_EXISTS_ERROR'
])
db.on('error', (err) => { db.on("error", (err) => {
if (ignore.has(err.code)) return if (ignore.has(err.code)) return;
throw err throw err;
}) });
if (process.argv[2]) { if (process.argv[2]) {
db.query(` db.query(
`
INSERT INTO tasks.tasks (task) INSERT INTO tasks.tasks (task)
VALUES (?); VALUES (?);
`, [process.argv[2]]) `,
[process.argv[2]]
);
} }
db.query(` db.query(
`
SELECT * FROM tasks.tasks; SELECT * FROM tasks.tasks;
`, (err, results, fields) => { `,
console.log(results) (err, results, fields) => {
}) console.log(results);
}
);
db.end() db.end();
Chapter07/postgres-app/tasks.js
+26 -26
View File
@@ -1,32 +1,32 @@
require('dotenv').config() require("dotenv").config();
const pg = require('pg') const pg = require("pg");
const db = new pg.Client() const db = new pg.Client();
const task = process.argv[2] const task = process.argv[2];
const CREATE_TABLE_SQL = `CREATE TABLE IF NOT EXISTS tasks const CREATE_TABLE_SQL = `CREATE TABLE IF NOT EXISTS tasks
(id SERIAL, task TEXT NOT NULL, PRIMARY KEY ( id ))` (id SERIAL, task TEXT NOT NULL, PRIMARY KEY ( id ))`;
const INSERT_TASK_SQL = `INSERT INTO tasks (task) VALUES ($1);` const INSERT_TASK_SQL = `INSERT INTO tasks (task) VALUES ($1);`;
const GET_TASKS_SQL = `SELECT * FROM tasks;` const GET_TASKS_SQL = `SELECT * FROM tasks;`;
db.connect((err) => { db.connect((err) => {
if (err) throw err if (err) throw err;
db.query(CREATE_TABLE_SQL, (err) => { db.query(CREATE_TABLE_SQL, (err) => {
if (err) throw err if (err) throw err;
if (task) { if (task) {
db.query(INSERT_TASK_SQL, [task], (err) => { db.query(INSERT_TASK_SQL, [task], (err) => {
if (err) throw err if (err) throw err;
listTasks() listTasks();
}) });
} else { } else {
listTasks() listTasks();
} }
}) });
}) });
function listTasks() { function listTasks() {
db.query(GET_TASKS_SQL, (err, results) => { db.query(GET_TASKS_SQL, (err, results) => {
if (err) throw err if (err) throw err;
console.log(results.rows); console.log(results.rows);
db.end() db.end();
}) });
} }
Chapter07/postgres-object-app/tasks.js
+26 -26
View File
@@ -1,32 +1,32 @@
require('dotenv').config() require("dotenv").config();
const pg = require('pg') const pg = require("pg");
const db = new pg.Client() const db = new pg.Client();
const task = process.argv[2] const task = process.argv[2];
const CREATE_TABLE_SQL = `CREATE TABLE IF NOT EXISTS task_docs const CREATE_TABLE_SQL = `CREATE TABLE IF NOT EXISTS task_docs
(id SERIAL, doc jsonb);` (id SERIAL, doc jsonb);`;
const INSERT_TASK_SQL = `INSERT INTO task_docs (doc) VALUES ($1);` const INSERT_TASK_SQL = `INSERT INTO task_docs (doc) VALUES ($1);`;
const GET_TASKS_SQL = `SELECT * FROM task_docs;` const GET_TASKS_SQL = `SELECT * FROM task_docs;`;
db.connect((err) => { db.connect((err) => {
if (err) throw err if (err) throw err;
db.query(CREATE_TABLE_SQL, (err) => { db.query(CREATE_TABLE_SQL, (err) => {
if (err) throw err if (err) throw err;
if (task) { if (task) {
db.query(INSERT_TASK_SQL, [task], (err) => { db.query(INSERT_TASK_SQL, [task], (err) => {
if (err) throw err if (err) throw err;
listTasks() listTasks();
}) });
} else { } else {
listTasks() listTasks();
} }
}) });
}) });
function listTasks() { function listTasks() {
db.query(GET_TASKS_SQL, (err, results) => { db.query(GET_TASKS_SQL, (err, results) => {
if (err) throw err if (err) throw err;
console.log(results.rows); console.log(results.rows);
db.end() db.end();
}) });
} }
Chapter07/redis-app/tasks-auth.js
+26 -26
View File
@@ -1,37 +1,37 @@
const redis = require('redis') const redis = require("redis");
const client = redis.createClient({ const client = redis.createClient({
port: 6380, port: 6380,
password: "PASSWORD" password: "PASSWORD",
}) });
const task = process.argv[2] const task = process.argv[2];
client.on('error', (err) => { client.on("error", (err) => {
console.log("Error:", err) console.log("Error:", err);
}) });
if (!task) { if (!task) {
listTasks() listTasks();
} else { } else {
addTask(task) addTask(task);
} }
function addTask(task) { function addTask(task) {
const key = `Task: ${Math.random().toString(32).replace('.', '')}` const key = `Task: ${Math.random().toString(32).replace(".", "")}`;
client.hmset(key, { client.hmset(key, {
task task,
}) });
listTasks() listTasks();
} }
function listTasks() { function listTasks() {
client.keys('Task:*', (err, keys) => { client.keys("Task:*", (err, keys) => {
if (err) throw err if (err) throw err;
keys.forEach(key => { keys.forEach((key) => {
client.hgetall(key, (err, task) => { client.hgetall(key, (err, task) => {
if (err) throw err if (err) throw err;
console.log(task) console.log(task);
}) });
}) });
client.quit() client.quit();
}) });
} }
Chapter07/redis-app/tasks.js
+24 -24
View File
@@ -1,34 +1,34 @@
const redis = require('redis') const redis = require("redis");
const client = redis.createClient() const client = redis.createClient();
const task = process.argv[2] const task = process.argv[2];
client.on('error', (err) => { client.on("error", (err) => {
console.log("Error:", err) console.log("Error:", err);
}) });
if (!task) { if (!task) {
listTasks() listTasks();
} else { } else {
addTask(task) addTask(task);
} }
function addTask(task) { function addTask(task) {
const key = `Task: ${Math.random().toString(32).replace('.', '')}` const key = `Task: ${Math.random().toString(32).replace(".", "")}`;
client.hmset(key, { client.hmset(key, {
task task,
}) });
listTasks() listTasks();
} }
function listTasks() { function listTasks() {
client.keys('Task:*', (err, keys) => { client.keys("Task:*", (err, keys) => {
if (err) throw err if (err) throw err;
keys.forEach(key => { keys.forEach((key) => {
client.hgetall(key, (err, task) => { client.hgetall(key, (err, task) => {
if (err) throw err if (err) throw err;
console.log(task) console.log(task);
}) });
}) });
client.quit() client.quit();
}) });
} }