java读写clob

feiyang10086

java读写clob

从数据库中读取clob值

1. 
   
2. public String clob2String(Clob clob)
   
3. {
   
4. 
   
5. StringBuffer retValue=new StringBuffer();
   
6. if(clob!=null)
   
7. {
   
8. try {
   
9. Reader reader=clob.getCharacterStream();
   
10. BufferedReader in=new BufferedReader(reader);
    
11. String s=in.readLine();
    
12. while(s!=null)
    
13. {
    
14. retValue.append(s);
    
15. s=in.readLine();
    
16. }
    
17. } catch (SQLException e) {
    
18. e.printStackTrace();
    
19. }catch (IOException e) {
    
20. }
    
21. }
    
22. return retValue.toString();
    
23. }
    
24. 
    
25. 将string存储到数据库
    
26. public void writeClob(String s)
    
27. {
    
28. Connection conn=null;
    
29. ResultSet rs=null;
    
30. try {
    
31. java.sql.Statement stmt=conn.createStatement();
    
32. boolean flag=conn.getAutoCommit();
    
33. conn.setAutoCommit(false);
    
34. String sql="update tableName set clobCloumn=empty_Clob()";
    
35. String updateSql="select clobCloumn from tableName for update";
    
36. stmt.executeUpdate(sql);
    
37. rs=stmt.executeQuery(updateSql);
    
38. while(rs.next())
    
39. {
    
40. Writer writer=rs.getClob("clobCloumn").setCharacterStream(1);
    
41. writer.write(s);
    
42. writer.flush();
    
43. writer.close();
    
44. }
    
45. 
    
46. conn.commit();
    
47. conn.setAutoCommit(flag);
    
48. } catch (SQLException e) {
    
49. e.printStackTrace();
    
50. } catch (IOException e) {
    
51. try {
    
52. conn.rollback();
    
53. } catch (SQLException e1) {
    
54. e1.printStackTrace();
    
55. }
    
56. e.printStackTrace();
    
57. }
    
58. }

复制代码