JDBC Spring数据 @Transactional不起作用

huangapple
go评论103阅读模式
英文:

JDBC Spring data @Transactional not working

问题

我正在使用Spring Boot和Spring Data JDBC。

我编写了这个Repository类

  1. @Repository
  2. @Transactional(rollbackFor = Exception.class)
  3. public class RecordRepository {
  4.     public RecordRepository() {}
  6.     public void insert(Record record) throws Exception {
  7.         JDBCConfig jdbcConfig = new JDBCConfig();
  8.         SimpleJdbcInsert messageInsert = new SimpleJdbcInsert(jdbcConfig.postgresDataSource());
  10.         messageInsert.withTableName(record.tableName()).execute(record.content());
  11.         throw new Exception();
  12.     }
  13. }

然后我编写了一个客户端类来调用insert方法

  1. @EnableJdbcRepositories()
  2. @Configuration
  3. public class RecordClient {
  4.     @Autowired
  5.     private RecordRepository repository;
  7.     public void insert(Record r) throws Exception {
  8.         repository.insert(r);
  9.     }
  10. }

我期望当调用RecordClient的insert()方法时，不会向数据库插入记录，因为RecordRepository的insert()方法抛出了Exception。然而实际上记录确实被添加了。

我漏掉了什么吗？

编辑。这是我配置数据源的类

  1. @Configuration
  2. @EnableTransactionManagement
  3. public class JDBCConfig {
  5.     @Bean
  6.     public DataSource postgresDataSource() {
  7.         DriverManagerDataSource dataSource = new DriverManagerDataSource();
  8.         dataSource.setDriverClassName("org.postgresql.Driver");
  9.         dataSource.setUrl("jdbc:postgresql://localhost:5432/db");
  10.         dataSource.setUsername("postgres");
  11.         dataSource.setPassword("root");
  13.         return dataSource;
  14.     }
  15. }
英文:

I'm using springboot and spring-data-jdbc.

I wrote this repository class

  1. @Repository
  2. @Transactional(rollbackFor = Exception.class)
  3. public class RecordRepository {
  4.     public RecordRepository() {}
  6.     public void insert(Record record) throws Exception {
  7.         JDBCConfig jdbcConfig = new JDBCConfig();
  8.         SimpleJdbcInsert messageInsert = new SimpleJdbcInsert(jdbcConfig.postgresDataSource());
  10.         messageInsert.withTableName(record.tableName()).execute(record.content());
  11.         throw new Exception();
  12.     }
  13. }

Then I wrote a client class that invokes the insert method

  1. @EnableJdbcRepositories()
  2. @Configuration
  3. public class RecordClient {
  4.     @Autowired
  5.     private RecordRepository repository;
  7.     public void insert(Record r) throws Exception {
  8.         repository.insert(r);
  9.     }
  10. }

I would expect that no record are insert to db when RecordClient's insert() method is invoked, because RecordRespository's insert() throws Exception. Instead the record is added however.

What am I missing?

EDIT. This is the class where I configure my Datasource

  1. @Configuration
  2. @EnableTransactionManagement
  3. public class JDBCConfig {
  5.     @Bean
  6.     public DataSource postgresDataSource() {
  7.         DriverManagerDataSource dataSource = new DriverManagerDataSource();
  8.         dataSource.setDriverClassName("org.postgresql.Driver");
  9.         dataSource.setUrl("jdbc:postgresql://localhost:5432/db");
  10.         dataSource.setUsername("postgres");
  11.         dataSource.setPassword("root");
  13.         return dataSource;
  14.     }
  15. }

答案1

得分: 2

你需要注入你的 datasource，而不是手动创建它。我猜这是因为 @Transactional 只对 Spring 管理的 bean 起作用。如果你通过调用 new 构造函数（例如 new JDBCConfig(). postgresDataSource()）来创建数据源实例，那么你是在手动创建它，它不是一个由 Spring 管理的 bean。

  1. @Repository
  2. @Transactional(rollbackFor = Exception.class)
  3. public class RecordRepository {
  5.   @Autowired
  6.   DataSource dataSource;
  8.   public RecordRepository() {}
  10.   public void insert(Record record) throws Exception {
  11.     SimpleJdbcInsert messageInsert = new SimpleJdbcInsert(dataSource);
  12.     messageInsert.withTableName(record.tableName()).execute(record.contents());
  13.     throw new Exception();
  14.   }
  15. }
英文:

You have to inject your datasource instead of creating it manually. I guess because @Transactional only works for Spring managed beans. If you create a datasource instance by calling new constructor (like this new JDBCConfig(). postgresDataSource()), you are creating it manually and it's not a Spring managed beans.

  1. @Repository
  2. @Transactional(rollbackFor = Exception.class)
  3. public class RecordRepository {
  5.   @Autowired
  6.   DataSource dataSource;
  8.   public RecordRepository() {}
  10.   public void insert(Record record) throws Exception {
  11.     SimpleJdbcInsert messageInsert = new SimpleJdbcInsert(dataSource);
  12.     messageInsert.withTableName(record.tableName()).execute(record.contents());
  13.     throw new Exception();
  14.   }
  15. }

huangapple
  • 本文由 发表于 2020年10月2日 17:06:23
  • 转载请务必保留本文链接：https://go.coder-hub.com/64168926.html
  • java
  • spring
  • spring-data
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定