package com.conexao;

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.UUID;

public class MigracaoDados {

    public static void main(String[] args) throws Exception {

        ResultSet rs = null;

        try {
            Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
            Connection connection = DriverManager.getConnection("jdbc:oracle:thin:@192.168.1.102:1521:xe","teste","123456");
            System.out.println("Conectado!");
            Statement statement = connection.createStatement();

            String sql = "SELECT id, dthinclusao, path, documentoarquivo FROM processodocumento";
            rs = statement.executeQuery(sql);

            while (rs.next()) {

                //obtendo o arquivo no banco
                int id = rs.getInt("id");
                Blob blob = rs.getBlob("documentoarquivo");

                //stream para leitura
                InputStream is = blob.getBinaryStream();

                String data = rs.getString("dthinclusao");
                String s_ano = data.substring(0,4);
                String s_mes = data.substring(5,7);
                String s_dia = data.substring(8,10);
                System.out.println(s_dia + "/" + s_mes + "/" + s_ano);
                System.out.println("---------------");

                //criacao do diretorio
                File novoDiretorio = new File("/home/phoenix/Documentos/workspace/files/" + "/"
                        + s_ano + "/"
                        + s_mes + "/"
                        + s_dia + "/");
                novoDiretorio.mkdirs();

                //geracao aleatoria dos nomes dos arquivos
                String descricaoArquivo = UUID.randomUUID().toString();

                //criacao do arquivo
                File file = new File(novoDiretorio, descricaoArquivo + ".pdf");
                System.out.println("Caminho do arquivo: " + file);

                String path = file.toString();
                System.out.println("Path: " + path);

                //atualizar campo path de acordo o nome do arquivo gerado
                String sqlAtualiza = "UPDATE processodocumento SET path=? WHERE id = ?";
                PreparedStatement stmt = connection.prepareStatement(sqlAtualiza);

                stmt.setString(1, path);
                stmt.setInt(2, id);
                stmt.executeUpdate();

                //stream para escrita
                FileOutputStream fos = new FileOutputStream(file);

                int b = 0;
                while ((b = is.read()) != -1)
                {
                    //efetuar a escrita no sistema de arquivos
                    fos.write(b);
                }
                fos.close();
                stmt.close();
            }
            statement.close();
            System.out.println("Todos os arquivos foram gravados no sistema de arquivos!");
            System.out.println("Desconectado!");


        } catch (SQLException e)
        {
            e.getMessage (); e.printStackTrace();
            System.out.println(e);
        }
    }
}