国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁(yè) > 數(shù)據(jù)庫(kù) > Oracle > 正文

解析jdbc處理oracle的clob字段的詳解

2020-07-26 14:26:44
字體:
來(lái)源:轉(zhuǎn)載
供稿:網(wǎng)友

import java.io.BufferedOutputStream;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.Reader;
import java.sql.Clob;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;

復(fù)制代碼 代碼如下:

public class ClobUtil {

 /**
  *
  * @param insertSQL 插入sql語(yǔ)句 有clob字段時(shí),值必須設(shè)置成empty_clob()函數(shù) 例:insert into ba valus(1,empty_clob())
  * @param updateSQL 帶有修改的查詢(xún)語(yǔ)句,并應(yīng)增加條件判斷.例:select * from BA where ba_id = '"+ba.getBA_id()+"' for update
  * @param con 數(shù)據(jù)庫(kù)鏈接
  * @param bigString 要插入的clob值
  * @param updateColumn 要插入的表字段名
  * @return
  * @throws SQLException
  */
 public static Boolean clobInsert(String insertSQL,String updateSQL,Connection con,String bigString,String updateColumn ) throws SQLException{
      // 結(jié)果集
      ResultSet rs = null;
      // 插入數(shù)據(jù)庫(kù)的sql
      String query = insertSQL;
      // 設(shè)置不自動(dòng)提交
      con.setAutoCommit(false);
      // 定義預(yù)處理
      java.sql.PreparedStatement pstmt = con.prepareStatement( query);
      // 執(zhí)行插入語(yǔ)句
      pstmt.executeUpdate();
      //清空
      pstmt = null;
      // 執(zhí)行更改
      query = updateSQL;
         //顯示執(zhí)行帶有修改方式的select
      pstmt = con.prepareStatement(query);
      rs = pstmt.executeQuery();
      // 采用流的方式處理結(jié)果集
      if(rs.next()) 
      {
        // 得到指定的clob字段
        oracle.sql.CLOB singnaturedateClob = (oracle.sql.CLOB)rs.getClob(updateColumn); 
        // 把clob字段放到輸出流當(dāng)中
        BufferedOutputStream out = new BufferedOutputStream(singnaturedateClob.getAsciiOutputStream());
        // 判斷傳入的數(shù)據(jù)是否為空
        if(bigString!=null){
        try{
         // 把要保存的數(shù)據(jù)轉(zhuǎn)換成輸入流
         InputStream  is = (InputStream)(new   ByteArrayInputStream(bigString.getBytes())); 
      copyStream( is, out );
      out.close();
    } catch (IOException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
        }
      }
      rs.close();
      con.commit();

   return true;
 }

 /**
  * 將輸入流寫(xiě)入到輸出流當(dāng)中
  * @param is 輸入流
  * @param os 輸出流
  * @throws IOException
  */
 public static void copyStream( InputStream is, OutputStream os )
 throws IOException
 {
  byte[] data             = new byte[4096];
  int readed              = is.read(data);
  while (readed != -1)
  {
   os.write(data,0,readed);
   readed = is.read(data);
  }
 }

 /**
  * 通過(guò)Clob對(duì)象返回字符串
  * @param c
  * @return
  */
 public static String getClobString(Clob c) { 
        try {

            Reader reader=c.getCharacterStream();
            if (reader == null) {
                return null;
            }
            StringBuffer sb = new StringBuffer();
            char[] charbuf = new char[4096];
            for (int i = reader.read(charbuf); i > 0; i = reader.read(charbuf)) {
                sb.append(charbuf, 0, i);
            }
            return sb.toString();
        } catch (Exception e) {
            return "";
        }
    }

}

發(fā)表評(píng)論 共有條評(píng)論
用戶(hù)名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 南城县| 辽阳县| 汪清县| 宣化县| 太谷县| 三门峡市| 邵武市| 西乌珠穆沁旗| 柳林县| 南京市| 庐江县| 宜兴市| 油尖旺区| 五峰| 城口县| 上蔡县| 昌吉市| 田林县| 阿拉善右旗| 富裕县| 镇安县| 延川县| 阳曲县| 东山县| 许昌市| 清远市| 南江县| 黄陵县| 武穴市| 名山县| 虞城县| 德钦县| 称多县| 新津县| 永吉县| 商河县| 巫溪县| 老河口市| 都匀市| 博客| 新竹市|