Java向Oracle数据库表中插入CLOB、BLOB字段

// ... ... 整个过程围绕xml节点的迭代来完成

while(iter1.hasNext()){  

  Element e = iter1.next();  
  Iterator<Element> iter2 = e.elementIterator(); 
    
  // 每一条SQL
  while(iter2.hasNext()){   
    	
    boolean flag1 = false; // 标志是否含有Clob字段
    boolean flag2 = false; // 标志是否含有Blob字段
    
    String blobId = "";	// 储存所在SQL语句的主键值
    
    // ... ...

    // 开始组装每一条SQL语句
    Iterator<Element> iter3 = f.elementIterator();  
    while(iter3.hasNext()){  
 
      // ... ...

      switch(colname){
	  
	    case "CLOB字段名1" :
	    case "CLOB字段名2" :	
	    // ... 	
	    case "CLOB字段名N" : { //暂存CLOB数据 
	      cList.add(colname);
	      cList.add(h.getStringValue());
	      flag1 = true;
	      break; // break switch
	    }
	    case "BLOB字段名1" :
	    case "BLOB字段名2" :
	    // ...
	    case "BLOB字段名N" :{ //暂存BLOB数据 
	      bList.add(colname);
	      bList.add(h.getStringValue());
	      flag2 = true;
	      break;
	    }
	    default:{
	      if( this value is the primary key ){
	        blobId = this value
	      }    
	
	      strVALUE.append( this valu , ); // 字段值
	      strNAMES.append( his value , ); // 字段名   
        }
      }
    }
    // 去掉最后一个多余的逗号
    strVALUE.deleteCharAt( strVALUE.length() - 1);
    strNAMES.deleteCharAt( strNAMES.length() - 1);
    	
    // 然后追加处理 empty_clob()和empty_blob()
    	
    for(int i = 0;i < cList.size(); i=i+2){
      strNAMES.append(",\""+cList.get(i)+"\"");
      strVALUE.append(",empty_clob()");
    }
    for(int i = 0;i < bList.size(); i=i+2){
      strNAMES.append(",\""+bList.get(i)+"\"");
      strVALUE.append(",empty_blob()");
    }
    	
    // 最终形态（第一次插入的语句）
    sqlStr.append("INSERT INTO 表名 ( "+strNAMES+" ) VALUES ( "+strVALUE+" )");
        	
    pstmt = con.prepareStatement(sqlStr.toString());

    pstmt.executeUpdate(); // first insert done
        
    if(pstmt != null){
      pstmt.close();
    }
        	
    // 上述第一次插入完成后，开始单独处理特殊类型（第二次插入）
        
    // 根据 flag1 判断是否有Clob类型的数据
    if(flag1){
      for(int i = 0;i < cList.size(); i=i+2){
        pstmt = con.prepareStatement(
          "SELECT "+cList.get(i)+" FROM 表名 WHERE 表主键 = "+blobId+" for update");
        ResultSet rs = pstmt.executeQuery();
        Writer outStream = null;
        if (rs.next()) {  
          //得到java.sql.Clob对象后强制转换为oracle.sql.CLOB  
          oracle.sql.CLOB clob = (oracle.sql.CLOB) rs.getClob(cList.get(i));  
          outStream = clob.getCharacterOutputStream();  
          //传入字符串
          char[] c = cList.get(i+1).toCharArray();  
          outStream.write(c, 0, c.length);  
        }  
        outStream.flush();  
        outStream.close();  
        con.commit(); 
        if(pstmt != null){
          pstmt.close();
        }
      }
    }
        
    // 根据 flag1 判断是否有Blob类型的数据
    if(flag2){
      for(int i = 0;i < bList.size(); i=i+2){
        pstmt = con.prepareStatement(
          "SELECT "+bList.get(i)+" FROM 表名 WHERE 表主键 = "+blobId+" for update" );
        ResultSet rs = pstmt.executeQuery();
        OutputStream os = null;
        if (rs.next()) {  
          // 得到java.sql.Blob对象后强制转换为oracle.sql.BLOB  
          oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob(bList.get(i));  
          // 通过getBinaryOutputStream()方法获得向数据库中插入图片的流
          os = blob.getBinaryOutputStream();  
          // 读取想要存储的图片文件（或串值） 
          InputStream is = new ByteArrayInputStream(bList.get(i+1).getBytes());
          // 依次读取流字节,并输出到已定义好的数据库字段中.  
          int b = 0;  
          while ((b = is.read()) != -1) {  
            os.write(b);  
          }  
        }  
        os.flush();  
        os.close();  
        con.commit(); 
        if(pstmt != null){
          pstmt.close();
        }
      }
    }
  } // end while 
} // end while