Spring 批次Neo4j物品阅读器

pkln4tw6  于 2022-11-05  发布在  其他
关注(0)|答案(1)|浏览(104)

我试图在spring批处理应用程序中使用Neo4jItemReader从neo4j数据库读取数据,但无法获得org.neo4j.ogm.session.SessionFactory的示例。PS:我还在同一个项目中使用了neo4j的spring数据。
Spring Boot 版本:2.6.7
我试过了

@Bean
fun postReader(): ItemReader<Post> {
    return Neo4jItemReaderBuilder<Post>()
        .name("postReader")
        .sessionFactory(WHERE_TO_GET_IT)
        .matchStatement("(p:Post)")
        .returnStatement("p")
        .pageSize(1000)
        .build()
}
cuxqih21

cuxqih211#

如果您将Sping Boot 与SDN启动程序一起使用,则应该能够自动连接由Boot自动配置的会话工厂:

@Bean
fun postReader(SessionFactory sessionFactory): ItemReader<Post> {
    return Neo4jItemReaderBuilder<Post>()
        .name("postReader")
        .sessionFactory(sessionFactory) // auto-configured by Spring Boot, autowired by Spring Framework
        .matchStatement("(p:Post)")
        .returnStatement("p")
        .pageSize(1000)
        .build()
}

相关问题