From 4939c4d14aaf4fd92ced789f33c2bcf1787b2583 Mon Sep 17 00:00:00 2001 From: maochongxin Date: Thu, 11 Dec 2025 14:13:08 +0800 Subject: [PATCH] add get_optimized flag for obtablequery --- .../payload/impl/execute/query/ObTableQuery.java | 4 ++++ .../payload/impl/execute/query/ObTableQueryFlag.java | 11 +++++++++++ 2 files changed, 15 insertions(+) diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQuery.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQuery.java index f817d322..7dfa14b5 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQuery.java +++ b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQuery.java @@ -618,4 +618,8 @@ public void setFlag(ObTableQueryFlag flag) { public void setHotOnly(boolean hotOnly) { this.flag.setHotOnly(hotOnly); } + + public void setGetOptimized(boolean getOptimized) { + this.flag.setGetOptimized(getOptimized); + } } diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQueryFlag.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQueryFlag.java index 4209ab44..4008a23b 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQueryFlag.java +++ b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQueryFlag.java @@ -19,6 +19,7 @@ public class ObTableQueryFlag { private static final int HOT_ONLY = 1 << 0; + private static final int GET_OPTIMIZED = 1 << 1; private long value = 0; @@ -43,4 +44,14 @@ public void setHotOnly(boolean hotOnly) { value = value | HOT_ONLY; } } + + public boolean isGetOptimized() { + return (value & GET_OPTIMIZED) != 0; + } + + public void setGetOptimized(boolean getOptimized) { + if (getOptimized) { + value = value | GET_OPTIMIZED; + } + } };