快捷導(dǎo)航

MyBatis執(zhí)行批處理操作的實(shí)現(xiàn)示例

更新時(shí)間：2024年07月05日 10:34:45 作者：辭暮爾爾-煙火年年

在MyBatis中,批處理操作是一種高效執(zhí)行多條語句的方式,下面就來介紹一下MyBatis執(zhí)行批處理操作的實(shí)現(xiàn)示例,具有一定的參考價(jià)值,感興趣的可以了解一下

執(zhí)行批處理的基本步驟

開啟批處理模式：在獲取SqlSession時(shí)，需要指定執(zhí)行器（Executor）類型為ExecutorType.BATCH。
執(zhí)行SQL語句：執(zhí)行需要批處理的SQL語句，此時(shí)語句并不會(huì)立即執(zhí)行，而是被添加到批處理隊(duì)列中。
提交事務(wù)：調(diào)用SqlSession.commit()方法，此時(shí)MyBatis會(huì)將批處理隊(duì)列中的語句一次性發(fā)送給數(shù)據(jù)庫執(zhí)行。
處理批處理結(jié)果：提交事務(wù)后，可以通過批處理結(jié)果進(jìn)行后續(xù)處理。

示例代碼

try (SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH)) {
    YourMapper mapper = sqlSession.getMapper(YourMapper.class);
    for (YourData data : dataList) {
        // 根據(jù)需要調(diào)用insert, update或delete方法
        mapper.insertOrUpdate(data);
    }
    sqlSession.commit();
    // 可以獲取批處理結(jié)果，處理特定邏輯
}

深入源碼解析

在MyBatis中，批處理的核心是BatchExecutor，這是Executor的一個(gè)實(shí)現(xiàn)。在開啟批處理模式時(shí)，MyBatis會(huì)使用BatchExecutor來處理SQL會(huì)話。

BatchExecutor的關(guān)鍵方法

doUpdate: 當(dāng)執(zhí)行insert、update、delete方法時(shí)，BatchExecutor會(huì)將這些操作存儲(chǔ)在內(nèi)部的批處理隊(duì)列中，而不是立即執(zhí)行它們。
doFlushStatements: 當(dāng)調(diào)用commit或flushStatements時(shí)，BatchExecutor會(huì)執(zhí)行批處理隊(duì)列中的所有SQL語句。這些操作是通過JDBC的PreparedStatement.executeBatch()方法執(zhí)行的。

@Override
public int doUpdate(MappedStatement ms, Object parameter) throws SQLException {
    final Configuration configuration = ms.getConfiguration();
    final StatementHandler handler = configuration.newStatementHandler(this, ms, parameter, RowBounds.DEFAULT, null, null);
    final BoundSql boundSql = handler.getBoundSql();
    final String sql = boundSql.getSql();
    final Statement stmt;
    if (sql.equals(currentSql) && ms.equals(currentStatement)) {
        int last = statementList.size() - 1;
        stmt = statementList.get(last);
        applyTransactionTimeout(stmt);
        handler.parameterize(stmt);//fix Issues 322
    } else {
        Connection connection = getConnection(ms.getStatementLog());
        stmt = handler.prepare(connection, transaction.getTimeout());
        handler.parameterize(stmt);    //fix Issues 322
        currentSql = sql;
        currentStatement = ms;
        statementList.add(stmt);
        batchResultList.add(new BatchResult(ms, sql, parameter));
    }
    handler.batch(stmt);
    return BATCH_UPDATE_RETURN_VALUE;
}

執(zhí)行批處理

當(dāng)調(diào)用commit或flushStatements時(shí)，BatchExecutor.doFlushStatements會(huì)被觸發(fā)，它負(fù)責(zé)實(shí)際執(zhí)行批處理操作。

@Override
public List<BatchResult> doFlushStatements(boolean isRollback) throws SQLException {
    try {
        if (isRollback) {
            return Collections.emptyList();
        }

        List<BatchResult> results = new ArrayList<>();
        if (statementList.size() > 0) {
            for (int i = 0, n = statementList.size(); i < n; i++) {
                Statement stmt = statementList.get(i);
                BatchResult batchResult = batchResultList.get(i);
                try {
                    batchResult.setUpdateCounts(stmt.executeBatch());
                    MappedStatement ms = batchResult.getMappedStatement();
                    List<Object> parameterObjects = batchResult.getParameterObjects();
                    KeyGenerator keyGenerator = ms.getKeyGenerator();
                    if (Jdbc3KeyGenerator.class.equals(keyGenerator.getClass())) {
                        Jdbc3KeyGenerator jdbc3KeyGenerator = (Jdbc3KeyGenerator) keyGenerator;
                        jdbc3KeyGenerator.processBatch(ms, stmt, parameterObjects);
                    } else if (!NoKeyGenerator.class.equals(keyGenerator.getClass())) { //issue #141
                        for (Object parameter : parameterObjects) {
                            keyGenerator.processAfter(this, ms, stmt, parameter);
                        }
                    }
                } finally {
                    closeStatement(stmt);
                }
            }
        }
        return results;
    } finally {
        for (Statement stmt : statementList) {
            closeStatement(stmt);
        }
        currentSql = null;
        statementList.clear();
        batchResultList.clear();
    }
}

小結(jié)

MyBatis的批處理通過BatchExecutor實(shí)現(xiàn)，它通過將SQL語句收集到批處理隊(duì)列中，然后在適當(dāng)?shù)臅r(shí)候（如調(diào)用commit）一次性執(zhí)行，以提高性能。正確使用批處理可以在執(zhí)行大量類似操作時(shí)大幅度減少應(yīng)用與數(shù)據(jù)庫的交互次數(shù)，優(yōu)化應(yīng)用性能。不過，要注意批處理可能會(huì)對(duì)事務(wù)管理、錯(cuò)誤處理等方面帶來額外的復(fù)雜性，使用時(shí)需要特別留意。

到此這篇關(guān)于MyBatis執(zhí)行批處理操作的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)MyBatis 批處理操作內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！