Hibernate JDBCでバッチ処理

2008/11/11 11:31Update

Hibernateでは、データの更新や挿入、削除などを行うとき、Session.save(...)やSession.delete(...)、Session.update(...)などのメソッドがありますが、大量のデータ（バッチ処理）の場合、OutOfMemoryExceptionを起こったり、効率を低下しまったりすることがあります。

こうした処理の場合、session.flush()やsession.clear()を使って、ある程度のパフォーマンスの改善ができますが、JDBCに比べ性能的には大幅に劣ることも確かめられています。

本文はHibernateでJDBCの使い方について学びます。

手順

１）org.hibernate.Sessionからjava.sql.Connectionを取得

Session session = ...;
Connection connection = sess.connection();

２）ConnectionからPreparedStatement オブジェクトやStatement オブジェクトを生成

PreparedStatement preparedStatement = connection.prepareStatement(sql);

または

Statement statement = connection.createStatement();

３）SQLの実行

statement.executeUpdate(sql);

サンプル

    //sql例： DELETE FROM some_table
    //INSERT... SELECT ...
    public static void testJdbcConnection(Session sess, String sql) {
        //java.sql.Connection
        Connection connection = sess.connection();
        
        Transaction tr = sess.beginTransaction();
        try {
            //パラメータ付き SQL 文
            //PreparedStatement preparedStatement = connection.prepareStatement(sql);
            //preparedStatement.setString(0, "value");
            //preparedStatement.executeUpdate();
            
            Statement statement = connection.createStatement();
            statement.executeUpdate(sql);
            
            tr.commit();
        } catch (SQLException e) {
            tr.rollback();
        }
    }