/** * This interceptor adds some pretty syntax highlighting in responses when a browser is detected */ /* @Bean(autowire = Autowire.BY_TYPE) public IServerInterceptor responseHighlighterInterceptor() { ResponseHighlighterInterceptor retVal = new ResponseHighlighterInterceptor(); return retVal; }*/ /* @Bean(autowire = Autowire.BY_TYPE) public IServerInterceptor subscriptionSecurityInterceptor() { SubscriptionsRequireManualActivationInterceptorDstu3 retVal = new SubscriptionsRequireManualActivationInterceptorDstu3(); return retVal; }*/ @Bean public JpaTransactionManager transactionManager(EntityManagerFactory entityManagerFactory) { JpaTransactionManager retVal = new JpaTransactionManager(); retVal.setEntityManagerFactory(entityManagerFactory); return retVal; }
@Before public void setUp() throws Exception { factory = mock(EntityManagerFactory.class); manager = mock(EntityManager.class); tx = mock(EntityTransaction.class); JpaTransactionManager tm = new JpaTransactionManager(factory); tt = new TransactionTemplate(tm); given(factory.createEntityManager()).willReturn(manager); given(manager.getTransaction()).willReturn(tx); given(manager.isOpen()).willReturn(true); bean = new EntityManagerHoldingBean(); @SuppressWarnings("serial") PersistenceAnnotationBeanPostProcessor pabpp = new PersistenceAnnotationBeanPostProcessor() { @Override protected EntityManagerFactory findEntityManagerFactory(String unitName, String requestingBeanName) { return factory; } }; pabpp.postProcessPropertyValues(null, null, bean, "bean"); assertTrue(TransactionSynchronizationManager.getResourceMap().isEmpty()); assertFalse(TransactionSynchronizationManager.isSynchronizationActive()); }
@Test public void testJpaCoexistsHappily() throws Exception { this.context = new AnnotationConfigWebApplicationContext(); this.context.setServletContext(new MockServletContext()); EnvironmentTestUtils.addEnvironment(this.context, "spring.datasource.url:jdbc:hsqldb:mem:testsecdb"); EnvironmentTestUtils.addEnvironment(this.context, "spring.datasource.initialize:false"); this.context.register(EntityConfiguration.class, PropertyPlaceholderAutoConfiguration.class, DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class, SecurityAutoConfiguration.class, ServerPropertiesAutoConfiguration.class); // This can fail if security @Conditionals force early instantiation of the // HibernateJpaAutoConfiguration (e.g. the EntityManagerFactory is not found) this.context.refresh(); assertThat(this.context.getBean(JpaTransactionManager.class)).isNotNull(); }
@Test public void testJpaComponentEMFandTM() throws Exception { JpaComponent comp = new JpaComponent(); comp.setCamelContext(context); assertNull(comp.getEntityManagerFactory()); assertNull(comp.getTransactionManager()); EntityManagerFactory fac = Persistence.createEntityManagerFactory("camel"); JpaTransactionManager tm = new JpaTransactionManager(fac); tm.afterPropertiesSet(); comp.setEntityManagerFactory(fac); comp.setTransactionManager(tm); assertSame(fac, comp.getEntityManagerFactory()); assertSame(tm, comp.getTransactionManager()); JpaEndpoint jpa = (JpaEndpoint) comp.createEndpoint("jpa://" + SendEmail.class.getName()); assertNotNull(jpa); assertNotNull(jpa.getEntityType()); }
/** * * @deprecated */ @Deprecated @Test public void testJpaEndpointCtrUrlEMFandTM() throws Exception { EntityManagerFactory fac = Persistence.createEntityManagerFactory("camel"); JpaTransactionManager tm = new JpaTransactionManager(fac); tm.afterPropertiesSet(); JpaEndpoint jpa = new JpaEndpoint("jpa://org.apache.camel.examples.SendEmail", fac, tm); jpa.setEntityType(SendEmail.class); assertSame(fac, jpa.getEntityManagerFactory()); assertSame(tm, jpa.getTransactionManager()); assertEquals("jpa://org.apache.camel.examples.SendEmail", jpa.getEndpointUri()); assertEquals("camel", jpa.getPersistenceUnit()); }
@Test public void testJpaEndpointCustomEMFandTM() throws Exception { EntityManagerFactory fac = Persistence.createEntityManagerFactory("camel"); JpaTransactionManager tm = new JpaTransactionManager(fac); tm.afterPropertiesSet(); JpaEndpoint jpa = new JpaEndpoint(); jpa.setEntityType(SendEmail.class); jpa.setEntityManagerFactory(fac); jpa.setTransactionManager(tm); assertSame(fac, jpa.getEntityManagerFactory()); assertSame(tm, jpa.getTransactionManager()); assertEquals("jpa://org.apache.camel.examples.SendEmail", jpa.getEndpointUri()); assertEquals("camel", jpa.getPersistenceUnit()); }
protected Site retrieveSiteById(final Long id, final boolean persistentResult) { //Since the methods on this class are frequently called during regular page requests and transactions are expensive, //only run the operation under a transaction if there is not already an entity manager in the view final Site[] response = new Site[1]; transUtil.runOptionalTransactionalOperation(new StreamCapableTransactionalOperationAdapter() { @Override public void execute() throws Throwable { Site site = siteDao.retrieve(id); if (persistentResult) { response[0] = site; } else { response[0] = getNonPersistentSite(site); } } }, RuntimeException.class, !TransactionSynchronizationManager.hasResource(((JpaTransactionManager) transUtil.getTransactionManager()).getEntityManagerFactory())); return response[0]; }
protected Site retrieveDefaultSite(final boolean persistentResult) { //Since the methods on this class are frequently called during regular page requests and transactions are expensive, //only run the operation under a transaction if there is not already an entity manager in the view final Site[] response = new Site[1]; transUtil.runOptionalTransactionalOperation(new StreamCapableTransactionalOperationAdapter() { @Override public void execute() throws Throwable { Site defaultSite = siteDao.retrieveDefaultSite(); if (persistentResult) { response[0] = defaultSite; } else { response[0] = getNonPersistentSite(defaultSite); } } }, RuntimeException.class, !TransactionSynchronizationManager.hasResource(((JpaTransactionManager) transUtil.getTransactionManager()).getEntityManagerFactory())); return response[0]; }
protected List<Site> findAllSites(final boolean persistentResult) { //Since the methods on this class are frequently called during regular page requests and transactions are expensive, //only run the operation under a transaction if there is not already an entity manager in the view final List<Site> response = new ArrayList<Site>(); transUtil.runOptionalTransactionalOperation(new StreamCapableTransactionalOperationAdapter() { @Override public void execute() throws Throwable { List<Site> sites = siteDao.readAllActiveSites(); for (Site site : sites) { if (persistentResult) { response.add(site); } else { response.add(getNonPersistentSite(site)); } } } }, RuntimeException.class, !TransactionSynchronizationManager.hasResource(((JpaTransactionManager) transUtil.getTransactionManager()).getEntityManagerFactory())); return response; }
@Test public void testJpaCoexistsHappily() throws Exception { this.context = new AnnotationConfigWebApplicationContext(); this.context.setServletContext(new MockServletContext()); EnvironmentTestUtils.addEnvironment(this.context, "spring.datasource.url:jdbc:hsqldb:mem:testsecdb"); EnvironmentTestUtils.addEnvironment(this.context, "spring.datasource.initialize:false"); this.context.register(EntityConfiguration.class, PropertyPlaceholderAutoConfiguration.class, DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class, SecurityAutoConfiguration.class, ServerPropertiesAutoConfiguration.class); // This can fail if security @Conditionals force early instantiation of the // HibernateJpaAutoConfiguration (e.g. the EntityManagerFactory is not found) this.context.refresh(); assertNotNull(this.context.getBean(JpaTransactionManager.class)); }
protected Site retrieveSiteById(final Long id, final boolean persistentResult) { //Since the methods on this class are frequently called during regular page requests and transactions are expensive, //only run the operation under a transaction if there is not already an entity manager in the view if (id == null) { return null; } final Site[] response = new Site[1]; transUtil.runOptionalTransactionalOperation(new StreamCapableTransactionalOperationAdapter() { @Override public void execute() throws Throwable { Site site = siteDao.retrieve(id); if (persistentResult) { response[0] = site; } else { response[0] = getNonPersistentSite(site); } } }, RuntimeException.class, !TransactionSynchronizationManager.hasResource(((JpaTransactionManager) transUtil.getTransactionManager()).getEntityManagerFactory())); return response[0]; }
@Autowired @Bean public PlatformTransactionManager transactionManagerEvents(@Qualifier("eventsEntityManagerFactory") final EntityManagerFactory emf) { final JpaTransactionManager mgmr = new JpaTransactionManager(); mgmr.setEntityManagerFactory(emf); return mgmr; }
@Autowired @Bean public PlatformTransactionManager transactionManagerGoogleAuthenticator( @Qualifier("googleAuthenticatorEntityManagerFactory") final EntityManagerFactory emf) { final JpaTransactionManager mgmr = new JpaTransactionManager(); mgmr.setEntityManagerFactory(emf); return mgmr; }
@Autowired @Bean public PlatformTransactionManager transactionManagerMfaAuthnTrust( @Qualifier("mfaTrustedAuthnEntityManagerFactory") final EntityManagerFactory emf) { final JpaTransactionManager mgmr = new JpaTransactionManager(); mgmr.setEntityManagerFactory(emf); return mgmr; }
@Autowired @Bean public PlatformTransactionManager transactionManagerServiceReg(@Qualifier("serviceEntityManagerFactory") final EntityManagerFactory emf) { final JpaTransactionManager mgmr = new JpaTransactionManager(); mgmr.setEntityManagerFactory(emf); return mgmr; }
@Autowired @Bean public PlatformTransactionManager transactionManagerConsent( @Qualifier("consentEntityManagerFactory") final EntityManagerFactory emf) { final JpaTransactionManager mgmr = new JpaTransactionManager(); mgmr.setEntityManagerFactory(emf); return mgmr; }
@Bean @Autowired public PlatformTransactionManager transactionManager(EntityManagerFactory emf) throws NamingException { JpaTransactionManager jpaTransaction = new JpaTransactionManager(); jpaTransaction.setEntityManagerFactory(emf); return jpaTransaction; }
@Bean public PlatformTransactionManager jpaTransactionManager() { return new JpaTransactionManager( this.entityManagerFactoryBean().getObject() ); }
@Bean(name="transactionManager") public JpaTransactionManager transactionManager( EntityManagerFactory entityManagerFactory) { JpaTransactionManager jtm = new JpaTransactionManager(); jtm.setEntityManagerFactory(entityManagerFactory); return jtm; }
/** * Configure given bean using provided configuration settings * @param tm Bean to configure */ public void configure(JpaTransactionManager tm) { // data context id if (dataContextId != null) { tm.setPersistenceUnitName(dataContextId); } // jpa properties if (jpaProperties != null) { tm.setJpaProperties(jpaProperties); } // settings if (transactionSynchronization != null) { tm.setTransactionSynchronization(transactionSynchronization); } if (defaultTimeout != null) { tm.setDefaultTimeout(defaultTimeout); } if (validateExistingTransaction != null) { tm.setValidateExistingTransaction(validateExistingTransaction); } if (globalRollbackOnParticipationFailure != null) { tm.setGlobalRollbackOnParticipationFailure(globalRollbackOnParticipationFailure); } if (failEarlyOnGlobalRollbackOnly != null) { tm.setFailEarlyOnGlobalRollbackOnly(failEarlyOnGlobalRollbackOnly); } if (rollbackOnCommitFailure != null) { tm.setRollbackOnCommitFailure(rollbackOnCommitFailure); } }
@Bean public PlatformTransactionManager getPlatformTransactionManager(final EntityManagerFactory emf) { final JpaTransactionManager transactionManager = new JpaTransactionManager(); transactionManager.setDefaultTimeout(ApplicationProperties.getAsInteger(JWALA_JTA_TRANSACTION_TIMEOUT, 30)); transactionManager.setEntityManagerFactory(emf); return transactionManager; }
@Bean @Autowired public PlatformTransactionManager transactionManager(EntityManagerFactory emf) { JpaTransactionManager txManager = new JpaTransactionManager(); txManager.setEntityManagerFactory(emf); return txManager; }
@Bean public PlatformTransactionManager transactionManager() { JpaTransactionManager txManager = new JpaTransactionManager(); txManager.setDataSource(dataSourceH2()); txManager.setEntityManagerFactory(entityManagerFactory().getObject()); return txManager; }
@Bean @Autowired public JpaTransactionManager transactionManager(EntityManagerFactory entityManagerFactory) { JpaTransactionManager txManager = new JpaTransactionManager(); JpaDialect jpaDialect = new HibernateJpaDialect(); txManager.setEntityManagerFactory(entityManagerFactory); txManager.setJpaDialect(jpaDialect); return txManager; }
@Test public void testEntityManagerCreated() throws Exception { setupTestConfiguration(); this.context.refresh(); assertThat(this.context.getBean(DataSource.class)).isNotNull(); assertThat(this.context.getBean(JpaTransactionManager.class)).isNotNull(); }
@Test public void testDataSourceTransactionManagerNotCreated() throws Exception { this.context.register(DataSourceTransactionManagerAutoConfiguration.class); setupTestConfiguration(); this.context.refresh(); assertThat(this.context.getBean(DataSource.class)).isNotNull(); assertThat(this.context.getBean("transactionManager")) .isInstanceOf(JpaTransactionManager.class); }
@Bean public PlatformTransactionManager transactionManager() { JpaTransactionManager txManager = new JpaTransactionManager(); txManager.setEntityManagerFactory(entityManagerFactory().getObject()); return txManager; }
/** * Transaction manager. * * @return the platform transaction manager */ @Bean public PlatformTransactionManager transactionManager() { JpaTransactionManager tm = new JpaTransactionManager(); tm.setEntityManagerFactory(this.entityManagerFactory().getObject()); return tm; }
/** * 配置 Spring 事务管理器 */ @Bean public PlatformTransactionManager transactionManager(EntityManagerFactory entityManagerFactory) { JpaTransactionManager jpaTransactionManager = new JpaTransactionManager(); jpaTransactionManager.setEntityManagerFactory(entityManagerFactory); return jpaTransactionManager; }