File tree Expand file tree Collapse file tree
vertx-mysql-client/src/test/java/io/vertx/mysqlclient/tck
main/java/io/vertx/sqlclient/impl
test/java/io/vertx/sqlclient/tck Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -45,6 +45,13 @@ public void testQueryCloseCursor(TestContext ctx) {
4545 super .testQueryCloseCursor (ctx );
4646 }
4747
48+ @ Test
49+ @ Ignore ("Fetch command not supported by ProxySQL" )
50+ @ Override
51+ public void testQueryCloseCursorTwice (TestContext ctx ) {
52+ super .testQueryCloseCursorTwice (ctx );
53+ }
54+
4855 @ Test
4956 @ Ignore ("Fetch command not supported by ProxySQL" )
5057 @ Override
Original file line number Diff line number Diff line change @@ -118,6 +118,8 @@ private synchronized void close(Promise<Void> promise) {
118118 result = null ;
119119 ps .closeCursor (id , promise );
120120 }
121+ } else {
122+ promise .complete ();
121123 }
122124 }
123125}
Original file line number Diff line number Diff line change 1111package io .vertx .sqlclient .tck ;
1212
1313import io .vertx .core .AsyncResult ;
14+ import io .vertx .core .Future ;
1415import io .vertx .core .Handler ;
1516import io .vertx .core .Vertx ;
1617import io .vertx .ext .unit .Async ;
@@ -273,6 +274,19 @@ public void testQueryCloseCursor(TestContext ctx) {
273274 });
274275 }
275276
277+ @ Test
278+ public void testQueryCloseCursorTwice (TestContext ctx ) {
279+ Async async = ctx .async ();
280+ testCursor (ctx , conn -> {
281+ conn
282+ .prepare ("SELECT * FROM immutable" )
283+ .onComplete (ctx .asyncAssertSuccess (ps -> {
284+ Cursor cursor = ps .cursor (Tuple .tuple ());
285+ Future .all (cursor .close (), cursor .close ()).onComplete (ctx .asyncAssertSuccess (v -> async .complete ()));
286+ }));
287+ });
288+ }
289+
276290 @ Test
277291 public void testQueryStreamCloseCursor (TestContext ctx ) {
278292 Async async = ctx .async ();
You can’t perform that action at this time.
0 commit comments