|
@@ -20,12 +20,12 @@ import java.sql.SQLException;
|
|
|
public class JtaJdbcSqlExecutor extends AbstractJdbcSqlExecutor {
|
|
|
@Override
|
|
|
public Connection getConnection() {
|
|
|
- return DataSourceUtils.getConnection(DataSourceHolder.currentDataSource());
|
|
|
+ return DataSourceUtils.getConnection(DataSourceHolder.currentDataSource().getNative());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void releaseConnection(Connection connection) throws SQLException {
|
|
|
- DataSourceUtils.releaseConnection(connection, DataSourceHolder.currentDataSource());
|
|
|
+ DataSourceUtils.releaseConnection(connection, DataSourceHolder.currentDataSource().getNative());
|
|
|
}
|
|
|
|
|
|
@Override
|