added inital suppport for Select command with where operation

Author: ariflogs

.gitignore

@@ -1,4 +1,5 @@
 .env
 node_modules
 build
-dist
+dist
+TODO.md

README.md

@@ -17,14 +17,14 @@ npm insall sql-to-nosql
 ### Roadmap
 
 - [ ] Database
-  - [ ] MongoDB
+  - [x] MongoDB
 - [ ] Commands
-  - [ ] SELECT
+  - [x] SELECT
   - [ ] INSERT
   - [ ] DELETE
   - [ ] UPDATE
 - [ ] Clauses
-  - [ ] WHERE
+  - [x] WHERE
   - [ ] ORDER BY
   - [ ] LIMIT
   - [ ] OFFSET
@@ -41,7 +41,7 @@ npm insall sql-to-nosql
   - [ ] MIN
   - [ ] MAX
 - [ ] Operators
-  - [ ] =
+  - [x] =
   - [ ] !=
   - [ ] >
   - [ ] <

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sql-to-nosql",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "description": "Run SQL quries on your Mongodb database.",
   "repository": {
     "type": "git",
@@ -25,4 +25,4 @@
     "sql-to-nosql": "^0.0.3"
   },
   "type": "module"
-}
+}

src/config/mapping.ts

@@ -1,9 +1,9 @@
 export const sqlToMongoDBcommandsMapping = {
   select: "find",
-  insert: "insertOne",
-  update: "updateOne",
-  delete: "deleteOne",
-};
+  insert: "insertMany",
+  update: "updateMany",
+  delete: "deleteMany",
+} as const;
 
 export const sqlToMongoDBoperatorsMapping = {
   "=": "$eq",
@@ -12,7 +12,7 @@ export const sqlToMongoDBoperatorsMapping = {
   ">=": "$gte",
   "<=": "$lte",
   "<>": "$ne",
-};
+} as const;
 
 export const mappings = {
   mongodb: {

src/index.ts

@@ -1,14 +1,16 @@
+import { MongoClient } from "mongodb";
+
 import { mappings } from "./config/mapping.js";
 import { parseQuery } from "./utils/parser.js";
 import { connect } from "./utils/database.js";
 import { SqlToNoSqlType } from "./types/index.js";
 
 export class SqlToNoSql {
-  constructor(private config: SqlToNoSqlType) {
-    connect(this.config.connection);
-  }
+  client: MongoClient | undefined;
+
+  constructor(private config: SqlToNoSqlType) {}
 
-  run(query: string) {
+  async run(query: string) {
     if (!query) {
       throw new Error("missing query!");
     }
@@ -19,6 +21,7 @@ export class SqlToNoSql {
     }
 
     const q = parseQuery(query);
+    this.client = await connect(this.config.connection);
 
     const filters: {
       [key: string]: {
@@ -43,15 +46,18 @@ export class SqlToNoSql {
       query: filters,
     };
 
-    return mongoQuery;
+    try {
+      await this.client.connect();
+      const db = this.client.db();
+      const collection = db.collection(mongoQuery.collection);
+      const data = await collection[mongoQuery[q.command]](
+        mongoQuery.query,
+      ).toArray();
+
+      return data;
+    } catch (err) {
+      console.error(err);
+      throw Error("Something went wrong!");
+    }
   }
 }
-
-const runner = new SqlToNoSql({
-  srcDBtype: "postgresql",
-  destDBtype: "mongodb",
-  connection: "mongodb://localhost:27017",
-});
-
-console.log(runner.run("SELECT * FROM users"));
-console.log(runner.run("select * from users where id = 1"));

src/utils/database.ts

@@ -4,6 +4,7 @@ export const connect = async (url: string) => {
   try {
     const client = new MongoClient(url);
     await client.connect();
+    return client;
   } catch (error) {
     throw new Error("Could not connect to Database!");
   }

test/test.js

@@ -1,3 +1,7 @@
-import { greetings } from "sql-to-nosql";
+const runner = new SqlToNoSql({
+    srcDBtype: "postgresql",
+    destDBtype: "mongodb",
+    connection: process.env.TEST_MONGODB_URI,
+});
 
-console.log(greetings());
+console.log(runner.run("select * from users where role = admin"));