spring下lob数据处理

做了个简单的通告管理，在本机测试时数据量比较小。最开始用的时varchar2到2000，之后用hibernate中的text类型，对应数据库中的Clob类型。当数据量小于4000时，可以直接使用setObject()插入数据库。当数据量大于4000时。报错：socket write error。
查找了一些资料，说当数据量超过4000时，应该使用流方式操作。看到头昏昏，烦都烦死了......
最后发现Spring封装了对lob数据的操作，可以直接使用jdbcTemple操作lob数据。
当使用MySql、MSSQL、Oracle 10g时，使用DefaultLobHandler；使用Oracle 9i时使用OracleLobHandler。
示例代码：【转值javaWorld】

 1         final File binaryFile = new File("c:\\workspace\\wish.jpg" );
 2         final File txtFile = new File("c:\\workspace\\test.txt" );
 3         
 4         final InputStream is = new  FileInputStream(binaryFile);
 5         final Reader reader = new  FileReader(txtFile);
 6         
 7         JdbcTemplate jdbcTemplate = new  JdbcTemplate(dataSource);
 8         
 9         final LobHandler lobHandler = new  DefaultLobHandler();
10         
11         jdbcTemplate.execute("INSERT INTO test (txt, image) VALUES(?, ?)" ,
12                      new  AbstractLobCreatingPreparedStatementCallback(lobHandler) {
13                         protected void  setValues(PreparedStatement pstmt, LobCreator lobCreator)
14                                                            throws  SQLException, DataAccessException {
15                             lobCreator.setClobAsCharacterStream(pstmt, 1, reader, (int ) txtFile.length());
16                             lobCreator.setBlobAsBinaryStream(pstmt, 2, is, (int ) binaryFile.length());
17                          }
18                       });
19         
20          reader.close();
21          is.close();
22 

读取代码：

 1         final Writer writer = new FileWriter("c:\\workspace\\test_bak.txt" );
 2         final OutputStream os = new FileOutputStream(new File("c:\\workspace\\wish_bak.jpg" ));
 3         
 4         jdbcTemplate.query("SELECT txt,image FROM test WHERE id = ?" ,
 5                 new Object[] {new Integer(1 )},
 6                 new  AbstractLobStreamingResultSetExtractor() {
 7                     protected void streamData(ResultSet rs) throws  SQLException, IOException, DataAccessException {
 8                         FileCopyUtils.copy(lobHandler.getClobAsCharacterStream(rs, 1 ), writer);
 9                         FileCopyUtils.copy(lobHandler.getBlobAsBinaryStream(rs, 2 ), os);
10                      }
11                   });
12          writer.close();
13          os.close();
14 
15 

备注1：OracleLobHandler要求注入CommonsDbcpNativeJdbcExtractor，否则报错：要求使用OracleConnection，不可以使用Dbcp连接池。

1      < bean id = " lobHandler "   class = " org.springframework.jdbc.support.lob.OracleLobHandler " >
2      < property name = " nativeJdbcExtractor " >
3         < bean  class = " org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor " />
4     property >
5     bean >

备注2：Oracle驱动版本很多，要求使用正确的驱动。当驱动版本错误时,报错：无法释放LobHandler；无法关闭Writer；无法从套接字读取更多的信息。执行插入操作，但是Clob类型数据为空。

风之力 2006-11-08 16:20 发表评论

评论

2 楼 _咖啡杯垫 2008-12-10  

代码如下：

public boolean executeSqlLob(final String sql, final Object[] objects,
			final int[] types) {
		if (objects.length != types.length) {
			return false;
		}
		try {
			transactionTemplate.execute(new TransactionCallbackWithoutResult() {
				@Override
				protected void doInTransactionWithoutResult(
						TransactionStatus status) {
					getJdbcTemplate().execute(sql,
							new AbstractLobCreatingPreparedStatementCallback(getLobHandler()) {
								protected void setValues(
										PreparedStatement pstmt,
										LobCreator lobCreator)
										throws SQLException,
										DataAccessException {
									for (int i = 0; i < objects.length; i++) {
										if (Types.CLOB == types[i]) {
											lobCreator.setClobAsCharacterStream(pstmt, i + 1, new CharArrayReader(objects[i].toString().toCharArray()), objects[i].toString().length());
										} 
										else if(Types.BLOB == types[i]){
											//do something...
										}
									}
								}

							});
				}
			});
			return true;
		} catch (DataAccessException exception) {
			exception.printStackTrace();
			return false;
		} 
	}

XML信息：

<!-- 适用于除Oracle10g外的其它版本Oracle数据库 -->
	<bean id="lobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler">
		<property name="nativeJdbcExtractor">
			<bean class="org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor"/>
		</property>
	</bean>

出现错误：

ava.lang.NoSuchMethodError: org.springframework.util.ReflectionUtils.invokeJdbcMethod(Ljava/lang/reflect/Method;Ljava/lang/Object;)Ljava/lang/Object;
	at org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor.getInnermostDelegate(CommonsDbcpNativeJdbcExtractor.java:81)
	at org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor.doGetNativeConnection(CommonsDbcpNativeJdbcExtractor.java:94)
	at org.springframework.jdbc.support.nativejdbc.NativeJdbcExtractorAdapter.getNativeConnection(NativeJdbcExtractorAdapter.java:99)
	at org.springframework.jdbc.support.nativejdbc.NativeJdbcExtractorAdapter.getNativeConnectionFromStatement(NativeJdbcExtractorAdapter.java:135)
	at org.springframework.jdbc.support.lob.OracleLobHandler$OracleLobCreator.getOracleConnection(OracleLobHandler.java:378)
	at org.springframework.jdbc.support.lob.OracleLobHandler$OracleLobCreator.createLob(OracleLobHandler.java:338)
	at org.springframework.jdbc.support.lob.OracleLobHandler$OracleLobCreator.setClobAsCharacterStream(OracleLobHandler.java:311)
	at com.model.support.impl.CommonServiceImpl$5$1.setValues(CommonServiceImpl.java:170)
	at org.springframework.jdbc.core.support.AbstractLobCreatingPreparedStatementCallback.doInPreparedStatement(AbstractLobCreatingPreparedStatementCallback.java:70)
	at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:538)
	at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:566)
	at com.model.support.impl.CommonServiceImpl$5.doInTransactionWithoutResult(CommonServiceImpl.java:161)
	at org.springframework.transaction.support.TransactionCallbackWithoutResult.doInTransaction(TransactionCallbackWithoutResult.java:33)
	at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:127)
	at com.model.support.impl.CommonServiceImpl.executeSqlLob(CommonServiceImpl.java:157)
	at com.test.Test.main(Test.java:26)

1 楼 _咖啡杯垫 2008-12-10  

很巧，我也是使用的这种方法，但是还是有问题，搞得我不明白。

数据库：oracle9i
dbcp连接池

现：使用jdbcTemplate的execute(sql,PreparedStatementCallback)处理包含lob数据的insert，update,的工作，其中PreparedStatementCallback是AbstractLobCreatingPreparedStatementCallback的实现类，并通过org.springframework.jdbc.support.lob.OracleLobHandler（注入的nativeJdbcExtractor为org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor）来处理来自web层的大于4000字节以上的文本信息，并存入数据库。但是在测试时发现，有一个方法始终找不到：java.lang.NoSuchMethodError: org.springframework.util.ReflectionUtils.invokeJdbcMethod(Ljava/lang/reflect/Method;Ljava/lang/Object;)Ljava/lang/Object;    我看过源代码，这个方法是存在的，我不知道为什么这里会有这样的错误。

我换过spring的jar包，还是一样的问题：找不到方法。

这个问题应该不是你说的DBCP连接池的原因吧， 你提到的：
    要求使用OracleConnection，不可以使用Dbcp连接池？