java如何将图片类型的数据存入mysql 数据库

shenzhang

OS  WindowsXP  MyEclipse7.0  mysql5.0
在mysql 建立一张photo 的表
图片类型在mysql 中的列类型是Blob; Java中是java.sql.Blob类型

create table photo(
id int not null auto_increment primary key ,
pname       varchar(30) not null ,
myphoto blob
);

在mysql 中的jdbc

package com.lyx.util;
import java.sql.*;
import java.io.*;
public class MyBlob {
/*
* create table photo( id int not null auto_increment primary key , pname
* varchar(30) not null , myphoto blob );
*/
public Connection getConn() {
Connection conn = null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mydb", "root", "791129");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
//fromFileName 有保证文件存在
public void add( String  fromFileName,  String  toFileName) {
Connection conn = this.getConn();
PreparedStatement ps;
try {
ps = conn.prepareStatement("insert into  photo( pname , myphoto)  values(?,?)");
ps.setString(1, toFileName);
File file = new File(fromFileName);
InputStream in;
in = new BufferedInputStream(new FileInputStream(file));
ps.setBinaryStream(2, in, (int) file.length());
int count = 0;
count = ps.executeUpdate();
if(count==1)
{
System.out.println("插入数据成功！");
}else
{
System.out.println("插入数据失败！");
}
in.close();
ps.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public    void  getAll(){
String sql = "select  *from   photo";
Connection conn = this.getConn();
PreparedStatement ps;
try {
ps = conn.prepareStatement(sql);
ResultSet rs = ps.executeQuery();
int  j=0;
while (rs.next()) {
InputStream ins = null;
OutputStream out = null;
j++;
System.out.println(rs.getInt(1) + "\t" + rs.getString(2));
Blob  blob= rs.getBlob("myphoto");
ins = blob.getBinaryStream();
File  f = new File(rs.getString(2));
out = new BufferedOutputStream(new FileOutputStream(f));
byte[] buf = new byte[1024];
int i = 0;
while ((i = ins.read(buf)) != -1) {
out.write(buf);
}
ins.close();
out.close();
}
rs.close();
ps.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public  void  get(int id)
{
String sql = "select  *from   photo  where  id= ?";
Connection conn = this.getConn();
PreparedStatement ps;
try {
ps = conn.prepareStatement(sql);
ResultSet rs = ps.executeQuery();
File f = null;
InputStream ins = null;
OutputStream out = null;
Blob blob =null;
while (rs.next()) {
System.out.println(rs.getInt(1) + "\t" + rs.getString(2));
blob= rs.getBlob("myphoto");
ins = blob.getBinaryStream();
f = new File(rs.getString(2));
out = new BufferedOutputStream(new FileOutputStream(f));
byte[] buf = new byte[1024];
int i = 0;
while ((i = ins.read(buf)) != -1) {
out.write(buf);
}
ins.close();
out.close();
}
rs.close();
ps.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public      void   update(int id  , File  newFile)
{
try {
String sql = "update  photo  set  myphoto=?  where  id="+id;
Connection conn = this.getConn();
PreparedStatement ps = conn.prepareStatement(sql);
InputStream  in = new BufferedInputStream(new FileInputStream(newFile));
ps.setBinaryStream(1, in, (int) newFile.length());
int   count=0;
count=ps.executeUpdate();
System.out.println(count);
ps.close();
in.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws IOException
{
}

用hibenate.cfg.xml

<?xml version='1.0' encoding='UTF-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
<session-factory>
<!--  
<property name="hbm2ddl.auto">update</property> -->
<property name="dialect">
org.hibernate.dialect.MySQLDialect
</property>
<property name="connection.url">
jdbc:mysql://localhost:3306/mydb
</property>
<property name="connection.username">root</property>
<property name="connection.password">791129</property>
<property name="connection.driver_class">
com.mysql.jdbc.Driver
</property>
<property name="myeclipse.connection.profile">mysql</property>
<property name="show_sql">true</property>
<mapping resource="com/h/Photo.hbm.xml" />
</session-factory>
</hibernate-configuration>
  
Photo.hbm.xml  文件

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<!--
Mapping file autogenerated by MyEclipse Persistence Tools
-->
<hibernate-mapping>
<class name="com.h.Photo" table="photo" >
<id name="id" type="java.lang.Integer">
<column name="id" />
<generator class="native" />
</id>
<property name="pname" type="java.lang.String">
<column name="pname" length="30" not-null="true" />
</property>
<property name="myphoto" type="java.sql.Blob">
<column name="myphoto" />
</property>
</class>
</hibernate-mapping>


程序文件SessionFactory .java

package com.h.util;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.cfg.Configuration;

public class SessionFactory {

private static String CONFIG_FILE_LOCATION = "/com/lyx/util/hibernate.cfg.xml";
private static final ThreadLocal<Session> threadLocal = new ThreadLocal<Session>();
private  static Configuration configuration = new Configuration();   
private static org.hibernate.SessionFactory sessionFactory;
private static String configFile = CONFIG_FILE_LOCATION;
static {
try {
configuration.configure(configFile);
sessionFactory = configuration.buildSessionFactory();
} catch (Exception e) {
System.err
.println("%%%% Error Creating SessionFactory %%%%");
e.printStackTrace();
}
}
private SessionFactory() {
}

public static Session getSession() throws HibernateException {
Session session = (Session) threadLocal.get();
if (session == null || !session.isOpen()) {
if (sessionFactory == null) {
rebuildSessionFactory();
}
session = (sessionFactory != null) ? sessionFactory.openSession()
: null;
threadLocal.set(session);
}
return session;
}

public static void rebuildSessionFactory() {
try {
configuration.configure(configFile);
sessionFactory = configuration.buildSessionFactory();
} catch (Exception e) {
System.err
.println("%%%% Error Creating SessionFactory %%%%");
e.printStackTrace();
}
}

public static void closeSession() throws HibernateException {
Session session = (Session) threadLocal.get();
threadLocal.set(null);
if (session != null) {
session.close();
}
}

public static org.hibernate.SessionFactory getSessionFactory() {
return sessionFactory;
}

public static void setConfigFile(String configFile) {
SessionFactory.configFile = configFile;
sessionFactory = null;
}
public static Configuration getConfiguration() {
return configuration;
}
}

pojo 文件

package com.h;
import java.sql.Blob;
/**
* Photo entity. @author MyEclipse Persistence Tools
*/
@SuppressWarnings("serial")
public class Photo implements java.io.Serializable {

private Integer id;
private String pname;
private Blob myphoto;

public Photo() {
}

public Photo(String pname) {
this.pname = pname;
}
public Integer getId() {
return this.id;
}
public void setId(Integer id) {
this.id = id;
}
public String getPname() {
return this.pname;
}
public void setPname(String pname) {
this.pname = pname;
}
public Blob getMyphoto() {
return myphoto;
}

public void setMyphoto(Blob myphoto) {
this.myphoto = myphoto;
}

}


session操作文件

package com.h;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Blob;
import java.sql.SQLException;
import java.util.List;
import com.h.util.SessionFactory;
import org.hibernate.Hibernate;
import org.hibernate.Session;
/**
* @author 李亚希 版权所有 ：天豪工作室 2009-9-21
*/
public class PhotoDao {
public PhotoDao() {
}
/**
* @param fromName  将要存入数据库的图片文件名
* @param toName    表中的列---定义的新的图片名
*/
public void save(String  fromName,   String  toName ) {
try {
Session session = SessionFactory.getSession();
File ff = new File(fromName);
FileInputStream fis = new FileInputStream(ff);
Blob bbb = Hibernate.createBlob(fis);
Photo pp = new Photo();
pp.setPname(toName);
pp.setMyphoto(bbb);
session.save(pp);
System.out.println(pp.getId());
session.close();
} catch (FileNotFoundException e1) {
e1.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* @param id    获取行数据的id值
* @param outputFileName  输出的文件名
*/
public void getById(int id) {
try{
Session session = SessionFactory.getSession();
Photo p = (Photo) session.get(Photo.class, id);
System.out.println(p.getId() + "\t" + p.getPname());
Blob b = p.getMyphoto();
InputStream in = b.getBinaryStream();
File f = null;
OutputStream out = null;
f = new File(p.getPname());
out = new BufferedOutputStream(new FileOutputStream(f));
byte[] buf = new byte[1024];
int i = 0;
while ((i = in.read(buf)) != -1)
{
out.write(buf);
}
session.close();
}catch(IOException  e)
{
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
@SuppressWarnings("unchecked")
public void getAll()  throws  IOException, SQLException  
{
Session session = SessionFactory.getSession();
List ps = session.createQuery("from   Photo").list();
System.out.println("ps.size=====" + ps.size());
if (ps.size() > 0) {
for (int i = 0; i < ps.size(); i++) {
InputStream in = null;
OutputStream out = null;
Blob b = null;
File f = null;
Photo p = (Photo) ps.get(i);
System.out.println(p.getId() + "\t" + p.getPname());
b = p.getMyphoto();
in = b.getBinaryStream();
f = new File(p.getPname());
out = new BufferedOutputStream(new FileOutputStream(f));
byte[] buf = new byte[1024];
int j = 0;
while ((j = in.read(buf)) != -1) {
out.write(buf);
}
in.close();
out.close();
}
}
session.close();
}
public static void main(String[] args) throws SQLException, IOException
{
PhotoDao  pd=new PhotoDao();
//pd.save("b.jpg","bbbbbb.jpg");
pd.getAll();

}
}