java序列化对象 插入、查询、更新到数据库 ：

实现代码例如以下：

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

import java.sql.Blob;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.Statement;

/**

 *

 * handle serial object with oracle dbStore<br/>

 * eg: create table TEST_OBJECTSTORE ( CLASSNAME VARCHAR2(256), CONTENT BLOB )

 * @author Administrator

 *

 */

public class ObjectSerialStore {

	private String tableName;

	private String classNameColumn;

	private String serialObjColumn;

	/**

	 * construct

	 *

	 * @param tableName

	 * @param classNameColumn

	 * @param serialObjColumn

	 */

	public ObjectSerialStore(String tableName, String classNameColumn,

			String serialObjColumn) {

		this.tableName = tableName;

		this.classNameColumn = classNameColumn;

		this.serialObjColumn = serialObjColumn;

	}

	public final void storeSerialObject(Connection dbConn,String className,Object serialObj){

		PreparedStatement pstmt = null;

		try {

			ByteArrayOutputStream byteArray = new ByteArrayOutputStream();

			ObjectOutputStream objOuts = new ObjectOutputStream(byteArray);

			objOuts.writeObject(serialObj);

			final byte[] objBytes = byteArray.toByteArray();

			pstmt = dbConn.prepareStatement("insert into "+ this.tableName +" ("

					+this.classNameColumn+", "+this.serialObjColumn

					+") values (?,?

)");

			pstmt.setString(1, className);

			ByteArrayInputStream bis = new ByteArrayInputStream(objBytes);

			pstmt.setBinaryStream(2, bis,objBytes.length);

			pstmt.execute();

		} catch (Exception e) {

			System.out.println("The error when serial obj:"+e.getMessage());

		} finally {

			close(null,pstmt,dbConn);

		}

	}

	/**

	 * update the serial Object

	 * @param dbConn close after use

	 * @param className serialObj.getClass().getName() or OBJ.class.getName()

	 * @param serialObj

	 */

	public final void updateSerialObject(Connection dbConn, String className,

			Object serialObj){

		PreparedStatement pstmt = null;

		ResultSet rs = null;

		try {

			ByteArrayOutputStream out = new ByteArrayOutputStream();

			ObjectOutputStream objOuts = new ObjectOutputStream(out);

			objOuts.writeObject(serialObj);

			final byte[] objBytes = out.toByteArray();

			pstmt = dbConn.prepareStatement("update "+this.tableName+" set "+this.serialObjColumn+"=? where "+this.classNameColumn+"=?");

			ByteArrayInputStream input = new ByteArrayInputStream(objBytes);

			pstmt.setBinaryStream(1, input, objBytes.length);

			pstmt.setString(2, className);

			pstmt.execute();

			input.close();

			out.close();

			objOuts.close();

		} catch (Exception e) {

			System.out.println("The error when update serial obj:"+e.getMessage());

		} finally {

			close(rs,pstmt,dbConn);

		}

	}

	public final Object getSerialObject(Connection dbConn,String className){

		Statement stmt = null;

		ResultSet rs = null;

		Object returnObj = null;

		try{

			stmt = dbConn.createStatement();

			rs = stmt.executeQuery("select "+this.serialObjColumn+" from "+this.tableName+" where "+this.classNameColumn+"='"+className+"'");

			Blob blob = null;

			if(rs.next()){

				blob = rs.getBlob(this.serialObjColumn);

			}

			byte[] getBytes = blob.getBytes(1, (int)blob.length());

			ObjectInputStream objInput = new ObjectInputStream(new ByteArrayInputStream(getBytes));

			returnObj = objInput.readObject();

			objInput.close();

		}catch(Exception e){

			System.out.println("The error when deserial obj:"+e.getMessage());

		}finally{

			close(rs,stmt,dbConn);

		}

		return returnObj;

	}

	private void close(ResultSet rs,Statement stmt,Connection conn){

		if(rs != null){

			try{

				rs.close();

			}catch(Exception e){}

		}

		if(stmt != null){

			try{

				stmt.close();

			}catch(Exception e){}

		}

		if(conn != null){

			try{

				conn.close();

			}catch(Exception e){}

		}

	}

}

java序列化对象 插入、查询、更新到数据库 。