Java认证关于JDBC中处理二进制类型数据
Java认证关于JDBC中处理二进制类型数据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）;
}
}
}
页:
[1]