Skip to content

(仿Spring 事务管理)声明式事务管理框架

License

Notifications You must be signed in to change notification settings

byx2000/byx-transaction

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

8 Commits
 
 
 
 
 
 
 
 

Repository files navigation

ByxTransaction

ByxTransaction是一个模仿Spring事务管理的声明式事务框架,实现了Spring中的Transactional声明式事务注解的使用方式,支持PROPAGATION_REQUIREDPROPAGATION_SUPPORTS两种事务传播行为。

Maven引入

<repositories>
    <repository>
        <id>byx-maven-repo</id>
        <name>byx-maven-repo</name>
        <url>https://gitee.com/byx2000/maven-repo/raw/master/</url>
    </repository>
</repositories>

<dependencies>
    <dependency>
        <groupId>byx.transaction</groupId>
        <artifactId>byx-transaction</artifactId>
        <version>1.0.0</version>
    </dependency>
</dependencies>

使用示例

下面通过一个转账案例来快速了解ByxTransaction的使用。

假设数据库中有一张account表,表中有id和balance两个字段,id表示账户id,balance表示当前账户余额。

表中的数据如下:

id balance
1 1000
2 0

表中有两个id分别为1和2的账户,账户1的余额为1000,账户2的余额为0。

AccountDaoAccountDaoImpl

public interface AccountDao {
    void transferIn(Integer id, Integer amount);
    void transferOut(Integer id, Integer amount);
}

public class AccountDaoImpl implements AccountDao {
    private final JdbcUtils jdbcUtils;

    public AccountDaoImpl(JdbcUtils jdbcUtils) {
        this.jdbcUtils = jdbcUtils;
    }

    @Override
    public void transferIn(Integer id, Integer amount) {
        jdbcUtils.update("update account set balance = balance + ? where id = ?",
                amount, id);
    }

    @Override
    public void transferOut(Integer id, Integer amount) {
        jdbcUtils.update("update account set balance = balance - ? where id = ?",
                amount, id);
    }
}

transferIn为转入操作,transferOut为转出操作。

AccountDaoImpl中使用JdbcUtils来操作数据库。JdbcUtils是一个小巧的JDBC工具类,详情请看JdbcUtils

AccountServiceAccountServiceImpl

public interface AccountService {
    void transfer(Integer outId, Integer inId, Integer amount);
}

public class AccountServiceImpl implements AccountService {
    private final AccountDao accountDao;

    public AccountServiceImpl(AccountDao accountDao) {
        this.accountDao = accountDao;
    }

    @Override
    @Transactional
    public void transfer(Integer outId, Integer inId, Integer amount) {
        accountDao.transferOut(outId, amount);
        accountDao.transferIn(inId, amount);
    }
}

transfer(out, in, amount)表示从id为out的账户转账amount给id为in的账户。

为简单起见,这里省略了转帐前的验证操作(如判断余额是否充足等)。

AccountServiceImpltransfer方法被标注了Transactional注解,表示对当前方法开启事务支持。

main函数的代码如下:

public class Main {
    private static final JdbcUtils jdbcUtils = new JdbcUtils(getDataSource());

    private static DataSource getDataSource() {
        // 返回一个DataSource ...
    }

    public static void main(String[] args) {
        AccountService accountService = new AccountServiceImpl(new AccountDaoImpl(jdbcUtils));
        accountService = TransactionManager.getProxy(jdbcUtils, accountService);
        accountService.transfer(1, 2, 100);
    }
}

下面这行代码用于创建事务增强的代理对象:

accountService = TransactionManager.getProxy(jdbcUtils, accountService);

执行main函数后,可以看到数据库中的数据被成功更新了:

id balance
1 900
2 100

以上是事务成功提交的情况,接下来演示一下事务回滚的情况。

首先把数据库中的数据恢复成下面这样:

id balance
1 1000
2 0

然后修改AccountServiceImpl中的transfer方法:

@Override
@Transactional
public void transfer(Integer outId, Integer inId, Integer amount) {
    accountDao.transferOut(outId, amount);
    int a = 1 / 0;
    accountDao.transferIn(inId, amount);
}

int a = 1 / 0用于故意引发一个RuntimeException,模拟事务中途失败的场景。

再次执行main函数,然后查看数据库:

id balance
1 1000
2 0

可以发现,数据库中的数据并没有变化,这说明事务已成功回滚。

事务传播行为

ByxTransaction支持两种事务传播行为:

  • PROPAGATION_REQUIRED:如果当前已存在事务,则直接使用当前事务,否则新开一个事务
  • PROPAGATION_SUPPORTS:如果当前已存在事务,则直接使用当前事务,否则不使用事务

标注@Transactional注解时通过设置propagationBehavior属性来指定事务传播行为。

// 指定PROPAGATION_REQUIRED传播行为
@Transactional(propagation = Propagation.PROPAGATION_REQUIRED)

// 指定PROPAGATION_SUPPORTS传播行为
@Transactional(propagation = Propagation.PROPAGATION_SUPPORTS)

About

(仿Spring 事务管理)声明式事务管理框架

Topics

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages