通過DataSourceTransactionManager實現Spring事務

通過注解實現

<!-- 配置阿里druid數據源 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
    <property name="username" value="root"/>
    <property name="password" value="0113"/>
    <property name="url" value="jdbc:mysql://localhost:3306/shiro"/>
</bean>

<!-- 配置事務管理器 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"/>
</bean>

<!--
spring-tx模塊以AOP方式管理spring中的事務；
proxy-target-class設為"true"是基於類的代理；
tx:annotation-driven開啟注解式事務聲明，在方法上添加@Transactional注解即可開啟事務
-->
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

在需要使用事務的方法上添加"@Transactional"，注解，可以通過"rollbackFor"指定特定異常時才進行回滾操作

@Transactional(rollbackFor = Exception.class)
@Override
public void addPermission(String roleName, Set<String> permissions) throws SQLException{
    String addPermission = "INSERT  INTO shiro_web_roles_permissions (role,permission) VALUES (?,?)";
    //批量添加數據
    jdbcTemplate.batchUpdate(addPermission, new BatchPreparedStatementSetter() {
        @Override
        public void setValues(PreparedStatement ps, int i) throws SQLException {
            ps.setString(1, roleName);
            ps.setString(2, tempPermissions.get(i));
        }


        @Override
        public int getBatchSize() {
            return permissions.size();
        }
    });
}

通過AOP配置全局事務

使用該種方法，可以不用手動添加"@Transactional"注解
maven依賴:

<!-- AOP -->
<dependency>
    <groupId>org.aspectj</groupId>
    <artifactId>aspectjrt</artifactId>
    <version>1.6.12</version>
</dependency>
<dependency>
    <groupId>org.aspectj</groupId>
    <artifactId>aspectjweaver</artifactId>
    <version>1.6.12</version>
</dependency>

配置:

<!-- 配置阿里druid數據源 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
    <property name="username" value="root"/>
    <property name="password" value="0113"/>
    <property name="url" value="jdbc:mysql://localhost:3306/shiro"/>
</bean>

<!-- 配置JdbcTemplate -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="dataSource"/>
</bean>

<!-- 配置注解方式使用事務 -->
<tx:annotation-driven proxy-target-class="true"/>

<!-- 配置AOP,配置通知的屬性 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
    <tx:attributes>
        <tx:method name="*" propagation="REQUIRED" rollback-for="Exception"/>
    </tx:attributes>
</tx:advice>

<!-- 配置AOP,配置切面 -->
<aop:config proxy-target-class="true">
    <aop:advisor advice-ref="txAdvice" pointcut="within(com.lifeofcoding.shiro.dao.impl..*)"/>
</aop:config>

編程式事務

需要手動commit以及rollback，比以上各種方式更靈活

public void addPermission(String roleName, Set<String> permissions) throws SQLException{
    String addPermission = "INSERT  INTO shiro_web_roles_permissions (role,permission) VALUES (?,?)";
    //聲明TransactionDefinition
    DefaultTransactionDefinition transactionDefinition = new DefaultTransactionDefinition();
    //聲明DatasourceTransactionManager
    DataSourceTransactionManager dm = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
    //聲明TransactionStatus
    TransactionStatus tmp = dm.getTransaction(transactionDefinition);
    permissions.remove("");
    ArrayList<String> tempPermissions = new ArrayList<>(permissions);
    try {
        //批量添加數據
        jdbcTemplate.batchUpdate(addPermission, new BatchPreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement ps, int i) throws SQLException {
                ps.setString(1, roleName);
                ps.setString(2, tempPermissions.get(i));
            }
            
            @Override
            public int getBatchSize() {
                return permissions.size();
            }
        });
        //手動提交事務
        dm.commit(tmp);
    }catch (Exception e){
        //發生異常時回滾
        dm.rollback(tmp);
        //把異常拋出，讓調用方處理
        throw e;
    }
}