利用数据库存储类对象.docx

create table Objects ( id varchar (50) COLLATE Chinese_PRC_CI_AS NOT NULL, Object binary (8000) NULL, CONSTRAINT PK_Objects PRIMARY KEY CLUSTERED( id ) ON PRIMARY) ON PRIMARYStudent.javapackage databasevisit;public class Student implements Serializablepublic String getSid() return sid;public void setSid(String sid) this.sid = sid;public String getName() return name;public void setName(String name) = name;private String sid;private String name;public Student() public Student(String sid, String name) this.sid = sid; = name;public String toString() return this.sid + : + ;package databasevisit;import java.io.ByteArrayOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.ObjectInputStream;import java.io.ObjectOutputStream;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;public class UsingDatabaseStorageClassObject /* * param args */public static void main(String args) / TODO Auto-generated method stubStudent s1 = new Student(000001, 张满);/ 创建支持类变量序列化的类变量BinaryObjectHandler boh = new BinaryObjectHandler();/ 将学生类变量存储到数据库中boh.storeObject(s1.getSid(), s1);Student s2 = (Student) boh.restoreObject(s1.getSid();System.out.println(s2.getName();class BinaryObjectHandler Connection con = null;PreparedStatement pstm = null;ResultSet rs = null;public BinaryObjectHandler() try Class.forName(com.microsoft.sqlserver.jdbc.SQLServerDriver);con = DriverManager.getConnection(jdbc:sqlserver:/localhost:1433;DatabaseName=test, sa,jocean); catch (ClassNotFoundException e) / TODO Auto-generated catch blocke.printStackTrace(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace();public void storeObject(String id, Object obj) try PreparedStatement pstm = con.prepareStatement(insert into Objects values (?,?);pstm.setString(1, id);ByteArrayOutputStream baos = new ByteArrayOutputStream();ObjectOutputStream oos = new ObjectOutputStream(baos);oos.writeObject(obj);oos.close();byte binaryData = baos.toByteArray();pstm.setBytes(2, binaryData);pstm.executeUpdate(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace(); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace();public Object restoreObject(String id) Object obj = null;try PreparedStatement pstm = con.prepareStatement(select * from Objects where id=?);pstm.setString(1, id);ResultSet rs = pstm.executeQuery();if (rs.next() InputStream is = rs.getBinaryStream(Object);ObjectInputStream ois = new ObjectInputStream(is);obj = ois.readObject(); catch (SQLException e) / TODO Auto-generated catch blocke.printStackTrace(); catch (IOException e) / TODO A