我为此找到了两个解决方案。
Spring 方法
非弹簧方法
在第一种情况下,只需注入 JdbcTemplate 并使用此帮助代码:
public static LobHandler getAppropriateLobHandler(Factory factory) {
LobHandler lobHandler = null;
switch( factory.getDialect() ) {
case ORACLE: lobHandler = new OracleLobHandler(); break;
default: lobHandler = new DefaultLobHandler(); break;
}
return lobHandler;
}
使用此代码读取 BLOB:
return jdbcTemplate.queryForObject(
"select BLOB from TABLE where PK = ?",
args,
new RowMapper<InputStream>() {
@Override
public InputStream mapRow( ResultSet rs, int rowNum ) throws SQLException {
return lobHandler.getBlobAsBinaryStream( rs, 1 );
}
}
);
这是写他们的:
jdbcTemplate.execute(
"update TABLE set BLOB = ? where PK = ?",
new AbstractLobCreatingPreparedStatementCallback( lobHandler ) {
@Override
protected void setValues( PreparedStatement ps, LobCreator lobCreator ) throws SQLException {
lobCreator.setBlobAsBinaryStream( ps, 1, stream, sizeInBytes );
ps.setLong( 2, pk );
}
}
);
在第二种情况下,除非您有 Oracle,否则使用 JDBC 读取和写入 BLOB。当你有 Oracle 时,你需要使用他们的special C/BLOB locator pattern。