fix: fix system_parameter value column type and remove unnecessary FK…

…s in mysql

src/meta/model_v2/migration/src/lib.rs

@@ -13,6 +13,8 @@ mod m20240506_112555_subscription_partial_ckpt;
 mod m20240525_090457_secret;
 mod m20240617_070131_index_column_properties;
 mod m20240618_072634_function_compressed_binary;
+mod m20240702_080451_system_param_value;
+mod m20240702_084927_unnecessary_fk;
 
 pub struct Migrator;
 
@@ -31,6 +33,8 @@ impl MigratorTrait for Migrator {
             Box::new(m20240525_090457_secret::Migration),
             Box::new(m20240618_072634_function_compressed_binary::Migration),
             Box::new(m20240617_070131_index_column_properties::Migration),
+            Box::new(m20240702_080451_system_param_value::Migration),
+            Box::new(m20240702_084927_unnecessary_fk::Migration),
         ]
     }
 }

src/meta/model_v2/migration/src/m20240702_080451_system_param_value.rs

@@ -0,0 +1,51 @@
+use sea_orm_migration::prelude::*;
+
+use crate::sea_orm::DbBackend;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        match manager.get_database_backend() {
+            DbBackend::MySql => {
+                manager
+                    .alter_table(
+                        Table::alter()
+                            .table(SystemParameter::Table)
+                            .modify_column(ColumnDef::new(SystemParameter::Value).text().not_null())
+                            .to_owned(),
+                    )
+                    .await?;
+            }
+            _ => {}
+        }
+        Ok(())
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        match manager.get_database_backend() {
+            DbBackend::MySql => {
+                manager
+                    .alter_table(
+                        Table::alter()
+                            .table(SystemParameter::Table)
+                            .modify_column(
+                                ColumnDef::new(SystemParameter::Value).string().not_null(),
+                            )
+                            .to_owned(),
+                    )
+                    .await?;
+            }
+            _ => {}
+        }
+        Ok(())
+    }
+}
+
+#[derive(DeriveIden)]
+enum SystemParameter {
+    Table,
+    Value,
+}

src/meta/model_v2/migration/src/m20240702_084927_unnecessary_fk.rs

@@ -0,0 +1,41 @@
+use sea_orm_migration::prelude::*;
+
+use crate::sea_orm::DbBackend;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        match manager.get_database_backend() {
+            DbBackend::MySql => {
+                manager
+                    .alter_table(
+                        Table::alter()
+                            .table(Alias::new("sink"))
+                            .drop_foreign_key(Alias::new("FK_sink_connection_id"))
+                            .drop_foreign_key(Alias::new("FK_sink_target_table_id"))
+                            .to_owned(),
+                    )
+                    .await?;
+                manager
+                    .alter_table(
+                        Table::alter()
+                            .table(Alias::new("source"))
+                            .drop_foreign_key(Alias::new("FK_source_connection_id"))
+                            .to_owned(),
+                    )
+                    .await?;
+            }
+            _ => {}
+        }
+
+        Ok(())
+    }
+
+    async fn down(&self, _manager: &SchemaManager) -> Result<(), DbErr> {
+        // Do nothing.
+        Ok(())
+    }
+}