2020-06-23

SSM-Spring【声明式事务控制三】

字数统计: 803字 | 阅读时长: 3分

一、前言

SSM-Spring【声明式事务控制一】中总结了XML方式配置事务控制；
SSM-Spring【声明式事务控制二】中总结了XML方式和注解方式配置事务控制；
本文则主要总结纯注解方式配置事务控制。

二、代码实现

（一）项目结构和数据库表

03-项目结构
数据库表结构：
该表为spring数据库下的名为account的表
01_数据库表结构
数据库表中的数据：
01_数据库表数据

（二）domain

Account.java:

public class Account implements Serializable {
    private Integer id;
    private String name;
    private float money;
    ......
}

（三）dao

IAccountDao.java:

public interface IAccountDao {
    /**
     * 根据id查询账户
     * @param id
     * @return
     */
    public Account findById(Integer id);

    /**
     * 根据账户名查询账户
     * @param name
     * @return
     */
    public Account findByName(String name);

    /**
     * 更新账户信息
     * @param account
     */
    public void update(Account account);
}

AccountDaoImpl.java:

@Repository("accountDao")
public class AccountDaoImpl implements IAccountDao {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    public Account findById(Integer id) {
        return jdbcTemplate.queryForObject("select * from account where id = ?", new BeanPropertyRowMapper<Account>(Account.class), id);
    }

    public Account findByName(String name) {
        return jdbcTemplate.queryForObject("select * from account where name = ?", new BeanPropertyRowMapper<Account>(Account.class), name);
    }

    public void update(Account account) {
        jdbcTemplate.update("update account set name = ?, money = ? where id = ?", account.getName(), account.getMoney(), account.getId());
    }
}

（四）service

IAccountService.java:

public interface IAccountService {
    /**
     * 根据 id 查询账户
     * @param id
     * @return
     */
    public Account findById(Integer id);

    /**
     * 转账操作
     * @param sourceName
     * @param targetName
     * @param money
     */
    public void transfer(String sourceName, String targetName, float money);
}

AccountServiceImpl.java:

@Service("accountService")
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true) //只读型事务配置
public class AccountServiceImpl implements IAccountService {

    @Autowired
    private IAccountDao accountDao;

    public Account findById(Integer id) {
        return accountDao.findById(id);
    }

    @Transactional(propagation = Propagation.REQUIRED, readOnly = false)    //读写型事务配置
    public void transfer(String sourceName, String targetName, float money) {
        //查找source账户
        Account sourceAccount = accountDao.findByName(sourceName);
        //2.2、查找target账户
        Account targetAccount = accountDao.findByName(targetName);
        //2.3、source账户金额减少
        sourceAccount.setMoney(sourceAccount.getMoney() - money);
        //2.4、target账户金额增加
        targetAccount.setMoney(targetAccount.getMoney() + money);
        //2.5、更新source账户信息
        accountDao.update(sourceAccount);
        int a = 10/0;
        //2.6、更新target账户信息
        accountDao.update(targetAccount);
    }
}

（五）配置（Configuration）

SpringConfiguration.java:

@Configuration
@ComponentScan("com.zuobiao")
@Import({JdbcConfiguration.class, TransactionConfiguratiion.class})
@EnableTransactionManagement
public class SpringConfiguration {
}

JdbcConfiguration.java:

@Configuration
@PropertySource("jdbc.properties")
public class JdbcConfiguration {

    @Value("${jdbc.driver}")
    private String driver;

    @Value("${jdbc.url}")
    private String url;

    @Value("${jdbc.username}")
    private String username;

    @Value("${jdbc.password}")
    private String password;

    /**
     * 创建DataSource
     * @return
     */
    @Bean
    public DataSource createDataSource(){
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName(driver);
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);
        return dataSource;
    }

    /**
     * 创建JdbcTemplate
     * @param dataSource
     * @return
     */
    @Bean
    public JdbcTemplate createTemplate(DataSource dataSource){
        return new JdbcTemplate(dataSource);
    }
}

jdbc.properties:

jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring?serverTimezone=UTC
jdbc.username=root
jdbc.password=123456

TransactionConfiguratin.java:

/**
 * 和事务相关的配置类
 */
@Configuration
public class TransactionConfiguratiion {

    /**
     * 创建TransactionManager对象
     * @return
     */
    @Bean
    public PlatformTransactionManager createTransactionManager(DataSource dataSource){
        return new DataSourceTransactionManager(dataSource);
    }
}

三、总结

和XMl方式相比，该方法还是有缺陷的：
1、可以看到在AccountServiceImpl.java中针对不同的方法需要添加不同的配置。因此，如果业务层中的方法比较多的话，那么就会比较麻烦，并且重复代码会增多。
2、和使用XML方法进行配置相比，当使用到了注解时，数据访问层不能再直接继承JdbcDaoSupport，从而直接使用JdbcTemplate，而是需要重新在XML文件中进行配置之后才能使用。
因此，相比较而言，可能使用XML前期比较麻烦，但是这会起到一劳永逸的效果。

Java新手，若有错误，欢迎指正！

| 阅读量次