init

Author: 100xdevs

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+dist

package.json

@@ -0,0 +1,13 @@
+{
+  "name": "sql-commands",
+  "version": "1.0.0",
+  "main": "index.js",
+  "license": "MIT",
+  "scripts": {
+    "build": "tsc -b"
+  },
+  "dependencies": {
+    "@types/pg": "^8.10.2",
+    "pg": "^8.11.3"
+  }
+}

src/create-index.ts

@@ -0,0 +1,12 @@
+import { getClient } from "./utils";
+
+async function addIndex() {
+    const client = await getClient();
+    
+    const createIndexQuery = 'CREATE INDEX idx_todos_user_id ON todos(user_id)';
+    await client.query(createIndexQuery);
+    
+    console.log("Index added successfully on user_id column of todos table!");
+}
+
+addIndex();

src/create-table.ts

@@ -0,0 +1,34 @@
+import { getClient } from "./utils";
+
+async function createTable() {
+    const createUserTableQuery = `
+        CREATE TABLE users (
+            id SERIAL PRIMARY KEY,
+            email VARCHAR(255) UNIQUE NOT NULL,
+            password VARCHAR(255) NOT NULL
+        );
+    `;
+
+    const client = await getClient();
+
+    await client.query(createUserTableQuery);
+
+    const createTodosQuery = `
+        CREATE TABLE todos (
+            id SERIAL PRIMARY KEY,
+            title TEXT NOT NULL,
+            description TEXT,
+            user_id INTEGER REFERENCES users(id),
+            done BOOLEAN DEFAULT FALSE
+        );
+    `;
+
+
+    await client.query(createTodosQuery);
+
+    console.log("Table created successfully!");
+}
+
+
+
+createTable();

src/delete-data.ts

@@ -0,0 +1,13 @@
+import { getClient } from "./utils";
+
+async function deleteTodo(todoId: number) {
+    const client = await getClient();
+    
+    const deleteTodoText = 'DELETE FROM todos WHERE id = $1';
+    await client.query(deleteTodoText, [todoId]);
+    
+    console.log(`Todo with ID ${todoId} deleted!`);
+}
+
+const todoIdToDelete = 1;
+deleteTodo(todoIdToDelete);

src/get-data.ts

@@ -0,0 +1,44 @@
+import { getClient } from "./utils";
+
+async function getUsers() {
+    const client = await getClient();
+    
+    const selectUsersText = 'SELECT * FROM users';
+    const userRes = await client.query(selectUsersText);
+    
+    console.log("Users:");
+    for (let user of userRes.rows) {
+        console.log(`ID: ${user.id}, Email: ${user.email}`);
+    }
+}
+
+async function getUserFromEmail(email: string) {
+    const client = await getClient();
+    
+    const selectUserText = 'SELECT * FROM users WHERE email = $1';
+    const userRes = await client.query(selectUserText, [email]);
+    
+    console.log("Single User detail:");
+    for (let user of userRes.rows) {
+        console.log(`ID: ${user.id}, Email: ${user.email}`);
+    }
+}
+
+async function getTodosForUser(userId: number) {
+    const client = await getClient();
+    
+    const selectTodosText = 'SELECT * FROM todos WHERE user_id = $1';
+    const todoRes = await client.query(selectTodosText, [userId]);
+    
+    console.log(`Todos for User ID ${userId}:`);
+    for (let todo of todoRes.rows) {
+        console.log(`ID: ${todo.id}, Title: ${todo.title}, Description: ${todo.description}, Done: ${todo.done}`);
+    }
+}
+
+getUsers();
+
+getUserFromEmail("[email protected]")
+
+const userIdToFetch = 1;
+getTodosForUser(userIdToFetch);

src/insert-data.ts

@@ -0,0 +1,18 @@
+import { getClient } from "./utils";
+
+async function createEntries() {
+    const client = await getClient();
+    const insertUserText = 'INSERT INTO users (email, password) VALUES ($1, $2) RETURNING id';
+    const userValues = ['[email protected]', 'hashed_password_here'];
+
+    let response = await client.query(insertUserText, userValues);
+    const insertTodoText = 'INSERT INTO todos (title, description, user_id, done) VALUES ($1, $2, $3, $4) RETURNING id';
+    const todoValues = ['Buy groceries', 'Milk, bread, and eggs', response.rows[0].id, false];
+    await client.query(insertTodoText, todoValues);
+
+    console.log("Entries created!");
+}
+
+
+
+createEntries();

src/joins/advance-1.ts

@@ -0,0 +1,21 @@
+import { getClient } from "../utils";
+
+// Get all todos for a give user
+// This needs to ensure that every user comes atleast once
+async function getUserAndTodosWithJoin(userId: number) {
+    const client = await getClient();
+
+    const joinQuery = `
+        SELECT users.*, todos.title, todos.description, todos.done
+        FROM users
+        LEFT JOIN todos ON users.id = todos.user_id
+        WHERE users.id = $1;
+    `;
+
+    const res = await client.query(joinQuery, [userId]);
+    const results = res.rows;
+
+    console.log("User and Todos:", results);
+}
+
+getUserAndTodosWithJoin(1)

src/joins/advance-2.ts

@@ -0,0 +1,21 @@
+import { getClient } from "../utils";
+
+// Get all todos for a give user
+// This shouldnt return a row if no todos exist for the user
+async function getUserAndTodosWithJoin(userId: number) {
+    const client = await getClient();
+
+    const joinQuery = `
+        SELECT users.*, todos.title, todos.description, todos.done
+        FROM users
+        JOIN todos ON users.id = todos.user_id
+        WHERE users.id = $1;
+    `;
+
+    const res = await client.query(joinQuery, [userId]);
+    const results = res.rows;
+
+    console.log("User and Todos:", results);
+}
+
+getUserAndTodosWithJoin(5)

src/joins/advance-3.ts

@@ -0,0 +1,18 @@
+import { getClient } from "../utils";
+
+async function getAllTodosWithUserDetails() {
+    const client = await getClient();
+
+    const joinQuery = `
+        SELECT todos.*, users.email, users.password
+        FROM todos
+        JOIN users ON todos.user_id = users.id;
+    `;
+
+    const res = await client.query(joinQuery);
+    const results = res.rows;
+
+    console.log("Todos with User Details:", results);
+}
+
+getAllTodosWithUserDetails();