往MySQL中存储图片_MySQL

CREATE TABLE photo ( id INT NOT NULL AUTO_INCREMENT, name VARCHAR(100), photo MediumBlob, PRIMARY KEY (id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;/*MySQL的四种BLOB类型类型 大小(单位：字节)TinyBlob 最大 255Blob 最大 65KMediumBlob 最大 16MLongBlob 最大 4G*/

package com.sk.util;import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;public class ImageUtil { private static File file = null; /** * 从本地文件读取图像的二进制流 * * @param infile * @return */ public static FileInputStream getImageByte(String infile) { FileInputStream imageByte = null; file = new File(infile); try { imageByte = new FileInputStream(file); } catch (FileNotFoundException e) { e.printStackTrace(); } return imageByte; } /** * 将图片流读出为图片 * * @param inputStream * @param path */ public static void readBlob(InputStream inputStream, String path) { try { FileOutputStream fileOutputStream = new FileOutputStream(path); byte[] buffer = new byte[1024]; int len = 0; while ((len = inputStream.read(buffer)) != -1) { fileOutputStream.write(buffer, 0, len); } inputStream.close(); fileOutputStream.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }}

package com.sk.handle;import java.io.IOException;import java.io.InputStream;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.SQLException;import com.sk.util.ImageUtil;public class WriteImage {	public static void main(String[] args) {	try {	Class.forName("com.mysql.jdbc.Driver").newInstance();	} catch (InstantiationException e) {	e.printStackTrace();	} catch (IllegalAccessException e) {	e.printStackTrace();	} catch (ClassNotFoundException e) {	e.printStackTrace();	}	String user = "root";	String password = "root";	String url = "jdbc:mysql://localhost:3306/oa?characterEncoding=utf-8";	Connection connection = null;	try {	connection = DriverManager.getConnection(url, user, password);	} catch (SQLException e) {	e.printStackTrace();	}	PreparedStatement preparedStatement = null;	InputStream inputStream = null;	inputStream = ImageUtil.getImageByte("D://工作//图片//5.jpg");	try {	String sql = "insert into photo(id,name,photo) values(?,?,?)";	preparedStatement = connection.prepareStatement(sql);	preparedStatement.setInt(1, 1);	preparedStatement.setString(2, "前言");	preparedStatement.setBinaryStream(3, inputStream,	inputStream.available());	preparedStatement.execute();	} catch (SQLException e) {	e.printStackTrace();	} catch (IOException e) {	e.printStackTrace();	} finally {	try {	if (inputStream != null)	inputStream.close();	} catch (IOException e) {	e.printStackTrace();	} finally {	try {	if (preparedStatement != null)	preparedStatement.close();	} catch (SQLException e) {	e.printStackTrace();	} finally {	try {	connection.close();	} catch (SQLException e) {	e.printStackTrace();	}	}	}	}	}}

package com.sk.handle;import java.io.IOException;import java.io.InputStream;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import com.sk.util.ImageUtil;public class ReadImage {	public static void main(String[] args) {	try {	Class.forName("com.mysql.jdbc.Driver").newInstance();	} catch (InstantiationException e) {	e.printStackTrace();	} catch (IllegalAccessException e) {	e.printStackTrace();	} catch (ClassNotFoundException e) {	e.printStackTrace();	}	String user = "root";	String password = "root";	String url = "jdbc:mysql://localhost:3306/oa?characterEncoding=utf-8";	Connection connection = null;	try {	connection = DriverManager.getConnection(url, user, password);	} catch (SQLException e) {	e.printStackTrace();	}	Statement statement = null;	ResultSet resultSet = null;	InputStream inputStream = null;	try {	statement = connection.createStatement();	String sql = "select p.photo from photo p where id = 1";	resultSet = statement.executeQuery(sql);	resultSet.next();	inputStream = resultSet.getBinaryStream("photo");	ImageUtil.readBlob(inputStream, "D://1.png");	} catch (SQLException e) {	e.printStackTrace();	} finally {	try {	if (inputStream != null)	inputStream.close();	} catch (IOException e) {	e.printStackTrace();	} finally {	try {	if (resultSet != null)	resultSet.close();	} catch (SQLException e) {	e.printStackTrace();	} finally {	if (statement != null)	if (statement != null)	try {	statement.close();	} catch (SQLException e) {	e.printStackTrace();	} finally {	if (connection != null)	try {	connection.close();	} catch (SQLException e) {	e.printStackTrace();	}	}	}	}	}	}}