溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶(hù)服務(wù)條款》

Mybatis傳list參數(shù)調(diào)用oracle存儲(chǔ)過(guò)程的解決方法

發(fā)布時(shí)間:2020-10-26 01:31:32 來(lái)源:腳本之家 閱讀:226 作者:球球愛(ài) 欄目:編程語(yǔ)言

怎么利用MyBatis傳List類(lèi)型參數(shù)到數(shù)據(jù)庫(kù)存儲(chǔ)過(guò)程中實(shí)現(xiàn)批量插入數(shù)據(jù)?

MyBatis中參數(shù)是List類(lèi)型時(shí)怎么處理?大家都知道MyBatis批處理大量數(shù)據(jù)是很難做到事務(wù)回滾的(事務(wù)由Spring管理),都將邏輯寫(xiě)在存儲(chǔ)中又是及其頭疼的一件事(參數(shù)長(zhǎng)度也有限制),那么我想的是將參數(shù)在后臺(tái)封裝為單個(gè)或多個(gè)list集合,直接通過(guò)MyBatis將此參數(shù)傳到數(shù)據(jù)庫(kù)存儲(chǔ)過(guò)程中,一來(lái)擺脫了MyBatis批量插入數(shù)據(jù)的諸多限制(例如:不能實(shí)時(shí)返回主鍵、foreach標(biāo)簽循環(huán)集合長(zhǎng)度有限制),二來(lái)就是在存儲(chǔ)中靈活的控制事務(wù),但是這又會(huì)涉及兩個(gè)問(wèn)題,MyBatis的xml文件中該怎么封裝,利用BaseTypeHandler嗎?

對(duì)于這個(gè)問(wèn)題,經(jīng)過(guò)一天的研究終于算是跑通了,說(shuō)一下解決辦法:

1.建立數(shù)據(jù)庫(kù)表,大家應(yīng)該都有自己的庫(kù)表了,所以這一步基本上就可以跳過(guò)了。我之所以在這里把庫(kù)表貼出來(lái)是為了讓大家對(duì)應(yīng)里面的參數(shù)。

數(shù)據(jù)庫(kù)表:

create table ZD_UNIT_MENU 
( 
 unit_id VARCHAR2(32), 
 menu_id VARCHAR2(32) 
) 

2.在數(shù)據(jù)庫(kù)中建立相應(yīng)的java對(duì)象(Oracle中的類(lèi)型)和數(shù)組:

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.存儲(chǔ)過(guò)程:

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;  
 --返回結(jié)果,執(zhí)行成功的話返回1 
 result0 := 1; 
 --捕捉異常,回滾操作 
 EXCEPTION 
   WHEN OTHERS THEN 
     result0 := -1;--執(zhí)行失敗的話返回-1 
   ROLLBACK; 
end save_unit_power; 

4.再看看mybatis的配置吧:

<parameterMap type="java.util.Map" id="_map"> 
    <parameter property="list0" jdbcType="ARRAY" 
      javaType="java.util.List" mode="IN" typeHandler="com.zd.util.ListHandler"/> 
    <parameter property="result0" jdbcType="DECIMAL" 
      javaType="java.lang.Integer" mode="OUT" /> 
 </parameterMap> 
 <select id="addUnitPower" statementType="CALLABLE" parameterMap="_map"> 
    <![CDATA[ 
    CALL save_unit_power(?,?) 
    ]]> 
 </select> 

5.看看我是如何調(diào)用的?我直接貼我的server代碼了,dao層的就沒(méi)必要了:        

List<UnitMenu> list = new ArrayList<UnitMenu>(); 
  Map<String, Object> _map = new HashMap<String, Object>(); 
  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.非常關(guān)鍵的一點(diǎn)兒,細(xì)心的人應(yīng)該會(huì)注意到,在mapper.xml配置中,有typeHandler配置,里面配置的實(shí)際上是我寫(xiě)的一個(gè)類(lèi),這個(gè)類(lèi)的作用就是講java中的list轉(zhuǎn)換成數(shù)據(jù)庫(kù)中我們建立的對(duì)象和數(shù)組,看代碼吧:

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<UnitMenu> list = (ArrayList<UnitMenu>) o; 
        conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.1.88:1521:orcl", "tctscm", "tctscm"); 
        //這里必須得用大寫(xiě),而且必須要引入一個(gè)包,如果不引入這個(gè)包的話字符串無(wú)法正常轉(zhuǎn)換,包是: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<UnitMenu> 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參數(shù)調(diào)用oracle存儲(chǔ)過(guò)程的解決方法,希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)億速云網(wǎng)站的支持!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI