`
hyw520110
  • 浏览: 221037 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

Ibatis读写CLOB数据

    博客分类:
  • java
阅读更多

转载:http://www.iteye.com/topic/74678
Ibatis是一个高效,方便,易于学习的数据访问组件,在性能上比hibernate高,学习难度也比hibernate和jdo要低,而且它比直接使用jdbc方便和易于维护。所以Ibatis深入大家的喜爱,一些对性能有更高的要求的系统(如保险,金融行业系统),或改造遗留系统时,Ibatis是数据访问组件的首选。
在使用Oracle数据库时,读取CLOB和BLOB等大类型的数据一直是个比较犯难的事,一般都是通过JDBC代码来实现对CLOB和BLOB数据的读写,效果和性能都是最好的,但是代码也相当复杂,且代码难以重用。
在使用ibatis作为数据访问组件,也经常会遇到要读取CLOB,BLOB大类型数据。怎样使用Ibatis读取CLOB,BLOB数据也是一个难题,并且Oracle在这方面一直没有解决好。
公司的项目正好有这方面的需要,要求我给予解决。在网上找了很多的资料,都没有一个比较简单易用的解决办法,通过不断的验实,终于得出了比较好的解决办法,所以写成文字,大家可以分享。如果大家以后有这方面的需要就可以直接使用,少走弯路,当然如果大家有更好的办法,希望能告诉我,我当不胜感激。
准备工作:
1. 测试数据库

Java代码 复制代码 收藏代码
  1. CREATE TABLE USERINFO(USERID VARCHAR2(5),    
  2.                          USERNAME VARCHAR2(20),   
  3.                          MEMO CLOB,   
  4.                         constraint PK_USERINFO  primary key(USERID));  
CREATE TABLE USERINFO(USERID VARCHAR2(5), 
                         USERNAME VARCHAR2(20),
                         MEMO CLOB,
						constraint PK_USERINFO  primary key(USERID));



2.域模型对象
UserInfoDTO.java

Java代码 复制代码 收藏代码
  1. import java.io.Serializable;   
  2.   
  3. public class UserInfoDTO implements Serializable {   
  4.   /*用户id*/  
  5.   private String userID;   
  6.      
  7.   /*用户名*/  
  8.   private String userName;   
  9.      
  10.   /*备注*/  
  11.   private String memo;   
  12.   
  13. public String getMemo() {   
  14.     return memo;   
  15. }   
  16. public void setMemo(String memo) {   
  17.     this.memo = memo;   
  18. }   
  19.   
  20. public String getUserID() {   
  21.     return userID;   
  22. }   
  23.   
  24. public void setUserID(String userID) {   
  25.     this.userID = userID;   
  26. }   
  27.   
  28. public String getUserName() {   
  29.     return userName;   
  30. }   
  31.   
  32. public void setUserName(String userName) {   
  33.     this.userName = userName;   
  34. }   
  35.      
  36. }  
import java.io.Serializable;

public class UserInfoDTO implements Serializable {
  /*用户id*/
  private String userID;
  
  /*用户名*/
  private String userName;
  
  /*备注*/
  private String memo;

public String getMemo() {
	return memo;
}
public void setMemo(String memo) {
	this.memo = memo;
}

public String getUserID() {
	return userID;
}

public void setUserID(String userID) {
	this.userID = userID;
}

public String getUserName() {
	return userName;
}

public void setUserName(String userName) {
	this.userName = userName;
}
  
}



3.数据访问对象接口
UserInfoDao.java

Java代码 复制代码 收藏代码
  1. public interface UserInfoDao {   
  2.  public List getUsers(UserInfoDTO user) throws DataAccessException;   
  3.  public void insertUser(UserInfoDTO user) throws DataAccessException;   
  4. }  
public interface UserInfoDao {
 public List getUsers(UserInfoDTO user) throws DataAccessException;
 public void insertUser(UserInfoDTO user) throws DataAccessException;
}



一、 读取CLOB,BLOB类型数据的几种方法
1. jdbc实现
采用jdbc来读写是最原始,也是最直接的方法
UserInfoDaoImpl.java

Java代码 复制代码 收藏代码
  1. public class UserInfoDaoImpl extends SqlMapClientDaoSupport implements  
  2.         UserInfoDao {   
  3. Connection con = null;   
  4.     private Connection getConnection() throws SQLException {   
  5.         Connection con = null;   
  6.         con = this.getSqlMapClientTemplate().getDataSource().getConnection();   
  7.         con.setAutoCommit(false);   
  8.         return con;   
  9.     }   
  10. public void insertUser(UserInfoDTO user) throws DataAccessException {   
  11.         try {   
  12.             this.con = this.getConnection();   
  13.             final String insertSql = "INSERT INTO USERINFO(USERID,USERName,memo) VALUES(?,?,?)";   
  14.             final String selectSql = "SELECT MEMO FROM USERINFO WHERE USERID = ? FOR UPDATE";   
  15.             final String updateSql = "UPDATE USERINFO SET MEME = ? WHERE USERID = ?";   
  16.             PreparedStatement ps = con.prepareStatement(insertSql);   
  17.             ps.setString(1, user.getUserID());   
  18.             ps.setString(2, user.getUserName());   
  19.             ps.setClob(3, CLOB.empty_lob());   
  20.             ps.executeUpdate();   
  21.             ps.close();   
  22.   
  23.             ps = this.con.prepareStatement(selectSql);   
  24.             ps.setString(1, user.getUserID());   
  25.             ResultSet rs = ps.executeQuery();   
  26.             rs.next();   
  27.   
  28.             CLOB memo = (CLOB) rs.getClob(1);   
  29.             memo.setString(1, user.getMemo());   
  30.   
  31.             ps = this.con.prepareStatement(updateSql);   
  32.             ps.setClob(1, memo);   
  33.             ps.setString(2, user.getUserID());   
  34.             ps.executeUpdate();   
  35.             ps.close();   
  36.             this.con.commit();   
  37.         } catch (Exception ex) {   
  38.             throw new DataAccessResourceFailureException(ex.getMessage(), ex);   
  39.         } finally {   
  40.             try {   
  41.                 if (this.con != null)   
  42.                     this.con.close();   
  43.             } catch (Exception ex) {   
  44.                 throw new DataAccessResourceFailureException(ex.getMessage(),   
  45.                         ex);   
  46.             }   
  47.         }   
  48.   
  49.     }  
public class UserInfoDaoImpl extends SqlMapClientDaoSupport implements
		UserInfoDao {
Connection con = null;
	private Connection getConnection() throws SQLException {
		Connection con = null;
		con = this.getSqlMapClientTemplate().getDataSource().getConnection();
		con.setAutoCommit(false);
		return con;
	}
public void insertUser(UserInfoDTO user) throws DataAccessException {
		try {
			this.con = this.getConnection();
			final String insertSql = "INSERT INTO USERINFO(USERID,USERName,memo) VALUES(?,?,?)";
			final String selectSql = "SELECT MEMO FROM USERINFO WHERE USERID = ? FOR UPDATE";
			final String updateSql = "UPDATE USERINFO SET MEME = ? WHERE USERID = ?";
			PreparedStatement ps = con.prepareStatement(insertSql);
			ps.setString(1, user.getUserID());
			ps.setString(2, user.getUserName());
			ps.setClob(3, CLOB.empty_lob());
			ps.executeUpdate();
			ps.close();

			ps = this.con.prepareStatement(selectSql);
			ps.setString(1, user.getUserID());
			ResultSet rs = ps.executeQuery();
			rs.next();

			CLOB memo = (CLOB) rs.getClob(1);
			memo.setString(1, user.getMemo());

			ps = this.con.prepareStatement(updateSql);
			ps.setClob(1, memo);
			ps.setString(2, user.getUserID());
			ps.executeUpdate();
			ps.close();
			this.con.commit();
		} catch (Exception ex) {
			throw new DataAccessResourceFailureException(ex.getMessage(), ex);
		} finally {
			try {
				if (this.con != null)
					this.con.close();
			} catch (Exception ex) {
				throw new DataAccessResourceFailureException(ex.getMessage(),
						ex);
			}
		}

	}



2. 使用Spring的org.springframework.jdbc.support.lob.OracleLobHandler类处理
2.1 sql-map-config.xml的配置

Java代码 复制代码 收藏代码
  1. <typeHandler jdbcType="CLOB" javaType="java.lang.String" callback="org.springframework.orm.ibatis.support.ClobStringTypeHandler"/>  
<typeHandler jdbcType="CLOB" javaType="java.lang.String" callback="org.springframework.orm.ibatis.support.ClobStringTypeHandler"/>


2.2 sqlMapClient的配置

Java代码 复制代码 收藏代码
  1. <bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">   
  2.   <property name="configLocation"><value>/sql-map-config.xml</value></property>   
  3.   <property name="dataSource"><ref local="dataSource"/></property>   
  4.   <property name="lobHandler"><ref local="oracleLobHandler"/></property>   
  5.  </bean>   
  6.   
  7. <bean id="oracleLobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler"  
  8.    lazy-init="true">  
<bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
  <property name="configLocation"><value>/sql-map-config.xml</value></property>
  <property name="dataSource"><ref local="dataSource"/></property>
  <property name="lobHandler"><ref local="oracleLobHandler"/></property>
 </bean>

<bean id="oracleLobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler"
   lazy-init="true">



特别注意:采用这种方法只对数据源是直接连接Oracle 的JDBC驱动方式有效,如果你采用数据连接池作为数据源,则这种办法无效。但是一般大型的项目都是使用连接池的,所以这个方法有很大的局限性。


3. 通过实现Ibatis的TypeHandlerCallback接口来实现
下面是读取的方法:

Java代码 复制代码 收藏代码
  1. public class OracleClobTypeHandlerCallback implements TypeHandlerCallback {   
  2.   
  3.     public void setParameter(ParameterSetter setter, Object obj)   
  4.             throws SQLException {   
  5.         // TODO Auto-generated method stub   
  6.         CLOB clob = CLOB.empty_lob();   
  7.         clob.setString(1, (String)obj);   
  8.         setter.setClob(clob);   
  9.   
  10.     }   
  11.   
  12.     public Object getResult(ResultGetter getter) throws SQLException {   
  13.            
  14.         CLOB clob = (CLOB) getter.getClob();   
  15.        
  16.         return (clob == null || clob.length() == 0 )? null :clob.getSubString((long)1, (int)clob.length());   
  17.            
  18.        
  19.     }   
  20.   
  21.     public Object valueOf(String param) {   
  22.         // TODO Auto-generated method stub   
  23.         return null;   
  24.     }   
  25.   
  26. }  
public class OracleClobTypeHandlerCallback implements TypeHandlerCallback {

	public void setParameter(ParameterSetter setter, Object obj)
			throws SQLException {
		// TODO Auto-generated method stub
		CLOB clob = CLOB.empty_lob();
		clob.setString(1, (String)obj);
		setter.setClob(clob);

	}

	public Object getResult(ResultGetter getter) throws SQLException {
		
		CLOB clob = (CLOB) getter.getClob();
	
		return (clob == null || clob.length() == 0 )? null :clob.getSubString((long)1, (int)clob.length());
		
	
	}

	public Object valueOf(String param) {
		// TODO Auto-generated method stub
		return null;
	}

}



sqlMap 的配置

Java代码 复制代码 收藏代码
  1.   <resultMap id="userResult" class="com.prs.application.ehld.sample.common.dto.UserInfoDTO">   
  2.     <result property="userID" column="USERID" columnIndex="1"/>   
  3.     <result property="userName" column="USERNAME" columnIndex="2"/>   
  4.     <result property="memo"  column="memo" jdbcType="CLOB" javaType = "java.lang.String"  typeHandler =" OracleClobTypeHandlerCallback "/>   
  5. </resultMap>  
  <resultMap id="userResult" class="com.prs.application.ehld.sample.common.dto.UserInfoDTO">
  	<result property="userID" column="USERID" columnIndex="1"/>
  	<result property="userName" column="USERNAME" columnIndex="2"/>
  	<result property="memo"  column="memo" jdbcType="CLOB" javaType = "java.lang.String"  typeHandler =" OracleClobTypeHandlerCallback "/>
</resultMap>




二、 存在的问题
上面三种方法都存在的问题:
1. 使用jdbc来实现,就失去了使用ibatis带来的便利,同时也失去了自动事务管理的能力,还有需要自己去手工管理连接对象。代码量也相当复杂。
2. 使用spring提供的处理器,不支持采用数据连接池的数据源,有很大的局限性。
3. 通过实现ibatis的回调接口来实现,也有一定的局限性,需要新增一个类,配置也不方便,还可能会出错。

难道ibatis读写LOB大类型数据就没辙了吗?通过试验,发现可以配置ParameterMap和ResultMap就可以方便的实现对LOB的读写了,而且不用去实现任何类。只需要配置就可以了

三、 通过配置ParameterMap和ResultMap来实现对LOB类型的读写
3.1 sqlMap的配置

Java代码 复制代码 收藏代码
  1. <resultMap id="userResult" class="com.prs.application.ehld.sample.common.dto.UserInfoDTO">   
  2.     <result property="userID" column="USERID" columnIndex="1"/>   
  3.     <result property="userName" column="USERNAME" columnIndex="2"/>   
  4.     [color=darkred]<result property="memo"  column="memo" jdbcType="CLOB" javaType = "java.lang.String" />[/color]</resultMap>   
  5.   
  6.   <parameterMap id="userPara" class = "com.prs.application.ehld.sample.common.dto.UserInfoDTO">   
  7.     <parameter property="userID" jdbcType="VARCHAR" javaType ="java.lang.String"/>   
  8.     <parameter property="userName" jdbcType="VARCHAR" javaType ="java.lang.String"/>   
  9.     [color=darkred]<parameter property="memo" jdbcType="CLOB" javaType ="java.lang.String"/>[/color]         
  10.   </parameterMap>  
<resultMap id="userResult" class="com.prs.application.ehld.sample.common.dto.UserInfoDTO">
  	<result property="userID" column="USERID" columnIndex="1"/>
  	<result property="userName" column="USERNAME" columnIndex="2"/>
  	[color=darkred]<result property="memo"  column="memo" jdbcType="CLOB" javaType = "java.lang.String" />[/color]</resultMap>

  <parameterMap id="userPara" class = "com.prs.application.ehld.sample.common.dto.UserInfoDTO">
  	<parameter property="userID" jdbcType="VARCHAR" javaType ="java.lang.String"/>
  	<parameter property="userName" jdbcType="VARCHAR" javaType ="java.lang.String"/>
  	[color=darkred]<parameter property="memo" jdbcType="CLOB" javaType ="java.lang.String"/>[/color]  	
  </parameterMap>

3.2 插入和读取语句的配置

Java代码 复制代码 收藏代码
  1.   <select id="getUserInfoList" resultMap="userResult" >   
  2.       SELECT   
  3.           USERINFO.USERID ,   
  4.           USERINFO.USERName ,   
  5.           USERINFO.MEMO   
  6.         FROM USERINFO   
  7. </select>   
  8.   
  9.   
  10.    <insert id="insertUserInfo"  parameterMap = "userPara"  >   
  11.     INSERT INTO USERINFO(USERID,   
  12.                          USERName,   
  13.                          memo)    
  14.                 VALUES([color=darkred]?,?,?[/color]   
  15.                        )   
  16.   </insert>  
  <select id="getUserInfoList" resultMap="userResult" >
      SELECT
          USERINFO.USERID ,
          USERINFO.USERName ,
          USERINFO.MEMO
 		FROM USERINFO
</select>


   <insert id="insertUserInfo"  parameterMap = "userPara"  >
  	INSERT INTO USERINFO(USERID,
  						 USERName,
  						 memo) 
  				VALUES([color=darkred]?,?,?[/color]
  					   )
  </insert>

注意:因为使用了ParameterMap作为输入参数,在插入语句中用?号来代替属性值(如:#userId#)

而不是常见的:

Java代码 复制代码 收藏代码
  1. INSERT INTO USERINFO(USERID,   
  2.                          USERName,   
  3.                          memo)    
  4.                 VALUES(#userId#,   
  5.                             #userName#,   
  6.                             #memo#   
  7.                        )  
INSERT INTO USERINFO(USERID,
  						 USERName,
  						 memo) 
  				VALUES(#userId#,
							#userName#,
							#memo#
  					   )


但是当paramaterMap的class属性是java.util.Map类时,应该使用#userId#类似的参数,不能用?来代替。
但是这又有一个问题,就是插入的字符串不能超过4000个字符,而CLOB类型的字段可以存4GB大小的字符。只要对userInfo对象的memo成员设置字符串超过了4000个字符,就提示“不能创建更多的套接字”,为什么会报这个错,暂是没有弄清楚。

而需求是要CLOB字段要存6000个汉字,相当于12000个英文字符。可以说是白忙了一场,没有达到目的。

四、 使用Oracle 10g的jdbc驱动程序
因为字符串只要超过了4000个字符就不能插入,所以不得不试着换一下驱动程序看看。一直以来都认为oracel的jdbc 驱动对处理LOB对象有一些问题,想看看10g出来后是不是有所改变。于是上网下载10g的驱动,一阵痛苦的等待后,问题解决,我把字符串设为12万个字符也没有问题了。

另外采用10g 的驱动就算不使用parameterMap也可以成功的插入字符串到CLOB类型字段去,请要注意的是,这样只能插入的字符一定要小于32767个。也就是说我把memo 属性设置多于32766个字符,照样插不进去。这个原因主要是jdbc驱动限制了String的长度的原因。

Java代码 复制代码 收藏代码
  1. <insert id="insertUserInfo"  parameterClass = "UserInfoDTO"  >   
  2.     INSERT INTO USERINFO(USERID,   
  3.                          USERName,   
  4.                          memo)    
  5.                 VALUES(#userID#,   
  6.                         #userName#,   
  7.                         #memo#   
  8.                        )   
  9. </insert>  
<insert id="insertUserInfo"  parameterClass = "UserInfoDTO"  >
  	INSERT INTO USERINFO(USERID,
  						 USERName,
  						 memo) 
  				VALUES(#userID#,
						#userName#,
						#memo#
  					   )
</insert>

使用10g的驱动,这样能写入32766个字符

五、 怎么读写BLOB
上面都一直在说CLOB,其实把CLOB实现了,那么BLOB也同样简单,只是注意它的java类型,如果一个字段为BLOB类型,那么在parameterMap中jdbcType 为BLOB,
把javaType设为:[]byte就可以了。
例:

Java代码 复制代码 收藏代码
  1. <parameterMap id="userPara" class = "com.prs.application.ehld.sample.common.dto.UserInfoDTO">   
  2.     <parameter property="userID" jdbcType="VARCHAR" javaType ="java.lang.String"/>   
  3.     <parameter property="userName" jdbcType="VARCHAR" javaType ="java.lang.String"/>   
  4.     [color=red]<parameter property="memo" jdbcType="BLOB" javaType ="[]byte"/>[/color]   
  5.        
  6. </parameterMap>  
  <parameterMap id="userPara" class = "com.prs.application.ehld.sample.common.dto.UserInfoDTO">
  	<parameter property="userID" jdbcType="VARCHAR" javaType ="java.lang.String"/>
  	<parameter property="userName" jdbcType="VARCHAR" javaType ="java.lang.String"/>
  	[color=red]<parameter property="memo" jdbcType="BLOB" javaType ="[]byte"/>[/color]
  	
  </parameterMap>



假设memo在数据库中为BLOB 类型

那么在javaBean中memo的java类型为[]byte


六、 总结
采用10g的驱动,和通过配置parameterMap和resultMap能够轻松和完美的解决LOB大型数据的读写,无需要编写新的java来实现,也没有局限性。

分享到:
评论

相关推荐

    ibatis oracle clob

    1. **插入CLOB数据**:在iBATIS的映射文件中,需要使用`&lt;clob&gt;`标签来处理CLOB字段。例如,当向数据库插入CLOB字段时,可以这样编写XML映射: ```xml INSERT INTO table_name (column_name) VALUES (#{value}) ...

    iBATIS操作Oracle CLOB数据

    本文将深入探讨如何在iBATIS中有效地处理Oracle的CLOB数据。 首先,我们需要了解什么是CLOB。CLOB是一种用于存储大量字符数据的数据类型,它可以容纳最大4GB的单个文本对象。在Oracle中,CLOB通常用于存储大段的...

    ibatis 读取oracle clob类型

    ibatis 读取oracle clob类型

    Spring+Struts+ibatis下配置数据读写分离及事务(一)

    本文将深入探讨如何在Spring、Struts和iBATIS这三大流行框架的集成环境中实现数据读写分离以及事务控制。我们将不涉及具体的代码实现,而是侧重于理论背景和设计原则。 首先,让我们理解数据读写分离的概念。数据...

    mybatis 对clob类型转换

    在实际操作中,可能会遇到如“数据过长”或“内存不足”等异常,这可能是因为CLOB数据超过了数据库或JVM的限制。为避免这些问题,可以考虑分段读写CLOB,或者调整数据库参数。另外,确保在MyBatis的...

    ibatis_数据缓存

    iBatis 数据缓存机制是提高数据库访问性能的重要手段,它允许将查询结果存储在内存中,以便后续相同查询能够快速获取数据,而无需每次都执行SQL查询。在深入理解iBatis的Cache概念之前,首先需要知道iBatis是一个轻...

    ibatis实现数据的操作

    本篇文章将详细讲解如何利用Ibatis实现数据的连接、增加、查询、删除和修改(CRUD)操作,以及.xml文件在SQL映射中的作用。 首先,Ibatis是一个轻量级的Java ORM(对象关系映射)框架,它的核心理念是将SQL语句与...

    ibatis3批量插入

    通过Ibatis3xml文件配置+Mysql实现数据批量插入,原先在网上找很多,都是关于批量更新,批量插入的很少,而且其写法又完全不同,所以自己研究了一下。可供参考。另外插入时如出现内容报错,请参照my.cnf修改书库配置...

    ibatis 连接字符串 SqlMapConfig.xml

    这个文件是iBATIS的核心配置文件,它包含了数据源、事务管理器、SQL映射文件等信息,确保了应用程序能够正确地连接到数据库并执行SQL语句。 在SqlMapConfig.xml中,最重要的部分是数据库连接的配置,通常包括以下几...

    ibatis总结 ibatis ibatis ibatis ibatis

    Ibatis的配置文件`sqlmapConfig.xml`包含了数据源、事务管理器、SqlSessionFactory等核心设置。在Java代码中,可以使用如下的方式加载配置文件: ```java String resource = ...

    ibatis demo,ibatis例子,ibatis示例

    Ibatis的出现,解决了传统JDBC中手动编写SQL和结果集映射的繁琐工作,提供了更加灵活的数据访问接口。 在"ibatis demo"中,我们通常会看到以下核心概念和知识点: 1. **配置文件**:Ibatis的配置文件(mybatis-...

    ibatis 数据缓存.pdf

    ibatis 数据缓存,讨论了ibatis 数据缓存方面的概念,即用法,用到ibatis 数据缓存的可以参考一下

    ibatis自定义数据类型在不支持中文的数据库存储汉字

    `iBatis`,作为一个轻量级的持久层框架,提供了自定义数据类型的功能,帮助我们在这些数据库中存储汉字。 `iBatis`是Java领域中广泛使用的SQL映射框架,它允许开发者将SQL语句直接写在配置文件中,与Java代码解耦,...

    Ibatis和Spring整合例子,实现增删改查功能

    Ibatis和Spring整合例子,实现增删改查功能.

    ibatis乱码解决方法(ibatis独立)

    - 如果是从文件中读取或写入数据,确保文件的读写操作使用了与数据库相同的编码格式。 8. **字符集转换**: - 使用Java的`Charset`类进行编码转换,如`new String(byte[], "GBK")`用于GBK编码的字符串转换。 ...

    ibatis源码,ibatis源码 ibatis源码 ibatis源码

    iBatis的配置文件SqlMapConfig.xml是系统启动时加载的关键,它包含了数据源(DataSource)、事务管理器(TransactionManager)和SqlMap配置信息。解析这个XML文件的过程涉及到DOM或SAX解析器,源码中这部分功能通常...

    ibatis应对批量update

    为了解决这个问题,ibatis(现已更名为MyBatis)提供了一种支持批量更新的机制,能够显著提高数据处理的速度。 #### 批量Update背景与问题 在实际应用中,经常会遇到需要批量更新数据库中的数据的情况,例如:商品...

Global site tag (gtag.js) - Google Analytics