当前位置:编程学习 > JAVA >>

java String与Blob类型数据转换

java String与Blob类型数据转换
需要把String类型数据转换成Reader,然后再使用setCharacterStream插入数据库中。

例如下例中,要插入String longStr,则先转换成Byte[],再ByteArrayInputStream,最后InputStreamReader。
添加或更新clob型数据,如下所示(以更新为例): 

[java]  t=conn.prepareStatement(“update   tablename   set   column1=?   “+条件语句);   
  byte[]     bytes_zyjs     =     longStr.getBytes();   
  ByteArrayInputStream     baisss     =     new     ByteArrayInputStream(bytes_zyjs);   
  InputStreamReader     bais     =     new     InputStreamReader(baisss);   
  pstmt.setCharacterStream(1,bais,bytes_zyjs.length);   
  pstmt.executeUpdate();    www.zzzyk.com

但是如上方式写入汉字就会产生乱码,于是查看资料得知,上述方法多用于oracle下,而mysql下使用的是setBinaryStream方法,只要传入位置,inputstream,和长度即可。示例如下:
[java]
byte[] cert_dataBytes = cert_data.getBytes(); 
  ByteArrayInputStream bais1 = new ByteArrayInputStream(cert_dataBytes); 
   
  byte[] prikey_dataBytes = prikey_data.getBytes(); 
  ByteArrayInputStream bais2 = new ByteArrayInputStream(prikey_dataBytes); 
   
  String sql = "insert into cert_data values(?,?,?)"; 
   
  PreparedStatement pstm = null; 
  try { 
   conn.setAutoCommit(false); 
    
   pstm = conn.prepareCall(sql); 
   pstm.setInt(1,cert_sn); 
   pstm.setBinaryStream(2, bais1,cert_dataBytes.length);//使用二进制读取,可以直接写入汉字,否则容易产生乱码 
   pstm.setBinaryStream(3, bais2, prikey_dataBytes.length); 
   pstm.executeUpdate(); 
    
   conn.commit(); 
   conn.setAutoCommit(true); 
   pstm.close(); 
    
  } catch (SQLException e) { 
   e.printStackTrace(); 
  }finally{ 
    
    try { 
     if(pstm != null) 
      pstm.close(); 
    } catch (SQLException e) { 
     e.printStackTrace(); 
    } 
  } 

从数据库中读取Blob类型数据后,要转换成String类型,即转换成InputStream,再从InputStream转成byte[],再到String即可。如下:
[java] 
//把数据库中blob类型转换成String类型 
 public String convertBlobToString(Blob blob){ 
   
  String result = ""; 
  try { 
   ByteArrayInputStream msgContent =(ByteArrayInputStream) blob.getBinaryStream(); 
   byte[] byte_data = new byte[msgContent.available()]; 
   msgContent.read(byte_data, 0,byte_data.length); 
   result = new String(byte_data); 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
  return result; 
 } 

补充:软件开发 , Java ,
CopyRight © 2012 站长网 编程知识问答 www.zzzyk.com All Rights Reserved
部份技术文章来自网络,