Imágenes, Java/JDBC y MySQL

  /*
 * imagenbbdd.java
 *
 * @author  Roberto Canales
 * Ejemplo de manipulación de imagenes en Base de Datos
 */

import java.io.*;
import javax.sql.*;
import java.sql.*;
import java.awt.*;

public class CImagenbbdd {
    public static void main(String[] args) {
        CImagenbbdd nuevo = new CImagenbbdd();
        nuevo.ejecuta();
    }

    public void depura(String param) {
        System.out.println("Mensaje depuración: " + param);
    }

    public void ejecuta() {

        long inicio = System.currentTimeMillis();

        Connection con = getConexion();

        long fin = System.currentTimeMillis() - inicio;
        depura("El tiempo transcurrido en conectar es " + fin + " milisegundos");

        InputStream imagenRecuperada = recuperaImagenBBDD(con);
        guardaImagenEnDisco(imagenRecuperada);

        fin = System.currentTimeMillis() - inicio;
        depura("El tiempo transcurrido completo es " + fin + " milisegundos");



    }

    public void guardaImagenEnDisco(InputStream imagenBuffer)
    {
        try // (esto es practicamente una copia de ficheros clasica)
        {
            File fichero = new File("c:\\melones.jpg");
            BufferedInputStream in = new BufferedInputStream(imagenBuffer);
            BufferedOutputStream out = new BufferedOutputStream(new FileOutputStream(fichero));

            byte[] bytes = new byte[8096];
            int len = 0;

            depura("Copiamos el fichero");

            while ( (len = in.read( bytes ))> 0 )
            {
                out.write( bytes, 0, len );
            }

            out.flush();
            out.close();
            in.close();

            depura("Teminación del proceso con éxito");
        }
        catch(Exception e)
        {
            depura("Error al escribir en disco " + e.getMessage());
        }
    }


    public Connection getConexion() {
        Connection con = null;

        try {
            Driver d = (Driver)Class.forName("com.mysql.jdbc.Driver").newInstance();

            depura("Recuperamos conexión");
            con = DriverManager.getConnection("jdbc:mysql://localhost/tutoriales","","");
        }
        catch(Exception e) {
            depura("Error al recuperar conexion " + e.toString());
            return null;
        }

        return con;

    }

    public InputStream recuperaImagenBBDD(Connection con) {
        try {
            String consultaGenerada = "select * from imagenesbbdd limit 1";

            depura("Ejecutamos Statement");
            java.sql.Statement stmt = con.createStatement();

            depura("Ejecutamos sentencia " + consultaGenerada);
            ResultSet results = stmt.executeQuery(consultaGenerada);

            results.next();

            Blob campo = results.getBlob("imagen");
            return campo.getBinaryStream();
        }
        catch(Exception e) {
            depura("Error al recuperar el Stream");
        }

        return null;
    }

}
 

Mensaje depuración: Recuperamos conexión
Mensaje depuración: El tiempo transcurrido en conectar es 270 milisegundos
Mensaje depuración: Ejecutamos Statement
Mensaje depuración: Ejecutamos sentencia select * from imagenesbbdd limit 1
Mensaje depuración: Copiamos el fichero
Mensaje depuración: Terminación del proceso con éxito
Mensaje depuración: El tiempo transcurrido completo es 280 milisegundos

   void escribeImagenEnBBDD(Connection con)
    {
        try {
              File fichero = new File("c:\\melones.jpg");
              FileInputStream streamEntrada = new FileInputStream(fichero);
              PreparedStatement pstmt = con.prepareStatement("insert into imagenesbbdd (nombre,imagen) values (?,?)");
              pstmt.setString(1, "melones.jpg");
              pstmt.setBinaryStream(2, streamEntrada, (int)fichero.length());
              pstmt.executeUpdate();
              pstmt.close();
              streamEntrada.close();

        }
        catch(Exception e) {
            depura("Error al escribir el Stream " + e.getMessage());
        }
    }