Skip to content
Snippets Groups Projects
Commit 2612e23e authored by OZGCloud's avatar OZGCloud
Browse files

OZG-6810 adjust constant names

parent dace46c9
Branches
Tags
1 merge request!4Revert "OZG-6810 [tmp] update version"
......@@ -12,7 +12,8 @@ import io.mongock.api.annotations.RollbackExecution;
@ChangeUnit(id = "2024-11-27 09:00:00 OZG-6810", order = "M013", author = "ebardin", runAlways = true)
public class M013_CreateBinaryFileCollection { // NOSONAR
static final String COLLECTION_NAME = "binaryFile";
static final String OLD_COLLECTION_NAME = "fs.files";
static final String NEW_COLLECTION_NAME = "binaryFile";
static final String FIELD_ID = "_id";
static final String FIELD_VERSION = "version";
static final String FIELD_FILE_NAME = "name";
......@@ -29,7 +30,7 @@ public class M013_CreateBinaryFileCollection { // NOSONAR
@Execution
public void doMigration(MongoTemplate template) {
template.aggregate(buildAggregationPipeline(), "fs.files", Document.class);
template.aggregate(buildAggregationPipeline(), OLD_COLLECTION_NAME, Document.class);
}
private Aggregation buildAggregationPipeline() {
......@@ -44,7 +45,7 @@ public class M013_CreateBinaryFileCollection { // NOSONAR
.and(RenameUtil.METADATA_KEY + "." + FIELD_CREATED_BY).as(FIELD_CREATED_BY)
.andExpression(SET_CONTENT_ID_EXPRESSION).as(FIELD_CONTENT_ID)
.and(FIELD_LENGTH).as(FIELD_SIZE),
Aggregation.merge().intoCollection(COLLECTION_NAME).on(FIELD_ID)
Aggregation.merge().intoCollection(NEW_COLLECTION_NAME).on(FIELD_ID)
.whenDocumentsMatch(MergeOperation.WhenDocumentsMatch.keepExistingDocument()).build()
);
}
......
......@@ -92,11 +92,11 @@ class M013_CreateBinaryFileCollectionTest {
@Test
void shouldSkipExistingFiles() {
var binaryFile = createNewBinaryFileFrom(fileId);
template.save(binaryFile, M013_CreateBinaryFileCollection.COLLECTION_NAME);
template.save(binaryFile, M013_CreateBinaryFileCollection.NEW_COLLECTION_NAME);
migration.doMigration(template);
var binaryFiles = template.findAll(Document.class, M013_CreateBinaryFileCollection.COLLECTION_NAME);
var binaryFiles = template.findAll(Document.class, M013_CreateBinaryFileCollection.NEW_COLLECTION_NAME);
assertThat(binaryFiles).hasSize(1).first().usingRecursiveComparison().isEqualTo(binaryFile);
}
......@@ -139,7 +139,7 @@ class M013_CreateBinaryFileCollectionTest {
}
private Document loadBinaryFile() {
return template.findById(fileId, Document.class, M013_CreateBinaryFileCollection.COLLECTION_NAME);
return template.findById(fileId, Document.class, M013_CreateBinaryFileCollection.NEW_COLLECTION_NAME);
}
private InputStream getFileContentByContentId(Document binaryFile) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment