From 6602f13cca8a24554b8c98931fabb1d72527b7e5 Mon Sep 17 00:00:00 2001
From: doxlik <doxlikx@gmail.com>
Date: Tue, 31 Mar 2026 21:06:30 +0400
Subject: [PATCH] Increment inflight counter on prepare-with-parametes-types
 query

Signed-off-by: doxlik <doxlikx@gmail.com>
---
 .../java/io/vertx/sqlclient/codec/SocketConnectionBase.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/vertx-sql-client-codec/src/main/java/io/vertx/sqlclient/codec/SocketConnectionBase.java b/vertx-sql-client-codec/src/main/java/io/vertx/sqlclient/codec/SocketConnectionBase.java
index 8b1b9a973..9fd755f25 100644
--- a/vertx-sql-client-codec/src/main/java/io/vertx/sqlclient/codec/SocketConnectionBase.java
+++ b/vertx-sql-client-codec/src/main/java/io/vertx/sqlclient/codec/SocketConnectionBase.java
@@ -336,6 +336,8 @@ private void fireCommandMessage(ChannelHandlerContext chctx, CommandMessage<?, ?
       } else {
         if (queryCmd.autoCommit() && isIndeterminatePreparedStatementError(cause) && !sendParameterTypes) {
           ChannelHandlerContext ctx = socket.channelHandlerContext();
+          // We need to increment inflight because new prepare command will be submitted
+          inflight++;
           // We cannot cache this prepared statement because it might be executed with another type
           fireCommandMessage(ctx, prepareCommand(queryCmd, handler, false, true));
           ctx.flush();