Skip to content

added data access object mongodb #573

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Artuomka merged 2 commits into from
Mar 27, 2024
Merged

added data access object mongodb #573

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
863745e
added data access object mongodb
Artuomka Mar 27, 2024
acf6a8e
Add MongoDB dependency to package.json and yarn.lock in agent and cli
Artuomka Mar 27, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions backend/package.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down
7 changes: 6 additions & 1 deletion backend/src/entities/table/use-cases/export-csv-from-table.use.case.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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 })));
Expand Down
3 changes: 3 additions & 0 deletions backend/src/enums/connection-type.enum.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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',
}
Loading