13

我有一个基于 Spring 的应用程序。@Transactional只要我对映射到 Java 对象的实体进行操作，我就让 Spring 做所有的魔法并且一切正常。

但是，当我想在未映射到我的任何 Java 实体的表上执行一些自定义工作时，我被卡住了。前段时间，我找到了执行这样的自定义查询的解决方案：

// em is instance of EntityManager
em.getTransaction().begin();
Statement st = em.unwrap(Connection.class).createStatement();
ResultSet rs = st.executeQuery("SELECT custom FROM my_data");
em.getTransaction().commit();

当我尝试使用带有@PersistenceContext注释的 Spring 注入的实体管理器时，我收到了几乎明显的异常：

java.lang.IllegalStateException: 
Not allowed to create transaction on shared EntityManager - 
use Spring transactions or EJB CMT instead

我终于设法像这样提取非共享实体管理器：

@Inject
public void myCustomSqlExecutor(EntityManagerFactory emf){
    EntityManager em = emf.createEntityManager();
    // the em.unwrap(...) stuff from above works fine here
}

然而，我发现这个解决方案既不舒适也不优雅。我只是想知道在这个 Spring 事务驱动的环境中是否有任何其他方法可以运行自定义 SQL 查询？

对于那些好奇的人——当我尝试同时在我的应用程序和相关论坛中创建用户帐户时出现了这个问题——我不希望论坛的用户表映射到我的任何 Java 实体。

4

2 回答 2

13

您可以使用createNativeQuery在数据库上执行任意 SQL。

EntityManager em = emf.createEntityManager();
List<Object> results = em.createNativeQuery("SELECT custom FROM my_data").getResultList();

上述答案仍然适用，但我想编辑一些可能与查看此问题的人相关的附加信息。

虽然确实可以使用createNativeQuery方法通过 EntityManager 执行本机查询；如果您使用的是 Spring 框架，还有一种替代方法（可以说是更好的方法）。

使用 Spring 执行查询的另一种方法（将与配置的事务一起运行）是使用JDBCTemplate。可以在同一个应用程序中同时使用 JDBCTemplate和JPA EntityManager。配置看起来像这样：

基础设施配置类：

@Configuration
@Import(AppConfig.class)
public class InfrastructureConfig {

    @Bean //Creates an in-memory database.
    public DataSource dataSource(){
        return new EmbeddedDatabaseBuilder().build(); 
    }   

    @Bean //Creates our EntityManagerFactory
    public AbstractEntityManagerFactoryBean entityManagerFactory(DataSource dataSource){
        LocalContainerEntityManagerFactoryBean emf = new LocalContainerEntityManagerFactoryBean();
        emf.setDataSource(dataSource);
        emf.setJpaVendorAdapter(new HibernateJpaVendorAdapter());

        return emf;
    }

    @Bean //Creates our PlatformTransactionManager. Registering both the EntityManagerFactory and the DataSource to be shared by the EMF and JDBCTemplate
    public PlatformTransactionManager transactionManager(EntityManagerFactory emf, DataSource dataSource){
        JpaTransactionManager tm = new JpaTransactionManager(emf);
        tm.setDataSource(dataSource);
        return tm;
    }

}

应用配置类：

@Configuration
@EnableTransactionManagement
public class AppConfig {

    @Bean
    public MyService myTransactionalService(DomainRepository domainRepository) {
        return new MyServiceImpl(domainRepository);
    }

    @Bean
    public DomainRepository domainRepository(JdbcTemplate template){
        return new JpaAndJdbcDomainRepository(template);
    }

    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource){
        JdbcTemplate template = new JdbcTemplate(dataSource);
        return template;
    }
}

还有一个同时使用 JPA 和 JDBC 的示例存储库：

public class JpaAndJdbcDomainRepository implements DomainRepository{

    private JdbcTemplate template;
    private EntityManager entityManager;

    //Inject the JdbcTemplate (or the DataSource and construct a new JdbcTemplate)
    public DomainRepository(JdbcTemplate template){
        this.template = template;
    }

    //Inject the EntityManager
    @PersistenceContext
    void setEntityManager(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    //Execute a JPA query
    public DomainObject getDomainObject(Long id){
        return entityManager.find(id);
    }

    //Execute a native SQL Query
    public List<Map<String,Object>> getData(){
        return template.queryForList("select custom from my_data");
    }
}
于 2013-08-15T22:13:31.430 回答
2

您可以使用EntityManager.createNativeQuery(String sql)直接使用 sql 代码或使用EntityManager.createNamedQuery(String name)执行预编译查询。您仍然使用弹簧管理的实体管理器，但处理非托管对象

于 2013-08-15T22:13:44.070 回答