一瞧栗、在需要使用流式查詢的mapper文件中，定義流式查詢方法

package com.unionpay.dao.db2;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.unionpay.entity.TblMallOrder;
import org.apache.ibatis.annotations.*;
import org.apache.ibatis.mapping.ResultSetType;
import org.apache.ibatis.session.ResultHandler;

/**
 * (TblMallOrder)表數(shù)據(jù)庫訪問層
 *
 * @author liudong
 * @since 2020-09-15 17:07:13
 */
@Mapper
public interface TblMallOrderDao extends BaseMapper<TblMallOrder> {
    @Select("${sql}")
    @Options(resultSetType = ResultSetType.FORWARD_ONLY, fetchSize = 1000)
    @ResultType(TblMallOrder.class)
    void dynamicSelectLargeData1(@Param("sql") String sql, ResultHandler<TblMallOrder> handler);

    @Select("${sql}")
    @Options(resultSetType = ResultSetType.FORWARD_ONLY, fetchSize = 1000)
    @ResultType(Map.class)
    void dynamicSelectLargeData2(@Param("sql") String sql, ResultHandler<Map> handler);
}

二海铆、使用示例

@RestController
public class TestSearchLargeData {
    // 這是每批處理的大小
    private final static int BATCH_SIZE = 1000;
    private int size;
    // 存儲(chǔ)每批數(shù)據(jù)的臨時(shí)容器
    private List<TblMallOrder> mallOrders;

    @Autowired
    private TblMallOrderDao tblMallOrderDao;

    @GetMapping("/getLargeData1")
    public void getLargeData1() {
        String sql = "select * from t_mall_order";
        tblMallOrderDao.dynamicSelectLargeData1(sql, new ResultHandler<TblMallOrder>() {
            @Override
            public void handleResult(ResultContext<? extends TblMallOrder> resultContext) {
                TblMallOrder tblMallOrder = resultContext.getResultObject();
                System.out.println(tblMallOrder);
            }
        });
    }

    @GetMapping("/getLargeData2")
    public void getLargeData2() {
        String sql = "select * from t_mall_order";
        tblMallOrderDao.dynamicSelectLargeData1(sql, new ResultHandler<TblMallOrder>() {
            @Override
            public void handleResult(ResultContext<? extends TblMallOrder> resultContext) {
                TblMallOrder tblMallOrder = resultContext.getResultObject();
                System.out.println(tblMallOrder);
                // 你可以看自己的項(xiàng)目需要分批進(jìn)行處理或者單個(gè)處理迹恐，這里以分批處理為例
                mallOrders.add(tblMallOrder);
                size++;
                if (size == BATCH_SIZE) {
                    handle();
                }
            }
        });
        //用來完成最后一批數(shù)據(jù)處理
        handle();
    }
    /**
     * 數(shù)據(jù)處理
     */
    private void handle(){
        try{
            // 在這里可以對(duì)你獲取到的批量結(jié)果數(shù)據(jù)進(jìn)行需要的業(yè)務(wù)處理
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            // 處理完每批數(shù)據(jù)后后將臨時(shí)清空
            size = 0;
            mallOrders.clear();
        }
    }
}

三、總結(jié)

1. Oracle和DB2卧斟，當(dāng)我們執(zhí)行一個(gè)SQL查詢語句的時(shí)候殴边，需要在客戶端和服務(wù)器端都打開一個(gè)游標(biāo)，并且分別申請(qǐng)一塊內(nèi)存空間珍语，作為存放查詢的數(shù)據(jù)的一個(gè)緩沖區(qū)锤岸。這塊內(nèi)存區(qū)，存放多少條數(shù)據(jù)就由fetchsize來決定板乙，同時(shí)每次網(wǎng)絡(luò)包會(huì)傳送fetchsize條記錄到客戶端是偷。應(yīng)該很容易理解，如果fetchsize設(shè)置為20募逞，當(dāng)我們從服務(wù)器端查詢數(shù)據(jù)往客戶端傳送時(shí)蛋铆，每次可以傳送20條數(shù)據(jù)，但是兩端分別需要20條數(shù)據(jù)的內(nèi)存空閑來保存這些數(shù)據(jù)凡辱。fetchsize決定了每批次可以傳輸?shù)挠涗洍l數(shù)戒职，但同時(shí)，也決定了內(nèi)存的大小透乾。這塊內(nèi)存洪燥，在oracle服務(wù)器端是動(dòng)態(tài)分配的。而在客戶端乳乌，PS對(duì)象會(huì)存在一個(gè)緩沖中（LRU鏈表）捧韵，也就是說，這塊內(nèi)存是事先配好的汉操，應(yīng)用端內(nèi)存的分配在conn.prepareStatement(sql)或都conn.CreateStatement(sql)的時(shí)候完成再来。
2. MySQL本身并沒有FetchSize方法, 它是使用CS阻塞的方式，通過網(wǎng)絡(luò)流控制服務(wù)端磷瘤，MySQL在執(zhí)行ResultSet.next()方法時(shí)芒篷，會(huì)通過數(shù)據(jù)庫連接一條一條的返回。MySQL按照自己的節(jié)奏不斷的把buffer寫回網(wǎng)絡(luò)中采缚。flush buffer的過程是阻塞式的针炉，也就是說如果網(wǎng)絡(luò)中發(fā)生了擁塞，send buffer被填滿扳抽，會(huì)導(dǎo)致buffer一直flush不出去篡帕，那MySQL的處理線程會(huì)阻塞殖侵，從而避免數(shù)據(jù)把客戶端內(nèi)存撐爆。這樣帶來的問題：如果使用了流式查詢镰烧，一個(gè)MySQL數(shù)據(jù)庫連接同一時(shí)間只能為一個(gè)ResultSet對(duì)象服務(wù)拢军，并且如果該ResultSet對(duì)象沒有關(guān)閉，勢(shì)必會(huì)影響其他查詢對(duì)數(shù)據(jù)庫連接的使用怔鳖！此為大坑茉唉，所以sharding-sphere費(fèi)勁心思要提供兩種數(shù)據(jù)庫連接模式，如果應(yīng)用對(duì)數(shù)據(jù)庫連接的消耗要求嚴(yán)苛结执，那么流式查詢就不再適合赌渣。