[CBRD-25241] Add SQL syntax to change the owner of the serial

src/object/authenticate.c

@@ -5254,6 +5254,13 @@ au_change_serial_owner_method (MOP obj, DB_VALUE * return_val, DB_VALUE * serial
       return;
     }
 
+  if (!au_is_dba_group_member (Au_user))
+    {
+      ERROR_SET_WARNING_1ARG (error, ER_AU_DBA_ONLY, "change_serial_owner");
+      db_make_error (return_val, error);
+      return;
+    }
+
   if (!DB_IS_STRING (serial_val) || (serial_name = db_get_string (serial_val)) == NULL)
     {
       ERROR_SET_WARNING_1ARG (error, ER_OBJ_INVALID_ARGUMENT, "");

src/parser/csql_grammar.y

@@ -3771,6 +3771,26 @@ alter_stmt
 					MSGCAT_SEMANTIC_SERIAL_ALTER_NO_OPTION, 0);
 			  }
 
+		DBG_PRINT}}
+	| ALTER				/* 1 */
+	  SERIAL			/* 2 */
+	  serial_name			/* 3 */
+	  OWNER TO identifier		/* 4, 5, 6 */
+	  opt_comment_spec		/* 7 */
+		{{ DBG_TRACE_GRAMMAR(alter_stmt, | ALTER SERIAL serial_name OWNER TO identifier opt_comment_spec);
+
+		  PT_NODE *node = parser_new_node (this_parser, PT_ALTER_SERIAL);
+
+		  if (node)
+                    {
+                      node->info.serial.serial_name = $3;
+                      node->info.serial.owner_name = $6;
+                      node->info.serial.comment = $7;
+                    }
+
+                  $$ = node;
+                  PARSER_SAVE_ERR_CONTEXT ($$, @$.buffer_pos)
+
 		DBG_PRINT}}
 	| ALTER						/* 1 */
 		{					/* 2 */

src/parser/parse_tree.h

@@ -2178,6 +2178,7 @@ struct pt_serial_info
   PT_NODE *max_val;		/* PT_VALUE */
   PT_NODE *min_val;		/* PT_VALUE */
   PT_NODE *cached_num_val;	/* PT_VALUE */
+  PT_NODE *owner_name;		/* PT_NAME */
   PT_NODE *comment;		/* PT_VALUE */
   int cyclic;
   int no_max;

src/parser/parse_tree_cl.c

@@ -8159,6 +8159,13 @@ pt_print_alter_serial (PARSER_CONTEXT * parser, PT_NODE * p)
       q = pt_append_nulstring (parser, q, " nocache ");
     }
 
+  if (p->info.serial.owner_name != NULL)
+    {
+      r1 = pt_print_bytes (parser, p->info.serial.owner_name);
+      q = pt_append_nulstring (parser, q, " owner to ");
+      q = pt_append_varchar (parser, q, r1);
+    }
+
   if (p->info.serial.comment != NULL)
     {
       r1 = pt_print_bytes (parser, p->info.serial.comment);
@@ -8273,6 +8280,7 @@ pt_apply_alter_serial (PARSER_CONTEXT * parser, PT_NODE * p, void *arg)
   PT_APPLY_WALK (parser, p->info.serial.increment_val, arg);
   PT_APPLY_WALK (parser, p->info.serial.min_val, arg);
   PT_APPLY_WALK (parser, p->info.serial.max_val, arg);
+  PT_APPLY_WALK (parser, p->info.serial.owner_name, arg);
   return p;
 }
 

src/query/execute_statement.c

@@ -2318,8 +2318,14 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
   DB_VALUE abs_inc_val, range_val;
   int cached_num;
   int ret_msg_id = 0;
+
+  PT_NODE *serial_owner = NULL;
+  const char *serial_owner_name = NULL;
+  DB_VALUE serial_name_val, returnval, serial_owner_val;
   const char *comment = NULL;
 
+  bool opt_serial_option_list_flag = false;
+
   int new_inc_val_flag = 0, new_cyclic;
   bool cur_val_change, inc_val_change, max_val_change, min_val_change, cyclic_change, cached_num_change;
 
@@ -2347,6 +2353,9 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
   db_make_null (&class_name_val);
   db_make_null (&abs_inc_val);
   db_make_null (&range_val);
+  db_make_null (&serial_name_val);
+  db_make_null (&returnval);
+  db_make_null (&serial_owner_val);
   OID_SET_NULL (&serial_obj_id);
 
   /*
@@ -2778,6 +2787,7 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
 	  goto end;
 	}
       pr_clear_value (&value);
+      opt_serial_option_list_flag = true;
     }
 
   /* increment_val */
@@ -2788,6 +2798,7 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
 	{
 	  goto end;
 	}
+      opt_serial_option_list_flag = true;
     }
 
   /* max_val */
@@ -2798,6 +2809,7 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
 	{
 	  goto end;
 	}
+      opt_serial_option_list_flag = true;
     }
 
   /* min_val */
@@ -2808,6 +2820,7 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
 	{
 	  goto end;
 	}
+      opt_serial_option_list_flag = true;
     }
 
   /* cyclic */
@@ -2820,6 +2833,7 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
 	  goto end;
 	}
       pr_clear_value (&value);
+      opt_serial_option_list_flag = true;
     }
 
   /* cached num */
@@ -2846,6 +2860,28 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
 	  goto end;
 	}
       pr_clear_value (&value);
+      opt_serial_option_list_flag = true;
+    }
+
+  /* owner to */
+  serial_owner = statement->info.serial.owner_name;
+  if (serial_owner != NULL)
+    {
+      serial_owner_name = serial_owner->info.name.original;
+
+      db_make_string (&serial_name_val, (char *) PT_NODE_SR_NAME (statement));
+      db_make_string (&serial_owner_val, serial_owner_name);
+
+      au_change_serial_owner_method (serial_class, &returnval, &serial_name_val, &serial_owner_val);
+
+      pr_clear_value (&serial_name_val);
+      pr_clear_value (&serial_owner_val);
+
+      if (DB_VALUE_TYPE (&returnval) == DB_TYPE_ERROR)
+	{
+	  error = db_get_error (&returnval);
+	  goto end;
+	}
     }
 
   /* comment */
@@ -2874,7 +2910,7 @@ do_alter_serial (PARSER_CONTEXT * parser, PT_NODE * statement)
   obj_tmpl = NULL;
 
 end:
-  if (!OID_ISNULL (&serial_obj_id))
+  if (!OID_ISNULL (&serial_obj_id) && opt_serial_option_list_flag == true)
     {
       (void) serial_decache ((OID *) (&serial_obj_id));
     }