Merge pull request #573 from rocket-admin/backend_development

added data access object mongodb

Author: Artuomka

backend/package.json

@@ -89,6 +89,7 @@
     "lodash": "4.17.21",
     "lru-cache": "^10.1.0",
     "moment": "2.29.4",
+    "mongodb": "^6.5.0",
     "nanoid": "5.0.4",
     "nest-winston": "1.9.4",
     "node-gyp": "^10.0.1",

backend/src/entities/table/use-cases/export-csv-from-table.use.case.ts

@@ -87,7 +87,12 @@ export class ExportCSVFromTableUseCase extends AbstractUseCase<GetTableRowsDs, a
       //todo: rework as streams when node oracle driver will support it correctly
       //todo: agent return data as array of table rows, not as stream, because we cant
       //todo: transfer data as a stream from clint to server
-      if (connection.type === 'oracledb' || connection.type === 'ibmdb2' || isConnectionTypeAgent(connection.type)) {
+      if (
+        connection.type === 'oracledb' ||
+        connection.type === 'ibmdb2' ||
+        connection.type === 'mongodb' ||
+        isConnectionTypeAgent(connection.type)
+      ) {
         return new StreamableFile(csv.stringify(rowsStream as any, { header: true }));
       }
       return new StreamableFile(rowsStream.pipe(csv.stringify({ header: true })));

backend/src/enums/connection-type.enum.ts

@@ -5,14 +5,17 @@ export enum ConnectionTypeTestEnum {
   oracledb = 'oracledb',
   mssql = 'mssql',
   ibmdb2 = 'ibmdb2',
+  mongodb = 'mongodb',
   agent_postgres = 'agent_postgres',
   agent_mysql = 'agent_mysql',
   agent_oracledb = 'agent_oracledb',
   agent_mssql = 'agent_mssql',
   agent_ibmdb2 = 'agent_ibmdb2',
+  agent_mongodb = 'agent_mongodb',
   cli_postgres = 'cli_postgres',
   cli_mysql = 'cli_mysql',
   cli_oracledb = 'cli_oracledb',
   cli_mssql = 'cli_mssql',
   cli_ibmdb2 = 'cli_ibmdb2',
+  cli_mongodb = 'cli_mongodb',
 }