Spring Boot调用JPA save后刷新Postgres物化视图，新数据是否同步？

结论：默认情况下不会包含，核心原因如下：

1. JPA持久化上下文的延迟刷新机制 #

JPA的saveAll()方法仅将实体纳入持久化上下文管理，默认不会立即执行SQL将数据写入数据库。这些变更会在事务提交前才由EntityManager批量刷写到数据库。

而refreshMyView()执行的是PostgreSQL原生SQL，读取的是数据库的实际状态。在saveAll()之后、事务提交前触发视图刷新时，数据库中还没有新保存的数据，因此物化视图不会包含这些新实体。

2. 事务传播的叠加影响 #

Service方法标注了@Transactional，Repository的refreshMyView()方法也标注了@Transactional。Spring事务默认传播行为为REQUIRED，意味着Repository方法会加入Service层的现有事务。在同一事务内，JPA的延迟刷新会导致数据库变更滞后于内存中的持久化上下文，进一步放大了数据不同步的问题。

要确保物化视图能包含新数据，可采用以下调整方案：

方案一：手动触发持久化上下文刷新 #

在saveAll()后调用EntityManager的flush()方法，强制将内存中的变更刷写到数据库，再执行视图刷新：

@Service
@RequiredArgsConstructor
public class MyService {
    private final MyRepository repository;
    private final EntityManager entityManager;

    @Transactional
    public Collection<FooEntity> updateDatabaseEntries() {
        // ...
        val saved = repository.saveAll(dataRecords);
        entityManager.flush(); // 强制刷写数据到数据库
        repository.refreshMyView();
        return saved;
    }
}

方案二：调整事务传播行为 #

将refreshMyView()的事务传播行为改为REQUIRES_NEW，让它在独立事务中执行。需结合方案一使用，确保Service层的变更已刷写到数据库：

@Repository
public interface MyRepository extends JpaRepository<FooEntity, UUID> {

    @Modifying
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    @Query(value = "REFRESH MATERIALIZED VIEW myView", nativeQuery = true)
    void refreshMyView();
}

方案三：PostgreSQL自动刷新物化视图（版本12+） #

若使用PostgreSQL 12及以上版本，可创建带触发器的自动刷新物化视图，适合对实时性要求不极端的场景：

CREATE MATERIALIZED VIEW myView AS SELECT * from foo;
CREATE UNIQUE INDEX idx_myview_id ON myView(id);

-- 创建刷新触发器函数
CREATE OR REPLACE FUNCTION refresh_myview()
RETURNS TRIGGER AS $$
BEGIN
    REFRESH MATERIALIZED VIEW CONCURRENTLY myView;
    RETURN NULL;
END;
$$ LANGUAGE plpgsql;

-- 给foo表添加触发器，数据变更时自动刷新视图
CREATE TRIGGER trigger_refresh_myview
AFTER INSERT OR UPDATE OR DELETE ON foo
FOR EACH STATEMENT EXECUTE FUNCTION refresh_myview();

注：CONCURRENTLY要求物化视图有唯一索引，适合高并发场景，但会产生一定性能开销。

内容的提问来源于stack exchange，提问作者Lutosław