在spring data jpa中，同一事务中的修改是不可见的，为什么我在同一事务中修改后得到null？

Question

首先显示代码，这是我的代码，如下所示：

   public void saveTestTx() {
        Lock lock = new Lock();
        lock.setName("ABCDEFG");
        lock.setDeviceId("22dfgdfgdftrtg");
        lock.setCreateTime((new Date()));
        Lock lock1 = lockDao.saveAndFlush(lock);
        System.out.println("lock1 = " + lock1);
        Lock lock2 = lockDao.findByDeviceId(lock.getDeviceId());
        System.out.println("lock2 = " + lock2);  // got null here
    }

在此处输入图像描述（这是屏幕截图）

我确信方法“saveTestTx（）”是一个完整的事务，因为如果我调用print（22/0），它可以回滚。我的意思是从192行到199行的代码在同一个事务中。根据我的java开发经验，我认为lock2是lock1的结果，我知道在打印lock2之前，事务还没有提交，但它们在同一个事务中，同一事务中的修改是可见的，所以在提交事务之前，可以从调用“saveAndFlush（）”方法后选择，并在控制台打印insert语句，但事实上，为什么lock2打印为null？

我的交易配置如下：

@Configuration
public class TxConfig {
    @Bean("txSource")
    public TransactionAttributeSource transactionAttributeSource() {
        NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();
        RuleBasedTransactionAttribute readOnlyTx = new RuleBasedTransactionAttribute();
        readOnlyTx.setReadOnly(true);
        readOnlyTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);
        RuleBasedTransactionAttribute requiredTx = new RuleBasedTransactionAttribute(TransactionDefinition.PROPAGATION_REQUIRED,
                Collections.singletonList(new RollbackRuleAttribute(Exception.class)));
        int isolationLevel = requiredTx.getIsolationLevel();
        // requiredTx.setTimeout(90);
        Map<String, TransactionAttribute> txMap = new HashMap<>();
        txMap.put("init*", requiredTx);
        txMap.put("add*", requiredTx);
        txMap.put("save*", requiredTx);
        txMap.put("insert*", requiredTx);
        txMap.put("create*", requiredTx);
        txMap.put("persist*", requiredTx);
        txMap.put("update*", requiredTx);
        txMap.put("modify*", requiredTx);
        txMap.put("merge*", requiredTx);
        txMap.put("bind*", requiredTx);
        txMap.put("delete*", requiredTx);
        txMap.put("del*", requiredTx);
        txMap.put("drop*", requiredTx);
        txMap.put("remove*", requiredTx);
        txMap.put("reset*", requiredTx);
        txMap.put("cancel*", requiredTx);
        txMap.put("login*", requiredTx);
        txMap.put("*", readOnlyTx);
        source.setNameMap(txMap);
        return source;
    }


    @Bean
    public AspectJExpressionPointcutAdvisor pointcutAdvisor(TransactionInterceptor txInterceptor) {
        AspectJExpressionPointcutAdvisor pointcutAdvisor = new AspectJExpressionPointcutAdvisor();
        pointcutAdvisor.setAdvice(txInterceptor);
//    pointcutAdvisor.setExpression("execution (* com.hl..service..*.*(..))");
        pointcutAdvisor.setExpression("execution (* com..service..*.*(..)) || execution (* com..dao..*.*(..))");
        return pointcutAdvisor;
    }

    @Bean("txInterceptor")
    TransactionInterceptor getTransactionInterceptor(PlatformTransactionManager tx) {
        return new TransactionInterceptor(tx, transactionAttributeSource());
    }

}

我的实体代码如下：

@Data
@ToString(callSuper = true)
@Entity
@Table(name = "police_lock")
@SQLDelete(sql = "update lock set is_deleted = 1 where id = ?")
@Where(clause = "is_deleted = 0")
@DynamicInsert
@DynamicUpdate
public class Lock extends LongBaseEntity {
    public static interface AddGroup {};
    public static interface UpdateGroup {};

    private static final long serialVersionUID = 1L;

    public Lock() {
        super();
    }

    public Lock(Long id) {
        this.id = id;
    }
    public Lock(boolean isInit) {
        super(isInit);
    }
    @NotBlank(groups = {AddGroup.class,UpdateGroup.class})
    private String deviceId;

    @NotBlank(groups = {AddGroup.class,UpdateGroup.class})
    private String name;
}

我的表格如下：

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for police_lock
-- ----------------------------
DROP TABLE IF EXISTS `police_lock`;
CREATE TABLE `police_lock` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `device_id` varchar(36) NOT NULL COMMENT 'device_id',
  `name` varchar(40) NOT NULL COMMENT 'name',
  `create_time` datetime NOT NULL COMMENT 'create_time',
 `is_deleted` bit(1) DEFAULT b'0' COMMENT 'is_deleted',  
  PRIMARY KEY (`id`),
  UNIQUE KEY `device_id` (`device_id`)
) ENGINE=InnoDB AUTO_INCREMENT=96 DEFAULT CHARSET=utf8mb4 COMMENT='lock';

findByDeviceId（）方法是spring数据jpa接口方法，仅定义一个方法就足够了。这是spring data jpa的特性，在调用saveAndFlush（）方法后，它发送如下sql：

Hibernate: insert into police_lock (create_time, is_deleted, device_id, name) values (?, ?, ?, ?)

该方法执行后，提交事务，数据库生成新记录。当然，它不是在方法执行之前生成的。但我的问题是：虽然它没有提交，但修改应该通过同一事务中的以下代码看到，即使它没有提交。但我的不是。我不知道为什么。。我错过什么了吗？

我的代码在Spring boot、Spring data jpa、mysql下。

Answer 1

我现在修复了，我的事务配置有问题，我修改如下：

@Configuration
public class TxConfig2 {
    @Autowired
    private PlatformTransactionManager transactionManager;

    @Bean(name = "txAdvice")
    public TransactionInterceptor getAdvisor() throws Exception {
        System.out.println("transactionManager = " + transactionManager);
        Properties properties = new Properties();
        properties.setProperty("init*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("add*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("insert*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("create*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("persist*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("update*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("modify*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("merge*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("bind*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("del*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("drop*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("remove*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("reset*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("cancel*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("login*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("save*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("update*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("delete*", "PROPAGATION_REQUIRED,-Exception");
        properties.setProperty("*", "PROPAGATION_REQUIRED,-Exception,readOnly");
        TransactionInterceptor tsi = new TransactionInterceptor(transactionManager, properties);
        return tsi;
    }
    @Bean
    public BeanNameAutoProxyCreator txProxy() {
        BeanNameAutoProxyCreator creator = new BeanNameAutoProxyCreator();
        creator.setInterceptorNames("txAdvice");
        creator.setBeanNames("*Service","*Dao");
        creator.setProxyTargetClass(true);
        return creator;
    }
}

那么它工作得很好！！！