处理大数据对象clob数据和blob数据

 1 package com.learn.jdbc.chap06;
 2 
 3 import java.io.File;
 4 import java.io.FileInputStream;
 5 import java.io.InputStream;
 6 import java.sql.Connection;
 7 import java.sql.PreparedStatement;
 8 
 9 import com.learn.jdbc.model.Album;
10 import com.learn.jdbc.util.DbUtil;
11 
12 /**
13  * 处理大数据对象clob数据和blob数据--插入
14  * @author Administrator
15  *
16  */
17 public class Demo1 {
18     private static DbUtil dbUtil=new DbUtil();
19     
20     private static int addAlbum(Album ab) throws Exception{
21         Connection con = dbUtil.getCon();
22         String sql="insert into sp_album_test values (null,?,?,?,?,?)";
23         PreparedStatement pstmt = con.prepareStatement(sql);
24         pstmt.setString(1, ab.getName());
25         pstmt.setInt(2, ab.getUid());
26         pstmt.setLong(3, ab.getTime());
27         
28         // 大字符数据(clob数据)插入数据库--文本文件
29         File content = ab.getContent();
30         InputStream inputStream = new FileInputStream(content);
31         pstmt.setAsciiStream(4, inputStream, content.length());
32         
33         // 二进制数据(blob数据)插入数据库--图片,电影,音乐
34         File pic = ab.getPic();
35         InputStream inputStream2 = new FileInputStream(pic);
36         pstmt.setBinaryStream(5, inputStream2, pic.length());
37         
38         int result = pstmt.executeUpdate();
39         dbUtil.close(pstmt, con);
40         return result;
41     }
42     
43     public static void main(String[] args) throws Exception {
44         File content = new File("e:/code.txt");
45         File pic     = new File("e:/Koala111.png");
46         Album ab = new Album("张三", 1, System.currentTimeMillis(), content, pic);
47         int result = addAlbum(ab);
48         if(result>0){
49             System.out.println("数据插入成功");
50         }else{
51             System.out.println("数据插入失败");
52         }
53     }
54 }

 1 package com.learn.jdbc.chap06;
 2 
 3 import java.io.File;
 4 import java.io.FileOutputStream;
 5 import java.io.OutputStream;
 6 import java.sql.Blob;
 7 import java.sql.Clob;
 8 import java.sql.Connection;
 9 import java.sql.PreparedStatement;
10 import java.sql.ResultSet;
11 
12 import com.learn.jdbc.util.DbUtil;
13 
14 
15 /**
16  * 处理大数据对象clob数据和blob数据--查询
17  * @author Administrator
18  *
19  */
20 public class Demo2 {
21     private static DbUtil dbUtil=new DbUtil();
22     
23     private static void listAlbum(int id) throws Exception{
24         Connection con = dbUtil.getCon();
25         String sql="select * from sp_album_test where id=?";
26         PreparedStatement pstmt = con.prepareStatement(sql);
27         pstmt.setInt(1, id);
28         ResultSet rs = pstmt.executeQuery();
29         
30         if(rs.next()){
31             String name = rs.getString("name");
32             int uid = rs.getInt("uid");
33             long time = rs.getLong("add_time");
34             // 读取大字符数据--clob数据
35             Clob clob =rs.getClob("content");
36             String content = clob.getSubString(1,(int) clob.length());
37             
38             // 读取二进制数据--blob数据
39             Blob blob = rs.getBlob("pic");
40             OutputStream out = new FileOutputStream(new File("e:/kaola.png"));
41             out.write(blob.getBytes(1, (int) blob.length()));
42             out.close();
43             
44             System.out.println("名字："+name);
45             System.out.println("uid: "+uid);
46             System.out.println("时间: "+time);
47             System.out.println("内容: "+content);
48             
49             
50         }
51         
52     }
53     
54     
55     public static void main(String[] args) throws Exception {
56         listAlbum(1);
57     }
58 }