Java String與Blob類型數據轉換

需要把String類型數據轉換成Reader，然後再使用setCharacterStream插入數據庫中。

例如下例中，要插入String longStr，則先轉換成Byte[]，再ByteArrayInputStream，最後InputStreamReader。

添加或更新clob型數據，如下所示（以更新為例）：

1. PreparedStatement pstmt=conn.prepareStatement(“update tablename set column1=? “+條件語句);
2. byte[] bytes_zyjs = longStr.getBytes();
3. ByteArrayInputStream baisss = new ByteArrayInputStream(bytes_zyjs);
4. InputStreamReader bais = new InputStreamReader(baisss);
5. pstmt.setCharacterStream(1,bais,bytes_zyjs.length);
6. pstmt.executeUpdate();

但是如上方式寫入漢字就會產生亂碼，於是查看資料得知，上述方法多用於Oracle下，而mysql下使用的是setBinaryStream方法，只要傳入位置，inputstream，和長度即可。示例如下：

1. byte[] cert_dataBytes = cert_data.getBytes();
2. ByteArrayInputStream bais1 = new ByteArrayInputStream(cert_dataBytes);
4. byte[] prikey_dataBytes = prikey_data.getBytes();
5. ByteArrayInputStream bais2 = new ByteArrayInputStream(prikey_dataBytes);
7. String sql = "insert into cert_data values(?,?,?)";
9. PreparedStatement pstm = null;
10. try {
11. conn.setAutoCommit(false);
13. pstm = conn.prepareCall(sql);
14. pstm.setInt(1,cert_sn);
15. pstm.setBinaryStream(2, bais1,cert_dataBytes.length);//使用二進制讀取，可以直接寫入漢字，否則容易產生亂碼
16. pstm.setBinaryStream(3, bais2, prikey_dataBytes.length);
17. pstm.executeUpdate();
19. conn.commit();
20. conn.setAutoCommit(true);
21. pstm.close();
23. } catch (SQLException e) {
24. e.printStackTrace();
25. }finally{
27. try {
28. if(pstm != null)
29. pstm.close();
30. } catch (SQLException e) {
31. e.printStackTrace();
32. }
33. }

從數據庫中讀取Blob類型數據後，要轉換成String類型，即轉換成InputStream，再從InputStream轉成byte[]，再到String即可。如下：

1. //把數據庫中blob類型轉換成String類型
2. public String convertBlobToString(Blob blob){
4. String result = "";
5. try {
6. ByteArrayInputStream msgContent =(ByteArrayInputStream) blob.getBinaryStream();
7. byte[] byte_data = newbyte[msgContent.available()];
8. msgContent.read(byte_data, 0,byte_data.length);
9. result = new String(byte_data);
10. } catch (SQLException e) {
11. // TODO Auto-generated catch block
12. e.printStackTrace();
13. }
14. return result;
15. }