JDBC中处理二进制类型数据
package jdbc;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;/** * * @author HaoWang */public class BlobTest { public static void main(String[] args) {// create(1,"C:\\a.jpg"); read(1,"C:\\a_bak.jpg"); } public static void create(int bid, String path) { Connection conn = null; String sql = null; PreparedStatement ps = null; ResultSet rs = null; try { conn = JdbcUtils.getConnection(); sql = "insert into blob_test(bid,content) value(?,?)"; ps = conn.prepareStatement(sql); ps.setInt(1, bid); File file = new File(path); InputStream in = new BufferedInputStream(new FileInputStream(file)); ps.setBinaryStream(2, in, file.length()); int i = ps.executeUpdate(); System.out.println("i="+i); in.close(); } catch (Exception ex) { System.out.println(ex.toString()); } finally { JdbcUtils.free(conn, ps, rs); } } public static void read(int bid, String path) { Connection conn = null; String sql = null; PreparedStatement ps = null; ResultSet rs = null; try { conn = JdbcUtils.getConnection(); sql = "select content from blob_test where bid=?"; ps = conn.prepareStatement(sql); ps.setInt(1, bid); rs = ps.executeQuery(); while(rs.next()) { InputStream in = rs.getBinaryStream(bid); File file = new File(path); OutputStream out = new BufferedOutputStream(new FileOutputStream(file)); byte[] buff = new byte[1024]; for(int i=0; (i=in.read(buff))>0;) { out.write(buff, 0, i); } out.close(); in.close(); } } catch (Exception ex) { System.out.println(ex.toString()); } finally { JdbcUtils.free(conn, ps, rs); } }}?