java - JDBC 查询看不到同一事务上的 session.flush 修改

Question

我有一个使用 Spring 和 Hibernate 的项目。

使用 hibernate 进行插入后，即使我调用了 session.flush 方法，我也看不到 jdbc sql 中的数据。知道为什么会发生这种情况吗？

我的配置是这样的:

 <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
    <property name="packagesToScan">
        <list>
            <value>ro.asf.capone.common.model</value>
        </list>
    </property>
    <property name="dataSource" ref="dataSource"></property>
    <property name="hibernateProperties">
        <props>
            <prop key="hibernate.dialect">${agency.hibernate.dialect}</prop>
            <prop key="hibernate.show_sql">${agency.hibernate.show_sql}</prop>
            <prop key="hibernate.format_sql">${agency.hibernate.format_sql}</prop>
            <prop key="hibernate.jdbc.batch_size">100</prop>
            <prop key="hibernate.jdbc.batch_versioned_data">true</prop>
            <prop key="hibernate.jdbc.use_streams_for_binary">true</prop>
            <prop key="hibernate.order_updates">true</prop>
            <prop key="hibernate.connection.release_mode">auto</prop>
            <prop key="hibernate.connection.autocommit">true</prop>
            <prop key="hibernate.cache.region.factory_class">org.hibernate.cache.ehcache.SingletonEhCacheRegionFactory</prop>
            <prop key="hibernate.cache.use_second_level_cache">true</prop>
            <prop key="hibernate.cache.use_query_cache">true</prop>
            <prop key="hibernate.cache.use_structured_entries">true</prop>
            <prop key="hibernate.cache.provider_configuration_file_resource_path">ehcache.xml</prop>
            <prop key="hibernate.generate_statistics">false</prop>
            <prop key="hibernate.query.factory_class">org.hibernate.hql.classic.ClassicQueryTranslatorFactory</prop>
            <prop key="hibernate.query.factory_class">org.hibernate.hql.internal.classic.ClassicQueryTranslatorFactory</prop>
        </props>
    </property>     
    <property name="entityInterceptor" ref="auditInterceptor" />
</bean>

我也尝试过<prop key="hibernate.connection.autocommit">false</prop>得到相同的结果。

数据源是hiraki ds，但我尝试过bonecp，结果相同。

@Bean
public DataSource dataSource() {
    final HikariDataSource dataSource = new HikariDataSource();
 //     dataSource.setAutoCommit(false);
    dataSource.setDriverClassName(jdbcDriver);
    dataSource.setJdbcUrl(jdbcUrl);
    dataSource.setUsername(jdbcUsername);
    dataSource.setPassword(jdbcPassword);
    dataSource.setIdleTimeout(60000);
    dataSource.setMinimumIdle(0);
    dataSource.setMaximumPoolSize(2);
    return dataSource;
}

我正在使用的代码是:

 final AuditUsers typ = new AuditUsers();
    typ.setEntityId(1l);
    typ.setLevel(29);
    final Serializable typid = getSession().save(typ);
    System.out.println(">>>>>>>>>>>>>> id: " + typid);
    getSession().flush();
    getSession().clear();
    final String sqltyp = "select * from AUDIT_USERS where id = " + typid;

  try(Connection con = getConnection(); Statement stm = con.createStatement()){
        System.out.println("!!!" + con.getAutoCommit());
        final ResultSet rs = stm.executeQuery(sqltyp);
        while(rs.next()){
            System.out.println("RS filename: " + rs.getString("ENTITY_ID"));
        }
    }catch (final Exception e) {
        e.printStackTrace();
    }

而且我没有得到 rs 的下一个值。

如果我使用 doWork 方法，结果集会有值，但我不想这样使用它。

                getSession().doWork(new Work() {

                @Override
                public void execute(final Connection connection) throws SQLException {
                    final Statement stm = connection.createStatement();
                    final ResultSet rs = stm.executeQuery(sqltyp);
                    while(rs.next()){
                        System.out.println("RS filename: " + rs.getString("ENTITY_ID"));
                    }
                }
            });

我有一个 HibernateDAOSupport 类，用于设置访问从 spring 配置 xml 设置的数据源和 sessionfactory:

public abstract class HibernateDAOSupport {

    private SessionFactory sessionFactory;

    private DataSource dataSource;


    public SessionFactory getSessionFactory() {
        return sessionFactory;
    }

    public void setSessionFactory(final SessionFactory sessionFactory)    {
        this.sessionFactory = sessionFactory;
    }

    public DataSource getDataSource() {
         return dataSource;
    }

    public void setDataSource(final DataSource dataSource) {
        this.dataSource = dataSource;
    }

    public void setDs(final DataSource dataSource) {
        this.dataSource = dataSource;
    }

    public Session getSession() {
         return sessionFactory.getCurrentSession();
    }

    public Connection getConnection() throws SQLException {
        return dataSource.getConnection();
    }
}

和 xml:

 <bean id="hibernateDAO" class="ro.asf.capone.server.dao.HibernateDAOSupport" abstract="true">
    <property name="sessionFactory" ref="sessionFactory" />
    <property name="dataSource" ref="dataSource" />
 </bean>

Answer 1

我通过更改 getConnection 找到了解决方案实现于HibernateDAOSupport类:

public Connection getConnection(){
    return org.springframework.jdbc.datasource.DataSourceUtils.getConnection(dataSource);
}

感谢 M. Deinum 指出数据源提供了一个新连接，但使用的连接不是同一个。我的印象是单个连接跨越一个事务。