`
wap
  • 浏览: 74328 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

[转载]oracle里读写clob

OracleJavaSQLXMLJDBC
阅读更多

闲来无事，想到备份clob数据的问题，就写了两个文件来备份clob, 表结构为：

sql 代码
  1. create table RULESETENTITY   
  2. (   
  3.       ACTIVE NUMBER,   
  4.      DESCRIPTION VARCHAR2(255),   
  5.      JDOCLASS VARCHAR2(255),   
  6.      JDOID NUMBER not null,   
  7.      JDOVERSION NUMBER,   
  8.       LASTMODIFIEDDATE DATE,   
  9.       LASTMODIFIEDUSER VARCHAR2(255),   
  10.       NAME VARCHAR2(255),   
  11.       TYPE VARCHAR2(35),   
  12.       XML CLOB   
  13. )   
  14.   

JAVA程序为：

java 代码
  1. package test;   
  2.   
  3. import java.io.BufferedReader;   
  4. import java.io.FileOutputStream;   
  5. import java.io.IOException;   
  6. import java.io.PrintStream;   
  7. import java.io.Reader;   
  8. import java.sql.Connection;   
  9. import java.sql.DriverManager;   
  10. import java.sql.ResultSet;   
  11. import java.sql.SQLException;   
  12. import java.sql.Statement;   
  13.   
  14. import oracle.sql.CLOB;   
  15.   
  16. public class DbAccess {   
  17. @SuppressWarnings("deprecation")   
  18. public static void main(String args[]) throws SQLException, IOException {   
  19.   
  20. DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());   
  21. Connection conn = DriverManager.getConnection(   
  22. "jdbc:oracle:thin:@10.6.244.5:1521:devdb", "servinv1",   
  23. "servinv1");   
  24.   
  25. Statement stmt = conn.createStatement();   
  26.   
  27. try {   
  28.   
  29. ResultSet rs = stmt.executeQuery("select name from rulesetentity");   
  30.   
  31. while (rs.next()) {   
  32. String name = rs.getString("name");   
  33. Statement stmt1 = conn.createStatement();   
  34. ResultSet rset = stmt1   
  35. .executeQuery("select rownum,name,xml from rulesetentity where name='"  
  36. + name + "'");   
  37. while (rset.next()) {   
  38.   
  39. oracle.sql.CLOB clob = (CLOB) ((oracle.jdbc.OracleResultSet) rset)   
  40. .getClob("xml");   
  41. Reader is = clob.getCharacterStream();   
  42. BufferedReader br = new BufferedReader(is);   
  43. String s = br.readLine();   
  44. FileOutputStream fo = new FileOutputStream(name + ".dri");   
  45. PrintStream so = new PrintStream(fo);   
  46. while (s != null) {   
  47. so.println(s);   
  48. s = br.readLine();   
  49. }   
  50. so.close();   
  51. }   
  52. rset.close();   
  53. stmt1.close();   
  54. System.out.println(name);   
  55. }   
  56.   
  57. rs.close();   
  58. } catch (Exception e) {   
  59. System.out.println("Error");   
  60. } finally {   
  61. stmt.close();   
  62. conn.close();   
  63. }   
  64. }   
  65.   
  66. }   
  67.   

oracle的存储过程为：

sql 代码
  1. create or replace procedure test(rule_name varchar2) is  
  2. bak_file utl_file.file_type;   
  3. rule_xml clob;   
  4.   
  5. filename varchar2(255);   
  6. l_buffer varchar2(32767);   
  7. l_pos INTEGER := 1;   
  8. l_amount BINARY_INTEGER := 1000;   
  9. xml_length integer;   
  10. begin  
  11. --rule_name :='ADDRESS RANGE VALIDATION';   
  12. select xml into rule_xml from rulesetentity where name = rule_name;   
  13. filename := replace(rule_name||'.dri',' ','_');   
  14.   
  15. bak_file := utl_file.fopen('MYTEMP',filename,'w');   
  16. xml_length := dbms_lob.getlength(rule_xml);   
  17.   
  18. dbms_output.put_line(rule_name);   
  19. dbms_output.put_line(filename);   
  20.   
  21.   
  22. dbms_output.put_line(TO_CHAR(xml_length));   
  23.   
  24.   
  25. WHILE l_pos < xml_length LOOP   
  26.   
  27. DBMS_LOB.read(rule_xml,l_amount,l_pos,l_buffer);   
  28. UTL_FILE.put_raw(bak_file, utl_raw.cast_to_raw(l_buffer),true);   
  29. l_pos := l_pos + l_amount;   
  30. END LOOP;   
  31.   
  32. utl_file.fclose(bak_file);   
  33.   
  34. end;   
  35.   


分享到：
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics