摘要：importcom.jspdev.util.*；//conn.createStatement（）.execute（“createtable blobtable（blobvalueblob）”）；stmt.execute（“插入blobtablevalues（empty_blob（））”）；
操作二进制数据
在数据库编程中，往往需要把二进制数据保存到数据库。这些二进制数据有Word文件、PDF文件、图片文件、声音文件、可执行文件等。
二进制数据在不同的SQL服务器中表示方法不同。SQL Server使用Binary类型表示二进制数据，Oracle使用Blob（大二进制对象）类型表示。在JDBC中操作二进制对象和其他数据类型有所不同，二进制对象通常使用输入、输出流的方式来写入和读取。
本节介绍怎么在JDBC编程中写入和读取二进制对象。Oracle提供了一个表示二进制数据的类：oracle.sql.BLOB，可以通过这个类操作二进制对象。
下面我们来看具体的代码，如例程16-5所示。
例程 在JDBC编程中读取、写入二进制对象（BlobBean.java）
package com.jspdev.ch13; import com.jspdev.util.*;
import java.sql.*;
import javax.sql.*;
import java.io.*;
import oracle.jdbc.driver.OracleResultSet;
import oracle.sql.BLOB; public class BlobBean
{ Connection conn ;
/**
*构造方法，创建Connection对象，并且在数据库中添加一个表
*/
public BlobBean()throws Exception
{
DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
conn = DriverManager.getConnection("jdbc:oracle:thin:system@127.0.0.1:1521:
hellking", "system", "manager");
// conn.createStatement().execute("create table blobtable(blobvalue blob)");
}
/**
*写入Blob数据到数据库
*/
public void addBlob(String fileName)throws Exception
{
conn.setAutoCommit(false);
Statement stmt = conn.createStatement();
stmt.execute("insert into blobtable values (empty_blob())");
ResultSet rset = stmt.executeQuery("SELECT blobvalue FROM blobtable
FOR UPDATE");
BLOB blob = null;
while (rset.next()) {
blob = ((OracleResultSet) rset).getBLOB(1);
System.out.println(blob.length());
}
File binaryFile = new File(fileName);
System.out.println(fileName+"'s length = " + binaryFile.length());
FileInputStream instream = new FileInputStream(binaryFile);
OutputStream outstream = blob.getBinaryOutputStream();
int chunk = blob.getChunkSize();
System.out.println("chunk size = " + chunk);
byte[] buffer = new byte[chunk];
int length = -1;
while ((length = instream.read(buffer)) != -1)
outstream.write(buffer, 0, length);
instream.close();
outstream.close();
conn.commit(); }
/**
*从数据库读取Blob数据，并且保存在文件系统中
*/
public void readBlob(String fileName)throws Exception
{
conn.setAutoCommit(false);
Statement stmt = conn.createStatement();
ResultSet rset = stmt.executeQuery("SELECT blobvalue FROM blobtable");
BLOB blob = null;
while (rset.next()) {
blob = ((OracleResultSet) rset).getBLOB(1);
System.out.println(blob.length());
} FileOutputStream file_out = new FileOutputStream(new File(fileName));
InputStream blob_in = blob.getBinaryStream();
int temp;
while((temp=blob_in.read())!=-1)
file_out.write(temp);//读取数据，写入文件系统
file_out.close();
blob_in.close();
conn.commit();
}
} |
由于普通的SQL语句不能表示Blob数据，在执行插入数据到数据库的语句时可以使用：
insert into blobtable values (empty_blob())
插入一个空值到数据库。empty_Blob()返回的是一个空的Blob数据。
在向数据库中添加Blob数据时，首先通过ResultSet.getBlob()方法获得Blob数据对象，然后通过：
OutputStream outstream = blob.getBinaryOutputStream();
语句获得这个Blob数据的输出流。有了这个输出流，就可以写入数据到数据库了。
和写入数据过程不同的是，在读取数据时，通过：
InputStream blob_in = blob.getBinaryStream();
语句获得这个Blob资料的输入流。有了这个输入流，就可以读取它的数据了。使用完成后，注意关闭输入流、输出流和连接。
最后我们来编写一个测试JSP，如例程16-6所示。
例程 testblob.jsp
<%@ page contentType="text/html; charset=gb2312" %>
<jsp:useBean class=
"com.jspdev.ch13.BlobBean" scope="page"/>
<%
try
{
blobtest.addBlob("c:\\case.mdl");
blobtest.readBlob("c:\\case2.mdl");
out.println("success!");
}
catch(Exception e)
{
out.println(e);
e.printStackTrace();
}
%> |
执行时，请更改“c:\\case.mdl”参数，使它指向一个有效的文件路径。