Как получить соединение внутри транзакции Spring?

(полностью переписано на основе ветки комментариев; не знаю, почему мой первоначальный ответ был сосредоточен на Hibernate, кроме того, с чем я сейчас работаю)

Менеджер транзакций полностью ортогонален источникам данных. Некоторые менеджеры транзакций взаимодействуют непосредственно с источниками данных, некоторые взаимодействуют через промежуточный уровень (например, Hibernate), а некоторые взаимодействуют через службы, предоставляемые контейнером (например, JTA).

Когда вы помечаете метод как @Transactional, все это означает, что Spring будет генерировать прокси при загрузке вашего компонента, и этот прокси будет передан любому другому классу, который захочет использовать ваш компонент. Когда вызывается метод прокси, он (прокси) просит диспетчера транзакций либо дать ему незавершенную транзакцию, либо создать новую. Затем он вызывает ваш фактический метод компонента. Когда ваш метод bean возвращается, прокси-сервер снова взаимодействует с менеджером транзакций, чтобы либо сказать «я могу зафиксировать», либо «я должен откатиться». В этом процессе есть повороты; например, транзакционный метод может вызывать другой транзакционный метод и совместно использовать ту же транзакцию.

Хотя менеджер транзакций взаимодействует с DataSource, он не владеет DataSource. Вы не можете попросить менеджера транзакций дать вам соединение. Вместо этого вы должны внедрить специфичный для фрейма объект, который будет возвращать соединения (например, Hibernate SessionFactory). В качестве альтернативы вы можете использовать статические служебные классы с поддержкой транзакций, но они снова привязаны к определенной структуре.

Вероятно, вы можете попробовать DataSourceUtils.getConnection(dataSource) в соответствии с API, он должен вернуть вам текущее соединение с источником данных.

Обновление: на основе ваших комментариев и исходного кода для org.springframework.transaction.support.TransactionSynchronizationManager :

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

TransactionSynchronizationManager.getResourceMap() вернет карту источника данных в ConnectionHolder в текущем потоке, предполагая, что у вас есть только 1 ресурс, участвующий в транзакции, вы, вероятно, можете сделать map.values().get(0), чтобы получить первый ConnectionHolder, из которого вы можете получить соединение, вызвав .getConnection()

Итак, по существу, вызывая следующее:

TransactionSynchronizationManager.getResourceMap().values().get(0).getConnection()

Хотя, наверное, должен быть лучший способ :-)

Я предполагаю, что вы используете Plain Jdbc, вам нужно сделать следующее:

BaseDao {
    @Autowired
    private DataSource dataSource;

    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    public Connection getConnection() {
        // ....use dataSource to create connection
        return DataSourceUtils.getConnection(dataSource);
    }
}

FooDao extends BaseDao {
    // your foo() method
    void foo() {
       Connection conn = getConnection();
       //....
    }
}

Что немного раздражает во всем этом, так это то, что документы Spring написаны в основном на маркетинговом языке, который скрывает уродство за кулисами.

Ясными словами:

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

Итак, то, что Spring делает довольно сложным способом, - это хранить ваши данные локально в вашем текущем потоке выполнения, что является тривиальной задачей, но недостаточно четко повторяется в документации Spring. Spring в основном помещает ваши вещи в «глобальный контекст», чтобы не тянуть их через все ваши интерфейсы и определения методов. Сначала это выглядит немного волшебно, но на самом деле это просто макияж.

Таким образом, вы получаете статический вызов метода DataSourceUtils для извлечения данных.

Если вы используете Spring Transaction с JDBC, настройте JdbcTemplate и получите доступ к текущей транзакции, используя JdbcTemplate.execute(ConnectionCallback). Это стандартный способ доступа к соединению, настроенному Spring.

3 других способа:

@Component
public class MyServiceNonTransactional {

    @Autowired
    private TransactionTemplate transactionTemplate;
    
    @Autowired
    private DataSource dataSource;
    
    public void doStuff() {
        transactionTemplate.executeWithoutResult(status -> {
            Connection connection = DataSourceUtils.getConnection(dataSource);
            // here we go...
        });
    }

}

@Service
public class MyServiceTransactional {

    @Autowired
    private DataSource dataSource;
    
    @Transactional
    public void doStuff() {
        Connection connection = DataSourceUtils.getConnection(dataSource);
        // here we go...
    }

}

@Service
public class MyServiceViaJdbc {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    public void doStuff() {
        jdbcTemplate.execute((ConnectionCallback<Void>) conn -> {
            // "conn" here we go!
            return null;
        });
    }
        
}