Mybatis传list参数调用oracle存储过程的解决方法-eolink官网

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的配置吧：

javaType="java.util.List" mode="IN" typeHandler="com.zd.util.ListHandler"/>

javaType="java.lang.Integer" mode="OUT" />

<![CDATA[

CALL save_unit_power(?,?)

]]>

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 < menuIds.length; i++){

UnitMenu um = new UnitMenu();

um.setMenuId(menuIds[i]);

um.setUnitId(unitId);

list.add(um);

}

_map.put("list0", list);

_map.put("result0", "");

unitMenuMapper.addUnitPower(_map);

System.out.println("================================================_map = "+_map.toString());

result = (Integer)_map.get("result0");

System.out.println("================================================result = "+result);

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 < listData.size(); i++){

Object[] result = {listData.get(i).getUnitId(),listData.get(i).getMenuId()};

structs[i] = new STRUCT(structdesc, con, result);

}

array = new ARRAY(desc, con, structs);

}else{

array = new ARRAY(desc, con, structs);

}

return array;

}

以上所述是给大家介绍的Mybatis传list参数调用oracle存储过程的解决方法，希望对大家有所帮助，如果大家有任何疑问请给我留言，会及时回复大家的。在此也非常感谢大家对我们网站的支持！

javaType="java.util.List" mode="IN" typeHandler="com.zd.util.ListHandler"/>

javaType="java.lang.Integer" mode="OUT" />

<![CDATA[

CALL save_unit_power(?,?)

]]>

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 < menuIds.length; i++){

UnitMenu um = new UnitMenu();

um.setMenuId(menuIds[i]);

um.setUnitId(unitId);

list.add(um);

}

_map.put("list0", list);

_map.put("result0", "");

unitMenuMapper.addUnitPower(_map);

System.out.println("================================================_map = "+_map.toString());

result = (Integer)_map.get("result0");

System.out.println("================================================result = "+result);

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 < listData.size(); i++){

Object[] result = {listData.get(i).getUnitId(),listData.get(i).getMenuId()};

structs[i] = new STRUCT(structdesc, con, result);

}

array = new ARRAY(desc, con, structs);

}else{

array = new ARRAY(desc, con, structs);

}

return array;

}

javaType="java.lang.Integer" mode="OUT" />

<![CDATA[

CALL save_unit_power(?,?)

]]>

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 < menuIds.length; i++){

UnitMenu um = new UnitMenu();

um.setMenuId(menuIds[i]);

um.setUnitId(unitId);

list.add(um);

}

_map.put("list0", list);

_map.put("result0", "");

unitMenuMapper.addUnitPower(_map);

System.out.println("================================================_map = "+_map.toString());

result = (Integer)_map.get("result0");

System.out.println("================================================result = "+result);

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 < listData.size(); i++){

Object[] result = {listData.get(i).getUnitId(),listData.get(i).getMenuId()};

structs[i] = new STRUCT(structdesc, con, result);

}

array = new ARRAY(desc, con, structs);

}else{

array = new ARRAY(desc, con, structs);

}

return array;

}

Flask接口签名sign原理与实例代码浅析

389 2023-06-03

Mybatis传list参数调用oracle存储过程的解决方法

Flask接口签名sign原理与实例代码浅析

vue项目接口域名动态的获取方法

zookeeper python接口实例详解

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！