上一节主要讲了JDBC的基本操作，这一节主要总结一下JDBC如何处理大文本、如何处理图片以及进行批处理。

1.JDBC处理大文本

        在MySQL中，大文本是text类型，使用Java操作数据库中的大文本需要两个方法setCharacterStream和getCharacterStream，一个是写入数据库的字符流，一个是从数据库中读取的字符流。setCharacterStream(index,Reader,length)有三个参数，Reader表示获取文件的流，length表示文件的长度，index表示参数的索引。那么获取文件的流Reader如何获得呢？我们可以通过下面方法获取：

[java]  view plain  copy

 

1. String path = Demo1.class.getClassLoader().getResource("1.txt").getPath(); //获取指定文件的Path  
2. File file = new File(path); //以这个path为参数构建一个file对象  
3. Reader reader = new FileReader(file); //以这个file对象为参数构建Reader流，这个流与这个文件就关联了  

[sql]  view plain  copy

 

1. create database tes<span style="font-family:Microsoft YaHei;">t</span>;  
2. use test;  
3. create table testclob  
4. (  
5.    id int primary key auto_increment,  
6.    resume text  
7. );  

[java]  view plain  copy

 

1. public class Demo1 {  
2.       
3.     @Test//向数据库中插入一个文本  
4.     public void add() throws FileNotFoundException {  
5.         Connection conn = null;  
6.         PreparedStatement st = null;  
7.         ResultSet rs = null;  
8.           
9.         try {  
10.             conn = JDBCUtils.getConnection();  //使用上一节中的JDBCUtils  
11.             String sql = "insert into testclob(resume) values(?)";  
12.             st = conn.prepareStatement(sql); //预处理sql语句  
13.   
14.             String path = Demo1.class.getClassLoader().getResource("1.txt").getPath();//在工程src目录下存放一个1.txt文件  
15.             File file = new File(path);   
16.             st.setCharacterStream(1, new FileReader(file), file.length());  
17.             int num = st.executeUpdate(); //执行向数据库中插入  
18.             if(num > 0) {  
19.                 System.out.println("插入成功");  
20.             }   
21.         } catch (SQLException e) {        
22.             e.printStackTrace();  
23.         } finally {  
24.             JdbcUtils.release(conn, st, rs);  
25.         }  
26.     }  
27.       
28.     @Test //从数据库中读取文本  
29.     public void read() throws IOException {  
30.         Connection conn = null;  
31.         PreparedStatement st = null;  
32.         ResultSet rs = null;  
33.         try {  
34.             conn = JDBCUtils.getConnection();  
35.             String sql = "select resume from testclob where id=?";  
36.             st = conn.prepareStatement(sql);  
37.             st.setInt(1, 1);  
38.             rs = st.executeQuery(); //执行sql语句  
39.             if(rs.next()){  
40.                 Reader reader = rs.getCharacterStream("resume"); //获取字段未resume的项，也就是我们刚刚存到数据库的1.txt文件  
41.                 char buffer[] = new char[1024];  
42.                 int len = 0;  
43.                 FileWriter out = new FileWriter("D:\\1.txt"); //写到D盘下  
44.                 while((len = reader.read(buffer)) > 0){  
45.                     out.write(buffer, 0, len);  
46.                 }  
47.                 out.close();  
48.                 reader.close();  
49.             }  
50.         } catch (SQLException e) {        
51.             e.printStackTrace();  
52.         } finally {  
53.             JdbcUtils.release(conn, st, rs);  
54.         }  
55.     }  
56.   
57. }  

2. JDBC处理图片

         在MySQL中，大文本是image类型，我们现在数据库中建立新的表：

[sql]  view plain  copy

 

1. create table testblob  
2.  (  
3.     id int primary key auto_increment,  
4.     image longblob  
5.  );  

[java]  view plain  copy

 

1. public class Demo2 {  
2.     @Test //向数据库中写入图片  
3.     public void add() throws FileNotFoundException {  
4.         Connection conn = null;  
5.         PreparedStatement st = null;  
6.         ResultSet rs = null;  
7.           
8.         try {  
9.             conn = JdbcUtils.getConnection();  
10.             String sql = "insert into testblob(image) values(?)";  
11.             st = conn.prepareStatement(sql);  
12.             String path = Demo2.class.getClassLoader().getResource("honey.jpg").getPath(); //图片存在src目录下  
13.             st.setBinaryStream(1, new FileInputStream(path), new File(path).length());//这里用的是setBinaryStream，字节流  
14.             //这种方法也行，FileInputStream方法重载了，既可以传递路径，也可以传递具体文件  
15.             //st.setBinaryStream(1, new FileInputStream(new File(path)), new File(path).length());    
16.             int num = st.executeUpdate();  
17.             /*这里会有这个错误： 
18.              * Packet for query is too large (4531349 > 1048576).  
19.              * You can change this value on the server by setting the max_allowed_packet' variable. 
20.              * 原因：MySQL的一个系统参数：max_allowed_packet，其默认值为1048576(1M)，即允许传递的最大packet为1M，如果照片超过1M无法导入 
21.              * 查询：show VARIABLES like '%max_allowed_packet%';修改此变量的值：set global max_allowed_packet = 1024*1024*10;(10M) 
22.              * */  
23.             if(num > 0){  
24.                 System.out.println("插入成功");  
25.             }  
26.         } catch (SQLException e) {        
27.             e.printStackTrace();  
28.         } finally {  
29.             JdbcUtils.release(conn, st, rs);  
30.         }  
31.     }  
32.       
33.     @Test //从数据库中读取图片  
34.     public void read() throws IOException {  
35.         Connection conn = null;  
36.         PreparedStatement st = null;  
37.         ResultSet rs = null;  
38.           
39.         try {  
40.             conn = JdbcUtils.getConnection();  
41.             String sql = "select image from testblob where id=?";  
42.             st = conn.prepareStatement(sql);  
43.             st.setInt(1, 1);  
44.             rs = st.executeQuery();  
45.             while(rs.next()){  
46.                 InputStream in = rs.getBinaryStream("image");//获取用getBinaryStream，也是字节流  
47.                 int len = 0;  
48.                 byte buffer[] = new byte[1024];  
49.                 FileOutputStream out = new FileOutputStream("D:\\honey.jpg"); //写到D盘下  
50.                 while((len = in.read(buffer)) > 0){  
51.                     out.write(buffer, 0, len);  
52.                 }  
53.                 out.close();  
54.                 in.close();  
55.             }  
56.         } catch (SQLException e) {        
57.             e.printStackTrace();  
58.         } finally {  
59.             JdbcUtils.release(conn, st, rs);  
60.         }  
61.     }  
62.   
63. }  

        JDBC操作图片也比较简单，跟操作大文本差不多。下面看看JDBC如何进行批处理。

3. JDBC进行批处理

首先我们还是先建立一个表：

[sql]  view plain  copy

 

1. create table testbatch  
2. (  
3.     id int primary key,  
4.     name varchar(20)  
5. );  

[java]  view plain  copy

 

1. //jdbc进行批处理  
2. public class Demo3 {  
3.   
4.     @Test  
5.     public void testBatch() {  
6.         Connection conn = null;  
7.         Statement st = null;  
8.         ResultSet rs = null;  
9.           
10.         try {  
11.             conn = JdbcUtils.getConnection();  
12.             String sql1 = "insert into testbatch(id,name) values(1,'aaa')";  
13.             String sql2 = "insert into testbatch(id,name) values(2,'bbb')";  
14.             String sql3 = "insert into testbatch(id,name) values(3,'ccc')";  
15.             String sql4 = "delete from testbatch where id=1";  
16.               
17.             st = conn.createStatement();  
18.             st.addBatch(sql1);  
19.             st.addBatch(sql2);  
20.             st.addBatch(sql3);  
21.             st.addBatch(sql4); //将四条sql语句加入Batch  
22.               
23.             st.executeBatch(); //然后依次执行这四条sql语句  
24.             st.clearBatch();//执行完后清除batch  
25.         } catch (Exception e) {       
26.             e.printStackTrace();  
27.         } finally {  
28.             JdbcUtils.release(conn, st, rs);  
29.         }  
30.     }  
31.       
32.     @Test //大量插入  
33.     public void testBatch2() {  
34.         Connection conn = null;  
35.         PreparedStatement st = null;  
36.         ResultSet rs = null;  
37.           
38.         try {  
39.             conn = J<span style="font-family:Microsoft YaHei;">DBC</span>Utils.getConnection();  
40.             String sql = "insert into testbatch(id,name) values(?,?)";    
41.             st = conn.prepareStatement(sql);  
42.               
43.             for(int i = 0; i < 10000000; i++){  
44.                 st.setInt(1, i);  
45.                 st.setString(2, "aa"+i);  
46.                 st.addBatch();  
47.                 if(i % 1000 == 0){//每1000条向数据库中添加一次  
48.                     st.executeBatch();  
49.                     st.clearBatch();  
50.                 }  
51.             }  
52.             st.executeBatch();//防止还剩一些零头的数据，这里刚好是1000的倍数  
53.             st.clearBatch();  
54.         } catch (Exception e) {       
55.             e.printStackTrace();  
56.         } finally {  
57.             JdbcUtils.release(conn, st, rs);  
58.         }  
59.     }  
60. }  

相关阅读：http://blog.csdn.net/column/details/servletandjsp.html

_____________________________________________________________________________________________________________________________________________________

-----乐于分享，共同进步！