Atomikos：使用PostgreSQL时无法保存数据 [英] Atomikos: data not getting saved when using PostgreSQL
问题描述
在使用 Atomikos 时遇到了一个奇怪的问题。
I have encountered a strange issue while using Atomikos.
我有一个小型测试应用程序（Spring + Hibernate）。它使用两个不同的数据源，我需要测试 JTA 非Java EE容器（在我的情况下为Tomcat）上的功能。
I have a small test application (Spring + Hibernate). It uses two different data sources which I need to test JTA functionality on a non Java EE container (Tomcat in my case).
当我使用MySQL作为数据库时，所有内容都可以毫无问题地保存下来。但是当我切换到PostgreSQL时，数据并没有保存到数据库中。
When I use MySQL as a database everything gets saved without a problem. But when I switch to PostgreSQL data are not getting saved to the database.
如果我不使用 @Transactional ，有趣的是code>并手动开始和提交事务-一切正常。但是，当使用 @Transactional 时，不会保存数据。我可以看到 hibernate_sequence 表在数据库中确实得到了更新（数字增加了），而只有数据本身没有被更新。尽管我在Atomikos日志中看到数据已提交等事实，但所有这一切。同样，SAME代码在MySQL中也能正常工作。此问题仅在使用PostgreSQL时发生。
What is interesting that IF I'm not using @Transactional and manually begin and commit transactions - everything works fine. But when using @Transactional - data are not getting saved. I can see that hibernate_sequence table DOES gets updated in the database (numbers are increased), and only the data itself is not. And all this despite the fact that I see in Atomikos logs that data was committed etc. Again the SAME code works fine with MySQL. This issue occurs only when using PostgreSQL.
我已经在PostgreSQL版本9.4（Linux上为64位）和9.5版本（在Windows 10上为64位）上进行了测试，并使用了不同的PostgreSQL JDBC 驱动程序版本（包括JDBC4和JDBC3）。
I have tested it both on PostgreSQL version 9.4 (64bit on Linux) and 9.5 (64bit on Windows 10) and using different PostgreSQL JDBC driver versions (both JDBC4 and JDBC3).
Atomikos版本： 4.0.4 （目前最新）和 3.9.3 。
春季版本： 4.0 .9 。
休眠版本： 3.6.10.Final 。
Atomikos versions tested: 4.0.4 (latest as of now) and 3.9.3.
Spring version: 4.0.9.
Hibernate version: 3.6.10.Final.
注意
我需要那些确切的Spring和Hibernate版本来仿真需要Atomikos集成到的工作应用程序。
NOTE
I need those exact Spring and Hibernate versions to emulate the working application I need Atomikos to integrate to.
这是我的 spring.xml 配置文件：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
<tx:annotation-driven />
<tx:jta-transaction-manager />
<context:component-scan base-package="com.byteslounge.spring.tx.service.impl" />
<context:component-scan base-package="com.byteslounge.spring.tx.servlet" />
<context:component-scan base-package="com.byteslounge.spring.tx.entity" />
<bean id="sessionFactory1" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
<property name="annotatedClasses">
<list>
<value>com.byteslounge.spring.tx.entity.TableOne</value>
</list>
</property>
<property name="dataSource" ref="dataSource1" />
<property name="hibernateProperties">
<props>
<prop key="hibernate.connection.autocommit">false</prop>
<prop key="hibernate.dialect">org.hibernate.dialect.PostgreSQLDialect</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.hbm2ddl.auto">update</prop>
<prop key="hibernate.current_session_context_class">jta</prop>
<prop key="javax.persistence.transactionType">jta</prop>
<prop key="hibernate.transaction.factory_class">com.atomikos.icatch.jta.hibernate3.AtomikosJTATransactionFactory </prop>
<prop key="hibernate.transaction.manager_lookup_class">com.atomikos.icatch.jta.hibernate3.TransactionManagerLookup</prop>
</props>
</property>
</bean>
<bean id="dataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
<property name="uniqueResourceName" value="DataSource1" />
<property name="xaDataSource" ref="dataBase1" />
<property name="maxPoolSize" value="20" />
<property name="minPoolSize" value="10"/>
</bean>
<bean id="dataBase1" class="org.postgresql.xa.PGXADataSource" lazy-init="true">
<property name="user" value="tester1" />
<property name="password" value="123456" />
<property name="serverName" value="localhost" />
<property name="portNumber" value="5432" />
<property name="databaseName" value="test_db1" />
<property name="url" value="jdbc:postgresql://localhost:5432/test_db1" />
</bean>
<bean id="sessionFactory2" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
<property name="annotatedClasses">
<list>
<value>com.byteslounge.spring.tx.entity.TableTwo</value>
</list>
</property>
<property name="dataSource" ref="dataSource2" />
<property name="hibernateProperties">
<props>
<prop key="hibernate.connection.autocommit">false</prop>
<prop key="hibernate.dialect">org.hibernate.dialect.PostgreSQLDialect</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.hbm2ddl.auto">update</prop>
<prop key="hibernate.current_session_context_class">jta</prop>
<prop key="javax.persistence.transactionType">jta</prop>
<prop key="hibernate.transaction.factory_class">com.atomikos.icatch.jta.hibernate3.AtomikosJTATransactionFactory </prop>
<prop key="hibernate.transaction.manager_lookup_class">com.atomikos.icatch.jta.hibernate3.TransactionManagerLookup</prop>
</props>
</property>
</bean>
<bean id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
<property name="uniqueResourceName" value="DataSource2" />
<property name="xaDataSource" ref="dataBase2" />
<property name="maxPoolSize" value="20" />
<property name="minPoolSize" value="10"/>
</bean>
<bean id="dataBase2" class="org.postgresql.xa.PGXADataSource" lazy-init="true">
<property name="user" value="tester2" />
<property name="password" value="123456" />
<property name="serverName" value="localhost" />
<property name="portNumber" value="5432" />
<property name="databaseName" value="test_db2" />
<property name="url" value="jdbc:postgresql://localhost:5432/test_db2" />
</bean>
<!-- Atomikos -->
<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">
<property name="forceShutdown" value="false" />
</bean>
<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
<property name="transactionTimeout" value="3000" />
</bean>
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager" depends-on="atomikosTransactionManager,atomikosUserTransaction">
<property name="transactionManager" ref="atomikosTransactionManager" />
<property name="userTransaction" ref="atomikosUserTransaction" />
<property name="allowCustomIsolationLevels" value="true" />
</bean>
<!-- DAO -->
<bean id="tableOneDao" class="com.byteslounge.spring.tx.dao.impl.TableOneDaoImpl">
<property name="sessionFactory" ref="sessionFactory1" />
</bean>
<bean id="tableTwoDao" class="com.byteslounge.spring.tx.dao.impl.TableTwoDaoImpl">
<property name="sessionFactory" ref="sessionFactory2" />
</bean>
</beans>
以下代码示例说明了如何保存数据：
Here is a code sample to illustrate how data is getting saved:
@Transactional(rollbackFor=Exception.class)
public void persist(TableOne tableOne, TableTwo tableTwo) throws Exception {
tableOneDao.save(tableOne);
tableTwoDao.save(tableTwo);
}
DAO类具有相同的保存逻辑：
And the DAO classes have the same logic for saving:
@Service
public class TableOneDaoImpl extends HibernateDaoSupport implements TableOneDao {
@Override
public void save(TableOne tableOne) throws Exception {
Session session = null;
try {
session = getSessionFactory().openSession();
session.save(tableOne);
} catch (Exception e) {
throw new Exception("Could not save tableOne!", e);
} finally {
if (session != null) {
session.close();
}
}
}
}
听到执行数据保存逻辑时得到的日志：
And hear are the logs I get when executing data saving logic:
13:48:58.521 [http-bio-8080-exec-3] DEBUG com.atomikos.icatch.imp.CompositeTransactionManagerImp - createCompositeTransaction ( 10000 ): created new ROOT transaction with id 192.168.50.67.tm147946973850200001
13:48:58.605 [http-bio-8080-exec-3] DEBUG org.hibernate.impl.SessionImpl - opened session at timestamp: 14794697385
13:48:58.610 [http-bio-8080-exec-3] DEBUG com.atomikos.icatch.imp.CompositeTransactionImp - registerSynchronization ( com.atomikos.icatch.jta.Sync2Sync@57e48ad3 ) for transaction 192.168.50.67.tm147946973850200001
13:48:58.610 [http-bio-8080-exec-3] DEBUG org.hibernate.jdbc.JDBCContext - successfully registered Synchronization
13:48:58.612 [http-bio-8080-exec-3] DEBUG org.hibernate.jdbc.AbstractBatcher - about to open PreparedStatement (open PreparedStatements: 0, globally: 0)
13:48:58.612 [http-bio-8080-exec-3] DEBUG org.hibernate.jdbc.ConnectionManager - opening JDBC connection
13:48:58.612 [http-bio-8080-exec-3] DEBUG com.atomikos.jdbc.AbstractDataSourceBean - AtomikosDataSoureBean 'DataSource1': getConnection()...
13:48:58.612 [http-bio-8080-exec-3] INFO com.atomikos.jdbc.AbstractDataSourceBean - AtomikosDataSoureBean 'DataSource1': init...
13:48:58.613 [http-bio-8080-exec-3] DEBUG org.hibernate.SQL - select nextval ('hibernate_sequence')
Hibernate: select nextval ('hibernate_sequence')
13:48:58.616 [http-bio-8080-exec-3] DEBUG com.atomikos.icatch.imp.CompositeTransactionImp - addParticipant ( XAResourceTransaction: 3139322E3136382E35302E36372E746D313437393436393733383530323030303031:3139322E3136382E35302E36372E746D31 ) for transaction 192.168.50.67.tm147946973850200001
13:48:58.616 [http-bio-8080-exec-3] DEBUG com.atomikos.datasource.xa.XAResourceTransaction - XAResource.start ( 3139322E3136382E35302E36372E746D313437393436393733383530323030303031:3139322E3136382E35302E36372E746D31 , XAResource.TMNOFLAGS ) on resource DataSource1 represented by XAResource instance org.postgresql.xa.PGXAConnection@7b57a36a
13:48:58.617 [http-bio-8080-exec-3] DEBUG com.atomikos.icatch.imp.CompositeTransactionImp - registerSynchronization ( com.atomikos.jdbc.AtomikosConnectionProxy$JdbcRequeueSynchronization@ede1e016 ) for transaction 192.168.50.67.tm147946973850200001
13:48:58.617 [http-bio-8080-exec-3] DEBUG com.atomikos.jdbc.AtomikosConnectionProxy - atomikos connection proxy for Pooled connection wrapping physical connection org.postgresql.jdbc3g.Jdbc3gConnection@2a39bdf5: calling prepareStatement(select nextval ('hibernate_sequence'))...
13:48:58.627 [http-bio-8080-exec-3] DEBUG org.hibernate.id.SequenceGenerator - Sequence identifier generated: BasicHolder[java.lang.Integer[43]]
13:48:58.627 [http-bio-8080-exec-3] DEBUG org.hibernate.jdbc.AbstractBatcher - about to close PreparedStatement (open PreparedStatements: 1, globally: 1)
13:48:58.627 [http-bio-8080-exec-3] DEBUG org.hibernate.jdbc.ConnectionManager - aggressively releasing JDBC connection
13:48:58.627 [http-bio-8080-exec-3] DEBUG org.hibernate.jdbc.ConnectionManager - releasing JDBC connection [ (open PreparedStatements: 0, globally: 0) (open ResultSets: 0, globally: 0)]
13:48:58.627 [http-bio-8080-exec-3] DEBUG com.atomikos.jdbc.AtomikosConnectionProxy - atomikos connection proxy for Pooled connection wrapping physical connection org.postgresql.jdbc3g.Jdbc3gConnection@2a39bdf5: isClosed()...
13:48:58.627 [http-bio-8080-exec-3] DEBUG com.atomikos.jdbc.AtomikosConnectionProxy - atomikos connection proxy for Pooled connection wrapping physical connection org.postgresql.jdbc3g.Jdbc3gConnection@2a39bdf5: calling getWarnings...
13:48:58.627 [http-bio-8080-exec-3] DEBUG com.atomikos.jdbc.AtomikosConnectionProxy - atomikos connection proxy for Pooled connection wrapping physical connection org.postgresql.jdbc3g.Jdbc3gConnection@2a39bdf5: calling clearWarnings...
13:48:58.627 [http-bio-8080-exec-3] DEBUG com.atomikos.jdbc.AtomikosConnectionProxy - atomikos connection proxy for Pooled connection wrapping physical connection org.postgresql.jdbc3g.Jdbc3gConnection@2a39bdf5: close()...
13:48:58.627 [http-bio-8080-exec-3] DEBUG com.atomikos.datasource.xa.XAResourceTransaction - XAResource.end ( 3139322E3136382E35302E36372E746D313437393436393733383530323030303031:3139322E3136382E35302E36372E746D31 , XAResource.TMSUCCESS ) on resource DataSource1 represented by XAResource instance org.postgresql.xa.PGXAConnection@7b57a36a
13:48:58.628 [http-bio-8080-exec-3] DEBUG org.hibernate.event.def.AbstractSaveEventListener - generated identifier: 43, using strategy: org.hibernate.id.SequenceGenerator
13:48:58.638 [http-bio-8080-exec-3] DEBUG com.atomikos.icatch.jta.Sync2Sync - beforeCompletion() called on Synchronization: org.hibernate.transaction.synchronization.HibernateSynchronizationImpl@3aa81ddb
13:48:58.638 [http-bio-8080-exec-3] DEBUG com.atomikos.icatch.imp.CompositeTransactionImp - commit() done (by application) of transaction 192.168.50.67.tm147946973850200001
13:48:58.641 [http-bio-8080-exec-3] DEBUG com.atomikos.datasource.xa.XAResourceTransaction - XAResource.commit ( 3139322E3136382E35302E36372E746D313437393436393733383530323030303031:3139322E3136382E35302E36372E746D31 , true ) on resource DataSource1 represented by XAResource instance org.postgresql.xa.PGXAConnection@7b57a36a
13:48:58.643 [http-bio-8080-exec-3] DEBUG com.atomikos.icatch.jta.Sync2Sync - afterCompletion ( STATUS_COMMITTED ) called on Synchronization: org.hibernate.transaction.synchronization.HibernateSynchronizationImpl@3aa81ddb
我也设置了< a href = https://www.postgresql.org/docs/9.5/static/runtime-config-resource.html#GUC-MAX-PREPARED-TRANSACTIONS rel = nofollow noreferrer> max_prepared_ postgresql.conf 中的transactions 参数至少与相关Atomikos
I have also set the max_prepared_transactions parameter in the postgresql.conf to be at least as large as the max_connections as it was recommended on the related Atomikos documentation page for PostgreSQL.
我想再次强调，相同的代码在MySQL上可以正常使用。仅当将此Web应用程序配置为使用PostgreSQL时，才会发生此奇怪的问题。
Again I want to emphasize that the same code works fine with MySQL. Only when configuring this web application to use PostgreSQL this strange issue occurs.
任何人都知道可能会有问题吗？
Anyone knows what might be a problem?
推荐答案
解决方案
好的，谜团解决了！原来，我需要显式调用在 session 对象上 flush （）。
以下答案给了我一个提示：
休眠状态没有在数据库中保存对象？
The following answer gave me a hint:
Hibernate not saving Object in the Database?
这是一个可行的示例（请注意 session.flush（），必须在关闭一个会话之前调用它）：
Here is a working example (pay attention to session.flush() which must be called before closing a session):
@Service
public class TableOneDaoImpl extends HibernateDaoSupport implements TableOneDao {
@Override
public void save(TableOne tableOne) throws Exception {
Session session = null;
try {
session = getSessionFactory().openSession();
session.save(tableOne);
session.flush();
} catch (Exception e) {
throw new Exception("Could not save tableOne!", e);
} finally {
if (session != null) {
session.close();
}
}
}
}
同样，当使用MySQL时，无需显式刷新就可以正常工作。
And again, when using MySQL it works just fine without explicit flushing.
上述测试Web应用程序使用了纯 Hibernate 配置和Hibernate的 SessionFactory （即没有 persistence .xml 和JPA entityManager ）。但是我也将同一测试应用程序配置为使用 JPA 。而且在该应用程序中，即使不使用MySQL和PostgreSQL进行显式刷新，所有内容也可以正常工作。
The above mentioned test web application used pure Hibernate configuration and Hibernate's SessionFactory (i.e. without persistence.xml and JPA entityManager). But I also have the same test application configured to use JPA. And in that application everything also works without explicit flushing both with MySQL and PostgreSQL.
这篇关于Atomikos：使用PostgreSQL时无法保存数据的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
