MyBatis中批量插入
方法一:
<insert id="insertbatch" parameterType="java.util.List">
<selectKey keyProperty="fetchTime" order="BEFORE"
resultType="java.lang.String">
SELECT CURRENT_TIMESTAMP()
</selectKey>
insert into kangaiduoyaodian ( depart1, depart2, product_name,
generic_name, img, product_specification, unit,
approval_certificate, manufacturer, marketPrice, vipPrice,
website, fetch_time, productdesc ) values
<foreach collection="list" item="item" index="index"
separator=",">
( #{item.depart1}, #{item.depart2}, #{item.productName},
#{item.genericName}, #{item.img},
#{item.productSpecification}, #{item.unit},
#{item.approvalCertificate}, #{item.manufacturer},
#{item.marketprice}, #{item.vipprice}, #{item.website},
#{fetchTime}, #{item.productdesc} )
</foreach>
</insert>
方法二:
<insert id="batchInsertB2B" parameterType="ArrayList"> insert into xxxxtable(hkgs,hkgsjsda,office,asdf,ddd,ffff,supfullName,classtype,agent_type,remark) <foreach collection="list" item="item" index="index" separator="union all"> select #{item.hkgs,jdbcType=VARCHAR}, #{item.hkgsjsda,jdbcType=VARCHAR}, #{item.office,jdbcType=VARCHAR}, #{item.asdf,jdbcType=VARCHAR}, #{item.ddd,jdbcType=VARCHAR}, #{item.ffff,jdbcType=VARCHAR}, #{item.supfullName,jdbcType=VARCHAR},0,0, #{item.remark,jdbcType=VARCHAR} from dual </foreach> </insert>
可以考慮用union all來(lái)實(shí)現(xiàn)批量插入。 例如: insert into XX_TABLE(XX,XX,XX)select 'xx','xx','xx' union all select 'xx','xx','xx' union all select 'xx','xx','xx' ... 先拼裝好語(yǔ)句再動(dòng)態(tài)傳入insert into XX_TABLE(XX,XX,XX)后面部分
MyBatis中批量刪除
<!-- 通過(guò)主鍵集合批量刪除記錄 -->
<delete id="batchRemoveUserByPks" parameterType="java.util.List">
DELETE FROM LD_USER WHERE ID in
<foreach item="item" index="index" collection="list" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
MyBatis中in子句
mybatis in 參數(shù) 使用方法
1.只有一個(gè)參數(shù)
參數(shù)的類型要聲明為L(zhǎng)ist或Array
Sql配置如下:
<select id="selectProduct" resultMap="Map">
SELECT *
FROM PRODUCT
WHERE PRODUCTNO IN
<foreach item="productNo" index="index" collection="參數(shù)的類型List或array">
#{productNo}
</foreach>
</select>
2.多個(gè)參數(shù)
首先要將多個(gè)參數(shù)寫(xiě)入同一個(gè)map,將map作為一個(gè)參數(shù)傳入mapper
Sql配置如下:
<select id="selectProduct" resultMap="Map">
SELECT *
FROM PRODUCT
WHERE PRODUCTNO IN
<foreach item="productNo" index="index" collection="map中集合參數(shù)的名稱">
#{productNo}
</foreach>
</select>
MyBatis批量修改
<update id="updateOrders" parameterType="java.util.List"> update orders set state = '0' where no in <foreach collection="list" item="nos" open="(" separator="," close=")"> #{nos} </foreach> </update>
MyBatis的關(guān)于批量數(shù)據(jù)操作的體會(huì)
- MyBatis的前身就是著名的Ibatis,不知何故脫離了Apache改名為MyBatis。
MyBatis所說(shuō)是輕量級(jí)的ORM框架,在網(wǎng)上看過(guò)一個(gè)測(cè)試報(bào)告,感覺(jué)相比于Hibernate來(lái)說(shuō),優(yōu)勢(shì)并不明顯。
下面說(shuō)一下比較有趣的現(xiàn)象,根據(jù)MyBatis的官方文檔,在獲得sqlSession時(shí),它有為批量更新而專門(mén)準(zhǔn)備的:
session = sessionFactory.openSession();//用于普通update session = sessionFactory.openSession(ExecutorType.BATCH, true);//用于批量update
一般來(lái)說(shuō),對(duì)MYSQL數(shù)據(jù)庫(kù)批量操作時(shí)速度取決于,是為每一個(gè)處理分別建立一個(gè)連接,還是為這一批處理一共建立一個(gè)連接。按MyBatis的手冊(cè)說(shuō)明,選擇ExecutorType.BATCH意味著,獲得的sqlSession會(huì)批量執(zhí)行所有更新語(yǔ)句。不過(guò)我測(cè)試了一下,批量插入1000條數(shù)據(jù),發(fā)覺(jué)ExecutorType.BATCH方式的效率居然比普通的方式差很多。我測(cè)試用的Mapper中的insert配置如下,再用for循環(huán)插入1000條記錄:
1 <insert id="insert" parameterType="sdc.mybatis.test.Student"> 2 <!-- WARNING - @mbggenerated This element is automatically generated by 3 MyBatis Generator, do not modify. This element was generated on Mon May 09 4 11:09:37 CST 2011. --> 5 insert into student (id, name, sex, 6 address, telephone, t_id 7 ) 8 values (#{id,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR}, 9 #{sex,jdbcType=VARCHAR}, 10 #{address,jdbcType=VARCHAR}, #{telephone,jdbcType=VARCHAR}, #{tId,jdbcType=INTEGER} 11 ) 12 </insert>
- 我不清楚原因在哪里, 就配置了MyBatis的log4j,想查看下日志。下載了log4j.jar和commons-logging.jar并配置到項(xiàng)目的類路徑,然后在代碼路徑下新建文件log4j.properties,內(nèi)容如下:
log4j.rootLogger=DEBUG, stdout
# SqlMap logging configuration... log4j.logger.com.ibatis=DEBUG log4j.logger.com.ibatis.common.jdbc.SimpleDataSource=DEBUG log4j.logger.com.ibatis.sqlmap.engine.cache.CacheModel=DEBUG log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientImpl=DEBUG log4j.logger.com.ibatis.sqlmap.engine.builder.xml.SqlMapParser=DEBUG log4j.logger.com.ibatis.common.util.StopWatch=DEBUG log4j.logger.java.sql.Connection=DEBUG log4j.logger.java.sql.Statement=DEBUG log4j.logger.java.sql.PreparedStatement=DEBUG log4j.logger.java.sql.ResultSet=DEBUG
# Console output... log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n
然后再次測(cè)試普通的sqlSession,發(fā)現(xiàn)日志內(nèi)容中雖然插入了1000條數(shù)據(jù),但只新建了一次連接,最后又關(guān)閉了該連接(日志如下)。也就是說(shuō)MyBatis中的普通sqlSession好像已經(jīng)對(duì)批量插入默認(rèn)是一次連接中完成,那么還提供ExecutorType.BATCH方式干什么,況且該方式好像效率也不行,或者是我使用ExecutorType.BATCH方式不對(duì)??
DEBUG [main] - Created connection 3502256. DEBUG [main] - ooo Connection Opened DEBUG [main] - ==> Executing: insert into student ( name, sex, address, telephone, t_id ) values ( ?, ?, ?, ?, ? ) DEBUG [main] - ==> Parameters: 新人0(String), male(String), addr0(String), dd(String),3(Integer) DEBUG [main] - ==> Executing: insert into student ( name, sex, address, telephone, t_id ) values ( ?, ?, ?, ?, ? ) DEBUG [main] - ==> Parameters: 新人1(String), male(String), ............... ............... DEBUG [main] - xxx Connection Closed DEBUG [main] - Returned connection 3502256 to pool.
- 最后一點(diǎn)是關(guān)于數(shù)據(jù)庫(kù)批量插入時(shí)sql語(yǔ)句級(jí)的優(yōu)化,我特意測(cè)試了兩種方式,在StudentMapper中配置了兩種insert模式。第一種對(duì)應(yīng)insert value1,insert value2,,,,;第二種對(duì)應(yīng)insert values (value1, value2,....)。發(fā)現(xiàn)后者果然比前者快很多啊。下面是兩種insert模式,及測(cè)試結(jié)果對(duì)應(yīng)圖:
<!-- 在外部for循環(huán)調(diào)用一千次 --> <insert id="insert" parameterType="sdc.mybatis.test.Student"> insert into student (id, name, sex, address, telephone, t_id ) values (#{id,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR}, #{sex,jdbcType=VARCHAR}, #{address,jdbcType=VARCHAR}, #{telephone,jdbcType=VARCHAR}, #{tId,jdbcType=INTEGER} ) </insert> <!-- 批量 ,傳入一個(gè)長(zhǎng)度為1000的list --> <insert id="insertBatch"> insert into student ( <include refid="Base_Column_List"/> ) values <foreach collection="list" item="item" index="index" separator=","> (null,#{item.name},#{item.sex},#{item.address},#{item.telephone},#{item.tId}) </foreach> </insert>
附錄:
- MyBatis配置文件的DTD文件(與Ibatis3不同):http:///dtd/
- MyBatis的中文手冊(cè):http://mybatis./files/MyBatis%203%20User%20Guide%20Simplified%20Chinese.pdf
|