src/main/java/ru/gb/spring/diplomawebjavaspringgb/service/UploadService.java - master - ilyaBu/WebSpringJava

src/main/java/ru/gb/spring/diplomawebjavaspringgb/service/UploadService.java
75 строк3 KB
IliaBu
Update code
14 июл 2024, 09:59
14 июл 2024, 09:592267cd9
package ru.gb.spring.diplomawebjavaspringgb.service;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.sql.Connection;

/**
 * Сервис UploadService.
 */
@Service
public class UploadService {

    @Value("${spring.datasource.url}")
    private String url;

    @Value("${spring.datasource.username}")
    private String username;

    @Value("${spring.datasource.password}")
    private String password;

    PGConnections pgConnections;

    Connection connection;

    @Value("${tables.table1}")
    public String table1;

    @Value("${tables.table2}")
    public String table2;

    @Value("${tables.table3}")
    public String table3;

    @Value("${tables.table4}")
    public String table4;

    @Value("${tables.table5}")
    public String table5;

    @Value("${tables.table6}")
    public String table6;

    @Value("${tables.table7}")
    public String table7;

    /**
     * Метод удаляет все записи в указанной таблице и вставляет новые записи из предоставленного файла.
     *
     * @param file  объект MultipartFile, содержащий данные, которые необходимо вставить в таблицу.
     * @param table имя таблицы в базе данных PostgreSQL, куда будут вставлены данные.
     * Исключение @throws если во время операций с базой данных возникает какая-либо ошибка.
     */
    public void truncateAndInsert(MultipartFile file, String table) {
        pgConnections = new PGConnections(url, username, password);
        connection = pgConnections.getConnection();
        pgConnections.truncateRecord(connection, table);
        pgConnections.copyToDB(connection, table, file);
    }

    /**
     * Метод выполняет слияние записей из нескольких таблиц в одну таблицу в базе данных PostgreSQL.
     * Слияние осуществляется путем объединения записей из указанных таблиц в одну новую таблицу.
     * При этом дубликаты записей удаляются.
     * Исключение @throws если во время операций с базой данных возникает какая-либо ошибка, будет брошено исключение.
     */
    public void mergeTables() {
        pgConnections = new PGConnections(url, username, password);
        connection = pgConnections.getConnection();
        pgConnections.mergeRecord(connection);
    }

}