5

我必须使用休眠将大量对象保存到数据库中。我不想一次提交所有这些,而是​​想在会话中存在 n (BATCH_SIZE) 对象时立即提交。

Session session = getSession();
session.setCacheMode(CacheMode.IGNORE);
for(int i=0;i<objects.length;i++){
    session.save(objects[i]);
    if( (i+1) % BATCH_SIZE == 0){
        session.flush();
        session.clear();
    }
}

我会尝试类似上面的方法,但我读到它session.flush()不会将更改提交到数据库。这是以下代码的正确方法吗?

Session session = getSession();
session.setFlushMode(FlushMode.COMMIT);
session.setCacheMode(CacheMode.IGNORE);
session.beginTransaction();
for(int i=0;i<objects.length;i++){
    session.save(objects[i]);
    if( (i+1) % BATCH_SIZE == 0){
        session.getTransaction().commit();
        session.clear();
        //should I begin a new transaction for next batch of objects?
        session.beginTransaction();
    }
}
session.getTransaction().commit();
4

1 回答 1

1

据我所知,您的解决方案是正确的。

可能只有一个问题:根据您从 SessionFactory 获取会话的方式,提交也可能会关闭您的会话,您将不得不打开一个新会话。据我所知,如果您使用 getCurrentSession() 和会话上下文“线程”,这总是会发生。如果您使用的是 openSession() 会话似乎不会被提交自动关闭。

提交事务后,您可以使用 isOpen() 方法轻松检查这一点。如果会话关闭,您必须在进一步调用 save() 之前打开一个新会话。

于 2013-05-20T21:07:14.043 回答