Mybatis批量插入Oracle數(shù)據(jù)的方法實例
基本環(huán)境
語言:Java 8 數(shù)據(jù)庫:Oracle ORM 框架:MyBatis 3.4.5
需求
批量插入數(shù)據(jù),數(shù)據(jù)需要有自增 id。每次插入有一個唯一的 sessionId 來標記這些記錄,插入完成之后返回這個 sessionId。
方案
循環(huán)插入單條記錄,偽代碼:
int sessionId = dao.querySessionId(); for (Record record : recordList) { dao.insertRecord(record, sessionId); } return sessionId;
上述解決方案很簡明易懂,但是循環(huán)中每次 insert 操作都會與 DB 交互一次,當數(shù)據(jù)量很大時,會花費很多時間在網(wǎng)絡傳輸上,導致性能問題。
改進
問題可以通過批量插入來改善。
帶自增 id 的批量插入
Oracle 中比較常見的批量插入模版是:
INSERT ALL INTO target_table (col1, col2, col3) VALUES ('id1_1', 'val1_2', 'val1_3') INTO target_table (col1, col2, col3) VALUES ('id2_1', 'val2_2', 'val2_3') ... Subquery;
但是每條記錄都需要有一個自增 id,Oracle 中一般用 Sequence 來實現(xiàn),于是比較容易想到的是用下面這種方式:
INSERT ALL INTO table (col1, col2, col3) VALUES (SEQUENCE.NEXTVAL, 'val1_2', 'val1_3') INTO table (col1, col2, col3) VALUES (SEQUENCE.NEXTVAL, 'val2_2', 'val2_3') ... SELECT 1 FROM DUAL;
不過遺憾的是,上述方案行不通,因為所有的 SEQUENCE.NEXTVAL 都會是同一個值,會產生主鍵沖突。
接著嘗試其他的方案。Oracle 支持從一個表里批量選取數(shù)據(jù)插入另一個表中:
INSERT INTO target_table (col1, col2, col3) SELECT col1, col2, col3 FROM source_table WHERE condition;
用上述方式,我們可以把被插入的數(shù)據(jù)用 UNION ALL
構造一個子表,也就是上面的 source_table 來實現(xiàn)批量插入。跟 INSERT ALL INTO
相比的好處是,可以使用 Sequence 的自增值:
INSERT INTO target_table (col1, col2, col3) SELECT SEQUENCE.NEXTVAL, col2, col3 FROM ( SELECT 'val1_2' col2, 'val1_3' col3 FROM dual UNION ALL SELECT 'val2_2' col2, 'val2_3' col3 FROM dual UNION ALL ... );
用 MyBatis 的 dynamic sql 來實現(xiàn)大致如下:
<insert id="sampleInsert" parameterType="java.util.List"> INSERT INTO target_table (col1, col2, col3) SELECT SEQUENCE.NEXTVAL,, col2, col3 FROM <foreach collection="list" item="item" index="index" open="(" close=")" separator=" UNION ALL "> SELECT #{item.val2} col2, #{item.val2} col3 FROM dual </foreach> </insert>
插入完成之后返回 sessionId
在 Mybatis 中,返回某個 property 可以用 SelectKey。SelectKey 是 Insert 的子標簽,實現(xiàn)原理是在執(zhí)行插入語句之前先做一次 SelectKey 的子查詢,此處,可以將子查詢的結果賦值到查詢的參數(shù)當中,例如
public class Foo { private int id; private String col2; private String col3; } public interface FooDao { void sampleInsert(Foo foo); }
<insert id="sampleInsert" useGeneratedKeys="true" parameterType="Foo" keyProperty="id"> <selectKey keyProperty="id" order="BEFORE" resultType="int"> SELECT SESSION_SEQUENCE.NEXTVAL FROM DUAL </selectKey> INSERT INTO target_table (col1, col2, col3) VALUES (#{id}, #{col2}, #{col3}) </insert>
當插入結束之后,參數(shù) foo.id 就會是 SESSION_SEQUENCE 的自增值(注意在 Dao 中不能用 @Param() 標注參數(shù))。
然而這種方式只支持單條記錄的插入,Oracle 中批量插入的情況就無法完成賦值了。所以此處只能分成兩步來做:
- 獲取
sessionId(SESSION_SEQUENCE.NEXTVAL)
- 批量插入帶 sessionId 的記錄
或者
- 用 SelectKey 選出
sessionId(SESSION_SEQUENCE.NEXTVAL)
并批量插入記錄 - 獲取
sessionId(SESSION_SEQUENCE.CURRVAL)
注意上述第二種方式,需要保證兩個方法在同一個 Transaction 里面,否則 Sequence 的值會不一致。
注意事項
oracle中用insert into xxx values (xxx,xxx),(xxx,xxx) 這種語法應該通不過的,會報錯,ORA-00933: SQL 命令未正確結束,要用這種
insert into t_test (id, prop_name) select 1,'aaa' from dual union all select 2,'bbb' from dual union all select 3,'ccc' from dual;
總結
本文簡單總結了在 MyBatis 中往 Oracle 批量插入數(shù)據(jù)的方法,作一個快速筆記。
到此這篇關于Mybatis批量插入Oracle數(shù)據(jù)的文章就介紹到這了,更多相關Mybatis批量插入Oracle內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
Reference
相關文章
Java SSM整合開發(fā)統(tǒng)一結果封裝詳解
這篇文章主要介紹了Java SSM整合開發(fā)實現(xiàn)統(tǒng)一結果封裝,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2022-08-08Java系統(tǒng)變量參數(shù)獲取設置System.getProperties()的方法
這篇文章主要介紹了Java系統(tǒng)變量參數(shù)System.getProperties()獲取設置方法,文末給大家提到了Systm.getenv()與System.getProperties()區(qū)別,需要的朋友可以參考下2022-01-01logback TimeBasedRollingPolicy按天生成日志源碼解析
這篇文章主要為大家介紹了logback TimeBasedRollingPolicy按天生成日志源碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-11-11