proper checking logic for UNDETERMINED status

zinal · zinal · commit bf22278688f8 · 2025-05-27T16:47:21.000+03:00
diff --git a/jdbc/src/main/java/tech/ydb/jdbc/context/QueryServiceExecutorExt.java b/jdbc/src/main/java/tech/ydb/jdbc/context/QueryServiceExecutorExt.java
@@ -79,7 +79,9 @@ private void commitWithCheck(YdbContext ctx, YdbValidator validator) throws SQLE
             validator.clearWarnings();
             Status status = upsertAndCommit(localTx);
             if (StatusCode.UNDETERMINED.equals(status.getCode())) {
-                if (!checkTransaction(ctx, localTx.getId(), validator, tracer)) {
+                if (checkTransaction(ctx, localTx.getId(), validator, tracer)) {
+                    status = Status.SUCCESS;
+                } else {
                     status = Status.of(StatusCode.ABORTED, status.getCause(), status.getIssues());
                 }
             }

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,9 @@ private void commitWithCheck(YdbContext ctx, YdbValidator validator) throws SQLE`
`79`	`79`	`validator.clearWarnings();`
`80`	`80`	`Status status = upsertAndCommit(localTx);`
`81`	`81`	`if (StatusCode.UNDETERMINED.equals(status.getCode())) {`
`82`		`- if (!checkTransaction(ctx, localTx.getId(), validator, tracer)) {`
	`82`	`+ if (checkTransaction(ctx, localTx.getId(), validator, tracer)) {`
	`83`	`+ status = Status.SUCCESS;`
	`84`	`+ } else {`
`83`	`85`	`status = Status.of(StatusCode.ABORTED, status.getCause(), status.getIssues());`
`84`	`86`	`}`
`85`	`87`	`}`