Java对象存储到Oracle数据库
Java对象存储到Oracle数据库
对象持久化,也就是可以把这个对象永远的保存起来,这里的保存不仅是对象本身,还包括他的属性和所依赖的其他类。通常,对象可以持久化到文件或者是数据库中。我这里只介绍如何将对象存储到数据库中。恰巧Oracle数据库为我们提供了这样的方便。
在Oracle中,有一种blog的字段类型,它是用来存储大量的二进制数据的。我们就利用这个字段去存储对象信息。
首先建立一个测试表:
- create table TESTBLOB
- (
- NAME VARCHAR2(50) not null,
- CONTENT BLOB not null,
- ID NUMBER(8) not null
- )alter table TESTBLOB
- add constraint IDFORTEST primary key (ID);
- 只用三个字段,其中id是属性,content是我们要存储对象的字段。
- 先来看看我们要存入的对象:
- import java.io.Serializable;
- import java.util.Date;
- import java.util.List;
- public class TestObject implements Serializable {
- private static final long serialVersionUID = 4558876142427402513L;
- /**
- * @param args
- */
- private String name;
- private String password;
- private Date date;
- private List<City> cityList;
- public List<City> getCityList() {
- return cityList;
- }
- public void setCityList(List<City> cityList) {
- this.cityList = cityList;
- }
- public Date getDate() {
- return date;
- }
- public void setDate(Date date) {
- this.date = date;
- }
- public String getName() {
- return name;
- }
- public void setName(String name) {
- this.name = name;
- }
- public String getPassword() {
- return password;
- }
- public void setPassword(String password) {
- this.password = password;
- }
- }
- 记得要实现Serializable接口,可以看到这是一个包含了string,date,和list类型的对象,为了给测试增加复杂度,我们的list是另外一个对象(city)的list,如下:
- import java.io.Serializable;
- public class City implements Serializable{
- private static final long serialVersionUID = 4558876127402513L;
- private String name;
- private String code;
- public String getCode() {
- return code;
- }
- public void setCode(String code) {
- this.code = code;
- }
- public String getName() {
- return name;
- }
- public void setName(String name) {
- this.name = name;
- }
- }
- City对象包括了城市名称和区号。下面是主要的应用了。
- import java.io.BufferedInputStream;
- import java.io.ByteArrayInputStream;
- import java.io.ByteArrayOutputStream;
- import java.io.InputStream;
- import java.io.ObjectInputStream;
- import java.io.ObjectOutputStream;
- import java.io.OutputStream;
- import java.sql.Connection;
- import java.sql.DriverManager;
- import java.sql.ResultSet;
- import java.sql.Statement;
- import java.util.ArrayList;
- import java.util.Date;
- import java.util.List;
- import oracle.sql.BLOB;
- public class Test {
- public static void main(String[] args) {
- //创建测试用对象
- City beijing = new City();
- beijing.setName("北京");
- beijing.setCode("010");
- City shanghai = new City();
- shanghai.setName("上海");
- shanghai.setCode("020");
- City tianjin = new City();
- tianjin.setName("天津");
- tianjin.setCode("021");
- List<City> cityList = new ArrayList<City>();
- cityList.add(beijing);
- cityList.add(shanghai);
- cityList.add(tianjin);
- TestObject obj = new TestObject();
- obj.setName("yangsq");
- obj.setPassword("111");
- obj.setDate(new Date());
- obj.setCityList(cityList);
- try{
- //将对象存入blob字段
- ByteArrayOutputStream byteOut=new ByteArrayOutputStream();
- ObjectOutputStream outObj=new ObjectOutputStream(byteOut);
- outObj.writeObject(obj) ;
- final byte[] objbytes=byteOut.toByteArray();
- Class.forName("oracle.jdbc.driver.OracleDriver");
- Connection con = DriverManager.getConnection(
- "jdbc:oracle:thin:@***.***.***.***:1521:****", "yangsq", "yangsq");
- con.setAutoCommit(false);
- Statement st = con.createStatement();
- st.executeUpdate("insert into TESTBLOB (ID, NAME, CONTENT) values (1, 'test1', empty_blob())");
- ResultSet rs = st.executeQuery("select CONTENT from TESTBLOB where ID=1 for update");
- if (rs.next()) {
- BLOB blob = (BLOB) rs.getBlob("CONTENT");
- OutputStream outStream = blob.getBinaryOutputStream();
- outStream.write(objbytes, 0, objbytes.length);
- outStream.flush();
- outStream.close();
- }
- byteOut.close();
- outObj.close();
- con.commit();
- //取出blob字段中的对象,并恢复
- rs = st.executeQuery("select CONTENT from TESTBLOB where ID=1");
- BLOB inblob = null;
- if (rs.next()) {
- inblob = (BLOB) rs.getBlob("CONTENT");
- }
- InputStream is = inblob.getBinaryStream();
- BufferedInputStream input = new BufferedInputStream(is);
- byte[] buff = new byte[inblob.getBufferSize()];
- while(-1 != (input.read(buff, 0, buff.length)));
- ObjectInputStream in =
- new ObjectInputStream(
- new ByteArrayInputStream(
- buff));
- TestObject w3 = (TestObject)in.readObject();
- System.out.println(w3.getName());
- System.out.println(w3.getPassword());
- System.out.println(w3.getDate());
- List<City> list = w3.getCityList();
- for(City city : list){
- System.out.println(city.getName() + " " + city.getCode());
- }
- st.close();
- con.close();
- } catch (Exception ex) {
- ex.printStackTrace();
- System.exit(1);
- }
- }
- }
- 代码的蓝色部分创建了要存储的对象。再看红色的对象写入部分,它首先把对象转化成二进制流的形式。对于blob字段,我们不能简单的在insert时插入,实际上,insert时,对于blob字段,只能先插入一个空的blob对象empty_blob(),然后再进行"select CONTENT from TESTBLOB where ID=1 for update"对blob字段进行更新。返回后,我们只要把对象的二进制流写入即可。
- OutputStream outStream = blob.getBinaryOutputStream();
- outStream.write(objbytes, 0, objbytes.length);
- 需要注意的是,上述步骤必须设置con.setAutoCommit(false),否则oracle会抛出异常。
- 接下来,绿色的代码是读取数据库中blob字段的对象,并恢复。我们要知道的是,所有对blob字段的操作都是二进制的,即插入时是二进制流,读出时也是二进制流。然后用io修饰器(ObjectInputStream)去修饰。以前学习java时,感觉它的io好繁琐啊,现在感觉还真是各有其用。下面是测试的输出结果。
- yangsq
- 111
- Tue Mar 27 12:11:28 CST 2007
- 北京 010
- 上海 020
- 天津 021
- 需要说明一下,buff的size一定要足够大,否则将抛出异常。在这里,我使用的是inblob.getBufferSize()来设置buff的size,这并不是一种好的方法,因为一般inblob.getBufferSize()都是32768,很可能出现异常,所以这个size最好自己设置,或系统运行时刻设置(幸好java提供数组长度的运行时刻设置)。
- 上面是我本人研究的结果,当然少不了网友们的知识奉献。下面就转自一位网友的blog。
- 转:
- 1.新建记录,插入BLOB数据
- 1.1首先新建记录的时候,使用oracle的函数插入一个空的BLOB,假设字段A是BLOB类型的:
- insert xxxtable(A,B,C) values(empty_blob(),'xxx','yyyy')
- 1.2后面再查询刚才插入的记录,然后更新BLOB,在查询前,注意设置Connection的一个属性:
- conn.setAutoCommit(false);如果缺少这一步,可能导致fetch out of sequence等异常.
- 1.3 查询刚才插入的记录,后面要加“ for update ”,如下:
- select A from xxxtable where xxx=999 for update ,如果缺少for update,可能出现row containing the LOB value is not locked
- 的异常
- 1.4 从查询到的 BLOB字段中,获取blob并进行更新,代码如下:
- BLOB blob = (BLOB) rs.getBlob("A");
- OutputStream os = blob.getBinaryOutputStream();
- BufferedOutputStream output = new BufferedOutputStream(os);
- 后面再使用output.write方法将需要写入的内容写到output中就可以了。例如我们将一个文件写入这个字段中:
- BufferedInputStream input = new BufferedInputStream(new File("c:\hpWave.log").toURL().openStream());
- byte[] buff = new byte[2048]; //用做文件写入的缓冲
- int bytesRead;
- while(-1 != (bytesRead = input.read(buff, 0, buff.length))) {
- output.write(buff, 0, bytesRead);
- System.out.println(bytesRead);
- }
- 上面的代码就是从input里2k地读取,然后写入到output中。
- 1.5上面执行完毕后,记得关闭output,input,以及关闭查询到的ResultSet
- 1.6最后执行conn.commit();将更新的内容提交,以及执行conn.setAutoCommit(true); 改回Connction的属性
- 2.修改记录,方法与上面的方法类似,
- 2.1首先更新BLOB以外的其他字段
- 2.2 使用1.3中类似的方法获取记录
- 2.3 修改的过程中,注意以下:a 需要更新的记录中,BLOB有可能为NULL,这样在执行blob.getBinaryOutputStream()获取的值可能为
- null,那么就关闭刚才select的记录,再执行一次update xxxtable set A = empty_blob() where xxx, 这样就先写入了一个空的BLOB(不是null),然后再
- 使用1.3,1.4中的方法执行更新记录.b 注意别忘了先执行setAutoCommit(false),以及"for update",以及后面的conn.commit();等。
- 3.读取BLOB字段中的数据.
- 3.1 读取记录不需要setAutoCommit(),以及 select ....for update.
- 3.2 使用普通的select 方法查询出记录
- 3.3 从ResultSet中获取BLOB并读取,如下:
- BLOB b_to = (BLOB) rs.getBlob("A");
- InputStream is = b_from.getBinaryStream();
- BufferedInputStream input = new BufferedInputStream(is);
- byte[] buff = new byte[2048];
- while(-1 != (bytesRead = input.read(buff, 0, buff.length))) {
- //在这里执行写入,如写入到文件的BufferedOutputStream里
- System.out.println(bytesRead);
- }
- 通过循环取出blob中的数据,写到buff里,再将buff的内容写入到需要的地方
- 4.两个数据库间blob字段的传输
- 类似上面1和3的方法,一边获取BufferedOutputStream,另外一边获取BufferedInputStream,然后读出写入,需要注意的是写入所用的
- Connection要执行conn.setAutoCommit(false);以及获取记录时添加“ for update ”以及最后的commit();
- 总结以上方法,其根本就是先创建空的BLOB,再获取其BufferedOutputStream进行写入,或获取BufferedInputStream进行读取
评论暂时关闭