Protei/PromucFlow_constructor
2
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

chore: Add migration for adding indexes to actionCollection collection (#30087)

Browse Source 
Fixes #30088

This PR adds an index to actionCollection collection on
unpublished.defaultResources.pageId keypath.

This is the most used keypath in the mongo db queries that can use an
index.

Relevant slack thread here.

<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->
## Summary by CodeRabbit

- **Refactor**
- Improved database query performance by adding an index to enhance the
search efficiency on collections.
<!-- end of auto-generated comment: release notes by coderabbit.ai -->
This commit is contained in:
Rajat Agrawal 2024-01-09 09:54:16 +05:30 committed by GitHub
parent 62a4587095
commit b32b669daf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 48 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
app/server/appsmith-server/src/main/java/com/appsmith/server/migrations/db/ce/Migration043AddIndexActionCollectionPageID.java Normal file
View File

@ -0,0 +1,48 @@
package com.appsmith.server.migrations.db.ce;
import com.appsmith.server.domains.ActionCollection;
import io.mongock.api.annotations.ChangeUnit;
import io.mongock.api.annotations.Execution;
import io.mongock.api.annotations.RollbackExecution;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.mongodb.UncategorizedMongoDbException;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.index.Index;
import static com.appsmith.server.migrations.DatabaseChangelog1.dropIndexIfExists;
import static com.appsmith.server.migrations.DatabaseChangelog1.ensureIndexes;
import static com.appsmith.server.migrations.DatabaseChangelog1.makeIndex;
@Slf4j
@ChangeUnit(order = "043", id = "add-index-to-action-collection-default-resources-pageid", author = "")
public class Migration043AddIndexActionCollectionPageID {
private final MongoTemplate mongoTemplate;
private static final String INDEX_KEYPATH = "unpublishedCollection.defaultResources.pageId";
private static final String PREVIOUS_INDEX_NAME = "unpublishedCollection.defaultResources.pageId_1";
public Migration043AddIndexActionCollectionPageID(MongoTemplate mongoTemplate) {
this.mongoTemplate = mongoTemplate;
}
@RollbackExecution
public void rollbackExecution() {}
@Execution
public void addIndexToActionCollectionCollection() {
Index index = makeIndex(INDEX_KEYPATH);
try {
dropIndexIfExists(mongoTemplate, ActionCollection.class, PREVIOUS_INDEX_NAME);
dropIndexIfExists(mongoTemplate, ActionCollection.class, INDEX_KEYPATH);
ensureIndexes(mongoTemplate, ActionCollection.class, index);
} catch (UncategorizedMongoDbException exception) {
log.error(
"An error occurred while creating the index : {}, skipping the additon of index because of {}.",
INDEX_KEYPATH,
exception.getMessage());
} catch (Exception e) {
log.error("An error occurred while creating the index : {}", INDEX_KEYPATH, e);
}
}
}