feat(udf): add body field for udf body definition

proto/catalog.proto

@@ -218,6 +218,7 @@ message Function {
   string language = 7;
   string link = 8;
   string identifier = 10;
+  string body = 14;
 
   oneof kind {
     ScalarFunction scalar = 11;

src/frontend/src/binder/expr/function.rs

@@ -233,7 +233,7 @@ impl Binder {
             if func.language == "sql" {
                 // This represents the current user defined function is `language sql`
                 let parse_result =
-                    risingwave_sqlparser::parser::Parser::parse_sql(func.identifier.as_str());
+                    risingwave_sqlparser::parser::Parser::parse_sql(func.body.as_str());
                 if let Err(ParserError::ParserError(err)) | Err(ParserError::TokenizerError(err)) =
                     parse_result
                 {

src/frontend/src/catalog/function_catalog.rs

@@ -30,6 +30,7 @@ pub struct FunctionCatalog {
     pub return_type: DataType,
     pub language: String,
     pub identifier: String,
+    pub body: String,
     pub link: String,
 }
 
@@ -63,6 +64,7 @@ impl From<&PbFunction> for FunctionCatalog {
             return_type: prost.return_type.as_ref().expect("no return type").into(),
             language: prost.language.clone(),
             identifier: prost.identifier.clone(),
+            body: prost.body.clone(),
             link: prost.link.clone(),
         }
     }

src/frontend/src/expr/user_defined_function.rs

@@ -55,6 +55,8 @@ impl UserDefinedFunction {
             return_type,
             language: udf.get_language().clone(),
             identifier: udf.get_identifier().clone(),
+            // TODO: Ensure if we need `body` here
+            body: "".to_string(),
             link: udf.get_link().clone(),
         };
 

src/frontend/src/handler/create_function.rs

@@ -162,6 +162,7 @@ pub async fn handle_create_function(
         return_type: Some(return_type.into()),
         language,
         identifier,
+        body: "".to_string(),
         link,
         owner: session.user_id(),
     };

src/frontend/src/handler/create_sql_function.rs

@@ -168,7 +168,8 @@ pub async fn handle_create_sql_function(
         arg_types: arg_types.into_iter().map(|t| t.into()).collect(),
         return_type: Some(return_type.into()),
         language,
-        identifier: body,
+        identifier: "".to_string(),
+        body,
         link: "".to_string(),
         owner: session.user_id(),
     };

src/meta/model_v2/src/function.rs

@@ -41,6 +41,7 @@ pub struct Model {
     pub language: String,
     pub link: String,
     pub identifier: String,
+    pub body: String,
     pub kind: FunctionKind,
 }
 
@@ -94,6 +95,7 @@ impl From<PbFunction> for ActiveModel {
             language: Set(function.language),
             link: Set(function.link),
             identifier: Set(function.identifier),
+            body: Set(function.body),
             kind: Set(function.kind.unwrap().into()),
         }
     }

src/meta/src/controller/mod.rs

@@ -279,6 +279,7 @@ impl From<ObjectModel<function::Model>> for PbFunction {
             language: value.0.language,
             link: value.0.link,
             identifier: value.0.identifier,
+            body: value.0.body,
             kind: Some(value.0.kind.into()),
         }
     }