怎么利用MyBatis傳List類型參數(shù)到數(shù)據(jù)庫存儲過程中實現(xiàn)批量插入數(shù)據(jù)?
成都創(chuàng)新互聯(lián)公司主營翼城網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,成都app開發(fā),翼城h5微信平臺小程序開發(fā)搭建,翼城網(wǎng)站營銷推廣歡迎翼城等地區(qū)企業(yè)咨詢
MyBatis中參數(shù)是List類型時怎么處理?大家都知道MyBatis批處理大量數(shù)據(jù)是很難做到事務(wù)回滾的(事務(wù)由Spring管理),都將邏輯寫在存儲中又是及其頭疼的一件事(參數(shù)長度也有限制),那么我想的是將參數(shù)在后臺封裝為單個或多個list集合,直接通過MyBatis將此參數(shù)傳到數(shù)據(jù)庫存儲過程中,一來擺脫了MyBatis批量插入數(shù)據(jù)的諸多限制(例如:不能實時返回主鍵、foreach標(biāo)簽循環(huán)集合長度有限制),二來就是在存儲中靈活的控制事務(wù),但是這又會涉及兩個問題,MyBatis的xml文件中該怎么封裝,利用BaseTypeHandler嗎?
對于這個問題,經(jīng)過一天的研究終于算是跑通了,說一下解決辦法:
1.建立數(shù)據(jù)庫表,大家應(yīng)該都有自己的庫表了,所以這一步基本上就可以跳過了。我之所以在這里把庫表貼出來是為了讓大家對應(yīng)里面的參數(shù)。
數(shù)據(jù)庫表:
create table ZD_UNIT_MENU ( unit_id VARCHAR2(32), menu_id VARCHAR2(32) )
2.在數(shù)據(jù)庫中建立相應(yīng)的java對象(Oracle中的類型)和數(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.存儲過程:
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層的就沒必要了:
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)鍵的一點兒,細(xì)心的人應(yīng)該會注意到,在mapper.xml配置中,有typeHandler配置,里面配置的實際上是我寫的一個類,這個類的作用就是講java中的list轉(zhuǎn)換成數(shù)據(jù)庫中我們建立的對象和數(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"); //這里必須得用大寫,而且必須要引入一個包,如果不引入這個包的話字符串無法正常轉(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存儲過程的解決方法,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復(fù)大家的。在此也非常感謝大家對創(chuàng)新互聯(lián)網(wǎng)站的支持!
網(wǎng)站標(biāo)題:Mybatis傳list參數(shù)調(diào)用oracle存儲過程的解決方法
鏈接地址:http://bm7419.com/article6/gigpog.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站營銷、商城網(wǎng)站、定制網(wǎng)站、品牌網(wǎng)站設(shè)計、動態(tài)網(wǎng)站、小程序開發(fā)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)