public interface Cursor<T> extends Closeable, Iterable<T> {
 //判斷cursor是否正處于打開狀態(tài)
 //當(dāng)返回true，則表示cursor已經(jīng)開始從數(shù)據(jù)庫里刷新數(shù)據(jù)了；
  boolean isOpen();
  //判斷查詢結(jié)果是否全部讀取完；
  //當(dāng)返回true,則表示查詢sql匹配的全部數(shù)據(jù)都消費(fèi)完了；
  boolean isConsumed();
   //查詢已讀取數(shù)據(jù)在全部數(shù)據(jù)里的索引位置；
   //第一條數(shù)據(jù)的索引位置為0；當(dāng)返回索引位置為-1時(shí)，則表示已經(jīng)沒有數(shù)據(jù)可以讀取；
  int getCurrentIndex();
}

@Mapper
public interface PersonDao {
    Cursor<Person> selectByCursor();
    Integer queryCount();
}

<select id="selectByCursor" resultMap="personMap">
    select * from sys_person order by id desc
</select>
<select id="queryCount" resultType="java.lang.Integer">
    select count(*) from sys_person
</select>

@Service
@Slf4j
public class PersonServiceImpl implements IPersonService {
    @Autowired
    private SqlSessionFactory sqlSessionFactory;
    @Override
    public void getOneByAsync() throws InterruptedException {
        new Thread(new Runnable() {
            @SneakyThrows
            @Override
            public void run() {
                //使用sqlSessionFactory打開一個(gè)sqlSession，在沒有讀取完數(shù)據(jù)之前不要提交事務(wù)或關(guān)閉sqlSession
                log.info("----開啟sqlSession");
                SqlSession sqlSession = sqlSessionFactory.openSession();
                 try {
                     //獲取到指定mapper
                     PersonDao mapper = sqlSession.getMapper(PersonDao.class);
                     //調(diào)用指定mapper的方法，返回一個(gè)cursor
                     Cursor<Person> cursor = mapper.selectByCursor();
                     //查詢數(shù)據(jù)總量
                     Integer total = mapper.queryCount();
                     //定義一個(gè)list，用來從cursor中讀取數(shù)據(jù)，每讀取夠1000條的時(shí)候，開始處理這批數(shù)據(jù)；
                     //當(dāng)前批數(shù)據(jù)處理完之后，清空list，準(zhǔn)備接收下一批次數(shù)據(jù)；直到大量的數(shù)據(jù)全部處理完；
                     List<Person> personList = new ArrayList<>();
                     int i = 0;
                     if (cursor != null) {
                         for (Person person : cursor) {
                             if (personList.size() < 1000) {
//                            log.info("----id:{},userName:{}", person.getId(), person.getUserName());
                                 personList.add(person);
                             } else if (personList.size() == 1000) {
                                 ++i;
                                 log.info("----{}、從cursor取數(shù)據(jù)達(dá)到1000條，開始處理數(shù)據(jù)", i);
                                 log.info("----處理數(shù)據(jù)中...");
                                 Thread.sleep(1000);//休眠1s模擬處理數(shù)據(jù)需要消耗的時(shí)間；
                                 log.info("----{}、從cursor中取出的1000條數(shù)據(jù)已經(jīng)處理完畢", i);
                                 personList.clear();
                                 personList.add(person);
                             }
                             if (total == (cursor.getCurrentIndex() + 1)) {
                                 ++i;
                                 log.info("----{}、從cursor取數(shù)據(jù)達(dá)到1000條，開始處理數(shù)據(jù)", i);
                                 log.info("----處理數(shù)據(jù)中...");
                                 Thread.sleep(1000);//休眠1s模擬處理數(shù)據(jù)需要消耗的時(shí)間；
                                 log.info("----{}、從cursor中取出的1000條數(shù)據(jù)已經(jīng)處理完畢", i);
                                 personList.clear();
                             }
                         }
                         if (cursor.isConsumed()) {
                             log.info("----查詢sql匹配中的數(shù)據(jù)已經(jīng)消費(fèi)完畢！");
                         }
                     }
                     sqlSession.commit();
                     log.info("----提交事務(wù)");
                 }catch (Exception e){
                     e.printStackTrace();
                     sqlSession.rollback();
                 }
                 finally {
                     if (sqlSession != null) {
                         //全部數(shù)據(jù)讀取并且做好其他業(yè)務(wù)操作之后，提交事務(wù)并關(guān)閉連接；
                         sqlSession.close();
                         log.info("----關(guān)閉sqlSession");  
                     }
                 }
            }
        }).start();
    }
}