一般来说,我们使用框架进行关系型数据库与对象类型的转换时没有过多注意。那么在使用jdbc转换对象时有一些对象可能会被忽略,例如CLOB字段,下面是我在使用JDBC转义CLOB时的处理。
public static List<Map<String,Object>> getDetail(final String instance,final String sql) throws Exception{
String key="";
Connection con=null;
Statement st=null;
ResultSet rs=null;
ResultSetMetaData rsmd=null;
List<Map<String,Object>> resultList =new ArrayList<Map<String,Object>>();
Map<String,String> jdbcMap=new HashMap<String,String>();
//取得jdbc连接串,此处省略掉,大家可以直接写上jdbc配置
//jdbcMap=praseXml(instance);
try {
Class.forName(jdbcMap.get("driver"));
//这里是由于配置的一个jdbc配置文件加密了,需要解密 ,大家可以按自己的方式写
con=DriverManager.getConnection(jdbcMap.get("url"),DesEncryptUtils.decrypt(jdbcMap.get("name")),DesEncryptUtils.decrypt(jdbcMap.get("pass")));
st = con.createStatement();
rs = st.executeQuery(sql);
rsmd=rs.getMetaData();
logger.info("...Running...");
int columnCount = rsmd.getColumnCount();
Map<String, Object> map = null;
while (rs.next()) {
map = new HashMap<String, Object>();
for (int i = 1; i <= columnCount; i++) {
key = rsmd.getColumnName(i);
//这里就是我们主要的处理CLOB方法了。
if( rs.getObject(key) instanceof Clob){
Clob clob = rs.getClob(key);// java.sql.Clob类型
String clobValue=getClobString(clob);
map.put(key,clobValue);
}else{
Object value = rs.getObject(key);
map.put(key, value);
}
}
resultList.add(map);
}
}finally{
con.close();
st.close();
rs.close();
}
return resultList;
}
//处理CLOB主要方法
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 new String(sb.toString().getBytes("UTF-8"));
} catch (Exception e) {
return "";
}
}