Ok, OOP it is... 😬

Author: ariflogs

package-lock.json

@@ -21,6 +21,7 @@
     "typescript": "^5.2.2"
   },
   "dependencies": {
+    "mongodb": "^6.1.0",
     "sql-to-nosql": "^0.0.3"
   },
   "type": "module"

package.json

@@ -1,41 +1,57 @@
 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 const SqlToNoSql = (query: string) => {
-  if (!query) {
-    throw new Error("missing query!");
+export class SqlToNoSql {
+  constructor(private config: SqlToNoSqlType) {
+    connect(this.config.connection);
   }
 
-  if ([";", "(", ")"].some((char) => query.includes(char))) {
-    throw new Error("Invalid query, your query contains invalid characters!");
-  }
-
-  const q = parseQuery(query);
+  run(query: string) {
+    if (!query) {
+      throw new Error("missing query!");
+    }
 
-  const filters: {
-    [key: string]: {
-      [operator: string]: string | number;
-    };
-  } = {};
+    // TODO: add better validation!
+    if ([";", "(", ")"].some((char) => query.includes(char))) {
+      throw new Error("Invalid query, your query contains invalid characters!");
+    }
 
-  q.filters?.forEach((filter) => {
-    const { column, operator, value } = filter;
+    const q = parseQuery(query);
 
-    if (!filters[column]) {
-      filters[column] = {
-        [mappings["mongodb"]["operators"][operator]]: value,
+    const filters: {
+      [key: string]: {
+        [operator: string]: string | number;
       };
-    }
-  });
+    } = {};
+
+    // Convert parsed filters to MongoDB query
+    q.filters?.forEach((filter) => {
+      const { column, operator, value } = filter;
+
+      if (!filters[column]) {
+        filters[column] = {
+          [mappings["mongodb"]["operators"][operator]]: value,
+        };
+      }
+    });
+
+    const mongoQuery = {
+      collection: q.table,
+      [q.command]: mappings["mongodb"]["commands"][q.command],
+      query: filters,
+    };
 
-  const mongoQuery = {
-    collection: q.table,
-    [q.command]: mappings["mongodb"]["commands"][q.command],
-    query: filters,
-  };
+    return mongoQuery;
+  }
+}
 
-  return mongoQuery;
-};
+const runner = new SqlToNoSql({
+  srcDBtype: "postgresql",
+  destDBtype: "mongodb",
+  connection: "mongodb://localhost:27017",
+});
 
-console.log(SqlToNoSql("SELECT * FROM users"));
-console.log(SqlToNoSql("select * from users where id = 1"));
+console.log(runner.run("SELECT * FROM users"));
+console.log(runner.run("select * from users where id = 1"));

src/index.ts

@@ -0,0 +1,5 @@
+export interface SqlToNoSqlType {
+  srcDBtype: "postgresql";
+  destDBtype: "mongodb";
+  connection: string;
+}