MongoDB connection persistance fixed

Author: anijitsao

.env.development

@@ -4,7 +4,7 @@ REGION="ap-south-1"
 # database related
 URI_TO_CONNECT_MONGODB="mongodb+srv://test:test1234@anijitsmongodb.l73ta.mongodb.net/?retryWrites=true&w=majority"
 
-DB_NAME=allapps
-COLLECTION_USER_STICKER=usersticker
-COLLECTION_BOOKS=books
-COLLECTION_AUTHORS=authors
+DB_NAME="allapps"
+COLLECTION_USER_STICKER="usersticker"
+COLLECTION_BOOKS="books"
+COLLECTION_AUTHORS="authors"

src/dbRelated/booksDbOps.js

@@ -9,6 +9,22 @@ import {
 const { DB_NAME, COLLECTION_BOOKS } = process.env;
 
 const findBooksFromDB = async () => {
+  // create the connection
+  const client = createConnectionToDB();
+  try {
+    // select the DB and collection
+    const db = selectDB(client, DB_NAME);
+    const booksFound = await db.collection(COLLECTION_BOOKS).find({}).toArray();
+    const res = booksFound || [];
+    return res;
+  } catch (error) {
+    return error.toString();
+  } finally {
+    await closeConnectionToDB(client);
+  }
+};
+
+const addBookToDB = async (bookToAdd) => {
   // create the connection
   const client = await createConnectionToDB();
   try {
@@ -24,4 +40,4 @@ const findBooksFromDB = async () => {
   }
 };
 
-export { findBooksFromDB };
+export { findBooksFromDB, addBookToDB };

src/helpers/dbHelpers.js

@@ -1,13 +1,13 @@
 // local dependencies
-import { dbClient, ObjectId } from "../libs/mongoClient.js";
+import { MongoClient, ObjectId } from "../libs/mongoClient.js";
 
-const createConnectionToDB = async () => {
-  const client = await dbClient.connect();
+const createConnectionToDB = () => {
+  const client = new MongoClient(process.env.URI_TO_CONNECT_MONGODB);
   return client;
 };
 
-const closeConnectionToDB = (client) => {
-  client.close();
+const closeConnectionToDB = async (client) => {
+  await client.close();
 };
 
 const selectDB = (client, DB_NAME) => {

src/libs/mongoClient.js

@@ -4,5 +4,5 @@ import mongodb from "mongodb";
 // initialize the client to connect MongoDB Atlas and export
 const { MongoClient, ObjectId } = mongodb;
 
-const dbClient = new MongoClient(process.env.URI_TO_CONNECT_MONGODB);
-export { dbClient, ObjectId };
+// const dbClient = new MongoClient(process.env.URI_TO_CONNECT_MONGODB);
+export { MongoClient, ObjectId };

src/resolvers/bookResolver.js

@@ -1,5 +1,5 @@
 // local dependencies
-import { findBooksFromDB } from "../dbRelated/booksDbOps.js";
+import { findBooksFromDB, addBookToDB } from "../dbRelated/booksDbOps.js";
 
 const resolvers = {
   Query: {
@@ -9,9 +9,8 @@ const resolvers = {
   },
 
   Mutation: {
-    getCount: (parent, arg) => {
-      // console.log("arg is", arg);
-      return arg.count + 1;
+    addBook: (_, args) => {
+      return addBookToDB(args);
     },
   },
 };

src/typedefs/bookTypedef.js

@@ -11,6 +11,11 @@ const booksTypeDefs = gql`
   type Query {
     findBooks: [Book]
   }
+
+  # All the Mutations on Book listed here
+  type Mutation {
+    addBook(name: String!): ID
+  }
 `;
 
 export { booksTypeDefs };