session.connection () объявлен устаревшим в Hibernate?

Question

Нам нужно иметь возможность получить java.sql.Connection сеанса гибернации.Никакое другое соединение не будет работать, так как это соединение может быть связано с запущенной транзакцией.

Если теперь session.connection () устарела, как мне это сделать?

Answer 1

Теперь вы должны использовать Work API:

session.doWork(
    new Work() {
        public void execute(Connection connection) throws SQLException 
        { 
            doSomething(connection); 
        }
    }
);

Или в Java 8+:

session.doWork(connection -> doSomething(connection)); 

Answer 2

Если session.connect() устарела, как мне это сделать?

Вы должны использовать Session#doWork(Work) и API Work, как указано в Javadoc:

connection()
Устаревший. (планируется удалить в 4.x). Замена зависит от необходимости; для непосредственного использования JDBC используйте doWork(org.hibernate.jdbc.Work); для использования «временного сеанса» (TBD).

У вас есть время до Hibernate 4.x, но использование устаревшего API выглядит как-то так:

:)

Обновление: В соответствии с RE: [hibernate-dev] Проксирование соединения в списке hibernate-dev, похоже, что первоначальное намерение устареть должен был препятствовать использованию Session#connection(), потому что он был / считается «плохим» API, но он должен был остаться в то время. Я думаю, они изменили свое мнение ...

Answer 3

Попробуйте это

((SessionImpl)getSession()).connection()

На самом деле getSession возвращает тип интерфейса сеанса, вы должны увидеть исходный класс для сеанса, набрать тип в исходный класс и получить соединение.УДАЧИ!

Answer 4

Это то, что я использую и работает для меня. Переведите метод Session в SessionImpl и легко получите объект подключения:

SessionImpl sessionImpl = (SessionImpl) session;
Connection conn = sessionImpl.connection();

где session - имя вашего объекта сеанса Hibernate.

Answer 5

Вот способ сделать это в Hibernate 4.3, и это не рекомендуется:

  Session session = entityManager.unwrap(Session.class);
  SessionImplementor sessionImplementor = (SessionImplementor) session;
  Connection conn = sessionImplementor.getJdbcConnectionAccess().obtainConnection();

Answer 6

Существует еще один вариант, в котором все еще используется много приведений, но, по крайней мере, он не нуждается в отражении, который вернет вам проверку времени компиляции:

public Connection getConnection(final EntityManager em) {
  HibernateEntityManager hem = (HibernateEntityManager) em;
  SessionImplementor sim = (SessionImplementor) hem.getSession();
  return sim.connection();
}

Конечно, вы могли бы сделать это еще "красивее" с помощью нескольких instanceof проверок, но версия выше работает для меня.

Answer 7

connection() просто устарел на интерфейсе.Это все еще доступно на SessionImpl.Вы можете делать то, что делает Spring, и просто вызывать его.

Вот код HibernateJpaDialect в Spring 3.1.1

public Connection getConnection() {
        try {
            if (connectionMethod == null) {
                // reflective lookup to bridge between Hibernate 3.x and 4.x
                connectionMethod = this.session.getClass().getMethod("connection");
            }
            return (Connection) ReflectionUtils.invokeMethod(connectionMethod, this.session);
        }
        catch (NoSuchMethodException ex) {
            throw new IllegalStateException("Cannot find connection() method on Hibernate session", ex);
        }
    }

Answer 8

Я нашел эту статью

package com.varasofttech.client;

import java.sql.Connection;
import java.sql.SQLException;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.engine.jdbc.connections.spi.ConnectionProvider;
import org.hibernate.engine.spi.SessionFactoryImplementor;
import org.hibernate.internal.SessionImpl;
import org.hibernate.jdbc.ReturningWork;
import org.hibernate.jdbc.Work;

import com.varasofttech.util.HibernateUtil;

public class Application {

public static void main(String[] args) {

    // Different ways to get the Connection object using Session

    SessionFactory sessionFactory = HibernateUtil.getSessionFactory();
    Session session = sessionFactory.openSession();

    // Way1 - using doWork method
    session.doWork(new Work() {
        @Override
        public void execute(Connection connection) throws SQLException {
            // do your work using connection
        }

    });

    // Way2 - using doReturningWork method
    Connection connection = session.doReturningWork(new ReturningWork<Connection>() {
        @Override
        public Connection execute(Connection conn) throws SQLException {
            return conn;
        }
    });

    // Way3 - using Session Impl
    SessionImpl sessionImpl = (SessionImpl) session;
    connection = sessionImpl.connection();
    // do your work using connection

    // Way4 - using connection provider
    SessionFactoryImplementor sessionFactoryImplementation = (SessionFactoryImplementor) session.getSessionFactory();
    ConnectionProvider connectionProvider = sessionFactoryImplementation.getConnectionProvider();
    try {
        connection = connectionProvider.getConnection();
        // do your work using connection
    } catch (SQLException e) {
        e.printStackTrace();
    }
}
}

Это помогло мне.

Answer 9

С Hibernate> = 5.0 вы можете получить Connection следующим образом:

Connection c = sessionFactory.
getSessionFactoryOptions().getServiceRegistry().
getService(ConnectionProvider.class).getConnection();

Answer 10

Для hibenate 4.3 попробуйте это:

public static Connection getConnection() {
        EntityManager em = <code to create em>;
        Session ses = (Session) em.getDelegate();
        SessionFactoryImpl sessionFactory = (SessionFactoryImpl) ses.getSessionFactory();
        try{
            connection = sessionFactory.getConnectionProvider().getConnection();
        }catch(SQLException e){
            ErrorMsgDialog.getInstance().setException(e);
        }
        return connection;
    }