使用PreparedStatement向数据表中插入、修改、删除、获取Blob类型的数据
2014-09-07 20:17
Blob介绍
BLOB类型的字段用于存储二进制数据
MySQL中，BLOB是个类型系列，包括：TinyBlob、Blob、MediumBlob、LongBlob，这几个类型之间的唯一区别是在存储文件的最大大小上不同。
MySQL的四种BLOB类型
类型 大小(单位：字节)
TinyBlob 最大 255
Blob 最大 65K
MediumBlob 最大 16M
LongBlob 最大 4G
Oracle LOB介绍
LOB，即Large Objects（大对象），是用来存储大量的二进制和文本数据的一种数据类型（一个LOB字段可存储可多达4GB的数据）。
LOB 分为两种类型：内部LOB和外部LOB。
内部LOB将数据以字节流的形式存储在数据库的内部。因而，内部LOB的许多操作都可以参与事务，也可以像处理普通数据一样对其进行备份和恢复操作。Oracle支持三种类型的内部LOB：
- BLOB（二进制数据）
- CLOB（单字节字符数据）
- NCLOB（多字节字符数据）。
目前只支持一种外部LOB类型，即BFILE类型。在数据库内，该类型仅存储数据在操作系统中的位置信息，而数据的实体以外部文件的形式存在于操作系统的文件系统中。因而，该类型所表示的数据是只读的，不参与事务。该类型可帮助用户管理大量的由外部程序访问的文件。
程序示例：
package tan ;
import java . io .*;
import java . sql .*;
import java . text . SimpleDateFormat ;
import org . junit . Test ;
public class TestJDBC {
//如何获取数据表中的 blob类型的变量
@Test
public void testBlob2 () {
Connection conn = null ;
PreparedStatement ps = null ;
ResultSet rs = null ;
InputStream is = null ;
FileOutputStream fos = null ;
try {
conn = JDBCUtils . getConnection ();
String sql = "select id,name,email,birth,photo from customers where id=?" ;
ps = conn . prepareStatement ( sql );
ps .setInt (1 , 16 );//获取id=16的数据
rs = ps . executeQuery ();
if ( rs . next ()){
int id = rs . getInt ( 1 );
String name = rs . getString ( 2 );
String email = rs . getString ( 3 );
Date birth = rs . getDate ( 4 );
Blob photo =rs .getBlob (5 );
is = photo . getBinaryStream ();//利用输入流来读取数据库中的二进制文件
fos = new FileOutputStream ( new File ( "girl.png" ));//输出到本地
byte [] buf = new byte [ 100 ];
int len = 0 ;
while (( len = is . read ( buf ))!=- 1 ){
fos . write ( buf , 0 , len );
}
Customer cust = new Customer ( id , name , email , birth );//将非blob类型封装成对象输出
System . out . println ( cust );
}
} catch ( Exception e ) {
} finally {
JDBCUtils . close ( rs , ps , conn );//记得要关闭流
if ( fos != null ){
try {
fos . close ();
} catch ( IOException e ) {
e . printStackTrace ();
}
}
if ( is != null ){
try {
is . close ();
} catch ( IOException e ) {
// TODO Auto-generated catch block
e . printStackTrace ();
}
}
}
}
// 修改数据表包含图片信息的数据
@Test
public void testBlob1 () {
Connection conn = null ;
PreparedStatement ps = null ;
FileInputStream fis = null ;
try {
conn = JDBCUtils . getConnection ();
String sql = "update customers set photo = ? where id = ?" ;
ps = conn . prepareStatement ( sql );
// 填充占位符
fis = new FileInputStream ( new File ( "1.png" ));
ps .setBlob (1 , fis );
ps . setInt ( 2 , 16 );
ps .execute ();
} catch ( Exception e ) {
e . printStackTrace ();
} finally {
JDBCUtils . close ( null , ps , conn );
try {
fis . close ();
} catch ( IOException e ) {
e . printStackTrace ();
}
}
}
// 向数据表中插入一条包含图片信息的数据
@Test
public void testBlob () {
Connection conn = null ;
PreparedStatement ps = null ;
FileInputStream fis = null ;
try {
conn = JDBCUtils . getConnection ();
String sql = "insert into customers(name,email,birth,photo)values(?,?,?,?)" ;
ps = conn . prepareStatement ( sql );
ps . setString ( 1 , " zhengqiang " );
ps . setString ( 2 , "beipiao@123.com" );
// 日期转换
String date = "1991-11-13" ;
SimpleDateFormat sdf = new SimpleDateFormat ( "yyyy-MM-dd" );
java . util . Date d = sdf . parse ( date );
ps . setDate ( 3 , new Date ( d . getTime ()));
//利用文件输入流写入
fis = new FileInputStream ( new File ( "66.jpg" ));
ps . setBlob ( 4 , fis );
// 执行预编译语句
ps .execute ();
} catch ( Exception e ) {
e . printStackTrace ();
} finally {
JDBCUtils . close ( null , ps , conn );
try {
fis . close ();
} catch ( IOException e ) {
e . printStackTrace ();
}
}
}
}