From 9e6127fe582d414dad58abfb97e093084b50c830 Mon Sep 17 00:00:00 2001 From: maochongxin Date: Tue, 17 Jun 2025 20:37:43 +0800 Subject: [PATCH] add log for deubg --- .../com/alipay/oceanbase/rpc/ObTableClient.java | 10 ++++++++++ .../rpc/protocol/payload/impl/ObRowKey.java | 14 ++++++++++++++ 2 files changed, 24 insertions(+) diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java index 67dd3202..6ebb16bd 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java +++ b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java @@ -2299,6 +2299,16 @@ public ObPayload execute(final ObTableAbstractOperationRequest request) throws E if (partIdMapObTable.size() > 1 && !isDistributedExecuteSupported) { throw new ObTablePartitionConsistentException( "query and mutate must be a atomic operation"); + } else if (partIdMapObTable.isEmpty()) { + StringBuilder rangeInfo = new StringBuilder(); + rangeInfo.append("could not find part id of ranges: ["); + for (int i = 0; i < tableQuery.getKeyRanges().size(); i++) { + if (i > 0) rangeInfo.append(", "); + ObNewRange range = tableQuery.getKeyRanges().get(i); + rangeInfo.append(range.getStartKey().toString()).append(" - ").append(range.getEndKey().toString()); + } + rangeInfo.append("]"); + throw new ObTableException(rangeInfo.toString()); } // Proceed with the operation Map.Entry entry = partIdMapObTable.entrySet().iterator().next(); diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/ObRowKey.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/ObRowKey.java index 619f5101..5f212a85 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/ObRowKey.java +++ b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/ObRowKey.java @@ -135,4 +135,18 @@ public int hashCode() { return Objects.hashCode(objs); } + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append("["); + for (int i = 0; i < objs.size(); i++) { + if (i > 0) { + sb.append(", "); + } + ObObj obj = objs.get(i); + sb.append(obj != null ? obj.toString() : "null"); + } + sb.append("]"); + return sb.toString(); + } }