首頁 > Java > java教程 > 基於Java怎麼用Mybatis實作oracle批量插入及分頁查詢

基於Java怎麼用Mybatis實作oracle批量插入及分頁查詢

WBOY
發布: 2023-05-03 23:52:05
轉載
1946 人瀏覽過

1、單一資料insert

<!--简单SQL-->
insert into userinfo (USERID, USERNAME, AGE) values(1001,&#39;小明&#39;,20);

<!--Mybatis写法1,有序列,主键是自增ID,主键是序列-->
<insert id="insert" parameterType="com.zznode.modules.bean.UserInfo">
    <selectKey resultType="java.lang.Integer" order="BEFORE" keyProperty="userid">
      SELECT userinfo_userid_seq.nextval as userid from dual
    </selectKey>
    insert into EPG_ALARM_INFO (USERID, USERNAME, AGE)
    values (#{userid}, #{username}, #{age})
</insert>

<!--Mybatis写法2,无序列,主键是uuid,字符串-->
<insert id="insert" parameterType="com.zznode.modules.bean.UserInfo">
    insert into EPG_ALARM_INFO (USERID, USERNAME, AGE, TIME)
    values (#{userid}, #{username}, #{age}, sysdate)
</insert>
登入後複製

2、批次資料批次insert

insert all into 的方式回傳值由最後的select 決定:

<!--简单SQL, 方法1-->
INSERT ALL 
INTO userinfo (USERID, USERNAME, AGE) values(1001,&#39;小明&#39;,20)
INTO userinfo (USERID, USERNAME, AGE) values(1002,&#39;小红&#39;,18)
INTO userinfo (USERID, USERNAME, AGE) values(1003,&#39;张三&#39;,23)
select 3 from dual;
<!--简单SQL, 方法2-->
begin
    insert into userinfo (USERID, USERNAME, AGE) values(1001,&#39;小明&#39;,20);
    insert into userinfo (USERID, USERNAME, AGE) values(1001,&#39;小红&#39;,18);
    insert into userinfo (USERID, USERNAME, AGE) values(1001,&#39;张三&#39;,23);
end;
<!--简单SQL, 方法3-->
insert into userinfo (USERID, USERNAME, AGE) 
select 1001, &#39;小明&#39;, 20 from dual union all
select 1002, &#39;小红&#39;, 18 from dual union all
select 1003, &#39;张三&#39;, 23 from dual
登入後複製
<!--Mybatis写法1,无序列-->
<insert id="insertBatch" parameterType="java.util.List">
    INSERT ALL 
    <foreach collection="list" index="index" item="item">
        INTO userinfo (USERID, USERNAME, AGE)
        VALUES (#{item.userid}, #{item.username}, #{item.age})
    </foreach>
    select list.size from dual
</insert>
<!--Mybatis写法2,无序列-->
<insert id="insertBatch">
    insert into EPG_ALARM_INFO (USERID, USERNAME, AGE)
    <foreach collection="list" item="item" index="index" separator="union all">
        <!-- <foreach collection="list" item="item" index="index" separator="union all" open="(" close=")"> -->
        <!-- (select #{item.userid}, #{item.username}, #{item.age} from dual) -->
        
        <!-- 上面带括号,下面不带括号,都可以,少量数据不带括号效率高 -->
        select #{item.userid}, #{item.username}, #{item.age} from dual
    </foreach>
</insert>    
<!--Mybatis写法3,有序列-->
<insert id="insertBatch">
    insert into EPG_ALARM_INFO (USERID, USERNAME, AGE)
    SELECT userinfo_userid_seq.nextval, m.* FROM (
    <foreach collection="list" item="item" index="index" separator="union all">
        select #{item.username}, #{item.age} from dual
    </foreach>
    ) m
</insert>
登入後複製

3、建立序列

  • minvalue n (/nominvalue):最小值為n

  • maxvalue n (/nomaxvalue):最大值為n

  • start with n:從n開始計數

  • #increment by n:每次增加n

  • cache n (/nocache):緩存n個sequence值/ 不緩存,如果緩存,則會有跳號的危險

  • noorder (/order):不保證序號依序產生請求

  • cycle n (/nocycle):如果到達最大值n後,再從start with n開始

  • currval:序列的目前值,新序列必須使用一次nextval 才能取得到值,否則會報錯

  • nextval:表示序列的下一個值。新序列首次使用時取得的是此序列的初始值,從第二次使用時開始依照設定的步進遞增

刪除序列語法: drop sequence seq_表名

<!--
create sequence 序列名     
       increment by 1 	--每次增加几个,我这里是每次增加1
       start with 1   	--从1开始计数
       nomaxvalue      	--不设置最大值
       nocycle         	--一直累加,不循环
       nocache;        	--不建缓冲区
在插入语句中调用:序列名.nextval  生成自增主键。
-->
<!--创建序列-->
create sequence SEQ_USERINFO
minvalue 1
maxvalue 9999999999
start with 1
increment by 1
nocache;

<!--删除序列-->
drop sequence SEQ_USERINFO
登入後複製

4、oracle分頁查詢

#前端與後端交互,分頁查詢

service業務實作:

public List<TBadUserW> queryPageBadUserInfo(TbadUserQuery queryModel) {
    log.info("分页查询请求参数,{}", JSON.toJSONString(queryModel));
    int pageNum = queryModel.getPageNum(); // 开始页
    int pageSize = queryModel.getPageSize(); // 每页数量
    queryModel.setStart((pageNum - 1) * pageSize); // 开始行数 (+1后)
    queryModel.setEnd(pageNum * pageSize); // 结束行数
    List<TBadUserW> beans = badUserWDao.queryPageBadUserInfo(queryModel);
    log.info("最终查询数量:", beans.size());
    return beans;
}
登入後複製

mapper.xml檔:

<select id="queryPageInfo" parameterType="com.zznode.test.bean.TbadUserQuery"
        resultMap="BaseResultMap" >
    SELECT tt.*	FROM
    (
    	<!--前端分页需要 total总记录-->
        SELECT t.*, ROWNUM rown, COUNT (*) OVER () total FROM
        (
            select <include refid="Base_Column_List"/> from T_BAD_USER_W
            <where>
                <if test="city != null and city !=&#39;&#39;">
                    and city = #{city}
                </if>
                <if test="county != null and county != &#39;&#39;">
                    and county = #{county}
                </if>
                <if test="startTime != null and startTime !=&#39;&#39;">
                    and loadtime >= to_date(#{startTime} , &#39;yyyy-mm-dd hh34:mi:ss&#39;)
                </if>
                <if test="endTime != null and endTime !=&#39;&#39;">
                    and loadtime <![CDATA[<=]]> to_date(#{endTime} , &#39;yyyy-mm-dd hh34:mi:ss&#39;)
                </if>
            </where>
        )t
    )tt
    where tt.rown > #{start} and tt.rown <![CDATA[<=]]> #{end}
</select>
登入後複製

後端海量資料匯出,批次查詢

service業務實作:

public List<TBadUserW> queryPageBadUserInfo(TbadUserQuery queryModel) {
    log.info("分页查询请求参数,{}", JSON.toJSONString(queryModel));
    List<TBadUserW> result = new ArrayList<>();
    int pageNum = queryModel.getPageNum(); // 开始页
    int pageSize = queryModel.getPageSize(); // 每页数量(可以每页设置为200/500/1000),每次查询的条数
    boolean searchAll = true;
    while (searchAll){
        queryModel.setStart((pageNum - 1) * pageSize); // 开始行数 (+1后)
        queryModel.setEnd(pageNum * pageSize); // 结束行数
        List<TBadUserW> beans = badUserWDao.queryPageBadUserInfo(queryModel);
        if (null == beans || beans.size() < pageSize) {
            searchAll = false;
        }
        if (CollectionUtils.isNotEmpty(beans)) {
            result.addAll(beans);
        }
        pageNum++;
    }
    log.info("最终查询数量:", result.size());
    return result;
}
登入後複製

mapper.xml檔案編寫

<!--这种写法是比较高效的分批查询方法,分批不需要查询total总量,不支持total-->
<select id="queryPageInfo" parameterType="com.zznode.test.bean.TbadUserQuery"
        resultMap="BaseResultMap" >
    SELECT tt.*	FROM
    (
        SELECT t.*, ROWNUM rown FROM
        (
            select <include refid="Base_Column_List"/> from T_BAD_USER_W
            <where>
                <if test="city != null and city !=&#39;&#39;">
                    and city = #{city}
                </if>
                <if test="county != null and county != &#39;&#39;">
                    and county = #{county}
                </if>
                <if test="startTime != null and startTime !=&#39;&#39;">
                    and loadtime >= to_date(#{startTime} , &#39;yyyy-mm-dd hh34:mi:ss&#39;)
                </if>
                <if test="endTime != null and endTime !=&#39;&#39;">
                    and loadtime <![CDATA[<=]]> to_date(#{endTime} , &#39;yyyy-mm-dd hh34:mi:ss&#39;)
                </if>
            </where>
        )t where ROWNUM <![CDATA[<=]]> #{end}
    )tt
    where tt.rown > #{start}
</select>
登入後複製

以上是基於Java怎麼用Mybatis實作oracle批量插入及分頁查詢的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:yisu.com
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板