From b94b1ac2c8925e3669c803d8d40ed5f708d0ccf3 Mon Sep 17 00:00:00 2001
From: yishenglanlingzui <395329313@qq.com>
Date: Tue, 2 Jul 2024 06:46:25 +0000
Subject: [PATCH] master branch place_holder

---
 src/sql/das/ob_das_insert_op.cpp | 6 ++++--
 src/sql/das/ob_das_insert_op.h   | 2 ++
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/sql/das/ob_das_insert_op.cpp b/src/sql/das/ob_das_insert_op.cpp
index b1ca275e89..688f05b5e9 100644
--- a/src/sql/das/ob_das_insert_op.cpp
+++ b/src/sql/das/ob_das_insert_op.cpp
@@ -474,7 +474,8 @@ ObDASInsertResult::ObDASInsertResult()
     result_buffer_(),
     result_newrow_iter_(),
     output_types_(nullptr),
-    is_duplicated_(false)
+    is_duplicated_(false),
+    response_snapshot_()
 {
 }
 
@@ -571,7 +572,8 @@ int ObDASInsertResult::reuse()
 OB_SERIALIZE_MEMBER((ObDASInsertResult, ObIDASTaskResult),
                     affected_rows_,
                     result_buffer_,
-                    is_duplicated_);
+                    is_duplicated_,
+                    response_snapshot_);
 
 
 void ObDASConflictIterator::reset()
diff --git a/src/sql/das/ob_das_insert_op.h b/src/sql/das/ob_das_insert_op.h
index 470e80f2a1..88a43105a9 100644
--- a/src/sql/das/ob_das_insert_op.h
+++ b/src/sql/das/ob_das_insert_op.h
@@ -130,6 +130,7 @@ public:
 
   bool is_duplicated() { return is_duplicated_; }
   void set_is_duplicated(bool is_duplicated) { is_duplicated_ = is_duplicated; }
+  transaction::ObTxReadSnapshot &get_response_snapshot() { return response_snapshot_; }
 
   INHERIT_TO_STRING_KV("ObIDASTaskResult", ObIDASTaskResult,
                         K_(affected_rows));
@@ -139,6 +140,7 @@ private:
   ObDASWriteBuffer::NewRowIterator result_newrow_iter_;
   const ObjMetaFixedArray *output_types_;
   bool is_duplicated_;
+  transaction::ObTxReadSnapshot response_snapshot_;
 };
 }  // namespace sql
 }  // namespace oceanbase