florian/codiki-database-extractor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Initial commit.

Browse Source
This commit is contained in:
Florian THIERRY
2024-03-21 14:26:09 +01:00
commit ba408ee0a2
36 changed files with 939 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
.gitignore vendored Normal file
View File

@@ -0,0 +1,33 @@
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/

62
pom.xml Normal file
View File

@@ -0,0 +1,62 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.2.3</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>org.codiki</groupId>
<artifactId>database-extractor</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>database-extractor</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>21</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>

13
src/main/java/org/codiki/databaseextractor/DatabaseExtractorApplication.java Normal file
View File

@@ -0,0 +1,13 @@
package org.codiki.databaseextractor;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class DatabaseExtractorApplication {
public static void main(String[] args) {
SpringApplication.run(DatabaseExtractorApplication.class, args);
}
}

158
src/main/java/org/codiki/databaseextractor/controller/ExportController.java Normal file
View File

@@ -0,0 +1,158 @@
package org.codiki.databaseextractor.controller;
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.nio.Buffer;
import java.util.List;
import org.codiki.databaseextractor.entity.previous.OldCategory;
import org.codiki.databaseextractor.entity.previous.Image;
import org.codiki.databaseextractor.entity.previous.Post;
import org.codiki.databaseextractor.entity.previous.OldUser;
import org.codiki.databaseextractor.entity.previous.Version;
import org.codiki.databaseextractor.entity.wrapper.*;
import org.codiki.databaseextractor.mapper.CategoryMapper;
import org.codiki.databaseextractor.mapper.PictureMapper;
import org.codiki.databaseextractor.mapper.PublicationMapper;
import org.codiki.databaseextractor.mapper.UserMapper;
import org.codiki.databaseextractor.repository.CategoryRepository;
import org.codiki.databaseextractor.repository.ImageRepository;
import org.codiki.databaseextractor.repository.PostRepository;
import org.codiki.databaseextractor.repository.UserRepository;
import org.codiki.databaseextractor.repository.VersionRepository;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/export")
public class ExportController {
private final CategoryRepository categoryRepository;
private final ImageRepository imageRepository;
private final PostRepository postRepository;
private final UserRepository userRepository;
private final VersionRepository versionRepository;
private final UserMapper userMapper;
private final PictureMapper pictureMapper;
private final CategoryMapper categoryMapper;
private final PublicationMapper publicationMapper;
public ExportController(
CategoryRepository categoryRepository,
ImageRepository imageRepository,
PostRepository postRepository,
UserRepository userRepository,
VersionRepository versionRepository,
UserMapper userMapper,
PictureMapper pictureMapper,
CategoryMapper categoryMapper, PublicationMapper publicationMapper
) {
this.categoryRepository = categoryRepository;
this.postRepository = postRepository;
this.userRepository = userRepository;
this.imageRepository = imageRepository;
this.versionRepository = versionRepository;
this.userMapper = userMapper;
this.pictureMapper = pictureMapper;
this.categoryMapper = categoryMapper;
this.publicationMapper = publicationMapper;
}
@GetMapping
public void exportDatabase() {
List<OldCategory> oldCategories = extractCategories();
List<Image> images = extractImages();
List<Post> posts = extractPosts();
List<OldUser> oldUsers = extractUsers();
List<Version> versions = extractVersions();
List<UserWrapper> users = userMapper.mapFrom(oldUsers);
List<PictureWrapper> pictures = pictureMapper.mapFrom(images, users);
List<CategoryWrapper> categories = categoryMapper.mapFrom(oldCategories);
List<PublicationWrapper> publications = publicationMapper.mapFrom(posts, users, categories, pictures);
List<NonCodikiPicture> nonCodikiPictures = publicationMapper.extractNonCodikiPictures(publications, pictures);
generateSqlScript(users, pictures, categories, publications);
System.out.println("yo");
}
private void generateSqlScript(
List<UserWrapper> users,
List<PictureWrapper> pictures,
List<CategoryWrapper> categories,
List<PublicationWrapper> publications
) {
String sqlScriptFilePath = "/Users/florian_thierry/Documents/Developpement/codiki-database-extractor/codiki_export.sql";
try(FileWriter fileWriter = new FileWriter(sqlScriptFilePath);
BufferedWriter writer = new BufferedWriter(fileWriter)) {
writeUsersQuery(writer, users);
writePicturesQuery(writer, pictures);
writeCategoriesQuery(writer, categories);
writePublicationsQuery(writer, publications);
} catch (IOException exception) {
System.out.println("An error occured while writing SQL script file");
}
}
private void writeUsersQuery(BufferedWriter writer, List<UserWrapper> users) throws IOException {
writer.write("-- Users insertion\n");
writer.write("INSERT INTO \"user\" (id, pseudo, email, password, photo_id) VALUES\n");
writeEntitiesQueryPart(writer, users);
}
private void writePicturesQuery(BufferedWriter writer, List<PictureWrapper> pictures) throws IOException {
writer.write("\n");
writer.write("-- Pictures insertion\n");
writer.write("INSERT INTO picture (id, publisher_id) VALUES\n");
writeEntitiesQueryPart(writer, pictures);
}
private void writeCategoriesQuery(BufferedWriter writer, List<CategoryWrapper> categories) throws IOException {
writer.write("\n");
writer.write("-- Categories insertion\n");
writer.write("INSERT INTO category (id, name, parent_category_id) VALUES\n");
writeEntitiesQueryPart(writer, categories);
}
private void writePublicationsQuery(BufferedWriter writer, List<PublicationWrapper> publications) throws IOException {
writer.write("\n");
writer.write("-- Publications insertion\n");
writer.write("INSERT INTO publication (id, key, title, text, description, creation_date, illustration_id, author_id, category_id) VALUES\n");
writeEntitiesQueryPart(writer, publications);
}
private void writeEntitiesQueryPart(BufferedWriter writer, List<? extends SqlFragmentGenerator> entities) throws IOException {
for (int i = 0; i < entities.size(); i++) {
var entity = entities.get(i);
writer.write(entity.buildSqlFragment());
if (i == entities.size() - 1) {
writer.write(";");
} else {
writer.write(",");
}
writer.write("\n");
}
}
private List<OldCategory> extractCategories() {
return categoryRepository.findAll();
}
private List<Image> extractImages() {
return imageRepository.findAll();
}
private List<Post> extractPosts() {
return postRepository.findAll();
}
private List<OldUser> extractUsers() {
return userRepository.findAll();
}
private List<Version> extractVersions() {
return versionRepository.findAll();
}
}

9
src/main/java/org/codiki/databaseextractor/entity/next/Author.java Normal file
View File

@@ -0,0 +1,9 @@
package org.codiki.databaseextractor.entity.next;
import java.util.UUID;
public record Author(
UUID id,
String name,
String image
) { }

11
src/main/java/org/codiki/databaseextractor/entity/next/Category.java Normal file
View File

@@ -0,0 +1,11 @@
package org.codiki.databaseextractor.entity.next;
import java.util.List;
import java.util.UUID;
public record Category(
UUID id,
String name,
List<Category> subCategories,
UUID parentCategoryId
) {}

10
src/main/java/org/codiki/databaseextractor/entity/next/Picture.java Normal file
View File

@@ -0,0 +1,10 @@
package org.codiki.databaseextractor.entity.next;
import java.io.File;
import java.util.UUID;
public record Picture(
UUID id,
UUID publisherId,
File contentFile
) {}

17
src/main/java/org/codiki/databaseextractor/entity/next/Publication.java Normal file
View File

@@ -0,0 +1,17 @@
package org.codiki.databaseextractor.entity.next;
import java.time.ZonedDateTime;
import java.util.UUID;
public record Publication(
UUID id,
String key,
String title,
String text,
String description,
ZonedDateTime creationDate,
UUID illustrationId,
UUID categoryId,
UUID authorId
) {
}

13
src/main/java/org/codiki/databaseextractor/entity/next/User.java Normal file
View File

@@ -0,0 +1,13 @@
package org.codiki.databaseextractor.entity.next;
import java.util.List;
import java.util.UUID;
public record User(
UUID id,
String pseudo,
String email,
String password,
UUID photoId,
List<UserRole> roles
) {}

22
src/main/java/org/codiki/databaseextractor/entity/next/UserRole.java Normal file
View File

@@ -0,0 +1,22 @@
package org.codiki.databaseextractor.entity.next;
import java.util.Optional;
import java.util.stream.Stream;
public enum UserRole {
STANDARD,
ADMIN;
public static Optional<UserRole> from(String roleAsString) {
return Stream.of(UserRole.values())
.filter(role -> role.name().equals(roleAsString))
.findFirst();
}
public static Optional<UserRole> from(int roleId) {
return Stream.of(UserRole.values())
.filter(role -> role.ordinal() == roleId)
.findFirst();
}
}

27
src/main/java/org/codiki/databaseextractor/entity/previous/Image.java Normal file
View File

@@ -0,0 +1,27 @@
package org.codiki.databaseextractor.entity.previous;
import java.util.Date;
import jakarta.persistence.Column;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Entity
@Table(name = "image")
@NoArgsConstructor
@AllArgsConstructor
@Getter
@Setter
public class Image {
@Id
private Long id;
private String link;
private Date date;
@Column(name = "user_id")
private int publisherId;
}

32
src/main/java/org/codiki/databaseextractor/entity/previous/OldCategory.java Normal file
View File

@@ -0,0 +1,32 @@
package org.codiki.databaseextractor.entity.previous;
import java.util.List;
import com.fasterxml.jackson.annotation.JsonView;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.Inheritance;
import jakarta.persistence.InheritanceType;
import jakarta.persistence.OneToMany;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Entity
@Table(name = "category")
@Inheritance(strategy = InheritanceType.JOINED)
@NoArgsConstructor
@AllArgsConstructor
@Getter
@Setter
public class OldCategory {
@Id
private Long id;
private String name;
private Long creatorId;
@OneToMany(mappedBy = "mainCategory")
private List<OldSubCategory> listSubCategories;
}

23
src/main/java/org/codiki/databaseextractor/entity/previous/OldSubCategory.java Normal file
View File

@@ -0,0 +1,23 @@
package org.codiki.databaseextractor.entity.previous;
import jakarta.persistence.Entity;
import jakarta.persistence.FetchType;
import jakarta.persistence.JoinColumn;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Entity
@Table(name = "sub_category")
@NoArgsConstructor
@AllArgsConstructor
@Getter
@Setter
public class OldSubCategory extends OldCategory {
@ManyToOne
@JoinColumn(name = "main_category")
private OldCategory mainCategory;
}

31
src/main/java/org/codiki/databaseextractor/entity/previous/OldUser.java Normal file
View File

@@ -0,0 +1,31 @@
package org.codiki.databaseextractor.entity.previous;
import java.util.Date;
import jakarta.persistence.Column;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Entity
@Table(name = "`user`")
@NoArgsConstructor
@AllArgsConstructor
@Getter
@Setter
public class OldUser {
@Id
private Long id;
private String key;
private String name;
private String email;
private String password;
private Date inscriptionDate;
private int roleId;
@Column(name = "image")
private String imageLink;
}

34
src/main/java/org/codiki/databaseextractor/entity/previous/Post.java Normal file
View File

@@ -0,0 +1,34 @@
package org.codiki.databaseextractor.entity.previous;
import java.util.Date;
import static jakarta.persistence.TemporalType.TIMESTAMP;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
import jakarta.persistence.Temporal;
import jakarta.persistence.TemporalType;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Entity
@Table(name = "post")
@NoArgsConstructor
@AllArgsConstructor
@Getter
@Setter
public class Post {
@Id
private Long id;
private String key;
private String title;
private String text;
private String description;
@Temporal(TIMESTAMP)
private Date creationDate;
private String image;
private Long creatorId;
private Long categoryId;
}

26
src/main/java/org/codiki/databaseextractor/entity/previous/Version.java Normal file
View File

@@ -0,0 +1,26 @@
package org.codiki.databaseextractor.entity.previous;
import java.util.List;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.OneToMany;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Entity
@Table(name = "version")
@NoArgsConstructor
@AllArgsConstructor
@Getter
@Setter
public class Version {
@Id
private Long id;
private String number;
@OneToMany(mappedBy = "version")
private List<VersionRevision> revisions;
}

27
src/main/java/org/codiki/databaseextractor/entity/previous/VersionRevision.java Normal file
View File

@@ -0,0 +1,27 @@
package org.codiki.databaseextractor.entity.previous;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.JoinColumn;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Entity
@Table(name = "version_revision")
@NoArgsConstructor
@AllArgsConstructor
@Getter
@Setter
public class VersionRevision {
@Id
private Long id;
private String text;
private boolean bugfix;
@ManyToOne
@JoinColumn(name = "version_id")
private Version version;
}

19
src/main/java/org/codiki/databaseextractor/entity/wrapper/CategoryWrapper.java Normal file
View File

@@ -0,0 +1,19 @@
package org.codiki.databaseextractor.entity.wrapper;
import org.codiki.databaseextractor.entity.next.Category;
import org.codiki.databaseextractor.entity.previous.OldCategory;
public record CategoryWrapper(
OldCategory oldCategory,
Category category
) implements SqlFragmentGenerator {
@Override
public String buildSqlFragment() {
return String.format(
"('%s', '%s', %s)",
category.id(),
category.name(),
"NULL"
);
}
}

7
src/main/java/org/codiki/databaseextractor/entity/wrapper/NonCodikiPicture.java Normal file
View File

@@ -0,0 +1,7 @@
package org.codiki.databaseextractor.entity.wrapper;
public record NonCodikiPicture(
PublicationWrapper associatedPublication,
String pictureExternalLink
) {
}

18
src/main/java/org/codiki/databaseextractor/entity/wrapper/PictureWrapper.java Normal file
View File

@@ -0,0 +1,18 @@
package org.codiki.databaseextractor.entity.wrapper;
import org.codiki.databaseextractor.entity.next.Picture;
import org.codiki.databaseextractor.entity.previous.Image;
public record PictureWrapper(
Image image,
Picture picture
) implements SqlFragmentGenerator {
@Override
public String buildSqlFragment() {
return String.format(
"('%s', '%s')",
picture.id(),
picture.publisherId()
);
}
}

28
src/main/java/org/codiki/databaseextractor/entity/wrapper/PublicationWrapper.java Normal file
View File

@@ -0,0 +1,28 @@
package org.codiki.databaseextractor.entity.wrapper;
import org.codiki.databaseextractor.entity.next.Publication;
import org.codiki.databaseextractor.entity.previous.Post;
import java.time.format.DateTimeFormatter;
public record PublicationWrapper(
Post post,
Publication publication
) implements SqlFragmentGenerator {
private static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
@Override
public String buildSqlFragment() {
return String.format(
"('%s', '%s', '%s', '%s', '%s', '%s', %s, '%s', '%s')",
publication.id(),
publication.key(),
publication.title().replaceAll("'", "''"),
publication.text().replaceAll("'", "''"),
publication.description().replaceAll("'", "''"),
String.format("%s +01:00", publication.creationDate().format(DATE_TIME_FORMATTER)),
publication.illustrationId() == null ? "NULL" : String.format("'%s'", publication().illustrationId()),
publication.authorId(),
publication.categoryId()
);
}
}

5
src/main/java/org/codiki/databaseextractor/entity/wrapper/SqlFragmentGenerator.java Normal file
View File

@@ -0,0 +1,5 @@
package org.codiki.databaseextractor.entity.wrapper;
public interface SqlFragmentGenerator {
String buildSqlFragment();
}

21
src/main/java/org/codiki/databaseextractor/entity/wrapper/UserWrapper.java Normal file
View File

@@ -0,0 +1,21 @@
package org.codiki.databaseextractor.entity.wrapper;
import org.codiki.databaseextractor.entity.next.User;
import org.codiki.databaseextractor.entity.previous.OldUser;
public record UserWrapper(
OldUser oldUser,
User user
) implements SqlFragmentGenerator {
@Override
public String buildSqlFragment() {
return String.format(
"('%s', '%s', '%s', '%s', %s)",
user.id(),
user.pseudo(),
user.email(),
user.password(),
user.photoId() == null ? "NULL" : String.format("'%s'", user.photoId())
);
}
}

18
src/main/java/org/codiki/databaseextractor/helper/CategoryHelper.java Normal file
View File

@@ -0,0 +1,18 @@
package org.codiki.databaseextractor.helper;
import static java.util.Collections.emptyList;
import java.util.List;
import java.util.Optional;
import org.codiki.databaseextractor.entity.wrapper.CategoryWrapper;
import org.springframework.stereotype.Component;
@Component
public class CategoryHelper {
public Optional<CategoryWrapper> findByOldCategoryId(List<CategoryWrapper> allCategories, Long mainCategoryId) {
return allCategories.stream()
.filter(category -> category.oldCategory().getId().equals(mainCategoryId))
.findFirst();
}
}

16
src/main/java/org/codiki/databaseextractor/helper/UserHelper.java Normal file
View File

@@ -0,0 +1,16 @@
package org.codiki.databaseextractor.helper;
import java.util.List;
import java.util.Optional;
import org.codiki.databaseextractor.entity.wrapper.UserWrapper;
import org.springframework.stereotype.Component;
@Component
public class UserHelper {
public Optional<UserWrapper> findByOldUserId(List<UserWrapper> users, int oldUserId) {
return users.stream()
.filter(user -> user.oldUser().getId().intValue() == oldUserId)
.findFirst();
}
}

56
src/main/java/org/codiki/databaseextractor/mapper/CategoryMapper.java Normal file
View File

@@ -0,0 +1,56 @@
package org.codiki.databaseextractor.mapper;
import static java.util.Collections.emptyList;
import java.util.List;
import java.util.UUID;
import org.codiki.databaseextractor.entity.next.Category;
import org.codiki.databaseextractor.entity.previous.OldCategory;
import org.codiki.databaseextractor.entity.wrapper.CategoryWrapper;
import org.codiki.databaseextractor.helper.CategoryHelper;
import org.springframework.stereotype.Component;
@Component
public class CategoryMapper {
private final CategoryHelper categoryHelper;
public CategoryMapper(CategoryHelper categoryHelper) {
this.categoryHelper = categoryHelper;
}
public List<CategoryWrapper> mapFrom(List<OldCategory> oldCategories) {
List<CategoryWrapper> allCategories = oldCategories.stream()
.map(oldCategory -> {
Category category = new Category(
UUID.randomUUID(),
oldCategory.getName(),
emptyList(),
null
);
return new CategoryWrapper(oldCategory, category);
})
.toList();
return allCategories.stream()
.map(category -> {
List<CategoryWrapper> subCategories = category.oldCategory()
.getListSubCategories()
.stream()
.map(subCategory -> categoryHelper.findByOldCategoryId(allCategories, subCategory.getId())
.orElseThrow(() -> new RuntimeException("No category wrapper found for sub category " + subCategory.getId())))
.toList();
Category categoryWithSubCategories = new Category(
category.category().id(),
category.category().name(),
subCategories.stream()
.map(CategoryWrapper::category)
.toList(),
null
);
return new CategoryWrapper(category.oldCategory(), categoryWithSubCategories);
})
.toList();
}
}

41
src/main/java/org/codiki/databaseextractor/mapper/PictureMapper.java Normal file
View File

@@ -0,0 +1,41 @@
package org.codiki.databaseextractor.mapper;
import java.util.List;
import java.util.UUID;
import org.codiki.databaseextractor.entity.next.Picture;
import org.codiki.databaseextractor.entity.next.User;
import org.codiki.databaseextractor.entity.previous.Image;
import org.codiki.databaseextractor.entity.previous.OldUser;
import org.codiki.databaseextractor.entity.wrapper.PictureWrapper;
import org.codiki.databaseextractor.entity.wrapper.UserWrapper;
import org.codiki.databaseextractor.helper.UserHelper;
import org.springframework.stereotype.Component;
@Component
public class PictureMapper {
private final UserHelper userHelper;
public PictureMapper(UserHelper userHelper) {
this.userHelper = userHelper;
}
public List<PictureWrapper> mapFrom(List<Image> images, List<UserWrapper> users) {
return images.stream()
.map(image -> {
int oldPublisherId = image.getPublisherId();
UserWrapper publisher = userHelper.findByOldUserId(users, oldPublisherId)
.orElseThrow(() -> new RuntimeException("Aucun publieur trouvé pour l'image " + image.getId()));
Picture picture = new Picture(
UUID.randomUUID(),
publisher.user().id(),
null
);
return new PictureWrapper(image, picture);
})
.toList();
}
}

70
src/main/java/org/codiki/databaseextractor/mapper/PublicationMapper.java Normal file
View File

@@ -0,0 +1,70 @@
package org.codiki.databaseextractor.mapper;
import java.time.ZoneId;
import java.time.ZonedDateTime;
import java.util.List;
import java.util.Optional;
import java.util.UUID;
import org.codiki.databaseextractor.entity.next.Publication;
import org.codiki.databaseextractor.entity.previous.Post;
import org.codiki.databaseextractor.entity.wrapper.*;
import org.springframework.stereotype.Component;
import static java.util.Objects.isNull;
@Component
public class PublicationMapper {
public List<PublicationWrapper> mapFrom(
List<Post> posts,
List<UserWrapper> users,
List<CategoryWrapper> categories,
List<PictureWrapper> pictures) {
return posts.stream()
.map(post -> {
CategoryWrapper publicationCategory = categories.stream()
.filter(category -> category.oldCategory().getId().equals(post.getCategoryId()))
.findFirst()
.orElseThrow(() -> new RuntimeException("No any category found for post " + post.getId()));
UserWrapper publicationAuthor = users.stream()
.filter(user -> user.oldUser().getId().equals(post.getCreatorId()))
.findFirst()
.orElseThrow(() -> new RuntimeException("No any author found for post " + post.getId()));
Optional<UUID> publicationIllustrationId = Optional.of(post.getImage())
.filter(imageLink -> imageLink.startsWith("https://codiki.org/api/images/"))
.map(imageLink -> imageLink.substring("https://codiki.org/api/images/".length()))
.flatMap(imageKey -> findPictureByLink(pictures, imageKey))
.map(picture -> picture.picture().id());
Publication publication = new Publication(
UUID.randomUUID(),
post.getKey(),
post.getTitle(),
post.getText(),
post.getDescription(),
ZonedDateTime.ofInstant(post.getCreationDate().toInstant(), ZoneId.systemDefault()),
publicationIllustrationId.orElse(null),
publicationCategory.category().id(),
publicationAuthor.user().id()
);
return new PublicationWrapper(post, publication);
})
.toList();
}
private Optional<PictureWrapper> findPictureByLink(List<PictureWrapper> pictures, String pictureLink) {
return pictures.stream()
.filter(picture -> picture.image().getLink().equals(pictureLink))
.findFirst();
}
public List<NonCodikiPicture> extractNonCodikiPictures(List<PublicationWrapper> publications, List<PictureWrapper> pictures) {
return publications.stream()
.filter(publication -> isNull(publication.publication().illustrationId()))
.map(publication -> new NonCodikiPicture(publication, publication.post().getImage()))
.toList();
}
}

35
src/main/java/org/codiki/databaseextractor/mapper/UserMapper.java Normal file
View File

@@ -0,0 +1,35 @@
package org.codiki.databaseextractor.mapper;
import java.util.List;
import java.util.UUID;
import org.codiki.databaseextractor.entity.next.User;
import org.codiki.databaseextractor.entity.next.UserRole;
import org.codiki.databaseextractor.entity.previous.OldUser;
import org.codiki.databaseextractor.entity.wrapper.UserWrapper;
import org.springframework.stereotype.Component;
@Component
public class UserMapper {
public List<UserWrapper> mapFrom(List<OldUser> oldUsers) {
return oldUsers.stream()
.map(oldUser -> {
User user = mapFrom(oldUser);
return new UserWrapper(oldUser, user);
})
.toList();
}
private static User mapFrom(OldUser user) {
return new User(
UUID.randomUUID(),
user.getName(),
user.getEmail(),
user.getPassword(),
null,
UserRole.from(user.getRoleId())
.stream()
.toList()
);
}
}

7
src/main/java/org/codiki/databaseextractor/repository/CategoryRepository.java Normal file
View File

@@ -0,0 +1,7 @@
package org.codiki.databaseextractor.repository;
import org.codiki.databaseextractor.entity.previous.OldCategory;
import org.springframework.data.jpa.repository.JpaRepository;
public interface CategoryRepository extends JpaRepository<OldCategory, Long> {
}

7
src/main/java/org/codiki/databaseextractor/repository/ImageRepository.java Normal file
View File

@@ -0,0 +1,7 @@
package org.codiki.databaseextractor.repository;
import org.codiki.databaseextractor.entity.previous.Image;
import org.springframework.data.jpa.repository.JpaRepository;
public interface ImageRepository extends JpaRepository<Image, Long> {
}

7
src/main/java/org/codiki/databaseextractor/repository/PostRepository.java Normal file
View File

@@ -0,0 +1,7 @@
package org.codiki.databaseextractor.repository;
import org.codiki.databaseextractor.entity.previous.Post;
import org.springframework.data.jpa.repository.JpaRepository;
public interface PostRepository extends JpaRepository<Post, Long> {
}

7
src/main/java/org/codiki/databaseextractor/repository/UserRepository.java Normal file
View File

@@ -0,0 +1,7 @@
package org.codiki.databaseextractor.repository;
import org.codiki.databaseextractor.entity.previous.OldUser;
import org.springframework.data.jpa.repository.JpaRepository;
public interface UserRepository extends JpaRepository<OldUser, Long> {
}

7
src/main/java/org/codiki/databaseextractor/repository/VersionRepository.java Normal file
View File

@@ -0,0 +1,7 @@
package org.codiki.databaseextractor.repository;
import org.codiki.databaseextractor.entity.previous.Version;
import org.springframework.data.jpa.repository.JpaRepository;
public interface VersionRepository extends JpaRepository<Version, Long> {
}

9
src/main/resources/application.yml Normal file
View File

@@ -0,0 +1,9 @@
spring:
datasource:
driverClassName: org.postgresql.Driver
url: jdbc:postgresql://localhost:50001/codiki_prod
username: codiki_admin
password: password
server:
port: 8765

13
src/test/java/org/codiki/databaseextractor/DatabaseExtractorApplicationTests.java Normal file
View File

@@ -0,0 +1,13 @@
package org.codiki.databaseextractor;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class DatabaseExtractorApplicationTests {
@Test
void contextLoads() {
}
}