MyBatis(九)：Mybatis Java API批量操作（增、刪、改、查）

最近工作中用到了mybatis的Java API方式進行開發，順便也整理下該功能的用法，接下來會針對基本部分進行學習：

1）Java API處理一對多、多對一的用法；

2）增、刪、改、查的用法；

3）涉及到類型轉化的用法；

4）批量修改、批量查詢、批量新增的用法(介紹的方案只使用於小批量數據處理，如果大批量數據處理，還需要使用ExecutorType.BATCH)。

Mybatis官網給了具體的文檔，但是並沒有對以上用法具體介紹，因此在這里整理下，以便以后工作用到時，可以參考。

本章主要使用Mybatis中使用typeHandlers進行對Enum進行轉化的用法（本章將結合Spring自動注入《Spring（二十三）：Spring自動注入的實現方式》）

本章將分為以下幾部分：

1）環境搭建（maven+mybatis+spring整合）；

2）查詢、批量查詢；

3）新增、批量新增；

4）修改、批量修改；

5）刪除、批量刪除。

下面我們針對每個步驟進行詳細講解。

1）環境搭建（maven+mybatis+spring整合）

新建maven項目 Learn-Spring-01，並在pom.xml導入mybatis/spring/mysql/druid/junit包，完整的pom.xml文章如下：

<project xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.dx.test</groupId>
    <artifactId>Learn-Spring-01</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>Learn-Spring-01</name>
    <url>http://maven.apache.org</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <!--Spring版本號 -->
        <org.springframework.version>5.2.0.RELEASE</org.springframework.version>
        <org.mybatis.version>3.4.6</org.mybatis.version>
        <com.alibaba.version>1.1.21</com.alibaba.version>
        <mysql.version>8.0.11</mysql.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.5.4</version>
        </dependency>
        <dependency>
            <groupId>aspectj</groupId>
            <artifactId>aspectjrt</artifactId>
            <version>1.5.4</version>
        </dependency>
        <!-- Sping Test相關依賴 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>

        <!--MyBatis -->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>${org.mybatis.version}</version>
        </dependency>
        <!-- Mybatis自身實現的Spring整合依賴 -->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>2.0.3</version>
        </dependency>


        <!--MySql數據庫驅動 -->
        <!-- https://mvnrepository.com/artifact/com.alibaba/druid -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>${com.alibaba.version}</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.version}</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

在/src/main/resources下新建jdbc.properties/mybatis-config.xml/spring-config.xml配置文件：

jdbc.properties

#jdbc settings
jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
jdbc.username=root
jdbc.password=123456

#pool settings
jdbc.pool.init=1
jdbc.pool.minIdle=3
jdbc.pool.maxActive=20

#jdbc.testSql=SELECT 'x'
jdbc.testSql=SELECT 'x' FROM DUAL

mybatis-config.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <!--配置全局屬性-->
    <settings>
        <!-- 打開延遲加載的開關 -->
        <setting name="lazyLoadingEnabled" value="true"/>
        <!-- 將積極加載改為消極加載（即按需加載） -->
        <setting name="aggressiveLazyLoading" value="false"/>
        <!-- 打開全局緩存開關（二級緩存）默認值就是 true -->
        <setting name="cacheEnabled" value="true"/>
        <!--使用jdbc的getGeneratekeys獲取自增主鍵值-->
        <setting name="useGeneratedKeys" value="true"/>
        <!--使用列別名替換別名　　默認true select name as title form table; -->
        <setting name="useColumnLabel" value="true"/>
        <!--開啟駝峰命名轉換-->
        <setting name="mapUnderscoreToCamelCase" value="true"/>
        <!--打印sql日志-->
        <setting name="logImpl" value="STDOUT_LOGGING" />
    </settings>
    
    <!-- 引用db.properties配置文件 -->
    <!-- 
    <properties resource="db.properties"/> 
    <typeAliases>
        <package name="com.dx.test.model"/>
    </typeAliases>
    -->
    
    <!-- 元素類型為 "configuration" 的內容必須匹配 "(properties?,settings?,typeAliases?,typeHandlers?,objectFactory?,objectWrapperFactory?,reflectorFactory?,plugins?,environments?,databaseIdProvider?,mappers?)"。-->
    <typeHandlers>
        <typeHandler handler="org.apache.ibatis.type.EnumOrdinalTypeHandler" javaType="com.dx.test.model.enums.ModuleType"/>
        <typeHandler handler="org.apache.ibatis.type.EnumOrdinalTypeHandler" javaType="com.dx.test.model.enums.OperateType"/>
        <typeHandler handler="org.apache.ibatis.type.EnumOrdinalTypeHandler" javaType="com.dx.test.model.enums.DataStatus"/>
    </typeHandlers>
    
    <!-- 對事務的管理和連接池的配置 -->
    <!-- 
    <environments default="mysql_jdbc">
        <environment id="oracle_jdbc">
            <transactionManager type="JDBC"/>
            <dataSource type="POOLED">
                <property name="driver" value="${driver}"/>
                <property name="url" value="${url}"/>
                <property name="username" value="${name}"/>
                <property name="password" value="${password}"/>
            </dataSource>
        </environment>

        <environment id="mysql_jdbc">
            <transactionManager type="JDBC"/>
            <dataSource type="POOLED">
                <property name="driver" value="${driver}"/>
                <property name="url" value="${url}"/>
                <property name="username" value="${name}"/>
                <property name="password" value="${password}"/>
            </dataSource>
        </environment>
    </environments>
    -->
    
    <!-- 當使用了xxxMapper.xml時，需要配置這些配置 -->
    <!--
    <mappers>
        <mapper resource="resources/mapper/TaskAutoExecutePlanMapper.xml"/>
    </mappers>
    -->
    <!-- 因在Mapper類上加入了@Mapper注解，因此這個配置也不需要了。 -->
    <!-- 
    <mappers>
        <mapper class="com.dx.test.mapper.ArticleCategoryMapper"></mapper>
        <mapper class="com.dx.test.mapper.ArticleMapper"></mapper>
    </mappers>
     -->
</configuration>

spring-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
 http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
 http://www.springframework.org/schema/context
 http://www.springframework.org/schema/context/spring-context-4.0.xsd ">

    <!-- bean annotation driven -->
    <context:annotation-config />
    <context:component-scan base-package="com.dx.test.repository,com.dx.test.mapper,com.dx.test.service" />

    <!-- 配置整合Mybatis過程 -->
    <!-- 配置數據庫相關參數 properties的屬性：${url} -->
    <context:property-placeholder location="classpath:jdbc.properties" />
    <!-- 
    <bean id="propertyPlaceholderConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> 
        <property name="locations">
         <list>
          <value>classpath:jdbc.properties</value> 
         </list> 
        </property> 
    </bean> 
    -->

    <!--2.配置連接池屬性 -->
    <!-- 數據源配置, 使用 Druid 數據庫連接池 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
        <!-- 數據源驅動類可不寫，Druid默認會自動根據URL識別DriverClass -->
        <property name="driverClassName" value="${jdbc.driver}" />

        <!-- 基本屬性 url、user、password -->
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />

        <!-- 配置初始化大小、最小、最大 -->
        <property name="initialSize" value="${jdbc.pool.init}" />
        <property name="minIdle" value="${jdbc.pool.minIdle}" />
        <property name="maxActive" value="${jdbc.pool.maxActive}" />

        <!-- 配置獲取連接等待超時的時間 -->
        <property name="maxWait" value="60000" />

        <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="60000" />

        <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="300000" />

        <property name="validationQuery" value="${jdbc.testSql}" />
        <property name="testWhileIdle" value="true" />
        <property name="testOnBorrow" value="false" />
        <property name="testOnReturn" value="false" />
        <!-- 打開PSCache，並且指定每個連接上PSCache的大小（Oracle使用） -->
        <!-- <property name="poolPreparedStatements" value="true"/> <property name="maxPoolPreparedStatementPerConnectionSize" 
            value="20"/> -->
        <!-- 配置監控統計攔截的filters: 監控統計用的filter:stat 日志用的filter:log4j 防御sql注入的filter:wall -->
        <property name="filters" value="stat,wall" />
    </bean>

    <!--3.配置SqlSessionFactory對象 -->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <!--注入數據庫連接池 -->
        <property name="dataSource" ref="dataSource" />
        <!--配置mybatis全局配置文件:mybatis-config.xml -->
        <property name="configLocation"
            value="classpath:mybatis-config.xml" />
        <!-- 因為我們這采用的是Mybatis Java API方式，因此不需要配置 -->
        <!--掃描entity包,使用別名,多個用;隔開 -->
        <!-- <property name="typeAliasesPackage" value="com.dx.test.model"/> -->
        <!--掃描sql配置文件:mapper需要的xml文件 -->
        <!-- <property name="mapperLocations" value="classpath:mapper/*.xml"/> -->
    </bean>

    <!-- Mapper接口所在包名，Spring會自動查找其下的類 -->
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.dx.test.mapper" />
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
    </bean>

    <!-- 如果想對單個mapper類關聯上sqlSessionFactory，可以這么使用，具體參考：http://mybatis.org/spring/getting-started.html -->
    <!-- <bean id="articlerMapper" class="org.mybatis.spring.mapper.MapperFactoryBean"> 
        <property name="mapperInterface" value="com.dx.test.dao.mapper.ArticleMapper" 
        /> <property name="sqlSessionFactory" ref="sqlSessionFactory" /> </bean> -->

    <!-- (事務管理)transaction manager, use JtaTransactionManager for global tx -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>
</beans>

在src/main/java/com.dx.test.module.enum包下新建DataStatus枚舉類：

package com.dx.test.model.enums;

public enum DataStatus {
    Living(0), // 啟用 
    UnUsed(1); // 作廢

    private int value;

    DataStatus(int value) {
        this.value = value;
    }

    public int getValue() {
        return this.value;
    }
}

在src/main/java/com.dx.test.model包下創建Log.java實體類：

package com.dx.test.model;

import java.util.Date;

import com.dx.test.model.enums.DataStatus;

/**
 * 文章分類
 * */
public class ArticleCategory {
    private Integer id; //文章分類id
    private String title; // 文章分類名稱
    private String imgSrc; // 文章分類banner圖片
    private String description; // 文章分類描述
    private DataStatus state; // 記錄狀態
    
    private String createUser; // 新建用戶
    private String createUserId;// 新建用戶id
    private Date createTime; // 新建時間
    private String updateUser; // 修改用戶
    private String updateUserId;// 修改用戶id
    private Date updateTime; // 修改時間
    private Integer version; // 樂觀鎖版本號
    
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getTitle() {
        return title;
    }
    public void setTitle(String title) {
        this.title = title;
    }
    public String getImgSrc() {
        return imgSrc;
    }
    public void setImgSrc(String imgSrc) {
        this.imgSrc = imgSrc;
    }
    public String getDescription() {
        return description;
    }
    public void setDescription(String description) {
        this.description = description;
    }
    public DataStatus getState() {
        return state;
    }
    public void setState(DataStatus state) {
        this.state = state;
    }
    public String getCreateUser() {
        return createUser;
    }
    public void setCreateUser(String createUser) {
        this.createUser = createUser;
    }
    public String getCreateUserId() {
        return createUserId;
    }
    public void setCreateUserId(String createUserId) {
        this.createUserId = createUserId;
    }
    public Date getCreateTime() {
        return createTime;
    }
    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }
    public String getUpdateUser() {
        return updateUser;
    }
    public void setUpdateUser(String updateUser) {
        this.updateUser = updateUser;
    }
    public String getUpdateUserId() {
        return updateUserId;
    }
    public void setUpdateUserId(String updateUserId) {
        this.updateUserId = updateUserId;
    }
    public Date getUpdateTime() {
        return updateTime;
    }
    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }
    public Integer getVersion() {
        return version;
    }
    public void setVersion(Integer version) {
        this.version = version;
    }
    @Override
    public String toString() {
        return "ArticleCategory [id=" + id + ", title=" + title + ", imgSrc=" + imgSrc + ", description=" + description
                + "]";
    }
}

在src/main/java/com.dx.test.mapper包下新建ArticleCategoryMapper.java mapper接口，目前該接口內容為空，在接口上添加上@Mapper注解。

package com.dx.test.mapper;
import org.apache.ibatis.annotations.Mapper;

public interface ArticleCategoryMapper{

}

在src/main/java/com.dx.test.mapper.sqlprovider下新建ArticleCategorySqlProvider.java mapper sql生成類：

package com.dx.test.mapper.sqlprovider;

public class ArticleCategorySqlProvider {

}

在src/main/test/com.dx.test下新建測試類ArticleCategoryTest.java

package com.dx.test;

import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import com.dx.test.mapper.ArticleCategoryMapper;

/**
 * Unit test for simple App.
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration({ "classpath:spring-config.xml" })
public class ArticleCategroyTest {
    @Autowired
    private ArticleCategoryMapper articleCategoryMapper;

}

2）查詢、批量查詢

在mapper類中新建查詢、批量查詢接口：

    /**
     * +根據文章分類id,查詢文件分類詳情
     * @param id 文章分類id
     * @return 查詢到的文章分類詳情
     * */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.FALSE, timeout = 60000)
    @Results(id="articleCategoryResult",value = {
            @Result(property = "id",column = "id",id = true),
            @Result(property = "title",column = "title"),
            @Result(property = "imgSrc",column = "img_src"),
            @Result(property = "status",column = "status",javaType = DataStatus.class),
            @Result(property = "description",column = "description"),
            @Result(property = "createUser",column = "create_user"),
            @Result(property = "createUserId",column = "create_user_id"),
            @Result(property = "createTime",column = "create_time"),
            @Result(property = "updateUser",column = "update_user"),
            @Result(property = "updateUserId",column = "update_user_id"),
            @Result(property = "updateTime",column = "update_time"),
            @Result(property = "version",column = "version")
    })
    @Select("select * from article_category where id=#{id}")
    ArticleCategory getById(Integer id);
    
    /**
     * 根據id列表，查詢多個文章分類，返回文章分類列表
     * 
     * @param list 查詢id列表
     * @return returnResult
     * */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.FALSE, timeout = 60000)
    @ResultMap(value ="articleCategoryResult")
    @SelectProvider(type = ArticleCategorySqlProvider.class, method = "getByIds")
    List<ArticleCategory> getByIds(@Param("list") List<Integer> list);
    
    /**
     * 根據過濾條件，查詢返回滿足條件的文章分類id列表
     * 
     * @param articleCategory 查詢條件
     * @return returnResult
     * */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.FALSE, timeout = 60000)
    @Select(value="select * from `article_category` where state=#{state} and `title` like CONCAT(CONCAT('%', #{title}), '%')")
    List<Integer> getIdsByCondition(ArticleCategory articleCategory);
    
    /**
     * +根據查詢條件，查詢記錄。
     * @param articleCategory 查詢條件
     * @return 返回查詢結果
     * */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.FALSE, timeout = 60000)
    @ResultMap(value ="articleCategoryResult")
    @SelectProvider(type = ArticleCategorySqlProvider.class, method = "queryList")
    List<ArticleCategory> queryList(ArticleCategory articleCategory);
    
    /**
     * +根據查詢條件，查詢記錄。
     * @param articleCategory 查詢條件
     * @return 返回查詢結果
     * */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.FALSE, timeout = 60000)
    @ResultMap(value ="articleCategoryResult")
    @Select(value="select * from `article_category` where state=#{state}")
    List<ArticleCategory> queryListByState(DataStatus state);

查詢返回Map的用法：

    /**
     * +根據查詢條件，查詢記錄。
     * 
     * @param articleCategory 查詢條件
     * @return 返回查詢結果
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.FALSE, timeout = 60000)
    @ResultType(value = HashMap.class)
    @MapKey(value="id")
    @Select(value = "select * from `article_category` where state=#{state}")
    Map<Integer, ArticleCategory> getIdVsModelMap(DataStatus state);

    /**
     * +根據查詢條件，查詢記錄。
     * 
     * @param articleCategory 查詢條件
     * @return 返回查詢結果
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.FALSE, timeout = 60000)
    @ResultType(value = HashMap.class)
//    @Results(id="idVsTitleMapResult",
//        value= {
//            @Result(property = "key",column = "id"),
//            @Result(property = "value",column = "title")
//        }
//    )
    @Select(value = "select id,title from `article_category` where state=#{state}")
    void getIdVsTitleMap(DataStatus state);
    
    /**
     * 根據條件查詢記錄結果，返回Map{key:id,value:title}
     * @param state 文章分類記錄狀態
     * @return returnResult
     * */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.FALSE, timeout = 60000)
    @ResultType(value = HashMap.class)
    @Select(value = "select id,title from `article_category` where state=#{state}")
    Map<Integer,String> getIdVsTitleMapWithResultHandler(@Param("state") DataStatus state, ResultHandler<?> resultHandler);

在mapper sql provider類中新建sql幫助方法：

     /**
     * +根據id集合，獲取文章分類列表 SQL
     *
     * @param map map
     * @return returnResult
     */
    public String getByIds(final Map<String, List<Integer>> map) {
        List<Integer> tmpList = map.get("list");
        if (tmpList == null || tmpList.isEmpty()) {
            return null;
        }

        StringBuilder sql = new StringBuilder("SELECT * FROM `article_category` WHERE `id` in (");
        for (int i = 0; i < tmpList.size(); i++) {
            sql.append("#{list[" + i + "]},");
        }
        sql.deleteCharAt(sql.length() - 1);
        sql.append(")");
        sql.append(";");

        return sql.toString();
    }

    /**
     * 根據查詢條件，查詢記錄
     * 
     * @param articleCategory 查詢條件
     * @return 返回查詢結果
     * */
    public String queryList(ArticleCategory articleCategory) {
        StringBuilder sql = new StringBuilder();
        sql.append("select * from `article_category` where 1=1 ");

        if (articleCategory.getId() != null) {
            sql.append(" AND `id`=#{id}");
        }
        if (articleCategory.getTitle() != null) {
            sql.append("  AND `title` like CONCAT(CONCAT('%', #{title}), '%')");
        }
        if(articleCategory.getState()!=null) {
            sql.append("  AND `state` = #{state}");
        }
        if (articleCategory.getCreateTime() != null) {
            sql.append("  AND `create_time` = #{createTime}");
        }
        if (articleCategory.getCreateUser() != null) {
            sql.append("  AND `create_user` = #{createUser}");
        }
        if (articleCategory.getCreateUserId() != null) {
            sql.append("  AND `create_user_id` = #{createUserId}");
        }
        if (articleCategory.getUpdateTime() != null) {
            sql.append("  AND `update_time` = #{updateTime}");
        }
        if (articleCategory.getUpdateUser() != null) {
            sql.append("  AND `update_user` = #{updateUser}");
        }
        if (articleCategory.getUpdateUserId() != null) {
            sql.append("  AND `update_user_id` = #{updateUserId}");
        }
        if (articleCategory.getVersion() != null) {
            sql.append("  AND `version` = #{version}");
        }
        sql.append("  ORDER BY `id` DESC");

        return sql.toString();
    }

在測試類中新增測試方法：

    private ArticleCategory articleCategory;
    private final String title = "category test title";
    private final String titleNew = "category test title new";

    @Test
    public void testGetById() {
        ArticleCategory articleCategory = this.articleCategoryMapper.getById(this.articleCategory.getId());
        Assert.assertEquals(articleCategory.getId(), this.articleCategory.getId());
        Assert.assertEquals(articleCategory.getTitle(), this.title);
    }

    @Test
    public void testGetByIds() {
        List<Integer> idList = new ArrayList<Integer>(Arrays.asList(5, 6));
        List<ArticleCategory> queryList = this.articleCategoryMapper.getByIds(idList);
        Assert.assertEquals(queryList.size(), idList.size());
    }

    @Test
    public void testGetIdsByCondition() {
        ArticleCategory articleCategory = new ArticleCategory();
        articleCategory.setState(DataStatus.Living);
        articleCategory.setTitle("test");

        List<Integer> idList = this.articleCategoryMapper.getIdsByCondition(articleCategory);
        Assert.assertTrue(idList.isEmpty() == false);
    }
    
    @Test
    public void testGetLivingIds() {
        List<ArticleCategory> articleCategoryList=this.articleCategoryMapper.queryListByState(DataStatus.Living);
        Assert.assertTrue(articleCategoryList.isEmpty() == false);
    }

    @Test
    public void testQueryList() {
        ArticleCategory queryArticleCategory = new ArticleCategory();
        queryArticleCategory.setTitle("test");

        List<ArticleCategory> queryResultList = this.articleCategoryMapper.queryList(queryArticleCategory);
        Assert.assertFalse(queryResultList.size() == 0);
    }

map測試代碼：

    @Test
    public void testGetIdVsModelMap() {
        Map<Integer,ArticleCategory> queryItems=this.articleCategoryMapper.getIdVsModelMap(DataStatus.Living);
        Assert.assertTrue(queryItems.size()>0);
    }
    
    @Autowired
    private SqlSessionFactory sqlSessionFactory;
    
    @Test
    public void testGetIdVsTitleMap() {
        MapResultHandler mapResultHandler=new MapResultHandler();
        this.sqlSessionFactory.openSession().select("com.dx.test.mapper.ArticleCategoryMapper.getIdVsTitleMap", DataStatus.Living,mapResultHandler);
        @SuppressWarnings("unchecked")
        Map<Integer, String> queryMap=mapResultHandler.getMappedResults();
        
        Assert.assertTrue(queryMap.size()>0);
    }

    @Test
    public void testGetIdVsTitleMapWithResultHandler() {
        MapResultHandler mapResultHandler=new MapResultHandler();
        this.articleCategoryMapper.getIdVsTitleMapWithResultHandler(DataStatus.Living, mapResultHandler);
        Assert.assertTrue(mapResultHandler.getMappedResults().size()>0);
    }

注意：上邊返回map的用法中，如果是非Map<Integer,Model>的模式時，需要使用ResultHandler來輔助實現：

package com.dx.test.mapper.resulthandlers;

import java.util.HashMap;
import java.util.Map;

import org.apache.ibatis.session.ResultContext;
import org.apache.ibatis.session.ResultHandler;

public class MapResultHandler implements ResultHandler {
    private final Map mappedResults = new HashMap();

    @Override
    public void handleResult(ResultContext context) {
        @SuppressWarnings("rawtypes")
        Map map = (Map) context.getResultObject();
        mappedResults.put(map.get("key"), map.get("value"));
    }

    public Map getMappedResults() {
        return mappedResults;
    }
}

3）新增、批量新增

在mapper類中新建查詢、批量查詢接口：

    /**
     * +入庫文章分類
     * 
     * @param articleCategory 待入庫實體
     * @return 影響條數
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE, useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
    @InsertProvider(type = ArticleCategorySqlProvider.class, method = "insert")
    int insert(ArticleCategory articleCategory);
     /**
     * +批量添加記錄
     *
     * @param articleCategoryList 文章分類列表 
     * @return returnResult
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE, useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
    @InsertProvider(type = ArticleCategorySqlProvider.class, method = "batchInsert")
    int batchInserts(@Param("list") final List<ArticleCategory> articleCategoryList);
    
    /**
     * +批量添加記錄
     *
     * @param articleCategoryList 文章分類列表 
     * @return returnResult
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE, useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
    @Insert(value = "<script>"
            + "INSERT INTO `article_category`"
            + "(`title`,`img_src`,`description`,`state`,`create_time`,`create_user`,`create_user_id`,`update_time`,`update_user`,`update_user_id`,`version`)"
            + "VALUES"
            + "<foreach collection=\"list\" item=\"item\" index=\"index\" separator=\",\">"
            + "     (#{item.title},#{item.imgSrc},#{item.description},#{item.state},now(),#{item.createUser},#{item.createUserId},now(),#{item.updateUser},#{item.updateUserId},0)"
            + "</foreach>"
            + "ON DUPLICATE KEY UPDATE `update_time` = now()"
            + "</script>")
    int batchInsertsWithScript(@Param("list") final List<ArticleCategory> articleCategoryList);

在mapper sql provider類中新建sql幫助方法：

    /**
     * 生成插入文章分類的SQL
     * 
     * @param articleCategory文章分類
     * @return 返回插入文章SQL
     */
    public String insert(ArticleCategory articleCategory) {
        return new SQL() {
            {
                INSERT_INTO("article_category");
                INTO_COLUMNS("title", "img_src", "description","state", "create_user", "create_user_id", "create_time","update_user", "update_user_id", "update_time", "version");
                INTO_VALUES("#{title}", "#{imgSrc}", "#{description}", "#{state}", "#{createUser}", "#{createUserId}", "now()","#{updateUser}", "#{updateUserId}", "now()", "0");
            }
        }.toString();
    }

    /**
     * 生成批量新增SQL
     * 
     * @param map 參數信息
     * @return 生成批量插入SQL語句
     * */
    public String batchInsert(Map<String, List<ArticleCategory>> map) {
        List<ArticleCategory> tmpList = map.get("list");
        if (tmpList == null || tmpList.isEmpty()) {
            return null;
        }

        StringBuilder sql = new StringBuilder("");
        sql.append("INSERT INTO `article_category`");
        sql.append("(`title`,`img_src`,`description`,`state`,`create_time`,`create_user`,`create_user_id`,`update_time`,`update_user`,`update_user_id`,`version`)");
        sql.append("VALUES");
        for (int i = 0; i < tmpList.size(); i++) {
            sql.append("(#{list[" + i + "].title},#{list[" + i + "].imgSrc},#{list[" + i + "].description},#{list["+i+"].state},now(),#{list[" + i + "].createUser},#{list[" + i + "].createUserId},now(),#{list[" + i + "].updateUser},#{list[" + i + "].updateUserId},0),");
        }
        sql.deleteCharAt(sql.length() - 1);
        sql.append(" ON DUPLICATE KEY UPDATE `update_time` = now()");
        sql.append(";");

        return sql.toString();
    }

在測試類中新增測試方法：

    @Test
    public void testInsert() {
        ArticleCategory articleCategory = new ArticleCategory();
        articleCategory.setTitle(title);
        articleCategory.setDescription("category description");
        articleCategory.setImgSrc("http://www.test.com/img/category/img-" + new Random().nextInt(1000) + ".gif");
        articleCategory.setState(DataStatus.Living);
        articleCategory.setCreateTime(new Date());
        articleCategory.setCreateUser("create user");
        articleCategory.setCreateUserId("user-" + new Random().nextInt(1000));

        int result = this.articleCategoryMapper.insert(articleCategory);
        this.articleCategory = articleCategory;
        Assert.assertEquals(result, 1);
    }

    @Test
    public void testBatchInsert() {
        List<ArticleCategory> articleCategoryList = new ArrayList<ArticleCategory>();
        for (int i = 0; i < 10; i++) {
            ArticleCategory articleCategory = new ArticleCategory();
            articleCategory.setTitle(title + i);
            articleCategory.setState(DataStatus.Living);
            articleCategory.setDescription("category description");
            articleCategory.setImgSrc("http://www.test.com/img/category/img-" + new Random().nextInt(1000) + ".gif");
            articleCategory.setCreateTime(new Date());
            articleCategory.setCreateUser("create user");
            articleCategory.setCreateUserId("user-" + new Random().nextInt(1000));

            articleCategoryList.add(articleCategory);
        }

        int result = this.articleCategoryMapper.batchInserts(articleCategoryList);
        Assert.assertEquals(result, 10);
    }

    @Test
    public void testBatchInsertWithScript() {
        List<ArticleCategory> articleCategoryList = new ArrayList<ArticleCategory>();
        for (int i = 0; i < 10; i++) {
            ArticleCategory articleCategory = new ArticleCategory();
            articleCategory.setTitle(title + i);
            articleCategory.setState(DataStatus.Living);
            articleCategory.setDescription("category description");
            articleCategory.setImgSrc("http://www.test.com/img/category/img-" + new Random().nextInt(1000) + ".gif");
            articleCategory.setCreateTime(new Date());
            articleCategory.setCreateUser("create user");
            articleCategory.setCreateUserId("user-" + new Random().nextInt(1000));

            articleCategoryList.add(articleCategory);
        }

        int result = this.articleCategoryMapper.batchInsertsWithScript(articleCategoryList);
        Assert.assertEquals(result, 10);
    }

4）修改、批量修改

在mapper類中新建查詢、批量查詢接口：

    /**
     * +根據文章id，刪除文章
     * 
     * @param id 文章id
     * @return 影響條數
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE)
    @UpdateProvider(type = ArticleCategorySqlProvider.class, method = "update")
    int update(ArticleCategory articleCategory);

    /**
     * +批量新增
     * @param articleCategoryList 待修改對象
     * @return 影響條數
     * */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE)
    @UpdateProvider(type = ArticleCategorySqlProvider.class, method = "batchUpdate")
    int batchUpdate(List<ArticleCategory> articleCategoryList);
    
    /**
     * +批量新增
     * @param articleCategoryList 待修改對象
     * @return 影響條數
     * */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE)
    @Update(value="<script>"
            + "<foreach item=\"item\" collection=\"list\" open=\"\" separator=\";\" close=\"\">"
            + "update `article_category` "
            + "<set>" +
            " `id`=#{item.id} "
            + " <if test='item.title !=null and item.title != \"\"'>" +
            "       ,`title` = #{item.title} " +
            "  </if> " +
            " <if test='item.imgSrc !=null'>" +
            "       ,`img_src` = #{item.imgSrc} " +
            "  </if> " +
            " <if test='item.description !=null and item.description != \"\"'>" +
            "       ,`description` = #{item.description} " +
            "  </if> " +
            " <if test='item.state !=null'>" +
            "       ,`state` = #{item.state} " +
            "  </if> " +
            ",`update_time` = now(), `update_user` = #{item.updateUser}, `update_user_id` = #{item.updateUserId}, `version` = `version` + 1 "
            + "</set>"
            + "where `id` = #{item.id} and `version`=#{item.version}"
            + "</foreach>"
            + "</script>")
    int batchUpdateWithScript(List<ArticleCategory> articleCategoryList);

在mapper sql provider類中新建sql幫助方法：

    /**
     * 生成修改文章分類SQL
     * 
     * @param articleCategory 文章分類實體
     * @return 返回修改文章分類SQL
     */
    public String update(ArticleCategory articleCategory) {
        StringBuilder sql = new StringBuilder();

        sql.append("update `article_category` set id=#{id}");
        if (articleCategory.getTitle() != null) {
            sql.append(", `title`=#{title}");
        }
        if (articleCategory.getImgSrc() != null) {
            sql.append(", `img_src`=#{imgSrc}");
        }
        if (articleCategory.getDescription() != null) {
            sql.append(", `description`=#{description}");
        }
        if(articleCategory.getState()!=null) {
            sql.append(", `state` = #{state}");
        }
        if (articleCategory.getCreateUser() != null) {
            sql.append(", `create_user` = #{createUser}");
        }
        if (articleCategory.getCreateUserId() != null) {
            sql.append(", `create_user_id` = #{createUserId}");
        }
        sql.append(", `update_time` = now()");
        if (articleCategory.getUpdateUser() != null) {
            sql.append(", `update_user` = #{updateUser}");
        }
        if (articleCategory.getUpdateUserId() != null) {
            sql.append(", `update_user_id` = #{updateUserId}");
        }

        sql.append(", `version` = `version` + 1");
        sql.append(" WHERE `id` = #{id} AND `version` = #{version}");

        return sql.toString();
    }

    /**
     * 生成批量更新SQL
     * 
     * @param map 查詢參數
     * @return 返回生成的批量更新語句
     * */
    public String batchUpdate(Map<String, List<ArticleCategory>> map) {
        List<ArticleCategory> tmpList = map.get("list");
        if (tmpList == null || tmpList.isEmpty()) {
            return null;
        }

        StringBuilder sql = new StringBuilder("");
        
        for (int i = 0; i < tmpList.size(); i++) {
            ArticleCategory articleCategory=tmpList.get(i);
            sql.append("update `article_category` set id=#{list["+i+"].id}");
            if (articleCategory.getTitle() != null) {
                sql.append(", `title`=#{list["+i+"].title}");
            }
            if (articleCategory.getImgSrc() != null) {
                sql.append(", `img_src`=#{list["+i+"].imgSrc}");
            }
            if (articleCategory.getDescription() != null) {
                sql.append(", `description`=#{list["+i+"].description}");
            }
            if(articleCategory.getState()!=null) {
                sql.append(", `state` = #{list["+i+"].state}");
            }
            if (articleCategory.getCreateUser() != null) {
                sql.append(", `create_user` = #{list["+i+"].createUser}");
            }
            if (articleCategory.getCreateUserId() != null) {
                sql.append(", `create_user_id` = #{list["+i+"].createUserId}");
            }
            sql.append(", `update_time` = now()");
            if (articleCategory.getUpdateUser() != null) {
                sql.append(", `update_user` = #{list["+i+"].updateUser}");
            }
            if (articleCategory.getUpdateUserId() != null) {
                sql.append(", `update_user_id` = #{list["+i+"].updateUserId}");
            }

            sql.append(", `version` = `version` + 1");
            sql.append(" WHERE `id` = #{list["+i+"].id} AND `version` = #{list["+i+"].version}");
            sql.append(";");
        }

        return sql.toString();
    }

在測試類中新增測試方法： 

    @Test
    public void testUpdate() {
        ArticleCategory articleCategory = this.articleCategoryMapper.getById(this.articleCategory.getId());
        Assert.assertEquals(articleCategory.getId(), this.articleCategory.getId());
        Assert.assertEquals(articleCategory.getTitle(), this.title);

        articleCategory.setTitle(this.titleNew);
        int result = this.articleCategoryMapper.update(articleCategory);
        Assert.assertEquals(result, 1);

        articleCategory = this.articleCategoryMapper.getById(this.articleCategory.getId());
        Assert.assertEquals(articleCategory.getId(), this.articleCategory.getId());
        Assert.assertEquals(articleCategory.getTitle(), this.title);
    }
    
    @Test
    public void testBatchUpdate() {
        ArticleCategory queryArticleCategory = new ArticleCategory();
        queryArticleCategory.setTitle("ccccc");
        List<ArticleCategory> queryItems = this.articleCategoryMapper.queryList(queryArticleCategory);
        for (ArticleCategory articleCategory : queryItems) {
            articleCategory.setTitle("DDD");
        }

        int result = this.articleCategoryMapper.batchUpdate(queryItems);
        Assert.assertEquals(result, 1);
    }

    @Test
    public void testBatchUpdateWithScript() {
        ArticleCategory queryArticleCategory = new ArticleCategory();
        queryArticleCategory.setTitle("DDD");
        List<ArticleCategory> queryItems = this.articleCategoryMapper.queryList(queryArticleCategory);
        for (ArticleCategory articleCategory : queryItems) {
            articleCategory.setTitle("ccccc");
        }

        int result = this.articleCategoryMapper.batchUpdateWithScript(queryItems);
        Assert.assertEquals(result, 1);
    }

測試執行批量插入，按照上邊jdbc.properties和spring-config.xml配置中會拋出以下異常：

Caused by: java.sql.SQLException: sql injection violation, multi-statement not allow : update `article_category` set id=?, `title`=?, `img_src`=?, `description`=?, `state` = ?, `create_user` = ?, `create_user_id` = ?, `update_time` = now(), `version` = `version` + 1 WHERE `id` = ? AND `version` = ?;update `article_category` set id=?, `title`=?, `img_src`=?, `description`=?, `state` = ?, `create_user` = ?, `create_user_id` = ?, `update_time` = now(), `version` = `version` + 1 WHERE `id` = ? AND `version` = ?;update `article_category` set id=?, `title`=?, `img_src`=?, `description`=?, `state` = ?, `create_user` = ?, `create_user_id` = ?, `update_time` = now(), `version` = `version` + 1 WHERE `id` = ? AND `version` = ?;update `article_category` set id=?, `title`=?, `img_src`=?, `description`=?, `state` = ?, `create_user` = ?, `create_user_id` = ?, `update_time` = now(), `version` = `version` + 1 WHERE `id` = ? AND `version` = ?;
    at com.alibaba.druid.wall.WallFilter.checkInternal(WallFilter.java:808)
    at com.alibaba.druid.wall.WallFilter.connection_prepareStatement(WallFilter.java:294)
    at com.alibaba.druid.filter.FilterChainImpl.connection_prepareStatement(FilterChainImpl.java:610)
    at com.alibaba.druid.filter.FilterAdapter.connection_prepareStatement(FilterAdapter.java:943)
    at com.alibaba.druid.filter.FilterEventAdapter.connection_prepareStatement(FilterEventAdapter.java:143)
    at com.alibaba.druid.filter.FilterChainImpl.connection_prepareStatement(FilterChainImpl.java:610)
    at com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl.prepareStatement(ConnectionProxyImpl.java:374)
    at com.alibaba.druid.pool.DruidPooledConnection.prepareStatement(DruidPooledConnection.java:388)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.apache.ibatis.logging.jdbc.ConnectionLogger.invoke(ConnectionLogger.java:55)
    at com.sun.proxy.$Proxy38.prepareStatement(Unknown Source)
    at org.apache.ibatis.executor.statement.PreparedStatementHandler.instantiateStatement(PreparedStatementHandler.java:85)
    at org.apache.ibatis.executor.statement.BaseStatementHandler.prepare(BaseStatementHandler.java:88)
    at org.apache.ibatis.executor.statement.RoutingStatementHandler.prepare(RoutingStatementHandler.java:59)
    at org.apache.ibatis.executor.SimpleExecutor.prepareStatement(SimpleExecutor.java:85)
    at org.apache.ibatis.executor.SimpleExecutor.doUpdate(SimpleExecutor.java:49)
    at org.apache.ibatis.executor.BaseExecutor.update(BaseExecutor.java:117)
    at org.apache.ibatis.executor.CachingExecutor.update(CachingExecutor.java:76)
    at org.apache.ibatis.session.defaults.DefaultSqlSession.update(DefaultSqlSession.java:198)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:426)
    ... 37 more

此時出現錯誤原因，多個sql語句執行被過濾器過濾掉了。

問題解決：

1）需要在jdbc.properties中url中添加allowMultiQueries=true

#jdbc settings
jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/mydb?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
jdbc.username=root
jdbc.password=123456

#pool settings
jdbc.pool.init=1
jdbc.pool.minIdle=3
jdbc.pool.maxActive=20

#jdbc.testSql=SELECT 'x'
jdbc.testSql=SELECT 'x' FROM DUAL

2）在spring-config.xml中修改，添加wall-filter/stat-filter，並引入dataSource下。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
 http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
 http://www.springframework.org/schema/context
 http://www.springframework.org/schema/context/spring-context-4.0.xsd ">

    <!-- bean annotation driven -->
    <context:annotation-config />
    <context:component-scan base-package="com.dx.test.repository,com.dx.test.mapper,com.dx.test.service" />

    <!-- 配置整合Mybatis過程 -->
    <!-- 配置數據庫相關參數 properties的屬性：${url} -->
    <context:property-placeholder location="classpath:jdbc.properties" />
    <!-- 
    <bean id="propertyPlaceholderConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> 
        <property name="locations">
         <list>
          <value>classpath:jdbc.properties</value> 
         </list> 
        </property> 
    </bean> 
    -->

    <!--2.配置連接池屬性 -->
    <!-- 數據源配置, 使用 Druid 數據庫連接池 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
        <!-- 數據源驅動類可不寫，Druid默認會自動根據URL識別DriverClass -->
        <property name="driverClassName" value="${jdbc.driver}" />

        <!-- 基本屬性 url、user、password -->
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />

        <!-- 配置初始化大小、最小、最大 -->
        <property name="initialSize" value="${jdbc.pool.init}" />
        <property name="minIdle" value="${jdbc.pool.minIdle}" />
        <property name="maxActive" value="${jdbc.pool.maxActive}" />

        <!-- 配置獲取連接等待超時的時間 -->
        <property name="maxWait" value="60000" />

        <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="60000" />

        <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="300000" />

        <property name="validationQuery" value="${jdbc.testSql}" />
        <property name="testWhileIdle" value="true" />
        <property name="testOnBorrow" value="false" />
        <property name="testOnReturn" value="false" />
        <!-- 打開PSCache，並且指定每個連接上PSCache的大小（Oracle使用） -->
        <!-- <property name="poolPreparedStatements" value="true"/> <property name="maxPoolPreparedStatementPerConnectionSize" 
            value="20"/> -->
        <property name="proxyFilters">
            <list>
                <ref bean="stat-filter" />
                <ref bean="wall-filter" />
            </list>
        </property>
        <!-- 配置監控統計攔截的filters: 監控統計用的filter:stat 日志用的filter:log4j 防御sql注入的filter:wall -->
        <property name="filters" value="stat,wall" />
    </bean>
    <bean id="stat-filter" class="com.alibaba.druid.filter.stat.StatFilter">
        <property name="slowSqlMillis" value="30000" />
        <property name="logSlowSql" value="true" />
        <property name="mergeSql" value="true" />
    </bean>

    <bean id="wall-filter" class="com.alibaba.druid.wall.WallFilter">
        <property name="dbType" value="mysql" />
        <property name="config" ref="wall-config" />
    </bean>

    <bean id="wall-config" class="com.alibaba.druid.wall.WallConfig">
        <!-- 批量sql -->
        <property name="multiStatementAllow" value="true" />
    </bean>

    <!--3.配置SqlSessionFactory對象 -->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <!--注入數據庫連接池 -->
        <property name="dataSource" ref="dataSource" />
        <!--配置mybatis全局配置文件:mybatis-config.xml -->
        <property name="configLocation"
            value="classpath:mybatis-config.xml" />
        <!-- 因為我們這采用的是Mybatis Java API方式，因此不需要配置 -->
        <!--掃描entity包,使用別名,多個用;隔開 -->
        <!-- <property name="typeAliasesPackage" value="com.dx.test.model"/> -->
        <!--掃描sql配置文件:mapper需要的xml文件 -->
        <!-- <property name="mapperLocations" value="classpath:mapper/*.xml"/> -->
    </bean>

    <!-- Mapper接口所在包名，Spring會自動查找其下的類 -->
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.dx.test.mapper" />
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
    </bean>

    <!-- 如果想對單個mapper類關聯上sqlSessionFactory，可以這么使用，具體參考：http://mybatis.org/spring/getting-started.html -->
    <!-- <bean id="articlerMapper" class="org.mybatis.spring.mapper.MapperFactoryBean"> 
        <property name="mapperInterface" value="com.dx.test.dao.mapper.ArticleMapper" 
        /> <property name="sqlSessionFactory" ref="sqlSessionFactory" /> </bean> -->

    <!-- (事務管理)transaction manager, use JtaTransactionManager for global tx -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>
</beans>

上邊加粗本分是要修改的部分。

5）刪除、批量刪除

在mapper類中新建查詢、批量查詢接口：

    /**
     * +根據文章分類id，刪除文章分類
     * 
     * @param id 文章分類id
     * @return 影響條數
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE)
    @Delete("delete from article_category where id=#{id}")
    int delete(Integer id);
    
    /**
     * +根據文章分類id集合，刪除文章分類
     * 
     * @param list 文章分類id集合
     * @return 影響條數
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE)
    @DeleteProvider(type = ArticleCategorySqlProvider.class, method = "batchDelete")
    int batchDelete(@Param("list") List<Integer> list);
    
    /**
     * +批量刪除記錄
     *
     * @param list 待刪除id集合
     * @return returnResult
     */
    @Options(useCache = true, flushCache = Options.FlushCachePolicy.TRUE)
    @Delete("<script>" +
            "delete from `article_category` where `id` in " +
            "<foreach collection=\"list\" index=\"i\" open=\"(\" separator=\",\" close=\")\" item=\"item\"  >" +
            "#{item}" +
            "</foreach>" +
            "</script>")
    int batchDeleteWithScript(@Param("list") List<Integer> list);

在mapper sql provider類中新建sql幫助方法：

   /**
    * +根據id集合，獲取文章分類列表 SQL
    *
    * @param map map
    * @return returnResult
    */
   public String batchDelete(final Map<String, List<Integer>> map) {
       List<Integer> tmpList = map.get("list");
       if (tmpList == null || tmpList.isEmpty()) {
           return null;
       }

       StringBuilder sql = new StringBuilder("DELETE FROM `article_category` WHERE `id` in (");
       for (int i = 0; i < tmpList.size(); i++) {
           sql.append("#{list[" + i + "]},");
       }
       sql.deleteCharAt(sql.length() - 1);
       sql.append(")");
       sql.append(";");

       return sql.toString();
   }

在測試類中新增測試方法： 

    @Test
    public void testDelete() {
        int result = this.articleCategoryMapper.delete(this.articleCategory.getId());
        Assert.assertEquals(result, 1);
    }

    @Test
    public void testBatchDelete() {
        List<Integer> idList = new ArrayList<Integer>(Arrays.asList(1, 2));
        int result = this.articleCategoryMapper.batchDelete(idList);
        Assert.assertEquals(result, idList.size());
    }

    @Test
    public void testBatchDeleteWithScript() {
        List<Integer> idList = new ArrayList<Integer>(Arrays.asList(3, 4));
        int result = this.articleCategoryMapper.batchDeleteWithScript(idList);
        Assert.assertEquals(result, idList.size());
    }

 

參考《MyBatis與Druid數據庫連接池集成監控統計后WallFilterSQL注入異常問題處理方案》