1

2

3

4

@Bean

public NutDao nutz(DataSource dataSource) {

    return new NutDao (dataSource);;

}

1

2

3

4

5

6

public void testService() {

    Trans.exec(() -> {

        dao.insert("test_table", Chain.make("id", 3));

        throw new RuntimeException("test exception");

    });

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

public class SpringNutDao extends NutDao {

    public SpringNutDao(DataSource dataSource) {

        super(dataSource);

    }

    @Override

    public void run(ConnCallback callback) {

        Connection con = DataSourceUtils.getConnection(getDataSource());

        try {

            callback.invoke(con);

        } catch (Exception e) {

            if (e instanceof RuntimeException) {

                throw (RuntimeException) e;

            } else {

                throw new RuntimeException(e);

            }

        } finally {

            DataSourceUtils.releaseConnection(con, getDataSource());

        }

    }

}

1

2

3

4

@Bean

public NutDao nutz(DataSource dataSource) {

    return new SpringNutDao(dataSource);

}

1

2

3

4

@Bean

public DataSourceTransactionManager  transactionManager(DataSource dataSource) {

    return new DataSourceTransactionManager(dataSource);

}

1

2

3

4

5

@Transactional

public void testService() {

    dao.insert("test_table", Chain.make("id", 3));

    throw new RuntimeException("test exception");

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

@Autowired

private PlatformTransactionManager transactionManager;

public void testService() {

    DefaultTransactionDefinition def = new DefaultTransactionDefinition();

    TransactionStatus transactionStatus = transactionManager.getTransaction(def);

    try{

        dao.insert("test_table", Chain.make("id", 3));

        throw new RuntimeException("test exception");

    }catch (Exception e){

        if (transactionStatus.isCompleted()) {

            System.out.println("事务已完成，无需回滚");

        }else {

            transactionManager.rollback(transactionStatus);

        }

    }

}