怎么利用MyBatis传List类型参数到数据库存储过程中实现批量插入数据?接下来通过本文给大家介绍Mybatis传list参数调用oracle存储过程,需要的朋友可以参考下
怎么利用MyBatis传List类型参数到数据库存储过程中实现批量插入数据?
MyBatis中参数是List类型时怎么处理?大家都知道MyBatis批处理大量数据是很难做到事务回滚的(事务由Spring管理),都将逻辑写在存储中又是及其头疼的一件事(参数长度也有限制),那么我想的是将参数在后台封装为单个或多个list集合,直接通过MyBatis将此参数传到数据库存储过程中,一来摆脱了MyBatis批量插入数据的诸多限制(例如:不能实时返回主键、foreach标签循环集合长度有限制),二来就是在存储中灵活的控制事务,但是这又会涉及两个问题,MyBatis的xml文件中该怎么封装,利用BaseTypeHandler吗?
对于这个问题,经过一天的研究终于算是跑通了,说一下解决办法:
1.建立数据库表,大家应该都有自己的库表了,所以这一步基本上就可以跳过了。我之所以在这里把库表贴出来是为了让大家对应里面的参数。
数据库表:
create table ZD_UNIT_MENU ( unit_id VARCHAR2(32), menu_id VARCHAR2(32) )
2.在数据库中建立相应的java对象(Oracle中的类型)和数组:
CREATE OR REPLACE TYPE unit_menu_obj AS OBJECT( unitId VARCHAR2(32), menuId VARCHAR2(32) ); CREATE OR REPLACE TYPE unit_menu_table AS table OF unit_menu_obj;
3.存储过程:
create or replace procedure save_unit_power(list0 in unit_menu_table,result0 out int) as sql_bind varchar(200); begin FOR i IN 1 .. list0.count LOOP sql_bind := 'insert into ZD_UNIT_MENU(UNIT_ID,MENU_ID) values('''||list0(i).unitId||''', '''||list0(i).menuId||''' )'; execute immediate sql_bind; end loop; commit; --返回结果,执行成功的话返回1 result0 := 1; --捕捉异常,回滚操作 EXCEPTION WHEN OTHERS THEN result0 := -1;--执行失败的话返回-1 ROLLBACK; end save_unit_power;
4.再看看mybatis的配置吧:
5.看看我是如何调用的?我直接贴我的server代码了,dao层的就没必要了:
List list = new ArrayList(); Map _map = new HashMap(); String[] menuIds = menuTreeIds.split(","); JSONObject job = new JSONObject(); int result = -1; for(int i = 0; i
6.非常关键的一点儿,细心的人应该会注意到,在mapper.xml配置中,有typeHandler配置,里面配置的实际上是我写的一个类,这个类的作用就是讲java中的list转换成数据库中我们建立的对象和数组,看代码吧:
package com.zd.util; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.sqlException; import java.util.ArrayList; import java.util.List; import oracle.sql.ARRAY; import oracle.sql.ArrayDescriptor; import oracle.sql.STRUCT; import oracle.sql.StructDescriptor; import org.apache.ibatis.type.BaseTypeHandler; import org.apache.ibatis.type.JdbcType; import com.zd.model.system.UnitMenu; public class ListHandler extends BaseTypeHandler{ @Override public Object getNullableResult(ResultSet arg0, String arg1) throws sqlException { // Todo Auto-generated method stub return null; } @Override public Object getNullableResult(CallableStatement arg0, int arg1) throws sqlException { // Todo Auto-generated method stub return null; } @SuppressWarnings("unchecked") @Override public void setNonNullParameter(java.sql.PreparedStatement parameterSetter, int i, Object o, JdbcType jdbcType) throws sqlException { Connection conn = null; try { if(null != o){ List list = (ArrayList) o; conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.1.88:1521:orcl", "tctscm", "tctscm"); //这里必须得用大写,而且必须要引入一个包,如果不引入这个包的话字符串无法正常转换,包是:orai18n.jar ARRAY array = getArray(conn, "UNIT_MENU_OBJ", "UNIT_MENU_TABLE", list); parameterSetter.setArray(i, array); } } catch (Exception e) { e.printstacktrace(); } finally{ if(null != conn){ conn.close(); } } } @SuppressWarnings("rawtypes") private ARRAY getArray(Connection con,String OracleObj, String Oraclelist, List listData) throws Exception { ARRAY array = null; ArrayDescriptor desc = ArrayDescriptor.createDescriptor(Oraclelist, con); STRUCT[] structs = new STRUCT[listData.size()]; if (listData != null && listData.size() > 0){ StructDescriptor structdesc = new StructDescriptor(OracleObj, con); for (int i = 0; i