2

在我们的 Web 应用程序中，我们有一个HibernateSessionFactory类，即打开和关闭连接。一切都很好，但是当我们更新数据库中的数据时，它在我们的应用程序中并没有改变。不幸的是，我们看到了数据库中的旧数据。我该如何解决？

public class HibernateSessionFactory {

    private static final ThreadLocal threadLocal = new ThreadLocal();
    private static org.hibernate.SessionFactory sessionFactory;

    private static Configuration configuration = new Configuration();
    private static ServiceRegistry serviceRegistry; 

    private static final Logger log = Logger.getLogger(HibernateSessionFactory.class);

    static {
        try {
            configuration.configure();
            serviceRegistry = new ServiceRegistryBuilder().applySettings(configuration.getProperties())
            . buildServiceRegistry();
            sessionFactory = configuration.buildSessionFactory(serviceRegistry);
        } catch (Exception e) {
            log.error("Error Creating SessionFactory",e);

        }
    }

    private HibernateSessionFactory() {
    }

    public static Session getSession() throws HibernateException {
        Session session = (Session) threadLocal.get(); 
        if (session == null || !session.isOpen()) {
            if (sessionFactory == null) {
                rebuildSessionFactory();
            }
            session = (sessionFactory != null) ? sessionFactory.openSession()
            : null;

            threadLocal.set(session);
        }
        return session;
    }

    public static void rebuildSessionFactory() {

        try {
            configuration.configure();
            serviceRegistry = new ServiceRegistryBuilder(). applySettings(configuration.getProperties()) 
            .buildServiceRegistry();
            sessionFactory = configuration.buildSessionFactory(serviceRegistry);
        } catch (Exception e) {
            log.error("Error Creating SessionFactory",e);
        }
    }

    public static void closeSession() throws HibernateException {
        Session session = (Session) threadLocal.get();
        threadLocal.set(null);
        if (session != null) {
            session.flush();
            session.close();

        }
    }

    public static org.hibernate.SessionFactory getSessionFactory() {
        return sessionFactory;
    }

    public static Configuration getConfiguration() {
        return configuration;
    }

}
4

1 回答 1

8

Hibernate 是一个复杂而复杂的框架，用于在您的程序和数据库之间构建一个层，提供一个面向对象的模型来帮助面向对象的程序完成它们的工作。

为了做到这一点，当然，为了提高性能，它创建了一个缓存，以某种方式存储来自数据库或进入数据库的一些数据。

我认为这个问题不在于与数据库的连接，而在于您如何保存和检索数据。我将尝试更好地解释我自己：当您查询数据库以保存数据时，您执行以下步骤：

  1. 公开课
  2. 公开交易
  3. 构建对象
  4. 在会话中刷新并保存对象
  5. 提交事务
  6. 关闭交易
  7. 关闭会话

例如

public Boolean saveNewCliente(Cliente c) {
    Session s = getSession();
    Transaction t = null;
    try {
        t = s.beginTransaction();
        s.save(c);
        s.flush();
        t.commit();
        s.close();
        return true;
    } catch (Exception e) {
         if (t!=null) t.rollback();
        System.out.println(e.getMessage());
        return false;
    }
    finally{
        s.close();
    }

}

当您查询数据库以获取数据时，一个常见的陷阱就是将与事务相关的部分排除在“查询”步骤之外。以及保存数据，你必须

  1. 公开课
  2. 公开交易
  3. 构建查询/标准
  4. 通过会话执行查询
  5. 关闭交易
  6. 关闭会话

如果您不遵循此步骤，您的应用程序中可能有陈旧的数据，但在您的数据库中没有。检查可能是执行您的更新/保存查询并在数据库中手动检查数据是否已更改/创建。如果您的应用程序然后加载陈旧数据，您知道您以错误的方式执行获取查询（不使用事务）。这是一个示例

    public Cliente get(Integer id) {
    Session s = getSession();
    Transaction tx = s.beginTransaction();
    try {
        System.out.println("get cliente by id");
        Cliente res = new Cliente();
        res = (Cliente) s.get(Cliente.class, id);
        tx.commit();
        return res;
    } catch (Exception e) {
        tx.rollback();
        System.out.println(e.getMessage());
        return null;
    }finally{
        s.close();
    }
}

如果您想进一步调查，您可以通过休眠暂停缓存的使用，您可以通过以下方式执行此操作，但请记住，如果数据被缓存，则有原因；）这可用作快速测试以继续在发现错误是否是由于错误的查询使用引起的。

您应该将此添加到您的休眠配置 xml

<!-- to disable cache -->
<property name="hibernate.cache.use_second_level_cache">false</property>
<property name="hibernate.cache.use_query_cache">false</property>
于 2013-10-13T15:26:27.863 回答