import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.StandardCopyOption;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class FileToDBExample {

    // Méthode pour lire les données du fichier texte et les stocker dans une liste ou un tableau
    private static String[] readDataFromFile(String filePath) throws IOException {
        BufferedReader reader = new BufferedReader(new FileReader(filePath));
        String line;
        StringBuilder dataBuilder = new StringBuilder();
        while ((line = reader.readLine()) != null) {
            dataBuilder.append(line).append("\n");
        }
        reader.close();
        return dataBuilder.toString().trim().split("\n");
    }

    // Méthode pour insérer les données dans la base de données
    private static void insertDataIntoDatabase(String[] data, Connection connection) throws SQLException {
        String sql = "INSERT INTO nom_table (colonne1, colonne2, colonne3) VALUES (?, ?, ?)";
        PreparedStatement statement = connection.prepareStatement(sql);

        for (String line : data) {
            String[] columns = line.split(",");
            String valeurColonne1 = columns[0].trim();
            String valeurColonne2 = columns[1].trim();
            String valeurColonne3 = columns[2].trim();

            statement.setString(1, valeurColonne1);
            statement.setString(2, valeurColonne2);
            statement.setString(3, valeurColonne3);

            statement.executeUpdate();
        }

        statement.close();
    }

    // Méthode pour déplacer le fichier traité dans un dossier de sauvegarde
    private static void moveFileToBackupFolder(String filePath, String backupFolderPath) throws IOException {
        File file = new File(filePath);
        Path sourcePath = file.toPath();
        Path destinationPath = new File(backupFolderPath, file.getName()).toPath();

        Files.move(sourcePath, destinationPath, StandardCopyOption.REPLACE_EXISTING);
    }

    public static void main(String[] args) {
        String filePath = "chemin/vers/fichier.txt";
        String backupFolderPath = "chemin/vers/dossier/sauvegarde";

        try {
            // Lire les données du fichier
            String[] data = readDataFromFile(filePath);

            // Établir la connexion à la base de données
            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/nom_base", "utilisateur", "mot_de_passe");

            // Insérer les données dans la base de données
            insertDataIntoDatabase(data, connection);

            // Déplacer le fichier traité dans le dossier de sauvegarde
            moveFileToBackupFolder(filePath, backupFolderPath);

            // Fermer la connexion à la base de données
            connection.close();

            System.out.println("Les données du fichier ont été insérées dans la base de données avec succès.");
            System.out.println("Le fichier a été déplacé vers le dossier de sauvegarde.");
        } catch (IOException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}