学步园

数据库中有表定义如下：

CREATE TABLE USERFILE_TABLE(
ID SERIAL PRIMARY KEY,
NAME VARCHAR(256),
USERFILE BLOB);

程序代码如下：（使用的数据库是特殊数据库，所以要想使用本代码，请自行修改，主要改一下“注册JDBC”和“建立连接”部分）

import java.sql.*;</p> <p>import java.io.*;</p> <p>public class OutputFile {</p> <p> public OutputFile() {</p> <p> }</p> <p> public static void main(String[] args) throws SQLException {</p> <p> try {</p> <p> //注册神通数据库 JDBC驱动<br /> Class.forName("com.oscar.Driver");</p> <p> }catch (ClassNotFoundException cnfe) {</p> <p> System.out.println(cnfe);</p> <p> }</p> <p> //与后台数据库建立连接</p> <p> String user = "SYSDBA";</p> <p> String name = "szoscar55";</p> <p> String url = "jdbc:oscar://localhost/OSRDB";</p> <p> Connection con = DriverManager.getConnection(url,user,name);</p> <p> //查询<br /> Statement stmt = con.createStatement();</p> <p> ResultSet result_set = stmt.executeQuery(</p> <p> "SELECT * FROM USERFILE_TABLE WHERE NAME='".concat(args[0]).concat("'"));</p> <p> //输出多个文件时，用int file_name_index来区别不同的文件<br /> Integer file_name_index = new Integer(0);<br /> //int file_name_index = 0;<br /> //输出文件流，用来保存文件<br /> FileOutputStream file_output_stream = null;<br /> //InputStream用来把数据库中的blob“输入”到buffer<br /> InputStream input_stream = null;<br /> try {</p> <p> while (result_set.next()) {</p> <p> String file_name = result_set.getString(2);<br /> file_name = "Output/".concat(file_name);<br /> //若Output目录不存在，则生成<br /> File output_file_path = new File("Output");<br /> if(!output_file_path.exists()){<br /> output_file_path.mkdir();<br /> }<br /> //生成file_output_stream对象，文件名自动生成，当有重名时，文件名后加上数字 1 2 3...<br /> if(0 == file_name_index){<br /> file_output_stream = new FileOutputStream(file_name);<br /> }<br /> else{<br /> //把文件名和扩展名分开<br /> int extension_name_index = file_name.lastIndexOf('.');<br /> //文件名<br /> String file_name_without_extension_name = file_name.substring(0,extension_name_index-1);<br /> //扩展名<br /> String extension_name = file_name.substring(extension_name_index);</p> <p> file_output_stream = new FileOutputStream(file_name_without_extension_name.concat(file_name_index.toString()).concat(extension_name));<br /> }</p> <p> //从查询的结果集中找出blob，由于结果是：ID NAME USERFILE，因此getBlob()的参数是 3<br /> Blob blob_output = result_set.getBlob(3);<br /> //把input_stream和blob_output绑定<br /> input_stream = blob_output.getBinaryStream();</p> <p> byte[] buffer = new byte[1024];</p> <p> int length = 0;</p> <p> while((length = input_stream.read(buffer)) >= 0){<br /> //把buffer中的内容，一点点地写到文件中<br /> file_output_stream.write(buffer,0,length);<br /> }<br /> file_output_stream.flush();//关闭文件<br /> //输出多个文件时，用int file_name_index来区别不同的文件<br /> file_name_index += 1;</p> <p> }<br /> }<br /> catch (Exception e) {</p> <p> String err = e.toString();</p> <p> System.out.println(err);</p> <p> }<br /> finally {</p> <p> //关闭流<br /> try{<br /> if(file_output_stream != null)<br /> file_output_stream.close();<br /> }<br /> catch(IOException file_output_stream_exception){<br /> System.out.println(file_output_stream_exception);<br /> }</p> <p> try{<br /> if(input_stream != null)<br /> input_stream.close();<br /> }<br /> catch(IOException input_stream_exception){<br /> System.out.println(input_stream_exception);<br /> }</p> <p> }</p> <p> result_set.close();</p> <p> stmt.close();</p> <p> con.close();</p> <p> }</p> <p>}<br />

编译：

      javac OutputFile.java

运行：

      java OutputFile  test.bmp