Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

migration manual run ctrl RED-3800

Browse Source
This commit is contained in:
Timo Bejan 2022-04-29 16:59:06 +03:00
parent b82d20473d
commit 5c57634d9c
2 changed files with 34 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/migration/Migration.java
View File

@ -1,13 +1,11 @@
package com.iqser.red.service.peristence.v1.server.migration; package com.iqser.red.service.peristence.v1.server.migration;
import org.springframework.beans.factory.annotation.Autowired;
import com.iqser.red.service.persistence.management.v1.processor.service.persistence.MigrationPersistenceService; import com.iqser.red.service.persistence.management.v1.processor.service.persistence.MigrationPersistenceService;
import lombok.Data; import lombok.Data;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@Data @Data
@Slf4j @Slf4j
@ -21,11 +19,14 @@ public abstract class Migration {
@Setter @Setter
private MigrationPersistenceService migrationPersistenceService; private MigrationPersistenceService migrationPersistenceService;
public void run() { public void run() {
run(false);
}
public void run(boolean force) {
var latestProcessedVersion = migrationPersistenceService.getLatestProcessedVersion(); var latestProcessedVersion = migrationPersistenceService.getLatestProcessedVersion();
if (!migrationPersistenceService.isProcessed(version, latestProcessedVersion)) { if (!migrationPersistenceService.isProcessed(version, latestProcessedVersion) || force) {
log.info("Starting migration with name {} and version {}", name, version); log.info("Starting migration with name {} and version {}", name, version);
migrate(); migrate();
migrationPersistenceService.insertMigration(name, version); migrationPersistenceService.insertMigration(name, version);

28
persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/migration/MigrationController.java Normal file
View File

@ -0,0 +1,28 @@
package com.iqser.red.service.peristence.v1.server.migration;
import lombok.Data;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@Data
@RestController
@RequiredArgsConstructor
@RequestMapping("/private/migration")
public class MigrationController {
private final List<Migration> migrations;
@PostMapping
public void run(@RequestParam("migrationName") String migrationName, @RequestParam("force") boolean force) {
migrations.stream().filter(m -> m.getName().equalsIgnoreCase(migrationName) || m.getClass().getSimpleName().equalsIgnoreCase(migrationName))
.forEach(m -> m.run(force));
}
}