MyBatis实现批量操作

MyBatis实现批量操作

/**
	 * 批量操作
	 * @param sqlID
	 * @param bindParams
	 * @return
	 * @throws SQLException
	 */
	@SuppressWarnings("unchecked")
	private <T> int[] batchUpdate(String sqlID, List<T> bindParams) throws SQLException
	{
		SqlSession sqlse = getSqlSession();
        Connection connection = null;
        Transaction transaction = null;
        Environment env;
        BatchExecutor be;

        Configuration conf = sqlse.getConfiguration();
        conf.setDefaultExecutorType(ExecutorType.BATCH);
        env = conf.getEnvironment();
        connection = env.getDataSource().getConnection();
        connection.setAutoCommit(false);
        transaction = env.getTransactionFactory().newTransaction(connection, false);
        be = new BatchExecutor(conf, transaction);
        MappedStatement ms = conf.getMappedStatement(sqlID);
        int x = 0;

        Object bt;
        List<Object> bts = (List<Object>) bindParams;
         
        for (int i = 0; i < bts.size(); i++) {
            bt = bts.get(i);
            x = be.update(ms, bt);
            System.out.println(x + "x:");
        }

        be.commit(true);
        transaction.commit();
        List<BatchResult> bl = be.flushStatements();
        int[] ret = null;
        if(bl != null){
            for(int b = 0; b < bl.size(); b ++){
                BatchResult br = bl.get(b);
                ret = br.getUpdateCounts();
                System.out.println("re length:" + ret.length);
            }
        }
        be.close(false);
        transaction.close();
        System.out.println(x);
        
        return ret;
	}

评论

1 楼 sunzhongcheng 2012-08-13  

.update