@@ -118,9 +118,9 @@ protected void cleanupTest() throws Exception {
118
118
119
119
@ Test
120
120
public void testBasicRelease () {
121
- connectionProvider .clear ();
122
121
ResourceRegistry registry = sessionFactoryScope ().fromSession (
123
122
session -> {
123
+ connectionProvider .clear ();
124
124
JdbcCoordinatorImpl jdbcCoord = (JdbcCoordinatorImpl ) session .getJdbcCoordinator ();
125
125
ResourceRegistry resourceRegistry = jdbcCoord .getLogicalConnection ().getResourceRegistry ();
126
126
try {
@@ -154,9 +154,9 @@ public void testBasicRelease() {
154
154
155
155
@ Test
156
156
public void testReleaseCircumventedByHeldResources () {
157
- connectionProvider .clear ();
158
157
ResourceRegistry registry = sessionFactoryScope ().fromSession (
159
158
session -> {
159
+ connectionProvider .clear ();
160
160
JdbcCoordinatorImpl jdbcCoord = (JdbcCoordinatorImpl ) session .getJdbcCoordinator ();
161
161
ResourceRegistry resourceRegistry = jdbcCoord .getLogicalConnection ().getResourceRegistry ();
162
162
@@ -217,10 +217,9 @@ public void testReleaseCircumventedByHeldResources() {
217
217
218
218
@ Test
219
219
public void testReleaseCircumventedManually () {
220
- connectionProvider .clear ();
221
- connectionProvider .clear ();
222
220
ResourceRegistry registry = sessionFactoryScope ().fromSession (
223
221
session -> {
222
+ connectionProvider .clear ();
224
223
JdbcCoordinatorImpl jdbcCoord = (JdbcCoordinatorImpl ) session .getJdbcCoordinator ();
225
224
ResourceRegistry resourceRegistry = jdbcCoord .getLogicalConnection ().getResourceRegistry ();
226
225
@@ -271,4 +270,19 @@ public void testReleaseCircumventedManually() {
271
270
assertEquals ( 0 , connectionProvider .getAcquiredConnections ().size () );
272
271
assertEquals ( 2 , connectionProvider .getReleasedConnections ().size () );
273
272
}
273
+
274
+ @ Test
275
+ public void testHql () {
276
+ sessionFactoryScope ().inTransaction ( session -> {
277
+ connectionProvider .clear ();
278
+ JdbcCoordinatorImpl jdbcCoord = (JdbcCoordinatorImpl ) session .getJdbcCoordinator ();
279
+ ResourceRegistry resourceRegistry = jdbcCoord .getLogicalConnection ().getResourceRegistry ();
280
+
281
+ session .createSelectionQuery ( "select 1" ).uniqueResult ();
282
+
283
+ assertFalse ( resourceRegistry .hasRegisteredResources () );
284
+ assertEquals ( 0 , connectionProvider .getAcquiredConnections ().size () );
285
+ assertEquals ( 1 , connectionProvider .getReleasedConnections ().size () );
286
+ } );
287
+ }
274
288
}
0 commit comments