1

2

3

4

5

6

7

8

9

try (SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH)) {

    YourMapper mapper = sqlSession.getMapper(YourMapper.class);

    for (YourData data : dataList) {

        // 根据需要调用insert, update或delete方法

        mapper.insertOrUpdate(data);

    }

    sqlSession.commit();

    // 可以获取批处理结果，处理特定逻辑

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

@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;

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

@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();

    }

}