詳解jdbc實現(xiàn)對CLOB和BLOB數(shù)據(jù)類型的操作

更新時間：2017年08月07日 15:17:29 投稿：lqh

這篇文章主要介紹了詳解jdbc實現(xiàn)對CLOB和BLOB數(shù)據(jù)類型的操作的相關(guān)資料,這里實現(xiàn)寫入操作與讀寫操作，需要的朋友可以參考下

詳解jdbc實現(xiàn)對CLOB和BLOB數(shù)據(jù)類型的操作

1、讀取操作

CLOB

//獲得數(shù)據(jù)庫連接    
  Connection con = ConnectionFactory.getConnection();    
  con.setAutoCommit(false);    
  Statement st = con.createStatement();    
  //不需要“for update”    
  ResultSet rs = st.executeQuery("select CLOBATTR from TESTCLOB where ID=1");    
  if (rs.next())    
  {    
    java.sql.Clob clob = rs.getClob("CLOBATTR");    
    Reader inStream = clob.getCharacterStream();    
    char[] c = new char[(int) clob.length()];    
    inStream.read(c);    
    //data是讀出并需要返回的數(shù)據(jù)，類型是String    
    data = new String(c);    
    inStream.close();    
  }    
  inStream.close();    
  con.commit();    
  con.close();

BLOB

//獲得數(shù)據(jù)庫連接    
  Connection con = ConnectionFactory.getConnection();    
  con.setAutoCommit(false);    
  Statement st = con.createStatement();    
  //不需要“for update”    
  ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1");    
  if (rs.next())    
  {    
    java.sql.Blob blob = rs.getBlob("BLOBATTR");    
    InputStream inStream = blob.getBinaryStream();    
    //data是讀出并需要返回的數(shù)據(jù)，類型是byte[]    
    data = new byte[input.available()];    
    inStream.read(data);    
    inStream.close();    
  }    
  inStream.close();    
  con.commit();    
  con.close();

2、寫入操作

CLOB

//獲得數(shù)據(jù)庫連接    
  Connection con = ConnectionFactory.getConnection();    
  con.setAutoCommit(false);    
  Statement st = con.createStatement();    
  //插入一個空對象empty_clob()    
  st.executeUpdate("insert into TESTCLOB (ID, NAME, CLOBATTR) values (1, "thename", empty_clob())");    
  //鎖定數(shù)據(jù)行進行更新，注意“for update”語句    
  ResultSet rs = st.executeQuery("select CLOBATTR from TESTCLOB where ID=1 for update");    
  if (rs.next())    
  {    
    //得到j(luò)ava.sql.Clob對象后強制轉(zhuǎn)換為oracle.sql.CLOB   
    oracle.sql.CLOB clob = (oracle.sql.CLOB) rs.getClob("CLOBATTR");    
    Writer outStream = clob.getCharacterOutputStream();    
    //data是傳入的字符串，定義：String data    
    char[] c = data.toCharArray();    
    outStream.write(c, 0, c.length);    
  }    
  outStream.flush();    
  outStream.close();    
  con.commit();    
  con.close();

BLOB

//獲得數(shù)據(jù)庫連接    
  Connection con = ConnectionFactory.getConnection();    
  con.setAutoCommit(false);    
  Statement st = con.createStatement();    
  //插入一個空對象empty_blob()    
  st.executeUpdate("insert into TESTBLOB (ID, NAME, BLOBATTR) values (1, "thename", empty_blob())");    
  //鎖定數(shù)據(jù)行進行更新，注意“for update”語句    
  ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1 for update");    
  if (rs.next())    
  {    
    //得到j(luò)ava.sql.Blob對象后強制轉(zhuǎn)換為oracle.sql.BLOB   
    oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob("BLOBATTR");    
    OutputStream outStream = blob.getBinaryOutputStream();    
    //data是傳入的byte數(shù)組，定義：byte[] data   
    outStream.write(data, 0, data.length);    
  }    
  outStream.flush();    
  outStream.close();    
  con.commit();    
  con.close();

3、讀寫CLOB/BLOB數(shù)據(jù)到文件

TNS：

# tnsnames.ora Network Configuration File: d:\oracle\product\10.2.0\client_1\NETWORK\ADMIN\tnsnames.ora  
 # Generated by Oracle configuration tools.  
 
 ORADB =  
   (DESCRIPTION =  
     (ADDRESS_LIST =  
       (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.100)(PORT = 1521))  
     )  
     (CONNECT_DATA =  
       (SID = ORCL)  
     )  
   )  
 
 MYORCL =  
   (DESCRIPTION =  
     (ADDRESS_LIST =  
       (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.100)(PORT = 1521))  
     )  
     (CONNECT_DATA =  
       (SERVICE_NAME = myorcl)  
     )  
   )

Table：

create table TEST_ORALOB  
 (  
   ID     VARCHAR2(20),  
   TSBLOB BLOB not null,  
   TSCLOB CLOB not null  
 )

測試代碼：

package lavasoft.oralob.common;  
 
import oracle.sql.BLOB;  
 
import java.io.*;  
import java.sql.*;  
 
/**  
 * JDBC讀寫Oracle10g的CLOB、BLOB  
 *  
 */  
public class TestOraLob {  
 
     public static void main(String[] args) {  
         insertBlob();  
         queryBlob();  
     }  
 
     public static void insertBlob() {  
         Connection conn = DBToolkit.getConnection();  
         PreparedStatement ps = null;  
         try {  
             String sql = "insert into test_oralob (ID, TSBLOB, TSCLOB) values (?, ?, ?)";  
             ps = conn.prepareStatement(sql);  
             ps.setString(1, "100");  
             //設(shè)置二進制BLOB參數(shù)  
             File file_blob = new File("C:\\a.jpg");  
             InputStream in = new BufferedInputStream(new FileInputStream(file_blob));  
             ps.setBinaryStream(2, in, (int) file_blob.length());  
             //設(shè)置二進制CLOB參數(shù)  
             File file_clob = new File("c:\\a.txt");  
             InputStreamReader reader = new InputStreamReader(new FileInputStream(file_clob));  
             ps.setCharacterStream(3, reader, (int) file_clob.length());  
             ps.executeUpdate();  
             in.close();  
         } catch (IOException e) {  
             e.printStackTrace();  
         } catch (SQLException e) {  
             e.printStackTrace();  
         } finally {  
             DBToolkit.closeConnection(conn);  
         }  
     }  
 
     public static void queryBlob() {  
         Connection conn = DBToolkit.getConnection();  
         PreparedStatement ps = null;  
         Statement stmt = null;  
         ResultSet rs = null;  
         try {  
             String sql = "select TSBLOB from TEST_ORALOB where id ='100'";  
             stmt = conn.createStatement();  
             rs = stmt.executeQuery(sql);  
             if (rs.next()) {  
                 //讀取Oracle的BLOB字段  
                 InputStream in = rs.getBinaryStream(1);  
                 File file = new File("c:\\a1.jpg");  
                 OutputStream out = new BufferedOutputStream(new FileOutputStream(file));  
                 byte[] buff1 = new byte[1024];  
                 for (int i = 0; (i = in.read(buff1)) > 0;) {  
                     out.write(buff1, 0, i);  
                 }  
                 out.flush();  
                 out.close();  
                 in.close();  
                 //讀取Oracle的CLOB字段  
                 char[] buff2 = new char[1024];  
                 File file_clob = new File("c:\\a1.txt");  
                 OutputStreamWriter writer = new OutputStreamWriter(new FileOutputStream(file_clob));  
                 Reader reader = rs.getCharacterStream(1);  
                 for (int i = 0; (i = reader.read(buff2)) > 0;) {  
                     writer.write(buff2, 0, i);  
                 }  
                 writer.flush();  
                 writer.close();  
                 reader.close();  
             }  
             rs.close();  
             stmt.close();  
         } catch (IOException e) {  
             e.printStackTrace();  
         } catch (SQLException e) {  
             e.printStackTrace();  
         } finally {  
             DBToolkit.closeConnection(conn);  
         }  
     }  
 }

注：如果是具體的字符串寫入CLOB字段，簡化寫法：

//設(shè)置二進制CLOB參數(shù)   
 String xxx = "abcdefg";  
 ps.setCharacterStream(3, new StringReader(xxx), xxx.getBytes("GBK").length);   
 ps.executeUpdate();   
 in.close();

感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持，如有疑問請留言或者到本站社區(qū)交流討論，感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！

您可能感興趣的文章: