MaDgiK-CITE
/
argos
13
0
Fork 0
Code Issues Pull Requests Projects Releases 3 Wiki Activity

migration changes

This commit is contained in:
Efstratios Giannopoulos 2023-11-24 18:19:22 +02:00
parent c67e4c8c9f
commit aa0a86b4d1
5 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dmp-backend/core/src/main/java/eu/eudat/data/DmpUserEntity.java
View File

@ -26,7 +26,7 @@ public class DmpUserEntity {
public static final String _dmp = "dmp"; public static final String _dmp = "dmp";
@Column(name = "user", columnDefinition = "uuid", nullable = false) @Column(name = "\"user\"", columnDefinition = "uuid", nullable = false)
private UUID userId; private UUID userId;
public static final String _userId = "userId"; public static final String _userId = "userId";

2
dmp-db-scema/updates/00.01.008_Add_DescriptionReference_table.sql
View File

@ -7,7 +7,7 @@ BEGIN
CREATE TABLE IF NOT EXISTS public."DescriptionReference" CREATE TABLE IF NOT EXISTS public."DescriptionReference"
( (
"id" uuid NOT NULL, "id" uuid NOT NULL,
"data" text COLLATE pg_catalog."default" NOT NULL, "data" text COLLATE pg_catalog."default",
"description_id" uuid NOT NULL, "description_id" uuid NOT NULL,
"reference_id" uuid NOT NULL, "reference_id" uuid NOT NULL,
"created_at" timestamp without time zone NOT NULL DEFAULT now(), "created_at" timestamp without time zone NOT NULL DEFAULT now(),

11
dmp-migration-tool/web/src/main/java/eu/old/eudat/migration/DmpDatasetProfileMigrationService.java
View File

@ -115,7 +115,7 @@ public class DmpDatasetProfileMigrationService {
} }
} while (items != null && !items.isEmpty() && !TestMode); } while (items != null && !items.isEmpty() && !TestMode);
//removeDuplicates(); removeDuplicates();
} }
private void removeDuplicates() { private void removeDuplicates() {
@ -128,8 +128,8 @@ public class DmpDatasetProfileMigrationService {
CriteriaBuilder b = this.entityManager.getCriteriaBuilder(); CriteriaBuilder b = this.entityManager.getCriteriaBuilder();
CriteriaQuery<Tuple> criteria = b.createQuery(Tuple.class); CriteriaQuery<Tuple> criteria = b.createQuery(Tuple.class);
Root<DmpDescriptionTemplateEntity> root = criteria.from(DmpDescriptionTemplateEntity.class); Root<DmpDescriptionTemplateEntity> root = criteria.from(DmpDescriptionTemplateEntity.class);
criteria.groupBy(Arrays.asList(root.get("dmp"), root.get("descriptionTemplateGroupId"), root.get("sectionId"))); criteria.groupBy(Arrays.asList(root.get(DmpDescriptionTemplateEntity._dmpId), root.get(DmpDescriptionTemplateEntity._descriptionTemplateGroupId), root.get(DmpDescriptionTemplateEntity._sectionId)));
criteria.multiselect(root.get("dmp"), root.get("descriptionTemplateGroupId"), root.get("sectionId"), b.count(root)); criteria.multiselect(root.get(DmpDescriptionTemplateEntity._dmpId), root.get(DmpDescriptionTemplateEntity._descriptionTemplateGroupId), root.get(DmpDescriptionTemplateEntity._sectionId), b.count(root));
List<Tuple> resultList = this.entityManager.createQuery(criteria).getResultList(); List<Tuple> resultList = this.entityManager.createQuery(criteria).getResultList();
List<Tuple> duplicatesList = resultList.stream().filter(x -> (long) x.get(3) > 1).toList(); List<Tuple> duplicatesList = resultList.stream().filter(x -> (long) x.get(3) > 1).toList();
@ -143,9 +143,8 @@ public class DmpDatasetProfileMigrationService {
.collect(); .collect();
List<UUID> toDelete = new ArrayList<>(duplicateEntities.stream().map(DmpDescriptionTemplateEntity::getId).toList()); List<UUID> toDelete = new ArrayList<>(duplicateEntities.stream().map(DmpDescriptionTemplateEntity::getId).toList());
int random = new SecureRandom().nextInt(0, toDelete.size()); toDelete.remove(0);
toDelete.remove(random); delete.where(root1.get(DmpDescriptionTemplateEntity._id).in(toDelete));
delete.where(root1.get("id").in(toDelete));
this.entityManager.createQuery(delete).executeUpdate(); this.entityManager.createQuery(delete).executeUpdate();
} }

6
dmp-migration-tool/web/src/main/java/eu/old/eudat/migration/DmpUserMigrationService.java
View File

@ -44,15 +44,15 @@ public class DmpUserMigrationService {
if (items != null && !items.isEmpty()) { if (items != null && !items.isEmpty()) {
logger.debug("Migrate UserDMP " + page * PageSize + " of " + total); logger.debug("Migrate UserDMP " + page * PageSize + " of " + total);
for (UserDMP item : items) { for (UserDMP item : items) {
entityManager.detach(item); //entityManager.detach(item);
DmpUserEntity data = new DmpUserEntity(); DmpUserEntity data = new DmpUserEntity();
data.setId(item.getId()); data.setId(item.getId());
data.setDmp(item.getDmp().getId()); data.setDmp(item.getDmp().getId());
data.setUserId(item.getUser().getId()); data.setUserId(item.getUser().getId());
data.setRole(DmpUserRole.of(item.getRole().shortValue())); data.setRole(DmpUserRole.of(item.getRole().shortValue()));
data.setCreatedAt(Instant.now()); data.setCreatedAt(item.getDmp().getCreated() != null ? item.getDmp().getCreated().toInstant() : Instant.now());
data.setUpdatedAt(Instant.now()); data.setUpdatedAt(item.getDmp().getModified() != null ? item.getDmp().getModified().toInstant() : Instant.now());
data.setIsActive(IsActive.Active); data.setIsActive(IsActive.Active);
this.entityManager.persist(data); this.entityManager.persist(data);
} }

7
dmp-migration-tool/web/src/main/java/eu/old/eudat/publicapi/migration/MigrationController.java
View File

@ -86,12 +86,15 @@ public class MigrationController {
this.dmpDatasetProfileMigrationService.migrate(); this.dmpDatasetProfileMigrationService.migrate();
this.datasetMigrationService.migrate(); this.datasetMigrationService.migrate();
this.dmpUserMigrationService.migrate();
this.referenceMigrationService.migrateDatasetReferences();
this.referenceMigrationService.migrateDmpReferences();
this.userContactInfoMigrationService.migrate(); this.userContactInfoMigrationService.migrate();
return true; return true;
} }
@GetMapping("contacts") @GetMapping("contacts")
@Transactional @Transactional
public boolean migrateContacts() { public boolean migrateContacts() {