Skip to content
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

N21-1029 bugfix renaming of collections #4551

Merged
merged 8 commits into from
Nov 10, 2023
Merged

N21-1029 bugfix renaming of collections #4551

Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
319a014
N21-1029 renames some collections:
arnegns Nov 9, 2023
e51519d
Merge branch 'main' into N21-1029-renaming-of-collections
arnegns Nov 9, 2023
8dc1faa
Merge branch 'main' into N21-1029-renaming-of-collections
arnegns Nov 9, 2023
90b3f48
Merge branch 'main' into N21-1029-renaming-of-collections
arnegns Nov 10, 2023
0520c26
N21-1456 review fixes
arnegns Nov 10, 2023
e7a9584
Merge branch 'main' into N21-1029-renaming-of-collections-2
arnegns Nov 10, 2023
24f2ba0
N21-1029 checks if new table already exists, because of starting of m…
arnegns Nov 10, 2023
e876d79
N21-1029 using aggregate for copying data
arnegns Nov 10, 2023
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
41 changes: 22 additions & 19 deletions migrations/1699529266062-tool-and-user-login-migration-renamings.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,14 +1,23 @@
const mongoose = require('mongoose');
const { info, error } = require('../src/logger');

const { connect, close } = require('../src/utils/database');

async function renameCollection(oldName, newName) {
async function aggregateAndDropCollection(oldName, newName) {
try {
await mongoose.connection.collection(oldName).rename(newName);
info(`Renamed collection ${oldName} to ${newName}`);
const { connection } = mongoose;

// Aggregation pipeline for copying the documents
const pipeline = [{ $match: {} }, { $out: newName }];

// Copy documents from the old collection to the new collection
await connection.collection(oldName).aggregate(pipeline).toArray();
info(`Aggregated and copied documents from ${oldName} to ${newName}`);

// Delete old collection
await connection.collection(oldName).drop();
info(`Dropped collection ${oldName}`);
} catch (err) {
error(`Error renaming collection ${oldName} to ${newName}: ${err.message}`);
error(`Error aggregating, copying, and deleting collection ${oldName} to ${newName}: ${err.message}`);
throw err;
}
}
Expand All @@ -17,27 +26,21 @@ module.exports = {
up: async function up() {
await connect();

await renameCollection('user_login_migrations', 'user-login-migrations');

await renameCollection('external_tools', 'external-tools');

await renameCollection('context_external_tools', 'context-external-tools');

await renameCollection('school_external_tools', 'school-external-tools');
await aggregateAndDropCollection('user_login_migrations', 'user-login-migrations');
await aggregateAndDropCollection('external_tools', 'external-tools');
await aggregateAndDropCollection('context_external_tools', 'context-external-tools');
await aggregateAndDropCollection('school_external_tools', 'school-external-tools');

await close();
},

down: async function down() {
await connect();

await renameCollection('user-login-migrations', 'user_login_migrations');

await renameCollection('external-tools', 'external_tools');

await renameCollection('context-external-tools', 'context_external_tools');

await renameCollection('school-external-tools', 'school_external_tools');
await aggregateAndDropCollection('user-login-migrations', 'user_login_migrations');
await aggregateAndDropCollection('external-tools', 'external_tools');
await aggregateAndDropCollection('context-external-tools', 'context_external_tools');
await aggregateAndDropCollection('school-external-tools', 'school_external_tools');

await close();
},
Expand Down
Loading