add item type and member of select into spec

src/objit/include/objit/common/ob_item_type.h

@@ -2435,6 +2435,11 @@ typedef enum ObItemType
   T_MV_OPTIONS,
   T_MV_REWRITE,
   T_MV_NO_REWRITE,
+
+  // select into outfile
+  T_INTO_FILE_LIST,
+  T_SINGLE_OPT,
+  T_MAX_FILE_SIZE,
   T_MAX //Attention: add a new type before T_MAX
 } ObItemType;
 

src/sql/engine/basic/ob_select_into_op.cpp

@@ -26,7 +26,8 @@ namespace sql
 {
 
 OB_SERIALIZE_MEMBER((ObSelectIntoSpec, ObOpSpec), into_type_, user_vars_,
-    outfile_name_, filed_str_, line_str_, closed_cht_, is_optional_, select_exprs_);
+    outfile_name_, filed_str_, line_str_, closed_cht_, is_optional_, select_exprs_, is_single_,
+    max_file_size_, escaped_cht_, cs_type_);
 
 
 int ObSelectIntoOp::inner_open()

src/sql/engine/basic/ob_select_into_op.h

@@ -36,8 +36,12 @@ public:
       line_str_(),
       closed_cht_(0),
       is_optional_(false),
-      select_exprs_(alloc)
+      select_exprs_(alloc),
+      is_single_(true),
+      max_file_size_(DEFAULT_MAX_FILE_SIZE),
+      escaped_cht_()
   {
+    cs_type_ = ObCharset::get_system_collation();
   }
 
   ObItemType into_type_;
@@ -48,6 +52,11 @@ public:
   char closed_cht_;
   bool is_optional_;
   common::ObFixedArray<ObExpr*, common::ObIAllocator> select_exprs_;
+  bool is_single_;
+  int64_t max_file_size_;
+  common::ObObj escaped_cht_;
+  common::ObCollationType cs_type_;
+  static const int64_t DEFAULT_MAX_FILE_SIZE = 256LL * 1024 * 1024;
 };
 
 class ObSelectIntoOp : public ObOperator