Глава 15. Пакетная обработка

1. 15.1. Пакетная вставка
2. 15.2. Пакетное обновление
3. 15.3. Интерфейс StatelessSession
4. 15.4. Операции в DML-стиле

Наивный подход к вставке 100 000 строк в базу данных с использованием Hibernate может выглядеть так:

Session session = sessionFactory.openSession();
Transaction tx = session.beginTransaction();
for ( int i=0; i<100000; i++ ) {
    Customer customer = new Customer(.....);
    session.save(customer);
}
tx.commit();
session.close();

Сие упадёт с OutOfMemoryException где-то около 50 000-й строки. Это связано с тем, что Hibernate кэширует все вновь вставленные экземпляры клиента в кэше уровня сессии. В этой главе мы покажем вам, как избежать этой проблемы.

Если вы выполняете пакетную обработку, вам необходимо включить использование пакетной обработки JDBC. Это абсолютно необходимо, если вы хотите достичь оптимальной производительности. Установите размер пакета JDBC на разумное число (например, 10-50):

hibernate.jdbc.batch_size 20

Hibernate отключает пакетную вставку на уровне JDBC прозрачно, если вы используете генератор идентификаторов identity.

Вы также можете выполнять такую работу в процессе, когда взаимодействие с кэшем второго уровня полностью отключено:

hibernate.cache.use_second_level_cache false

Однако это не является абсолютно необходимым, поскольку мы можем явно установить CacheMode для отключения взаимодействия с кэшем второго уровня.

15.1. Пакетная вставка

Когда делаете новые объекты постоянными, вызывайте flush(), а затем clear() регулярно, чтобы контролировать размер кеша первого уровня.

Session session = sessionFactory.openSession();
Transaction tx = session.beginTransaction();

for ( int i=0; i<100000; i++ ) {
    Customer customer = new Customer(.....);
    session.save(customer);
    if ( i % 20 == 0 ) { //20, такой же размер, как в JDBC
        //сбросить пакет вставок и освободить память:
        session.flush();
        session.clear();
    }
}

tx.commit();
session.close();

15.2. Пакетное обновление

Для получения и обновления данных применяются те же идеи. Кроме того, вам нужно использовать scroll(), чтобы получить преимущество от использования серверных курсоров запросов, которые возвращают много записей.

Session session = sessionFactory.openSession();
Transaction tx = session.beginTransaction();

ScrollableResults customers = session.getNamedQuery("GetCustomers")
    .setCacheMode(CacheMode.IGNORE)
    .scroll(ScrollMode.FORWARD_ONLY);
int count=0;
while ( customers.next() ) {
    Customer customer = (Customer) customers.get(0);
    customer.updateStuff(...);
    if ( ++count % 20 == 0 ) {
        //сбросить пакет обновлений и освободить память:
        session.flush();
        session.clear();
    }
}

tx.commit();
session.close();