Updated examples with get started, and organised the examples. Added stringifier method to the partiQL insert example

Author: abbathaw

.gitIgnore

@@ -1,3 +1,4 @@
 node_modules/
 .DS_Store
-draft.js
+draft.js
+.env

MoviesLoadData.js

@@ -0,0 +1,13 @@
+require('dotenv').config()
+const AWS = require("aws-sdk");
+
+AWS.config.update({
+
+    region: "us-east-1",
+
+    // For security reasons, do not store AWS Credentials in your files. 
+    accessKeyId: process.env.AWS_ACCESS_KEY_ID,
+    secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY
+});
+
+module.exports = { AWS };

aws-config.js

@@ -0,0 +1,30 @@
+const { AWS } = require('../aws-config')
+
+const dynamoDB = new AWS.DynamoDB();
+
+async function createMoviesTable() {
+    const params = {
+        TableName : "Movies",
+        KeySchema: [
+            { AttributeName: "year", KeyType: "HASH"},
+            { AttributeName: "title", KeyType: "RANGE" }
+        ],
+        AttributeDefinitions: [
+            { AttributeName: "year", AttributeType: "N" },
+            { AttributeName: "title", AttributeType: "S" }
+        ],
+        ProvisionedThroughput: {
+            ReadCapacityUnits: 5,
+            WriteCapacityUnits: 5
+        }
+    };
+
+    try {
+        const table = await dynamoDB.createTable(params).promise();
+    } catch(e) {
+        console.log("An error occurred while creating the table", e)
+        throw new Error("Failed to create a table")
+    }
+}
+
+module.exports = { createMoviesTable };

current.js

@@ -0,0 +1,44 @@
+const { AWS } = require('../aws-config')
+const { createMoviesTable } = require('./create-table');
+const { uploadMoviesData } = require('./upload-data');
+
+const dynamoDB = new AWS.DynamoDB();
+
+const checkIfTableExists = async () => {
+    try {
+        const table = await dynamoDB.describeTable({TableName: 'Movies'}).promise();
+        return true;
+    } catch(e) {
+        if (e.code === "ResourceNotFoundException") {
+            return false;
+        } else {
+            throw new Error("An error occured while checking for table")
+        }
+    }
+}
+
+const setupTableAndData = async() => {
+    try {
+     const isTableExist =  await checkIfTableExists();
+     if (isTableExist) {
+        console.log(`A table called 'Movies' already exists.`)
+     } else {
+        console.log(`Creating Table called 'Movies'`)
+        await createMoviesTable();
+        await sleep(10000); // a small delay to wait for the table to be ready on dynamoDb side
+        console.log(`Table called 'Movies' created. Uploading sample data. This will take a few minutes.`)
+        await uploadMoviesData();
+        console.log('Done');
+     }
+    } catch(e) {
+        console.log("Something wrong happened", e)
+    }
+}
+
+function sleep(ms) {
+    return new Promise((resolve) => {
+      setTimeout(resolve, ms);
+    });
+  } 
+
+setupTableAndData();

getting-started/create-table.js

@@ -0,0 +1,30 @@
+const { AWS } = require('../aws-config')
+const sampleData = require('../sample-data/moviedata.json')
+
+const docClient = new AWS.DynamoDB.DocumentClient();
+
+async function uploadMoviesData() {
+    const allMovies = sampleData;
+    let num = 0;
+    for (const movie of allMovies) {
+        const params = {
+            TableName: "Movies",
+            Item: {
+                "year":  movie.year,
+                "title": movie.title,
+                "info":  movie.info
+            }
+        };
+        try {
+            await docClient.put(params).promise();
+            console.log(`Added ${movie.title}`)
+            num++;
+        } catch(err) {
+            console.log("Unable to add movie", movie.title, ". Error JSON:", JSON.stringify(err, null, 2))
+        }
+    };
+    console.log(`Added ${num} movies to the table`)
+}
+
+
+module.exports = { uploadMoviesData };

getting-started/index.js

@@ -0,0 +1,30 @@
+const { AWS } = require('../aws-config')
+
+const documentClient = new AWS.DynamoDB.DocumentClient();
+
+async function insertWithDocumentClient(movie) {
+    console.time("Document Client Insert Duration")
+    const params = {
+        TableName: "Movies",
+        Item: movie
+    };
+
+    try {
+        await documentClient.put(params).promise();
+        console.log(`New Movie with title of '${movie.title}' inserted successfully`)
+        console.timeEnd("Document Client Insert Duration")
+    } catch(err) {
+        console.error("Unable to insert item", err);
+    }
+};
+
+const movieDetails = {
+    "year": 2020,
+    "title": `The Big New Movie: ${Math.random().toString(36).slice(-6)}`,
+    "info":{
+        "plot": "Nothing happens at all.",
+        "rating": 0
+    }
+}
+
+insertWithDocumentClient(movieDetails);

getting-started/upload-data.js

@@ -0,0 +1,50 @@
+const { AWS } = require('../aws-config')
+
+const dynamoDB = new AWS.DynamoDB();
+
+async function insertWithPartiQL(movie) {
+    try {
+        console.time("PartiQL Insert Duration")
+        const item = stringify(movie);
+        await dynamoDB.executeStatement({Statement: `INSERT INTO Movies VALUE ${item}`}).promise();
+        console.log(`New Movie with title of '${movie.title}' inserted successfully`)
+        console.timeEnd("PartiQL Insert Duration")
+    } catch(err) {
+        console.error("Unable to write item", JSON.stringify(err, null, 2));
+    }
+}
+
+const movieDetails = {
+    "year": 2020,
+    "title": `The Big New Movie: ${Math.random().toString(36).slice(-6)}`,
+    "info":{
+        "plot": "Nothing happens at all.",
+        "rating": 0
+    }
+}
+
+insertWithPartiQL(movieDetails);
+
+
+// Crude implementation of a custom JSON stringifier which uses single quotes instead of double quotes
+// Credit to the code for this from this article by Juan Dalmasso titled `Creating your own simplified implementation of JSON.stringify()`
+// https://levelup.gitconnected.com/creating-your-own-simplified-implementation-of-json-stringify-ed8e50b9144a
+function stringify(value) {
+    const lastKey = Object.keys(value).pop();
+    let objString = '';
+    if (typeof value === 'object') {
+        objString += '{';
+        for (const key in value) {
+            objString += `'${key}':${stringify(value[key])}`;
+            if (key !== lastKey) {
+                objString += ',';
+            }
+        }
+        objString += '}';
+    } else if (typeof value === 'string') {
+        objString += `'${value}'`;
+    } else if (typeof value === 'number') {
+        objString += `${value}`;
+    }
+    return objString;
+}

insert-data/insert-documentAPI.js

@@ -1,15 +1,24 @@
 {
-  "name": "dynnamoDb-partiQL-javascript",
+  "name": "dynamodb-partiql-javascript",
   "version": "1.0.0",
-  "description": "",
+  "description": "Code examples and a getting started part to follow along with blog article.",
   "main": "index.js",
   "scripts": {
+    "get-started": "node ./getting-started/index.js",
     "test": "echo \"Error: no test specified\" && exit 1"
   },
-  "keywords": [],
-  "author": "",
+  "keywords": [
+    "dynamoDb",
+    "partiQL",
+    "aws",
+    "javascript"
+  ],
+  "author": "Abdullah Althawr",
   "license": "MIT",
   "dependencies": {
-    "aws-sdk": "^2.799.0"
+    "aws-sdk": "^2.842.0"
+  },
+  "devDependencies": {
+    "dotenv": "^8.2.0"
   }
 }