MyBatis批量插入數(shù)據(jù)過程解析

在程序中封裝了一個(gè)List集合對(duì)象，然后需要把該集合中的實(shí)體插入到數(shù)據(jù)庫(kù)中，由于項(xiàng)目使用了Spring+MyBatis的配置，所以打算使用MyBatis批量插入，由于之前沒用過批量插入，在網(wǎng)上找了一些資料后最終實(shí)現(xiàn)了，把詳細(xì)過程貼出來。

創(chuàng)新互聯(lián)建站服務(wù)項(xiàng)目包括鶴山網(wǎng)站建設(shè)、鶴山網(wǎng)站制作、鶴山網(wǎng)頁制作以及鶴山網(wǎng)絡(luò)營(yíng)銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，鶴山網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到鶴山省份的部分城市，未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

實(shí)體類TrainRecord結(jié)構(gòu)如下：

public class TrainRecord implements Serializable { 
   private static final long serialVersionUID = -1206960462117924923L;  
  private long id;  
  private long activityId; 
  private long empId; 
  private int flag;  
  private String addTime;      
  //setter and getter   
}

對(duì)應(yīng)的mapper.xml中定義如下：

<resultMap type="TrainRecord" id="trainRecordResultMap"> 
  <id column="id" property="id" jdbcType="BIGINT" /> 
  <result column="add_time" property="addTime" jdbcType="VARCHAR" /> 
  <result column="emp_id" property="empId" jdbcType="BIGINT" /> 
  <result column="activity_id" property="activityId" jdbcType="BIGINT" /> 
  <result column="flag" property="status" jdbcType="VARCHAR" /> 
</resultMap>

mapper.xml中批量插入方法的定義如下：

<insert id="addTrainRecordBatch" useGeneratedKeys="true" parameterType="java.util.List"> 
  <selectKey resultType="long" keyProperty="id" order="AFTER"> 
    SELECT 
    LAST_INSERT_ID() 
  </selectKey> 
  insert into t_train_record (add_time,emp_id,activity_id,flag)  
  values 
  <foreach collection="list" item="item" index="index" separator="," > 
    (#{item.addTime},#{item.empId},#{item.activityId},#{item.flag}) 
  </foreach> 
</insert>

對(duì)于foreach標(biāo)簽的解釋參考了網(wǎng)上的資料，具體如下：

foreach的主要用在構(gòu)建in條件中，它可以在SQL語句中進(jìn)行迭代一個(gè)集合。

foreach元素的屬性主要有 item，index，collection，open，separator，close。item表示集合中每一個(gè)元素進(jìn)行迭代時(shí)的別名，index指定一個(gè)名字，用于表示在迭代過程中，每次迭代到的位置，open表示該語句以什么開始，separator表示在每次進(jìn)行迭代之間以什么符號(hào)作為分隔符，close表示以什么結(jié)束，在使用foreach的時(shí)候最關(guān)鍵的也是最容易出錯(cuò)的就是collection屬性，該屬性是必須指定的，但是在不同情況下，該屬性的值是不一樣的，主要有一下3種情況：

1.如果傳入的是單參數(shù)且參數(shù)類型是一個(gè)List的時(shí)候，collection屬性值為list

2.如果傳入的是單參數(shù)且參數(shù)類型是一個(gè)array數(shù)組的時(shí)候，collection的屬性值為array

3.如果傳入的參數(shù)是多個(gè)的時(shí)候，我們就需要把它們封裝成一個(gè)Map了，當(dāng)然單參數(shù)也可以封裝成map

關(guān)于foreach的具體例子在這里就先不舉，以后有機(jī)會(huì)可以把每一種情況都舉一個(gè)例子列出來。

MySQLBaseDAO：

public class MySqlBaseDAO extends SqlSessionDaoSupport { 
  /** 
   * insert:插入操作. <br/> 
   * 
   * @author chenzhou 
   * @param method 插入操作的方法名 
   * @param entity 查詢參數(shù)或?qū)嶓w類 
   * @return 返回影響的行數(shù) 
   * @since JDK 1.6 
   */ 
  public int insert(String method,Object entity){ 
    return this.getSqlSession().insert(method, entity); 
  }      
  //其余方法省略 
}

TrainRecord實(shí)體類對(duì)應(yīng)的TrainRecordDAO 定義如下：

public class TrainRecordDAO extends MySqlBaseDAO { 
  /** 
   * addTrainRecordBatch:批量插入培訓(xùn)記錄. <br/> 
   * 
   * @author chenzhou 
   * @param trainRecordList 培訓(xùn)記錄list集合 
   * @return 影響的行數(shù) 
   * @since JDK 1.6 
   */ 
  public int addTrainRecordBatch(List<TrainRecord> trainRecordList){ 
    return this.insert("addTrainRecordBatch", trainRecordList); 
  }    
  //省略其余的方法 
}

然后直接調(diào)用TrainRecordDAO 中的 addTrainRecordBatch方法就可以批量插入了。

特別說明的是在嘗試時(shí)碰到了一個(gè)讓人無語的錯(cuò)誤，折騰了我差不多1個(gè)小時(shí)才解決。就是我在定義mapper.xml中的插入方法時(shí)一般都會(huì)默認(rèn)用<![CDATA[ ]]>標(biāo)簽把sql語句括起來，如下所示：

<![CDATA[ 
  select * from t_train_record t where t.activity_id=#{activityId} 
]]>

這樣做的目的主要是因?yàn)樵?XML 元素中，"<" 和 "&" 是非法的。"<" 會(huì)產(chǎn)生錯(cuò)誤，因?yàn)榻馕銎鲿?huì)把該字符解釋為新元素的開始。"&" 也會(huì)產(chǎn)生錯(cuò)誤，因?yàn)榻馕銎鲿?huì)把該字符解釋為字符實(shí)體的開始。而sql語句或者腳本語句中可能會(huì)存在 "<" 或 "&" 字符。為了避免錯(cuò)誤，可以將sql語句定義為 CDATA。CDATA 部分中的所有內(nèi)容都會(huì)被解析器忽略。

當(dāng)時(shí)我在addTrainRecordBatch方法中也用了這種用法：

<![CDATA[ 
  insert into t_train_record (add_time,emp_id,activity_id,flag) 
  values 
  <foreach collection="list" item="item" index="index" separator="," > 
    (#{item.addTime},#{item.empId},#{item.activityId},#{item.flag}) 
  </foreach> 
]]>

結(jié)果程序在執(zhí)行時(shí)老是報(bào)錯(cuò): com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException，查看錯(cuò)誤信息就是傳入的參數(shù)都是null。糾結(jié)了很久，后面才發(fā)現(xiàn)原來是<![CDATA[ ]]>把xml中的<foreach>標(biāo)簽括起來后把標(biāo)簽直接當(dāng)成字符串處理了。后面把外面的<![CDATA[ ]]>去掉后就能正常執(zhí)行了。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。

分享名稱：MyBatis批量插入數(shù)據(jù)過程解析
文章來源：http://muchs.cn/article12/ghisdc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App設(shè)計(jì)、ChatGPT、移動(dòng)網(wǎng)站建設(shè)、用戶體驗(yàn)、品牌網(wǎng)站建設(shè)、微信公眾號(hào)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容