From 6851f834de181518ef61093c02032976633811e7 Mon Sep 17 00:00:00 2001 From: Adam Gong <43736198+adamgongca@users.noreply.github.com> Date: Thu, 21 Dec 2023 16:48:39 -0500 Subject: [PATCH] Update RpcQueryMessageFlow.java to fix the bud #276 #273 Signed-off-by: Adam Gong adam.gong.ca@gmail.com --- src/main/java/io/r2dbc/mssql/RpcQueryMessageFlow.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/r2dbc/mssql/RpcQueryMessageFlow.java b/src/main/java/io/r2dbc/mssql/RpcQueryMessageFlow.java index 7e7b1f7..98635fa 100644 --- a/src/main/java/io/r2dbc/mssql/RpcQueryMessageFlow.java +++ b/src/main/java/io/r2dbc/mssql/RpcQueryMessageFlow.java @@ -262,7 +262,7 @@ static Flux exchange(PreparedStatementCache statementCache, Client clie state.update(message); if (message instanceof ErrorToken) { - if (isPreparedStatementNotFound(((ErrorToken) message).getNumber()) && retryReprepare.compareAndSet(true, false)) { + if (retryReprepare.compareAndSet(true, false)) { logger.debug("Prepared statement no longer valid: {}", handle); state.update(Phase.PREPARE_RETRY); } @@ -304,7 +304,7 @@ static Flux exchange(PreparedStatementCache statementCache, Client clie * @return */ private static boolean isPreparedStatementNotFound(long errorNumber) { - return errorNumber == 8179 || errorNumber == 586; + return errorNumber == 8179 || errorNumber == 586 || errorNumber == 8144 || errorNumber == 8178; } private static boolean handleSpCursorReturnValue(PreparedStatementCache statementCache, Codecs codecs, String query, Binding binding, CursorState state, boolean needsPrepare,